| /external/syzkaller/vendor/golang.org/x/net/http2/ |
| D | client_conn_pool.go | 17 GetClientConn(req *http.Request, addr string) (*ClientConn, error)
18 MarkDead(*ClientConn) argument
40 conns map[string][]*ClientConn // key is host:port
42 keys map[*ClientConn][]string
46 func (p *clientConnPool) GetClientConn(req *http.Request, addr string) (*ClientConn, error) {
55 …ientConnPool) getClientConn(req *http.Request, addr string, dialOnMiss bool) (*ClientConn, error) {
86 res *ClientConn // valid after done is closed
177 func (p *clientConnPool) addConn(key string, cc *ClientConn) {
184 func (p *clientConnPool) addConnLocked(key string, cc *ClientConn) {
191 p.conns = make(map[string][]*ClientConn)
[all …]
|
| D | transport.go | 145 type ClientConn struct { struct
191 cc *ClientConn
459 func (t *Transport) dialClientConn(addr string, singleUse bool) (*ClientConn, error) {
528 func (t *Transport) NewClientConn(c net.Conn) (*ClientConn, error) {
532 func (t *Transport) newClientConn(c net.Conn, singleUse bool) (*ClientConn, error) {
533 cc := &ClientConn{
600 func (cc *ClientConn) setGoAway(f *GoAwayFrame) { argument
627 func (cc *ClientConn) CanTakeNewRequest() bool { argument
633 func (cc *ClientConn) canTakeNewRequestLocked() bool { argument
647 func (cc *ClientConn) onIdleTimeout() { argument
[all …]
|
| D | not_go17.go | 37 func traceGotConn(*http.Request, *ClientConn) {} argument
83 func (cc *ClientConn) Ping(ctx contextContext) error {
|
| D | go17.go | 51 func traceGotConn(req *http.Request, cc *ClientConn) { argument
104 func (cc *ClientConn) Ping(ctx context.Context) error {
|
| /external/syzkaller/vendor/google.golang.org/grpc/ |
| D | interceptor.go | 26 type UnaryInvoker func(ctx context.Context, method string, req, reply interface{}, cc *ClientConn, …
31 …r func(ctx context.Context, method string, req, reply interface{}, cc *ClientConn, invoker UnaryIn…
34 type Streamer func(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, opts ...Ca…
39 type StreamClientInterceptor func(ctx context.Context, desc *StreamDesc, cc *ClientConn, method str…
|
| D | clientconn.go | 439 func Dial(target string, opts ...DialOption) (*ClientConn, error) {
459 func DialContext(ctx context.Context, target string, opts ...DialOption) (conn *ClientConn, err err…
460 cc := &ClientConn{
678 type ClientConn struct { struct
714 func (cc *ClientConn) WaitForStateChange(ctx context.Context, sourceState connectivity.State) bool { argument
729 func (cc *ClientConn) GetState() connectivity.State { argument
733 func (cc *ClientConn) scWatcher() { argument
752 func (cc *ClientConn) handleResolvedAddrs(addrs []resolver.Address, err error) { argument
814 func (cc *ClientConn) switchBalancer(name string) { argument
846 func (cc *ClientConn) handleSubConnStateChange(sc balancer.SubConn, s connectivity.State) { argument
[all …]
|
| D | call.go | 29 func (cc *ClientConn) Invoke(ctx context.Context, method string, args, reply interface{}, opts ...C…
59 func Invoke(ctx context.Context, method string, args, reply interface{}, cc *ClientConn, opts ...Ca… argument
65 func invoke(ctx context.Context, method string, req, reply interface{}, cc *ClientConn, opts ...Cal… argument
|
| D | pickfirst.go | 38 func (*pickfirstBuilder) Build(cc balancer.ClientConn, opt balancer.BuildOptions) balancer.Balancer…
47 cc balancer.ClientConn
|
| D | resolver_conn_wrapper.go | 32 cc *ClientConn
73 func newCCResolverWrapper(cc *ClientConn) (*ccResolverWrapper, error) { argument
|
| D | balancer_conn_wrappers.go | 95 cc *ClientConn
105 func newCCBalancerWrapper(cc *ClientConn, b balancer.Builder, bopts balancer.BuildOptions) *ccBalan… argument
|
| D | stream.go | 119 func (cc *ClientConn) NewStream(ctx context.Context, desc *StreamDesc, method string, opts ...CallO…
133 func NewClientStream(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, opts ...… argument
137 func newClientStream(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, opts ...… argument
339 cc *ClientConn
|
| D | balancer_v1_wrapper.go | 38 func (bwb *balancerWrapperBuilder) Build(cc balancer.ClientConn, opts balancer.BuildOptions) balanc…
80 cc balancer.ClientConn
|
| /external/syzkaller/vendor/google.golang.org/grpc/resolver/passthrough/ |
| D | passthrough.go | 29 func (*passthroughBuilder) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.Buil…
44 cc resolver.ClientConn
|
| /external/syzkaller/vendor/google.golang.org/grpc/resolver/ |
| D | resolver.go | 104 type ClientConn interface { interface
128 Build(target Target, cc ClientConn, opts BuildOption) (Resolver, error) argument
|
| /external/golang-protobuf/protoc-gen-go/testdata/deprecated/ |
| D | deprecated.pb.go | 195 var _ grpc.ClientConn
212 cc *grpc.ClientConn
216 func NewDeprecatedServiceClient(cc *grpc.ClientConn) DeprecatedServiceClient { argument
|
| /external/syzkaller/vendor/google.golang.org/grpc/balancer/ |
| D | balancer.go | 99 type ClientConn interface { interface
139 Build(cc ClientConn, opts BuildOptions) Balancer argument
|
| /external/syzkaller/vendor/google.golang.org/api/option/ |
| D | option.go | 118 func WithGRPCConn(conn *grpc.ClientConn) ClientOption { argument
122 type withGRPCConn struct{ conn *grpc.ClientConn }
|
| /external/syzkaller/vendor/google.golang.org/grpc/resolver/dns/ |
| D | dns_resolver.go | 74 func (b *dnsBuilder) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptio…
124 cc resolver.ClientConn
162 cc resolver.ClientConn
|
| /external/syzkaller/vendor/google.golang.org/genproto/googleapis/iam/v1/ |
| D | iam_policy.pb.go | 227 var _ grpc.ClientConn
251 cc *grpc.ClientConn
254 func NewIAMPolicyClient(cc *grpc.ClientConn) IAMPolicyClient { argument
|
| /external/syzkaller/vendor/google.golang.org/grpc/balancer/base/ |
| D | balancer.go | 34 func (bb *baseBuilder) Build(cc balancer.ClientConn, opt balancer.BuildOptions) balancer.Balancer {
54 cc balancer.ClientConn
|
| /external/syzkaller/vendor/google.golang.org/api/internal/ |
| D | settings.go | 36 GRPCConn *grpc.ClientConn
|
| /external/golang-protobuf/protoc-gen-go/testdata/grpc/ |
| D | grpc.pb.go | 180 var _ grpc.ClientConn
200 cc *grpc.ClientConn
203 func NewTestClient(cc *grpc.ClientConn) TestClient { argument
|
| /external/flatbuffers/tests/MyGame/Example/ |
| D | MonsterStorage_grpc.go | 27 cc *grpc.ClientConn
30 func NewMonsterStorageClient(cc *grpc.ClientConn) MonsterStorageClient { argument
|
| /external/syzkaller/vendor/cloud.google.com/go/iam/ |
| D | iam.go | 78 func InternalNewHandle(conn *grpc.ClientConn, resource string) *Handle { argument
|