Searched refs:conn (Results 1 – 8 of 8) sorted by relevance
| /ssl/test/runner/ |
| A D | dtls.go | 814 c := &Conn{config: config, isDTLS: true, conn: conn}
824 c := &Conn{config: config, isClient: true, isDTLS: true, conn: conn}
881 conn *Conn member
896 return DTLSController{conn: conn, retransmitNeeded: retransmitNeeded}
921 return c.conn.out.epoch.epoch
926 return c.conn.in.epoch.epoch
965 c.conn.maxPacketLen = mtu
972 config := c.conn.config
1044 config := c.conn.config
1056 c.conn.expectedACK = append(c.conn.expectedACK, num)
[all …]
|
| A D | shim_dispatcher.go | 73 conn, err := d.listener.Accept()
81 if err := d.dispatch(conn); err != nil {
85 conn.Close()
91 func (d *shimDispatcher) dispatch(conn net.Conn) error {
92 conn.SetReadDeadline(time.Now().Add(*idleTimeout))
94 if _, err := io.ReadFull(conn, buf[:]); err != nil {
97 conn.SetReadDeadline(time.Time{})
110 conn.Close()
116 shim.connChan <- conn
193 case conn, ok := <-l.connChan:
[all …]
|
| A D | tls.go | 27 func Server(conn net.Conn, config *Config) *Conn {
28 c := &Conn{conn: conn, config: config}
37 func Client(conn net.Conn, config *Config) *Conn {
38 c := &Conn{conn: conn, config: config, isClient: true}
144 conn := Client(rawConn, config)
147 err = conn.Handshake()
150 errChannel <- conn.Handshake()
161 return conn, nil
|
| A D | packet_adapter.go | 47 func newPacketAdaptor(conn net.Conn) *packetAdaptor {
48 return &packetAdaptor{conn, nil}
180 func newReplayAdaptor(conn net.Conn) net.Conn {
181 return &replayAdaptor{Conn: conn}
204 func newDamageAdaptor(conn net.Conn) *damageAdaptor {
205 return &damageAdaptor{Conn: conn}
|
| A D | runner.go | 705 conn = &timeoutConn{conn, *idleTimeout}
710 conn = config.Bugs.PacketAdaptor
719 Conn: conn,
724 conn = connDebug
769 conn = newReplayAdaptor(conn)
774 connDamage = newDamageAdaptor(conn)
775 conn = connDamage
789 tlsConn = Server(conn, config)
796 tlsConn = Client(conn, config)
1327 conn, err := shim.accept()
[all …]
|
| A D | conn.go | 41 conn net.Conn member
167 c.in.conn = c
168 c.out.conn = c
178 return c.conn.LocalAddr()
183 return c.conn.RemoteAddr()
190 return c.conn.SetDeadline(t)
196 return c.conn.SetReadDeadline(t)
239 conn *Conn member
1244 return c.conn.Write(record)
1371 _, err = c.conn.Write(record)
[all …]
|
| A D | mock_quic_transport.go | 80 func newMockQUICTransport(conn net.Conn) *mockQUICTransport {
81 return &mockQUICTransport{Conn: conn}
|
| A D | handshake_client.go | 118 cacheKey = clientSessionCacheKey(c.conn.RemoteAddr(), c.config)
|
Completed in 22 milliseconds