Home
last modified time | relevance | path

Searched refs:sendQueue (Results 1 – 25 of 110) sorted by relevance

12345

/dports/net/storj/storj-1.45.3/vendor/github.com/lucas-clemente/quic-go/
H A Dsend_queue.go11 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 Ddatagram_queue.go10 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 Dsend_queue.go11 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 Ddatagram_queue.go10 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 Dsend_queue.go11 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 Ddatagram_queue.go10 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 Dsend_queue.go11 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 Ddatagram_queue.go10 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 Dsend_queue.go11 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 Ddatagram_queue.go10 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 Dsend_queue.go11 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 Ddatagram_queue.go10 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 Dsend_queue.go3 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 Dsend_queue.go3 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 Dsend_queue.go3 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 Dsend_queue.go3 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 Dsend_queue.go3 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 DMockDatagramAssociation.java38 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 Dpubsub.php19 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 Dmodule_mock.cc41 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 Dsmtp.C126 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 Dwebsocket.ts24 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 Droot.py27 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 Dmplayer.py312 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 DSocket_p.h115 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()

12345