Home
last modified time | relevance | path

Searched refs:Conn (Results 1 – 25 of 45) sorted by relevance

12

/external/boringssl/src/ssl/test/runner/
Dpacket_adapter.go30 net.Conn anonMember
37 func newPacketAdaptor(conn net.Conn) *packetAdaptor { argument
51 if _, err := io.ReadFull(p.Conn, out); err != nil {
59 if err := binary.Read(p.Conn, binary.BigEndian, &length); err != nil {
63 if _, err := io.ReadFull(p.Conn, out); err != nil {
89 if _, err := p.Conn.Write(payload); err != nil {
104 if _, err := p.Conn.Write(payload); err != nil {
134 net.Conn anonMember
141 func newReplayAdaptor(conn net.Conn) net.Conn { argument
142 return &replayAdaptor{Conn: conn}
[all …]
Dtls.go27 func Server(conn net.Conn, config *Config) *Conn { argument
28 c := &Conn{conn: conn, config: config}
37 func Client(conn net.Conn, config *Config) *Conn { argument
38 c := &Conn{conn: conn, config: config, isClient: true}
51 func (l *listener) Accept() (c net.Conn, err error) {
99 func DialWithDialer(dialer *net.Dialer, network, addr string, config *Config) (*Conn, error) {
170 func Dial(network, addr string, config *Config) (*Conn, error) {
Dmock_quic_transport.go73 net.Conn anonMember
80 func newMockQUICTransport(conn net.Conn) *mockQUICTransport { argument
81 return &mockQUICTransport{Conn: conn}
87 if _, err := io.ReadFull(m.Conn, header); err != nil {
95 if _, err := io.ReadFull(m.Conn, value); err != nil {
142 if _, err := m.Conn.Write(payload); err != nil {
Ddtls.go26 func (c *Conn) dtlsDoReadRecord(want recordType) (recordType, *block, error) {
121 func (c *Conn) makeFragment(header, data []byte, fragOffset, fragLen int) []byte {
131 func (c *Conn) dtlsWriteRecord(typ recordType, data []byte) (n int, err error) {
267 func (c *Conn) dtlsPackHandshake() error {
319 func (c *Conn) dtlsFlushHandshake() error {
333 func (c *Conn) dtlsPackRecord(typ recordType, data []byte, mustPack bool) (n int, err error) {
409 func (c *Conn) dtlsFlushPacket() error {
418 func (c *Conn) dtlsDoReadHandshake() ([]byte, error) {
488 func DTLSServer(conn net.Conn, config *Config) *Conn { argument
489 c := &Conn{config: config, isDTLS: true, conn: conn}
[all …]
Dconn.go26 type Conn struct { struct
28 conn net.Conn argument
125 func (c *Conn) init() { argument
139 func (c *Conn) LocalAddr() net.Addr { argument
144 func (c *Conn) RemoteAddr() net.Addr { argument
151 func (c *Conn) SetDeadline(t time.Time) error { argument
157 func (c *Conn) SetReadDeadline(t time.Time) error { argument
164 func (c *Conn) SetWriteDeadline(t time.Time) error { argument
738 func (c *Conn) useInTrafficSecret(level encryptionLevel, version uint16, suite *cipherSuite, secret… argument
756 func (c *Conn) useOutTrafficSecret(level encryptionLevel, version uint16, suite *cipherSuite, secre… argument
[all …]
/external/cronet/third_party/boringssl/src/ssl/test/runner/
Dpacket_adapter.go30 net.Conn anonMember
37 func newPacketAdaptor(conn net.Conn) *packetAdaptor { argument
51 if _, err := io.ReadFull(p.Conn, out); err != nil {
59 if err := binary.Read(p.Conn, binary.BigEndian, &length); err != nil {
63 if _, err := io.ReadFull(p.Conn, out); err != nil {
89 if _, err := p.Conn.Write(payload); err != nil {
104 if _, err := p.Conn.Write(payload); err != nil {
134 net.Conn anonMember
141 func newReplayAdaptor(conn net.Conn) net.Conn { argument
142 return &replayAdaptor{Conn: conn}
[all …]
Dtls.go27 func Server(conn net.Conn, config *Config) *Conn { argument
28 c := &Conn{conn: conn, config: config}
37 func Client(conn net.Conn, config *Config) *Conn { argument
38 c := &Conn{conn: conn, config: config, isClient: true}
51 func (l *listener) Accept() (c net.Conn, err error) {
99 func DialWithDialer(dialer *net.Dialer, network, addr string, config *Config) (*Conn, error) {
170 func Dial(network, addr string, config *Config) (*Conn, error) {
Dmock_quic_transport.go73 net.Conn anonMember
80 func newMockQUICTransport(conn net.Conn) *mockQUICTransport { argument
81 return &mockQUICTransport{Conn: conn}
87 if _, err := io.ReadFull(m.Conn, header); err != nil {
95 if _, err := io.ReadFull(m.Conn, value); err != nil {
142 if _, err := m.Conn.Write(payload); err != nil {
Ddtls.go26 func (c *Conn) dtlsDoReadRecord(want recordType) (recordType, *block, error) {
121 func (c *Conn) makeFragment(header, data []byte, fragOffset, fragLen int) []byte {
131 func (c *Conn) dtlsWriteRecord(typ recordType, data []byte) (n int, err error) {
267 func (c *Conn) dtlsPackHandshake() error {
319 func (c *Conn) dtlsFlushHandshake() error {
333 func (c *Conn) dtlsPackRecord(typ recordType, data []byte, mustPack bool) (n int, err error) {
409 func (c *Conn) dtlsFlushPacket() error {
418 func (c *Conn) dtlsDoReadHandshake() ([]byte, error) {
488 func DTLSServer(conn net.Conn, config *Config) *Conn { argument
489 c := &Conn{config: config, isDTLS: true, conn: conn}
[all …]
Dconn.go26 type Conn struct { struct
28 conn net.Conn argument
125 func (c *Conn) init() { argument
139 func (c *Conn) LocalAddr() net.Addr { argument
144 func (c *Conn) RemoteAddr() net.Addr { argument
151 func (c *Conn) SetDeadline(t time.Time) error { argument
157 func (c *Conn) SetReadDeadline(t time.Time) error { argument
164 func (c *Conn) SetWriteDeadline(t time.Time) error { argument
738 func (c *Conn) useInTrafficSecret(level encryptionLevel, version uint16, suite *cipherSuite, secret… argument
756 func (c *Conn) useOutTrafficSecret(level encryptionLevel, version uint16, suite *cipherSuite, secre… argument
[all …]
/external/angle/third_party/vulkan-deps/spirv-tools/src/utils/vscode/src/lsp/protocol/
Dtsserver.go541 *jsonrpc2.Conn anonMember
545 return s.Conn.Notify(ctx, "workspace/didChangeWorkspaceFolders", params)
549 return s.Conn.Notify(ctx, "initialized", params)
553 return s.Conn.Notify(ctx, "exit", nil)
557 return s.Conn.Notify(ctx, "workspace/didChangeConfiguration", params)
561 return s.Conn.Notify(ctx, "textDocument/didOpen", params)
565 return s.Conn.Notify(ctx, "textDocument/didChange", params)
569 return s.Conn.Notify(ctx, "textDocument/didClose", params)
573 return s.Conn.Notify(ctx, "textDocument/didSave", params)
577 return s.Conn.Notify(ctx, "textDocument/willSave", params)
[all …]
Dtsclient.go159 *jsonrpc2.Conn anonMember
163 return s.Conn.Notify(ctx, "window/showMessage", params)
167 return s.Conn.Notify(ctx, "window/logMessage", params)
171 return s.Conn.Notify(ctx, "telemetry/event", params)
175 return s.Conn.Notify(ctx, "textDocument/publishDiagnostics", params)
179 if err := s.Conn.Call(ctx, "workspace/workspaceFolders", nil, &result); err != nil {
187 if err := s.Conn.Call(ctx, "workspace/configuration", params, &result); err != nil {
194 return s.Conn.Call(ctx, "client/registerCapability", params, nil) // Call, not Notify
198 return s.Conn.Call(ctx, "client/unregisterCapability", params, nil) // Call, not Notify
203 if err := s.Conn.Call(ctx, "window/showMessageRequest", params, &result); err != nil {
[all …]
Dprotocol.go44 func (canceller) Request(ctx context.Context, conn *jsonrpc2.Conn, direction jsonrpc2.Direction, r …
56 func (canceller) Cancel(ctx context.Context, conn *jsonrpc2.Conn, id jsonrpc2.ID, cancelled bool) b…
64 …context.Context, stream jsonrpc2.Stream, client Client) (context.Context, *jsonrpc2.Conn, Server) {
68 return ctx, conn, &serverDispatcher{Conn: conn}
71 …context.Context, stream jsonrpc2.Stream, server Server) (context.Context, *jsonrpc2.Conn, Client) {
73 client := &clientDispatcher{Conn: conn}
/external/deqp-deps/SPIRV-Tools/utils/vscode/src/lsp/protocol/
Dtsserver.go541 *jsonrpc2.Conn anonMember
545 return s.Conn.Notify(ctx, "workspace/didChangeWorkspaceFolders", params)
549 return s.Conn.Notify(ctx, "initialized", params)
553 return s.Conn.Notify(ctx, "exit", nil)
557 return s.Conn.Notify(ctx, "workspace/didChangeConfiguration", params)
561 return s.Conn.Notify(ctx, "textDocument/didOpen", params)
565 return s.Conn.Notify(ctx, "textDocument/didChange", params)
569 return s.Conn.Notify(ctx, "textDocument/didClose", params)
573 return s.Conn.Notify(ctx, "textDocument/didSave", params)
577 return s.Conn.Notify(ctx, "textDocument/willSave", params)
[all …]
Dtsclient.go159 *jsonrpc2.Conn anonMember
163 return s.Conn.Notify(ctx, "window/showMessage", params)
167 return s.Conn.Notify(ctx, "window/logMessage", params)
171 return s.Conn.Notify(ctx, "telemetry/event", params)
175 return s.Conn.Notify(ctx, "textDocument/publishDiagnostics", params)
179 if err := s.Conn.Call(ctx, "workspace/workspaceFolders", nil, &result); err != nil {
187 if err := s.Conn.Call(ctx, "workspace/configuration", params, &result); err != nil {
194 return s.Conn.Call(ctx, "client/registerCapability", params, nil) // Call, not Notify
198 return s.Conn.Call(ctx, "client/unregisterCapability", params, nil) // Call, not Notify
203 if err := s.Conn.Call(ctx, "window/showMessageRequest", params, &result); err != nil {
[all …]
Dprotocol.go44 func (canceller) Request(ctx context.Context, conn *jsonrpc2.Conn, direction jsonrpc2.Direction, r …
56 func (canceller) Cancel(ctx context.Context, conn *jsonrpc2.Conn, id jsonrpc2.ID, cancelled bool) b…
64 …context.Context, stream jsonrpc2.Stream, client Client) (context.Context, *jsonrpc2.Conn, Server) {
68 return ctx, conn, &serverDispatcher{Conn: conn}
71 …context.Context, stream jsonrpc2.Stream, server Server) (context.Context, *jsonrpc2.Conn, Client) {
73 client := &clientDispatcher{Conn: conn}
/external/swiftshader/third_party/SPIRV-Tools/utils/vscode/src/lsp/protocol/
Dtsserver.go541 *jsonrpc2.Conn anonMember
545 return s.Conn.Notify(ctx, "workspace/didChangeWorkspaceFolders", params)
549 return s.Conn.Notify(ctx, "initialized", params)
553 return s.Conn.Notify(ctx, "exit", nil)
557 return s.Conn.Notify(ctx, "workspace/didChangeConfiguration", params)
561 return s.Conn.Notify(ctx, "textDocument/didOpen", params)
565 return s.Conn.Notify(ctx, "textDocument/didChange", params)
569 return s.Conn.Notify(ctx, "textDocument/didClose", params)
573 return s.Conn.Notify(ctx, "textDocument/didSave", params)
577 return s.Conn.Notify(ctx, "textDocument/willSave", params)
[all …]
Dtsclient.go159 *jsonrpc2.Conn anonMember
163 return s.Conn.Notify(ctx, "window/showMessage", params)
167 return s.Conn.Notify(ctx, "window/logMessage", params)
171 return s.Conn.Notify(ctx, "telemetry/event", params)
175 return s.Conn.Notify(ctx, "textDocument/publishDiagnostics", params)
179 if err := s.Conn.Call(ctx, "workspace/workspaceFolders", nil, &result); err != nil {
187 if err := s.Conn.Call(ctx, "workspace/configuration", params, &result); err != nil {
194 return s.Conn.Call(ctx, "client/registerCapability", params, nil) // Call, not Notify
198 return s.Conn.Call(ctx, "client/unregisterCapability", params, nil) // Call, not Notify
203 if err := s.Conn.Call(ctx, "window/showMessageRequest", params, &result); err != nil {
[all …]
Dprotocol.go44 func (canceller) Request(ctx context.Context, conn *jsonrpc2.Conn, direction jsonrpc2.Direction, r …
56 func (canceller) Cancel(ctx context.Context, conn *jsonrpc2.Conn, id jsonrpc2.ID, cancelled bool) b…
64 …context.Context, stream jsonrpc2.Stream, client Client) (context.Context, *jsonrpc2.Conn, Server) {
68 return ctx, conn, &serverDispatcher{Conn: conn}
71 …context.Context, stream jsonrpc2.Stream, server Server) (context.Context, *jsonrpc2.Conn, Client) {
73 client := &clientDispatcher{Conn: conn}
/external/deqp-deps/SPIRV-Tools/utils/vscode/src/lsp/jsonrpc2/
Dhandler.go39 Cancel(ctx context.Context, conn *Conn, id ID, cancelled bool) bool argument
51 Request(ctx context.Context, conn *Conn, direction Direction, r *WireRequest) context.Context argument
53 Response(ctx context.Context, conn *Conn, direction Direction, r *WireResponse) context.Context argument
99 func (EmptyHandler) Cancel(ctx context.Context, conn *Conn, id ID, cancelled bool) bool {
103 func (EmptyHandler) Request(ctx context.Context, conn *Conn, direction Direction, r *WireRequest) c…
107 func (EmptyHandler) Response(ctx context.Context, conn *Conn, direction Direction, r *WireResponse)…
Djsonrpc2.go30 type Conn struct { struct
53 conn *Conn
73 func NewConn(s Stream) *Conn {
74 conn := &Conn{
87 func (c *Conn) AddHandler(handler Handler) { argument
97 func (c *Conn) Cancel(id ID) { argument
109 func (c *Conn) Notify(ctx context.Context, method string, params interface{}) (err error) { argument
140 func (c *Conn) Call(ctx context.Context, method string, params, result interface{}) (err error) { argument
214 func (r *Request) Conn() *Conn { return r.conn } func
290 func (c *Conn) setHandling(r *Request, active bool) { argument
[all …]
/external/swiftshader/third_party/SPIRV-Tools/utils/vscode/src/lsp/jsonrpc2/
Dhandler.go39 Cancel(ctx context.Context, conn *Conn, id ID, cancelled bool) bool argument
51 Request(ctx context.Context, conn *Conn, direction Direction, r *WireRequest) context.Context argument
53 Response(ctx context.Context, conn *Conn, direction Direction, r *WireResponse) context.Context argument
99 func (EmptyHandler) Cancel(ctx context.Context, conn *Conn, id ID, cancelled bool) bool {
103 func (EmptyHandler) Request(ctx context.Context, conn *Conn, direction Direction, r *WireRequest) c…
107 func (EmptyHandler) Response(ctx context.Context, conn *Conn, direction Direction, r *WireResponse)…
Djsonrpc2.go30 type Conn struct { struct
53 conn *Conn
73 func NewConn(s Stream) *Conn {
74 conn := &Conn{
87 func (c *Conn) AddHandler(handler Handler) { argument
97 func (c *Conn) Cancel(id ID) { argument
109 func (c *Conn) Notify(ctx context.Context, method string, params interface{}) (err error) { argument
140 func (c *Conn) Call(ctx context.Context, method string, params, result interface{}) (err error) { argument
214 func (r *Request) Conn() *Conn { return r.conn } func
290 func (c *Conn) setHandling(r *Request, active bool) { argument
[all …]
/external/angle/third_party/vulkan-deps/spirv-tools/src/utils/vscode/src/lsp/jsonrpc2/
Dhandler.go39 Cancel(ctx context.Context, conn *Conn, id ID, cancelled bool) bool argument
51 Request(ctx context.Context, conn *Conn, direction Direction, r *WireRequest) context.Context argument
53 Response(ctx context.Context, conn *Conn, direction Direction, r *WireResponse) context.Context argument
99 func (EmptyHandler) Cancel(ctx context.Context, conn *Conn, id ID, cancelled bool) bool {
103 func (EmptyHandler) Request(ctx context.Context, conn *Conn, direction Direction, r *WireRequest) c…
107 func (EmptyHandler) Response(ctx context.Context, conn *Conn, direction Direction, r *WireResponse)…
Djsonrpc2.go30 type Conn struct { struct
53 conn *Conn
73 func NewConn(s Stream) *Conn {
74 conn := &Conn{
87 func (c *Conn) AddHandler(handler Handler) { argument
97 func (c *Conn) Cancel(id ID) { argument
109 func (c *Conn) Notify(ctx context.Context, method string, params interface{}) (err error) { argument
140 func (c *Conn) Call(ctx context.Context, method string, params, result interface{}) (err error) { argument
214 func (r *Request) Conn() *Conn { return r.conn } func
290 func (c *Conn) setHandling(r *Request, active bool) { argument
[all …]

12