/dports/net/storj/storj-1.45.3/vendor/github.com/lucas-clemente/quic-go/ |
H A D | send_queue.go | 11 type sendQueue struct { struct 19 var _ sender = &sendQueue{} 24 return &sendQueue{ 36 func (h *sendQueue) Send(p *packetBuffer) { argument 45 func (h *sendQueue) WouldBlock() bool { argument 49 func (h *sendQueue) Available() <-chan struct{} { argument 53 func (h *sendQueue) Run() error { argument 78 func (h *sendQueue) Close() { argument
|
H A D | datagram_queue.go | 10 sendQueue chan *wire.DatagramFrame member 26 sendQueue: make(chan *wire.DatagramFrame, 1), 38 case h.sendQueue <- f: 55 case f := <-h.sendQueue:
|
/dports/security/xray-core/Xray-core-1.5.0/vendor/github.com/lucas-clemente/quic-go/ |
H A D | send_queue.go | 11 type sendQueue struct { struct 19 var _ sender = &sendQueue{} 24 return &sendQueue{ 36 func (h *sendQueue) Send(p *packetBuffer) { argument 45 func (h *sendQueue) WouldBlock() bool { argument 49 func (h *sendQueue) Available() <-chan struct{} { argument 53 func (h *sendQueue) Run() error { argument 78 func (h *sendQueue) Close() { argument
|
H A D | datagram_queue.go | 10 sendQueue chan *wire.DatagramFrame member 26 sendQueue: make(chan *wire.DatagramFrame, 1), 38 case h.sendQueue <- f: 55 case f := <-h.sendQueue:
|
/dports/dns/nextdns/nextdns-1.32.2/vendor/github.com/lucas-clemente/quic-go/ |
H A D | send_queue.go | 11 type sendQueue struct { struct 19 var _ sender = &sendQueue{} 24 return &sendQueue{ 36 func (h *sendQueue) Send(p *packetBuffer) { argument 45 func (h *sendQueue) WouldBlock() bool { argument 49 func (h *sendQueue) Available() <-chan struct{} { argument 53 func (h *sendQueue) Run() error { argument 78 func (h *sendQueue) Close() { argument
|
H A D | datagram_queue.go | 10 sendQueue chan *wire.DatagramFrame member 26 sendQueue: make(chan *wire.DatagramFrame, 1), 38 case h.sendQueue <- f: 55 case f := <-h.sendQueue:
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/lucas-clemente/quic-go/ |
H A D | send_queue.go | 11 type sendQueue struct { struct 19 var _ sender = &sendQueue{} 24 return &sendQueue{ 36 func (h *sendQueue) Send(p *packetBuffer) { argument 45 func (h *sendQueue) WouldBlock() bool { argument 49 func (h *sendQueue) Available() <-chan struct{} { argument 53 func (h *sendQueue) Run() error { argument 78 func (h *sendQueue) Close() { argument
|
H A D | datagram_queue.go | 10 sendQueue chan *wire.DatagramFrame member 26 sendQueue: make(chan *wire.DatagramFrame, 1), 38 case h.sendQueue <- f: 55 case f := <-h.sendQueue:
|
/dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/lucas-clemente/quic-go/ |
H A D | send_queue.go | 11 type sendQueue struct { struct 19 var _ sender = &sendQueue{} 24 return &sendQueue{ 36 func (h *sendQueue) Send(p *packetBuffer) { argument 45 func (h *sendQueue) WouldBlock() bool { argument 49 func (h *sendQueue) Available() <-chan struct{} { argument 53 func (h *sendQueue) Run() error { argument 78 func (h *sendQueue) Close() { argument
|
H A D | datagram_queue.go | 10 sendQueue chan *wire.DatagramFrame member 26 sendQueue: make(chan *wire.DatagramFrame, 1), 38 case h.sendQueue <- f: 55 case f := <-h.sendQueue:
|
/dports/net/traefik/traefik-2.6.1/vendor/github.com/lucas-clemente/quic-go/ |
H A D | send_queue.go | 11 type sendQueue struct { struct 19 var _ sender = &sendQueue{} 24 return &sendQueue{ 36 func (h *sendQueue) Send(p *packetBuffer) { argument 45 func (h *sendQueue) WouldBlock() bool { argument 49 func (h *sendQueue) Available() <-chan struct{} { argument 53 func (h *sendQueue) Run() error { argument 78 func (h *sendQueue) Close() { argument
|
H A D | datagram_queue.go | 10 sendQueue chan *wire.DatagramFrame member 26 sendQueue: make(chan *wire.DatagramFrame, 1), 38 case h.sendQueue <- f: 55 case f := <-h.sendQueue:
|
/dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/ooni/psiphon/oopsi/github.com/Psiphon-Labs/quic-go/ |
H A D | send_queue.go | 3 type sendQueue struct { struct 9 func newSendQueue(conn connection) *sendQueue { 10 s := &sendQueue{ 18 func (h *sendQueue) Send(p *packedPacket) { argument 22 func (h *sendQueue) Run() error { argument 37 func (h *sendQueue) Close() { argument
|
/dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/ooni/psiphon/oopsi/github.com/Psiphon-Labs/quic-go/ |
H A D | send_queue.go | 3 type sendQueue struct { struct 9 func newSendQueue(conn connection) *sendQueue { 10 s := &sendQueue{ 18 func (h *sendQueue) Send(p *packedPacket) { argument 22 func (h *sendQueue) Run() error { argument 37 func (h *sendQueue) Close() { argument
|
/dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/lucas-clemente/quic-go/ |
H A D | send_queue.go | 3 type sendQueue struct { struct 10 func newSendQueue(conn sendConn) *sendQueue { 11 s := &sendQueue{ 20 func (h *sendQueue) Send(p *packetBuffer) { argument 27 func (h *sendQueue) Run() error { argument 48 func (h *sendQueue) Close() { argument
|
/dports/net/v2ray/v2ray-core-4.36.2/vendor/github.com/lucas-clemente/quic-go/ |
H A D | send_queue.go | 3 type sendQueue struct { 10 func newSendQueue(conn sendConn) *sendQueue { 11 s := &sendQueue{ 20 func (h *sendQueue) Send(p *packetBuffer) { 27 func (h *sendQueue) Run() error { 48 func (h *sendQueue) Close() {
|
/dports/net/syncthing/syncthing-1.18.1/syncthing/vendor/github.com/lucas-clemente/quic-go/ |
H A D | send_queue.go | 3 type sendQueue struct { struct 10 func newSendQueue(conn sendConn) *sendQueue { 11 s := &sendQueue{ 20 func (h *sendQueue) Send(p *packetBuffer) { argument 27 func (h *sendQueue) Run() error { argument 48 func (h *sendQueue) Close() { argument
|
/dports/java/bouncycastle15/crypto-169/tls/src/test/java/org/bouncycastle/tls/test/ |
H A D | MockDatagramAssociation.java | 38 private Vector receiveQueue, sendQueue; field in MockDatagramAssociation.MockDatagramTransport 40 MockDatagramTransport(Vector receiveQueue, Vector sendQueue) in MockDatagramTransport() argument 43 this.sendQueue = sendQueue; in MockDatagramTransport() 97 synchronized (sendQueue) in send() 99 sendQueue.addElement(packet); in send() 100 sendQueue.notify(); in send()
|
/dports/www/davical/davical-9da21ad116a2913bf788bd4b0b8c58c0de83d9da/inc/ |
H A D | pubsub.php | 19 private $sendQueue = Array(); variable in xmpp 229 $this->sendQueue[] = $send; 254 $this->sendQueue[] = $out; 289 $this->sendQueue[] = $out; 307 $this->sendQueue[] = $out; 324 $this->sendQueue[] = $out; 341 $this->sendQueue[] = $out; 369 $this->sendQueue[] = $out; 386 $this->sendQueue[] = $out; 473 $this->sendQueue[] = $this->streamTagBegin; [all …]
|
/dports/sysutils/lizardfs/lizardfs-3.12.0/src/unittests/mocks/ |
H A D | module_mock.cc | 41 clients_.at(currentClient()).sendQueue.push(std::move(message)); in respondToCurrentClient() 146 client.sendQueue.pop(); in serveFd() 149 if (!client.writer.hasDataToSend() && !client.sendQueue.empty()) { in serveFd() 151 client.sendQueue.front().data(), in serveFd() 152 client.sendQueue.front().size()); in serveFd()
|
/dports/mail/cone/cone-1.1/libmail/ |
H A D | smtp.C | 126 FILE *fp=mySmtp->sendQueue.front().message; in fillWriteBuffer() 257 while (!sendQueue.empty()) in disconnect() 263 sendQueue.pop(); in disconnect() 867 if (!sendQueue.empty()) in authenticated() 1096 bool wasEmpty=sendQueue.empty(); in send() 1098 sendQueue.push(msgInfo); in send() 1122 sendQueue.pop(); in rsetResponse() 1124 if (!sendQueue.empty()) in rsetResponse() 1255 pipelineError=sendQueue.front().messageInfo in pipelinedResponse() 1400 sendQueue.pop(); in messageProcessed() [all …]
|
/dports/net/evans/evans-0.9.1/vendor/github.com/improbable-eng/grpc-web/client/grpc-web/src/transports/websocket/ |
H A D | websocket.ts | 24 const sendQueue: Array<Uint8Array | WebsocketSignal> = []; constant 44 sendQueue.push(msgBytes); 51 sendQueue.push(WebsocketSignal.FINISH_SEND); 64 sendQueue.forEach(toSend => {
|
/dports/devel/py-foolscap/foolscap-21.7.0/src/foolscap/slicers/ |
H A D | root.py | 27 self.sendQueue = [] 81 if self.sendQueue: 82 (obj, self.objectSentDeferred) = self.sendQueue.pop() 101 idle = (len(self.protocol.slicerStack) == 1) and not self.sendQueue 103 self.sendQueue.append((obj, objectSentDeferred)) 124 for obj, d in self.sendQueue: 126 self.sendQueue = []
|
/dports/multimedia/syncplay/syncplay-1.6.4a/syncplay/players/ |
H A D | mplayer.py | 312 self.sendQueue = [] 431 if self.sendQueue: 435 for itemID, deletionCandidate in enumerate(self.sendQueue): 438 … "<mpv> Remove duplicate (supersede): {}".format(self.sendQueue[itemID])) 440 self.sendQueue.remove(self.sendQueue[itemID]) 451 for itemID, deletionCandidate in enumerate(self.sendQueue): 454 … "<mpv> Remove duplicate (delete both): {}".format(self.sendQueue[itemID])) 455 … self.__playerController._client.ui.showDebugMessage(self.sendQueue[itemID]) 459 self.sendQueue.append(line) 465 while self.sendQueue and self.readyToSend: [all …]
|
/dports/net/libarcus/libArcus-4.8.0/src/ |
H A D | Socket_p.h | 115 std::deque<MessagePtr> sendQueue; variable 256 while(sendQueue.size() > 0) in run() 258 messagesToSend.push_back(sendQueue.front()); in run() 259 sendQueue.pop_front(); in run() 285 while(sendQueue.size() > 0) in run() 287 messagesToSend.push_back(sendQueue.front()); in run() 288 sendQueue.pop_front(); in run() 318 sendQueue.clear(); in run()
|