Home
last modified time | relevance | path

Searched defs:Conn (Results 1 – 25 of 76) sorted by relevance

1234

/aosp_15_r20/external/boringssl/src/ssl/test/runner/
H A Dconn.go26 type Conn struct { struct
28 conn net.Conn
29 isDTLS bool
30 isClient bool
33 handshakeMutex sync.Mutex // handshakeMutex < in.Mutex, out.Mutex, errMutex
34 handshakeErr error // error resulting from handshake
35 wireVersion uint16 // TLS wire version
36 vers uint16 // TLS version
37 haveVers bool // version has been negotiated
38 config *Config // configuration passed to constructor
[all …]
H A Dpacket_adapter.go30 net.Conn anonMember
37 func newPacketAdaptor(conn net.Conn) *packetAdaptor {
134 net.Conn anonMember
141 func newReplayAdaptor(conn net.Conn) net.Conn {
159 net.Conn anonMember
165 func newDamageAdaptor(conn net.Conn) *damageAdaptor {
H A Ddtls.go488 func DTLSServer(conn net.Conn, config *Config) *Conn {
498 func DTLSClient(conn net.Conn, config *Config) *Conn {
H A Dmock_quic_transport.go73 net.Conn anonMember
80 func newMockQUICTransport(conn net.Conn) *mockQUICTransport {
/aosp_15_r20/external/cronet/third_party/boringssl/src/ssl/test/runner/
H A Dconn.go26 type Conn struct { struct
28 conn net.Conn
29 isDTLS bool
30 isClient bool
33 handshakeMutex sync.Mutex // handshakeMutex < in.Mutex, out.Mutex, errMutex
34 handshakeErr error // error resulting from handshake
35 wireVersion uint16 // TLS wire version
36 vers uint16 // TLS version
37 haveVers bool // version has been negotiated
38 config *Config // configuration passed to constructor
[all …]
H A Dpacket_adapter.go30 net.Conn anonMember
37 func newPacketAdaptor(conn net.Conn) *packetAdaptor {
134 net.Conn anonMember
141 func newReplayAdaptor(conn net.Conn) net.Conn {
159 net.Conn anonMember
165 func newDamageAdaptor(conn net.Conn) *damageAdaptor {
H A Ddtls.go488 func DTLSServer(conn net.Conn, config *Config) *Conn {
498 func DTLSClient(conn net.Conn, config *Config) *Conn {
H A Dmock_quic_transport.go73 net.Conn anonMember
80 func newMockQUICTransport(conn net.Conn) *mockQUICTransport {
/aosp_15_r20/prebuilts/go/linux-x86/src/crypto/tls/
Dconn.go28 type Conn struct { struct
30 conn net.Conn
31 isClient bool
32 handshakeFn func(context.Context) error // (*Conn).clientHandshake or serverHandshake
33 quic *quicState // nil for non-QUIC connections
38 isHandshakeComplete atomic.Bool
40 handshakeMutex sync.Mutex
41 handshakeErr error // error resulting from handshake
42 vers uint16 // TLS version
43 haveVers bool // version has been negotiated
[all …]
/aosp_15_r20/external/swiftshader/third_party/SPIRV-Tools/utils/vscode/src/lsp/jsonrpc2/
H A Djsonrpc2.go30 type Conn struct { struct
31 seq int64 // must only be accessed using atomic operations
32 handlers []Handler
33 stream Stream
34 err error
35 pendingMu sync.Mutex // protects the pending map
36 pending map[ID]chan *WireResponse
37 handlingMu sync.Mutex // protects the handling map
38 handling map[ID]*Request
87 func (c *Conn) AddHandler(handler Handler) {
[all …]
H A Dhandler.go39 Cancel(ctx context.Context, conn *Conn, id ID, cancelled bool) bool
51 Request(ctx context.Context, conn *Conn, direction Direction, r *WireRequest) context.Context
53 Response(ctx context.Context, conn *Conn, direction Direction, r *WireResponse) context.Context
/aosp_15_r20/external/deqp-deps/SPIRV-Tools/utils/vscode/src/lsp/jsonrpc2/
Djsonrpc2.go30 type Conn struct { struct
31 seq int64 // must only be accessed using atomic operations
32 handlers []Handler
33 stream Stream
34 err error
35 pendingMu sync.Mutex // protects the pending map
36 pending map[ID]chan *WireResponse
37 handlingMu sync.Mutex // protects the handling map
38 handling map[ID]*Request
87 func (c *Conn) AddHandler(handler Handler) {
[all …]
Dhandler.go39 Cancel(ctx context.Context, conn *Conn, id ID, cancelled bool) bool
51 Request(ctx context.Context, conn *Conn, direction Direction, r *WireRequest) context.Context
53 Response(ctx context.Context, conn *Conn, direction Direction, r *WireResponse) context.Context
/aosp_15_r20/external/angle/third_party/spirv-tools/src/utils/vscode/src/lsp/jsonrpc2/
H A Djsonrpc2.go30 type Conn struct { struct
31 seq int64 // must only be accessed using atomic operations
32 handlers []Handler
33 stream Stream
34 err error
35 pendingMu sync.Mutex // protects the pending map
36 pending map[ID]chan *WireResponse
37 handlingMu sync.Mutex // protects the handling map
38 handling map[ID]*Request
87 func (c *Conn) AddHandler(handler Handler) {
[all …]
H A Dhandler.go39 Cancel(ctx context.Context, conn *Conn, id ID, cancelled bool) bool
51 Request(ctx context.Context, conn *Conn, direction Direction, r *WireRequest) context.Context
53 Response(ctx context.Context, conn *Conn, direction Direction, r *WireResponse) context.Context
/aosp_15_r20/prebuilts/go/linux-x86/src/vendor/golang.org/x/net/nettest/
Dconntest.go65 func testBasicIO(t *testing.T, c1, c2 net.Conn) {
98 func testPingPong(t *testing.T, c1, c2 net.Conn) {
146 func testRacyRead(t *testing.T, c1, c2 net.Conn) {
174 func testRacyWrite(t *testing.T, c1, c2 net.Conn) {
201 func testReadTimeout(t *testing.T, c1, c2 net.Conn) {
213 func testWriteTimeout(t *testing.T, c1, c2 net.Conn) {
226 func testPastTimeout(t *testing.T, c1, c2 net.Conn) {
248 func testPresentTimeout(t *testing.T, c1, c2 net.Conn) {
287 func testFutureTimeout(t *testing.T, c1, c2 net.Conn) {
314 func testCloseTimeout(t *testing.T, c1, c2 net.Conn) {
[all …]
/aosp_15_r20/external/rust/android-crates-io/crates/hyper/src/server/
Daccept.rs20 type Conn; typedef
28 ) -> Poll<Option<Result<Self::Conn, Self::Error>>>; in poll_accept()
50 pub fn poll_fn<F, IO, E>(func: F) -> impl Accept<Conn = IO, Error = E> in poll_fn()
63 type Conn = IO; in poll_fn() typedef
68 ) -> Poll<Option<Result<Self::Conn, Self::Error>>> { in poll_fn()
83 pub fn from_stream<S, IO, E>(stream: S) -> impl Accept<Conn = IO, Error = E> in from_stream()
98 type Conn = IO; in from_stream() typedef
103 ) -> Poll<Option<Result<Self::Conn, Self::Error>>> { in from_stream()
/aosp_15_r20/prebuilts/go/linux-x86/src/net/textproto/
Dtextproto.go57 type Conn struct { struct
58 Reader
59 Writer
60 Pipeline
61 conn io.ReadWriteCloser
74 func (c *Conn) Close() error {
112 func (c *Conn) Cmd(format string, args ...any) (id uint, err error) {
/aosp_15_r20/prebuilts/go/linux-x86/src/database/sql/
Dsql.go1937 func (db *DB) Conn(ctx context.Context) (*Conn, error) { func
1968 type Conn struct { struct
1969 db *DB
1974 closemu sync.RWMutex
1978 dc *driverConn
1982 done atomic.Bool
1984 releaseConnOnce sync.Once
1987 releaseConnCache releaseConn
1992 func (c *Conn) grabConn(context.Context) (*driverConn, releaseConn, error) {
2004 func (c *Conn) PingContext(ctx context.Context) error {
[all …]
Dctxutil.go13 func ctxDriverPrepare(ctx context.Context, ci driver.Conn, query string) (driver.Stmt, error) {
97 func ctxDriverBegin(ctx context.Context, opts *TxOptions, ci driver.Conn) (driver.Tx, error) {
/aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/tools/http2_interop/
Dhttp2interop.go315 func expectGoAway(conn net.Conn) (*GoAwayFrame, error) {
330 func expectGoAwaySoon(conn net.Conn) (*GoAwayFrame, error) {
344 func http2Connect(c net.Conn, sf *SettingsFrame) error {
360 net.Conn anonMember
/aosp_15_r20/external/grpc-grpc/tools/http2_interop/
H A Dhttp2interop.go315 func expectGoAway(conn net.Conn) (*GoAwayFrame, error) {
330 func expectGoAwaySoon(conn net.Conn) (*GoAwayFrame, error) {
344 func http2Connect(c net.Conn, sf *SettingsFrame) error {
360 net.Conn anonMember
/aosp_15_r20/external/rust/android-crates-io/crates/hyper/src/proto/h1/
Dconn.rs34 pub(crate) struct Conn<I, B, T> { struct
40 impl<I, B, T> Conn<I, B, T> argument
798 impl<I, B: Buf, T> fmt::Debug for Conn<I, B, T> { implementation
808 impl<I: Unpin, B, T> Unpin for Conn<I, B, T> {} implementation
/aosp_15_r20/prebuilts/go/linux-x86/src/net/http/httputil/
Dpersist.go54 func NewServerConn(c net.Conn, r *bufio.Reader) *ServerConn {
248 func NewClientConn(c net.Conn, r *bufio.Reader) *ClientConn {
265 func NewProxyClientConn(c net.Conn, r *bufio.Reader) *ClientConn {
/aosp_15_r20/prebuilts/go/linux-x86/test/fixedbugs/
Dissue7405.go20 Conn anonMember
41 type Conn interface { interface

1234