Home
last modified time | relevance | path

Searched refs:connID (Results 1 – 25 of 412) sorted by relevance

12345678910>>...17

/dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/lucas-clemente/quic-go/
H A Dzero_rtt_queue_test.go25 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 Dpacket_handler_map_test.go45 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 Dconn_id_generator.go78 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 Dzero_rtt_queue_test.go25 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 Dpacket_handler_map_test.go45 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 Dconn_id_generator.go78 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 Dzero_rtt_queue.go28 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 Dpacket_handler_map_test.go45 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 Dconn_id_generator.go81 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 Dpacket_handler_map_test.go45 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 Dconn_id_generator.go81 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 Dpacket_handler_map_test.go45 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 Dconn_id_generator.go78 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 Dpacket_handler_map_test.go45 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 Dconn_id_generator.go81 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 Dpacket_handler_map_test.go45 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 Dconn_id_generator.go81 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 Dpacket_handler_map_test.go33 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 Dmessage.go41 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 Dmessage.go41 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 Dconn_id_generator.go81 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 Dconn_id_generator.go78 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 Ddriver.go43 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 Dtracer.go15 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 Dtracer.go15 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 …]

12345678910>>...17