/dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/lucas-clemente/quic-go/ |
H A D | zero_rtt_queue_test.go | 25 for connID := range q.queue { 41 q.Enqueue(connID, p) 42 Expect(q.Dequeue(connID)).To(Equal(p)) 43 Expect(q.Dequeue(connID)).To(BeNil()) 60 Expect(q.Dequeue(connID)).To(BeNil()) 63 connID := make([]byte, 4) 65 p := q.Dequeue(connID) 81 Expect(q.Dequeue(connID)).To(BeNil()) 100 p := q.Dequeue(connID) 105 Expect(q.Dequeue(connID)).To(BeNil()) [all …]
|
H A D | packet_handler_map_test.go | 45 DestConnectionID: connID, 55 return getPacketWithLength(connID, 2) 110 delete(handler.handlers, connID) 135 Expect(connID).To(Equal(connID1)) 167 handler.Remove(connID) 176 handler.Add(connID, sess) 177 handler.Retire(connID) 192 handler.Retire(connID) 242 p := getPacket(connID) 247 Expect(cid).To(Equal(connID)) [all …]
|
H A D | conn_id_generator.go | 78 connID, ok := m.activeSrcConnIDs[seq] 86 m.retireConnectionID(connID) 99 connID, err := protocol.GenerateConnectionID(m.connIDLen) 103 m.activeSrcConnIDs[m.highestSeq+1] = connID 104 m.addConnectionID(connID) 107 ConnectionID: connID, 108 StatelessResetToken: m.getStatelessResetToken(connID), 125 for _, connID := range m.activeSrcConnIDs { 126 m.removeConnectionID(connID) 134 for _, connID := range m.activeSrcConnIDs { [all …]
|
/dports/net/v2ray/v2ray-core-4.36.2/vendor/github.com/lucas-clemente/quic-go/ |
H A D | zero_rtt_queue_test.go | 25 for connID := range q.queue { 41 q.Enqueue(connID, p) 42 Expect(q.Dequeue(connID)).To(Equal(p)) 43 Expect(q.Dequeue(connID)).To(BeNil()) 60 Expect(q.Dequeue(connID)).To(BeNil()) 63 connID := make([]byte, 4) 65 p := q.Dequeue(connID) 81 Expect(q.Dequeue(connID)).To(BeNil()) 100 p := q.Dequeue(connID) 105 Expect(q.Dequeue(connID)).To(BeNil()) [all …]
|
H A D | packet_handler_map_test.go | 45 DestConnectionID: connID, 55 return getPacketWithLength(connID, 2) 110 delete(handler.handlers, connID) 135 Expect(connID).To(Equal(connID1)) 167 handler.Remove(connID) 176 handler.Add(connID, sess) 177 handler.Retire(connID) 192 handler.Retire(connID) 242 p := getPacket(connID) 247 Expect(cid).To(Equal(connID)) [all …]
|
H A D | conn_id_generator.go | 78 connID, ok := m.activeSrcConnIDs[seq] 86 m.retireConnectionID(connID) 99 connID, err := protocol.GenerateConnectionID(m.connIDLen) 103 m.activeSrcConnIDs[m.highestSeq+1] = connID 104 m.addConnectionID(connID) 107 ConnectionID: connID, 108 StatelessResetToken: m.getStatelessResetToken(connID), 125 for _, connID := range m.activeSrcConnIDs { 126 m.removeConnectionID(connID) 134 for _, connID := range m.activeSrcConnIDs { [all …]
|
H A D | zero_rtt_queue.go | 28 func (h *zeroRTTQueue) Enqueue(connID protocol.ConnectionID, p *receivedPacket) { 32 cid := string(connID) 38 h.deleteQueue(connID) 48 func (h *zeroRTTQueue) Dequeue(connID protocol.ConnectionID) *receivedPacket { 52 entry, ok := h.queue[string(connID)] 60 delete(h.queue, string(connID)) 65 func (h *zeroRTTQueue) deleteQueue(connID protocol.ConnectionID) { 69 entry, ok := h.queue[string(connID)] 76 delete(h.queue, string(connID))
|
/dports/net/storj/storj-1.45.3/vendor/github.com/lucas-clemente/quic-go/ |
H A D | packet_handler_map_test.go | 45 DestConnectionID: connID, 110 delete(handler.handlers, connID) 135 Expect(connID).To(Equal(connID1)) 167 handler.Remove(connID) 176 handler.Add(connID, sess) 177 handler.Retire(connID) 192 handler.Retire(connID) 242 p := getPacket(connID) 247 Expect(cid).To(Equal(connID)) 268 p := getPacket(connID) [all …]
|
H A D | conn_id_generator.go | 81 connID, ok := m.activeSrcConnIDs[seq] 86 if connID.Equal(sentWithDestConnID) { 92 m.retireConnectionID(connID) 106 m.activeSrcConnIDs[m.highestSeq+1] = connID 107 m.addConnectionID(connID) 110 ConnectionID: connID, 111 StatelessResetToken: m.getStatelessResetToken(connID), 128 for _, connID := range m.activeSrcConnIDs { 129 m.removeConnectionID(connID) 137 for _, connID := range m.activeSrcConnIDs { [all …]
|
/dports/security/xray-core/Xray-core-1.5.0/vendor/github.com/lucas-clemente/quic-go/ |
H A D | packet_handler_map_test.go | 45 DestConnectionID: connID, 110 delete(handler.handlers, connID) 135 Expect(connID).To(Equal(connID1)) 167 handler.Remove(connID) 176 handler.Add(connID, sess) 177 handler.Retire(connID) 192 handler.Retire(connID) 242 p := getPacket(connID) 247 Expect(cid).To(Equal(connID)) 268 p := getPacket(connID) [all …]
|
H A D | conn_id_generator.go | 81 connID, ok := m.activeSrcConnIDs[seq] 86 if connID.Equal(sentWithDestConnID) { 92 m.retireConnectionID(connID) 106 m.activeSrcConnIDs[m.highestSeq+1] = connID 107 m.addConnectionID(connID) 110 ConnectionID: connID, 111 StatelessResetToken: m.getStatelessResetToken(connID), 128 for _, connID := range m.activeSrcConnIDs { 129 m.removeConnectionID(connID) 137 for _, connID := range m.activeSrcConnIDs { [all …]
|
/dports/dns/nextdns/nextdns-1.32.2/vendor/github.com/lucas-clemente/quic-go/ |
H A D | packet_handler_map_test.go | 45 DestConnectionID: connID, 110 delete(handler.handlers, connID) 135 Expect(connID).To(Equal(connID1)) 167 handler.Remove(connID) 176 handler.Add(connID, sess) 177 handler.Retire(connID) 192 handler.Retire(connID) 242 p := getPacket(connID) 247 Expect(cid).To(Equal(connID)) 268 p := getPacket(connID) [all …]
|
H A D | conn_id_generator.go | 78 connID, ok := m.activeSrcConnIDs[seq] 86 m.retireConnectionID(connID) 99 connID, err := protocol.GenerateConnectionID(m.connIDLen) 103 m.activeSrcConnIDs[m.highestSeq+1] = connID 104 m.addConnectionID(connID) 107 ConnectionID: connID, 108 StatelessResetToken: m.getStatelessResetToken(connID), 125 for _, connID := range m.activeSrcConnIDs { 126 m.removeConnectionID(connID) 134 for _, connID := range m.activeSrcConnIDs { [all …]
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/lucas-clemente/quic-go/ |
H A D | packet_handler_map_test.go | 45 DestConnectionID: connID, 110 delete(handler.handlers, connID) 135 Expect(connID).To(Equal(connID1)) 167 handler.Remove(connID) 176 handler.Add(connID, sess) 177 handler.Retire(connID) 192 handler.Retire(connID) 242 p := getPacket(connID) 247 Expect(cid).To(Equal(connID)) 268 p := getPacket(connID) [all …]
|
H A D | conn_id_generator.go | 81 connID, ok := m.activeSrcConnIDs[seq] 86 if connID.Equal(sentWithDestConnID) { 92 m.retireConnectionID(connID) 106 m.activeSrcConnIDs[m.highestSeq+1] = connID 107 m.addConnectionID(connID) 110 ConnectionID: connID, 111 StatelessResetToken: m.getStatelessResetToken(connID), 128 for _, connID := range m.activeSrcConnIDs { 129 m.removeConnectionID(connID) 137 for _, connID := range m.activeSrcConnIDs { [all …]
|
/dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/lucas-clemente/quic-go/ |
H A D | packet_handler_map_test.go | 45 DestConnectionID: connID, 110 delete(handler.handlers, connID) 135 Expect(connID).To(Equal(connID1)) 167 handler.Remove(connID) 176 handler.Add(connID, sess) 177 handler.Retire(connID) 192 handler.Retire(connID) 242 p := getPacket(connID) 247 Expect(cid).To(Equal(connID)) 268 p := getPacket(connID) [all …]
|
H A D | conn_id_generator.go | 81 connID, ok := m.activeSrcConnIDs[seq] 86 if connID.Equal(sentWithDestConnID) { 92 m.retireConnectionID(connID) 106 m.activeSrcConnIDs[m.highestSeq+1] = connID 107 m.addConnectionID(connID) 110 ConnectionID: connID, 111 StatelessResetToken: m.getStatelessResetToken(connID), 128 for _, connID := range m.activeSrcConnIDs { 129 m.removeConnectionID(connID) 137 for _, connID := range m.activeSrcConnIDs { [all …]
|
/dports/devel/mutagen/mutagen-0.11.8/vendor/github.com/lucas-clemente/quic-go/ |
H A D | packet_handler_map_test.go | 33 DestConnectionID: connID, 43 return getPacketWithLength(connID, 2) 61 delete(handler.handlers, connID) 106 Expect(connID).To(Equal(connID1)) 112 Expect(connID).To(Equal(connID2)) 132 handler.Remove(connID) 141 handler.Retire(connID) 156 handler.Retire(connID) 182 p := getPacket(connID) 187 Expect(cid).To(Equal(connID)) [all …]
|
/dports/net/inlets/inlets-3.0.2/vendor/github.com/rancher/remotedialer/ |
H A D | message.go | 41 connID int64 member 53 func newMessage(connID int64, bytes []byte) *message { 56 connID: connID, 62 func newConnect(connID int64, proto, address string) *message { 65 connID: connID, 73 func newErrorMessage(connID int64, err error) *message { 77 connID: connID, 109 connID, err := binary.ReadVarint(buf) 122 connID: connID, 184 offset += binary.PutVarint(buf[offset:], m.connID) [all …]
|
/dports/net/inlets/inlets-3.0.2/vendor/github.com/rancher/remotedialer/remotedialer-8b1b7bb7d05f/ |
H A D | message.go | 41 connID int64 member 53 func newMessage(connID int64, bytes []byte) *message { 56 connID: connID, 62 func newConnect(connID int64, proto, address string) *message { 65 connID: connID, 73 func newErrorMessage(connID int64, err error) *message { 77 connID: connID, 109 connID, err := binary.ReadVarint(buf) 122 connID: connID, 184 offset += binary.PutVarint(buf[offset:], m.connID) [all …]
|
/dports/net/traefik/traefik-2.6.1/vendor/github.com/lucas-clemente/quic-go/ |
H A D | conn_id_generator.go | 81 connID, ok := m.activeSrcConnIDs[seq] 86 if connID.Equal(sentWithDestConnID) { 92 m.retireConnectionID(connID) 106 m.activeSrcConnIDs[m.highestSeq+1] = connID 107 m.addConnectionID(connID) 110 ConnectionID: connID, 111 StatelessResetToken: m.getStatelessResetToken(connID), 128 for _, connID := range m.activeSrcConnIDs { 129 m.removeConnectionID(connID) 137 for _, connID := range m.activeSrcConnIDs { [all …]
|
/dports/net/syncthing/syncthing-1.18.1/syncthing/vendor/github.com/lucas-clemente/quic-go/ |
H A D | conn_id_generator.go | 78 connID, ok := m.activeSrcConnIDs[seq] 86 m.retireConnectionID(connID) 99 connID, err := protocol.GenerateConnectionID(m.connIDLen) 103 m.activeSrcConnIDs[m.highestSeq+1] = connID 104 m.addConnectionID(connID) 107 ConnectionID: connID, 108 StatelessResetToken: m.getStatelessResetToken(connID), 125 for _, connID := range m.activeSrcConnIDs { 126 m.removeConnectionID(connID) 134 for _, connID := range m.activeSrcConnIDs { [all …]
|
/dports/www/mattermost-server/mattermost-server-6.0.2/plugin/plugintest/ |
H A D | driver.go | 43 ret := _m.Called(connID) 47 r0 = rf(connID) 61 r0 = rf(connID, q, args) 68 r1 = rf(connID, q, args) 78 ret := _m.Called(connID) 82 r0 = rf(connID) 96 r0 = rf(connID, q, args) 231 r0 = rf(connID, q) 238 r1 = rf(connID, q) 322 r0 = rf(connID, opts) [all …]
|
/dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/ooni/psiphon/oopsi/github.com/Psiphon-Labs/quic-go/quictrace/ |
H A D | tracer.go | 15 connID protocol.ConnectionID member 39 func (t *tracer) Trace(connID protocol.ConnectionID, ev Event) { 40 t.eventQueue <- traceEvent{connID: connID, ev: ev} 45 key := string(tev.connID) 55 for connID := range t.events { 56 data, err := t.emitByConnIDAsString(connID) 60 traces[connID] = data 66 func (t *tracer) Emit(connID protocol.ConnectionID) ([]byte, error) { 67 return t.emitByConnIDAsString(string(connID)) 71 events, ok := t.events[connID] [all …]
|
/dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/ooni/psiphon/oopsi/github.com/Psiphon-Labs/quic-go/quictrace/ |
H A D | tracer.go | 15 connID protocol.ConnectionID member 39 func (t *tracer) Trace(connID protocol.ConnectionID, ev Event) { 40 t.eventQueue <- traceEvent{connID: connID, ev: ev} 45 key := string(tev.connID) 55 for connID := range t.events { 56 data, err := t.emitByConnIDAsString(connID) 60 traces[connID] = data 66 func (t *tracer) Emit(connID protocol.ConnectionID) ([]byte, error) { 67 return t.emitByConnIDAsString(string(connID)) 71 events, ok := t.events[connID] [all …]
|