/dports/security/vault/vault-1.8.2/vendor/google.golang.org/grpc/xds/internal/client/ |
H A D | v2client.go | 102 v2c := &v2Client{ 118 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background()) 120 go v2c.run() 121 return v2c 126 v2c.cancelCtx() 133 go v2c.send() 210 v2c.mu.Lock() 233 v2c.mu.Lock() 268 v2c.mu.Lock() 477 v2c.mu.Lock() [all …]
|
/dports/www/pomerium/pomerium-0.8.3/vendor/google.golang.org/grpc/xds/internal/client/ |
H A D | v2client.go | 102 v2c := &v2Client{ 118 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background()) 120 go v2c.run() 121 return v2c 126 v2c.cancelCtx() 133 go v2c.send() 210 v2c.mu.Lock() 233 v2c.mu.Lock() 261 v2c.mu.Lock() 464 v2c.mu.Lock() [all …]
|
/dports/sysutils/istio/istio-1.6.7/vendor/google.golang.org/grpc/xds/internal/client/ |
H A D | v2client.go | 102 v2c := &v2Client{ 118 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background()) 120 go v2c.run() 121 return v2c 126 v2c.cancelCtx() 133 go v2c.send() 210 v2c.mu.Lock() 233 v2c.mu.Lock() 268 v2c.mu.Lock() 477 v2c.mu.Lock() [all …]
|
/dports/net/grpcui/grpcui-1.1.0/vendor/google.golang.org/grpc/xds/internal/client/ |
H A D | v2client.go | 107 v2c := &v2Client{ 122 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background()) 124 go v2c.run() 125 return v2c 130 v2c.cancelCtx() 137 go v2c.send() 214 v2c.mu.Lock() 240 v2c.mu.Lock() 268 v2c.hostname = "" 306 v2c.mu.Lock() [all …]
|
/dports/net/evans/evans-0.9.1/vendor/google.golang.org/grpc/xds/internal/client/ |
H A D | v2client.go | 107 v2c := &v2Client{ 122 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background()) 124 go v2c.run() 125 return v2c 130 v2c.cancelCtx() 137 go v2c.send() 214 v2c.mu.Lock() 240 v2c.mu.Lock() 268 v2c.hostname = "" 306 v2c.mu.Lock() [all …]
|
/dports/security/lego/lego-4.5.3/vendor/google.golang.org/grpc/xds/internal/client/ |
H A D | v2client.go | 97 v2c := &v2Client{ 107 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background()) 109 go v2c.run() 110 return v2c 115 v2c.cancelCtx() 196 v2c.mu.Lock() 218 v2c.mu.Lock() 244 v2c.mu.Lock() 420 v2c.mu.Lock() 449 v2c.mu.Lock() [all …]
|
/dports/misc/concourse/concourse-6.7.2/vendor/google.golang.org/grpc/xds/internal/client/ |
H A D | v2client.go | 97 v2c := &v2Client{ 107 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background()) 109 go v2c.run() 110 return v2c 115 v2c.cancelCtx() 196 v2c.mu.Lock() 218 v2c.mu.Lock() 244 v2c.mu.Lock() 420 v2c.mu.Lock() 449 v2c.mu.Lock() [all …]
|
/dports/www/oauth2-proxy/oauth2-proxy-7.2.0/vendor/google.golang.org/grpc/xds/internal/client/ |
H A D | v2client.go | 97 v2c := &v2Client{ 107 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background()) 109 go v2c.run() 110 return v2c 115 v2c.cancelCtx() 196 v2c.mu.Lock() 218 v2c.mu.Lock() 244 v2c.mu.Lock() 420 v2c.mu.Lock() 449 v2c.mu.Lock() [all …]
|
/dports/net-im/nextcloud-spreed-signaling/nextcloud-spreed-signaling-0.2.0/vendor/src/google.golang.org/grpc/xds/internal/client/ |
H A D | v2client.go | 97 v2c := &v2Client{ 107 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background()) 109 go v2c.run() 110 return v2c 115 v2c.cancelCtx() 196 v2c.mu.Lock() 218 v2c.mu.Lock() 244 v2c.mu.Lock() 420 v2c.mu.Lock() 449 v2c.mu.Lock() [all …]
|
/dports/sysutils/helm/helm-3.5.2/vendor/google.golang.org/grpc/xds/internal/client/ |
H A D | v2client.go | 97 v2c := &v2Client{ 107 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background()) 109 go v2c.run() 110 return v2c 115 v2c.cancelCtx() 196 v2c.mu.Lock() 218 v2c.mu.Lock() 244 v2c.mu.Lock() 420 v2c.mu.Lock() 449 v2c.mu.Lock() [all …]
|
/dports/net/storj/storj-1.45.3/vendor/google.golang.org/grpc/xds/internal/client/ |
H A D | v2client.go | 97 v2c := &v2Client{ 107 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background()) 109 go v2c.run() 110 return v2c 115 v2c.cancelCtx() 196 v2c.mu.Lock() 218 v2c.mu.Lock() 244 v2c.mu.Lock() 420 v2c.mu.Lock() 449 v2c.mu.Lock() [all …]
|
/dports/devel/mutagen/mutagen-0.11.8/vendor/google.golang.org/grpc/xds/internal/client/ |
H A D | v2client.go | 97 v2c := &v2Client{ 107 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background()) 109 go v2c.run() 110 return v2c 115 v2c.cancelCtx() 196 v2c.mu.Lock() 218 v2c.mu.Lock() 244 v2c.mu.Lock() 420 v2c.mu.Lock() 449 v2c.mu.Lock() [all …]
|
/dports/sysutils/terraform/terraform-1.0.11/vendor/google.golang.org/grpc/xds/internal/client/ |
H A D | v2client.go | 97 v2c := &v2Client{ 107 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background()) 109 go v2c.run() 110 return v2c 115 v2c.cancelCtx() 196 v2c.mu.Lock() 218 v2c.mu.Lock() 244 v2c.mu.Lock() 420 v2c.mu.Lock() 449 v2c.mu.Lock() [all …]
|
/dports/sysutils/helmfile/helmfile-0.138.7/vendor/google.golang.org/grpc/xds/internal/client/v2/ |
H A D | client.go | 66 v2c := &client{ 72 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background()) 74 return v2c, nil 108 v2c.mu.Lock() 115 v2c.ldsWatchCount++ 120 v2c.mu.Unlock() 127 v2c.mu.Lock() 134 v2c.ldsWatchCount-- 139 v2c.mu.Unlock() 242 v2c.mu.Lock() [all …]
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/google.golang.org/grpc/xds/internal/client/v2/ |
H A D | client.go | 69 v2c := &client{ 76 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background()) 78 return v2c, nil 113 v2c.mu.Lock() 120 v2c.ldsWatchCount++ 125 v2c.mu.Unlock() 132 v2c.mu.Lock() 139 v2c.ldsWatchCount-- 144 v2c.mu.Unlock() 251 v2c.mu.Lock() [all …]
|
/dports/net-mgmt/py-pysnmp/pysnmp-4.4.9/pysnmp/proto/proxy/ |
H A D | rfc2576.py | 8 from pysnmp.proto.api import v1, v2c 14 v1.Integer.tagSet: v2c.Integer32(), 16 v1.Null.tagSet: v2c.Null(), 19 v1.Counter.tagSet: v2c.Counter32(), 20 v1.Gauge.tagSet: v2c.Gauge32(), 22 v1.Opaque.tagSet: v2c.Opaque() 26 v2c.Integer32.tagSet: v1.Integer(), 28 v2c.Null.tagSet: v1.Null(), 32 v2c.Gauge32.tagSet: v1.Gauge(), 34 v2c.Opaque.tagSet: v1.Opaque() [all …]
|
/dports/ftp/sftpgo/sftpgo-2.2.0/vendor/google.golang.org/grpc/xds/internal/xdsclient/v2/ |
H A D | client.go | 68 v2c := &client{ 75 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background()) 76 v2c.TransportHelper = xdsclient.NewTransportHelper(v2c, opts.Logger, opts.Backoff) 77 return v2c, nil 117 Node: v2c.nodeProto, 168 err = v2c.handleLDSResponse(resp) 171 err = v2c.handleRDSResponse(resp) 194 Logger: v2c.logger, 208 Logger: v2c.logger, 222 Logger: v2c.logger, [all …]
|
/dports/net-mgmt/py-pysnmp/pysnmp-4.4.9/examples/v1arch/asyncore/manager/cmdgen/ |
H A D | getbulk-pull-whole-mib.py | 21 from pysnmp.proto.api import v2c 28 reqPDU = v2c.GetBulkRequestPDU() 29 v2c.apiBulkPDU.setDefaults(reqPDU) 30 v2c.apiBulkPDU.setNonRepeaters(reqPDU, 0) 32 v2c.apiBulkPDU.setVarBinds(reqPDU, [(x, v2c.null) for x in headVars]) 35 reqMsg = v2c.Message() 36 v2c.apiMessage.setDefaults(reqMsg) 38 v2c.apiMessage.setPDU(reqMsg, reqPDU) 57 if v2c.apiBulkPDU.getRequestID(reqPDU) == v2c.apiBulkPDU.getRequestID(rspPDU): 86 v2c.apiBulkPDU.setVarBinds( [all …]
|
/dports/net/grpcurl/grpcurl-1.8.5/vendor/google.golang.org/grpc/xds/internal/client/v2/ |
H A D | client.go | 67 v2c := &client{ 73 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background()) 74 v2c.TransportHelper = xdsclient.NewTransportHelper(v2c, opts.Logger, opts.Backoff) 75 return v2c, nil 114 Node: v2c.nodeProto, 165 err = v2c.handleLDSResponse(resp) 168 err = v2c.handleRDSResponse(resp) 171 err = v2c.handleCDSResponse(resp) 174 err = v2c.handleEDSResponse(resp) 189 v2c.parent.NewListeners(update, md) [all …]
|
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/google.golang.org/grpc/xds/internal/client/v2/ |
H A D | client.go | 67 v2c := &client{ 73 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background()) 74 v2c.TransportHelper = xdsclient.NewTransportHelper(v2c, opts.Logger, opts.Backoff) 75 return v2c, nil 114 Node: v2c.nodeProto, 165 err = v2c.handleLDSResponse(resp) 168 err = v2c.handleRDSResponse(resp) 171 err = v2c.handleCDSResponse(resp) 174 err = v2c.handleEDSResponse(resp) 189 v2c.parent.NewListeners(update, md) [all …]
|
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/google.golang.org/grpc/xds/internal/client/v2/ |
H A D | client.go | 67 v2c := &client{ 73 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background()) 74 v2c.TransportHelper = xdsclient.NewTransportHelper(v2c, opts.Logger, opts.Backoff) 75 return v2c, nil 114 Node: v2c.nodeProto, 165 err = v2c.handleLDSResponse(resp) 168 err = v2c.handleRDSResponse(resp) 171 err = v2c.handleCDSResponse(resp) 174 err = v2c.handleEDSResponse(resp) 189 v2c.parent.NewListeners(update, md) [all …]
|
/dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/google.golang.org/grpc/xds/internal/client/v2/ |
H A D | client.go | 67 v2c := &client{ 73 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background()) 74 v2c.TransportHelper = xdsclient.NewTransportHelper(v2c, opts.Logger, opts.Backoff) 75 return v2c, nil 114 Node: v2c.nodeProto, 165 err = v2c.handleLDSResponse(resp) 168 err = v2c.handleRDSResponse(resp) 171 err = v2c.handleCDSResponse(resp) 174 err = v2c.handleEDSResponse(resp) 189 v2c.parent.NewListeners(update, md) [all …]
|
/dports/net/v2ray/v2ray-core-4.36.2/vendor/google.golang.org/grpc/xds/internal/client/v2/ |
H A D | client.go | 67 v2c := &client{ 73 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background()) 74 v2c.TransportHelper = xdsclient.NewTransportHelper(v2c, opts.Logger, opts.Backoff) 75 return v2c, nil 114 Node: v2c.nodeProto, 165 err = v2c.handleLDSResponse(resp) 168 err = v2c.handleRDSResponse(resp) 171 err = v2c.handleCDSResponse(resp) 192 v2c.parent.NewListeners(update) 216 v2c.parent.NewClusters(update) [all …]
|
/dports/sysutils/restic/restic-0.12.1/vendor/google.golang.org/grpc/xds/internal/client/v2/ |
H A D | client.go | 67 v2c := &client{ 73 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background()) 74 v2c.TransportHelper = xdsclient.NewTransportHelper(v2c, opts.Logger, opts.Backoff) 75 return v2c, nil 114 Node: v2c.nodeProto, 165 err = v2c.handleLDSResponse(resp) 168 err = v2c.handleRDSResponse(resp) 171 err = v2c.handleCDSResponse(resp) 174 err = v2c.handleEDSResponse(resp) 189 v2c.parent.NewListeners(update, md) [all …]
|
/dports/sysutils/gomplate/gomplate-3.9.0/vendor/google.golang.org/grpc/xds/internal/client/v2/ |
H A D | client.go | 67 v2c := &client{ 73 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background()) 74 v2c.TransportHelper = xdsclient.NewTransportHelper(v2c, opts.Logger, opts.Backoff) 75 return v2c, nil 114 Node: v2c.nodeProto, 165 err = v2c.handleLDSResponse(resp) 168 err = v2c.handleRDSResponse(resp) 171 err = v2c.handleCDSResponse(resp) 192 v2c.parent.NewListeners(update) 216 v2c.parent.NewClusters(update) [all …]
|