| /dports/devel/etcd33/etcd-3.3.23/vendor/github.com/grpc-ecosystem/go-grpc-middleware/go-grpc-middleware-1.0.0/retry/ |
| H A D | retry.go | 42 callCtx := perCallContext(parentCtx, callOpts, attempt)
43 lastErr = invoker(callCtx, method, req, reply, cc, grpcOpts...)
89 callCtx := perCallContext(parentCtx, callOpts, 0)
90 newStreamer, err := streamer(callCtx, desc, cc, method, grpcOpts...)
165 callCtx := perCallContext(s.parentCtx, s.callOpts, attempt)
166 newStream, err := s.reestablishStreamAndResendBuffer(callCtx)
209 func (s *serverStreamingRetryingStream) reestablishStreamAndResendBuffer(callCtx context.Context) (…
213 newStream, err := s.streamerCall(callCtx)
215 logTrace(callCtx, "grpc_retry failed redialing new stream: %v", err)
220 logTrace(callCtx, "grpc_retry failed resending message: %v", err)
[all …]
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/github.com/grpc-ecosystem/go-grpc-middleware/retry/ |
| H A D | retry.go | 43 callCtx := perCallContext(parentCtx, callOpts, attempt)
44 lastErr = invoker(callCtx, method, req, reply, cc, grpcOpts...)
96 callCtx := perCallContext(parentCtx, callOpts, 0)
99 newStreamer, lastErr = streamer(callCtx, desc, cc, method, grpcOpts...)
191 callCtx := perCallContext(s.parentCtx, s.callOpts, attempt)
192 newStream, err := s.reestablishStreamAndResendBuffer(callCtx)
240 callCtx context.Context,
245 newStream, err := s.streamerCall(callCtx)
247 logTrace(callCtx, "grpc_retry failed redialing new stream: %v", err)
252 logTrace(callCtx, "grpc_retry failed resending message: %v", err)
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grpc-ecosystem/go-grpc-middleware/retry/ |
| H A D | retry.go | 43 callCtx := perCallContext(parentCtx, callOpts, attempt)
44 lastErr = invoker(callCtx, method, req, reply, cc, grpcOpts...)
96 callCtx := perCallContext(parentCtx, callOpts, 0)
99 newStreamer, lastErr = streamer(callCtx, desc, cc, method, grpcOpts...)
191 callCtx := perCallContext(s.parentCtx, s.callOpts, attempt)
192 newStream, err := s.reestablishStreamAndResendBuffer(callCtx)
240 callCtx context.Context,
245 newStream, err := s.streamerCall(callCtx)
247 logTrace(callCtx, "grpc_retry failed redialing new stream: %v", err)
252 logTrace(callCtx, "grpc_retry failed resending message: %v", err)
[all …]
|
| /dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/grpc-ecosystem/go-grpc-middleware/retry/ |
| H A D | retry.go | 42 callCtx := perCallContext(parentCtx, callOpts, attempt)
43 lastErr = invoker(callCtx, method, req, reply, cc, grpcOpts...)
94 callCtx := perCallContext(parentCtx, callOpts, 0)
97 newStreamer, lastErr = streamer(callCtx, desc, cc, method, grpcOpts...)
188 callCtx := perCallContext(s.parentCtx, s.callOpts, attempt)
189 newStream, err := s.reestablishStreamAndResendBuffer(callCtx)
232 func (s *serverStreamingRetryingStream) reestablishStreamAndResendBuffer(callCtx context.Context) (…
236 newStream, err := s.streamerCall(callCtx)
238 logTrace(callCtx, "grpc_retry failed redialing new stream: %v", err)
243 logTrace(callCtx, "grpc_retry failed resending message: %v", err)
[all …]
|
| /dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/github.com/grpc-ecosystem/go-grpc-middleware/retry/ |
| H A D | retry.go | 43 callCtx := perCallContext(parentCtx, callOpts, attempt)
44 lastErr = invoker(callCtx, method, req, reply, cc, grpcOpts...)
96 callCtx := perCallContext(parentCtx, callOpts, 0)
99 newStreamer, lastErr = streamer(callCtx, desc, cc, method, grpcOpts...)
191 callCtx := perCallContext(s.parentCtx, s.callOpts, attempt)
192 newStream, err := s.reestablishStreamAndResendBuffer(callCtx)
240 callCtx context.Context,
245 newStream, err := s.streamerCall(callCtx)
247 logTrace(callCtx, "grpc_retry failed redialing new stream: %v", err)
252 logTrace(callCtx, "grpc_retry failed resending message: %v", err)
[all …]
|
| /dports/sysutils/nomad/nomad-1.1.0/vendor/github.com/grpc-ecosystem/go-grpc-middleware/retry/ |
| H A D | retry.go | 43 callCtx := perCallContext(parentCtx, callOpts, attempt)
44 lastErr = invoker(callCtx, method, req, reply, cc, grpcOpts...)
96 callCtx := perCallContext(parentCtx, callOpts, 0)
99 newStreamer, lastErr = streamer(callCtx, desc, cc, method, grpcOpts...)
191 callCtx := perCallContext(s.parentCtx, s.callOpts, attempt)
192 newStream, err := s.reestablishStreamAndResendBuffer(callCtx)
235 func (s *serverStreamingRetryingStream) reestablishStreamAndResendBuffer(callCtx context.Context) (…
239 newStream, err := s.streamerCall(callCtx)
241 logTrace(callCtx, "grpc_retry failed redialing new stream: %v", err)
246 logTrace(callCtx, "grpc_retry failed resending message: %v", err)
[all …]
|
| /dports/www/tusd/tusd-1.8.0/vendor/github.com/grpc-ecosystem/go-grpc-middleware/retry/ |
| H A D | retry.go | 43 callCtx := perCallContext(parentCtx, callOpts, attempt)
44 lastErr = invoker(callCtx, method, req, reply, cc, grpcOpts...)
96 callCtx := perCallContext(parentCtx, callOpts, 0)
99 newStreamer, lastErr = streamer(callCtx, desc, cc, method, grpcOpts...)
191 callCtx := perCallContext(s.parentCtx, s.callOpts, attempt)
192 newStream, err := s.reestablishStreamAndResendBuffer(callCtx)
240 callCtx context.Context,
245 newStream, err := s.streamerCall(callCtx)
247 logTrace(callCtx, "grpc_retry failed redialing new stream: %v", err)
252 logTrace(callCtx, "grpc_retry failed resending message: %v", err)
[all …]
|
| /dports/textproc/gitlab-elasticsearch-indexer/gitlab-elasticsearch-indexer-ef1440548effec15831eda2d246dacc43233cefb/vendor/github.com/grpc-ecosystem/go-grpc-middleware/retry/ |
| H A D | retry.go | 43 callCtx := perCallContext(parentCtx, callOpts, attempt)
44 lastErr = invoker(callCtx, method, req, reply, cc, grpcOpts...)
96 callCtx := perCallContext(parentCtx, callOpts, 0)
99 newStreamer, lastErr = streamer(callCtx, desc, cc, method, grpcOpts...)
191 callCtx := perCallContext(s.parentCtx, s.callOpts, attempt)
192 newStream, err := s.reestablishStreamAndResendBuffer(callCtx)
240 callCtx context.Context,
245 newStream, err := s.streamerCall(callCtx)
247 logTrace(callCtx, "grpc_retry failed redialing new stream: %v", err)
252 logTrace(callCtx, "grpc_retry failed resending message: %v", err)
[all …]
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/grpc-ecosystem/go-grpc-middleware/retry/ |
| H A D | retry.go | 42 callCtx := perCallContext(parentCtx, callOpts, attempt)
43 lastErr = invoker(callCtx, method, req, reply, cc, grpcOpts...)
94 callCtx := perCallContext(parentCtx, callOpts, 0)
97 newStreamer, lastErr = streamer(callCtx, desc, cc, method, grpcOpts...)
188 callCtx := perCallContext(s.parentCtx, s.callOpts, attempt)
189 newStream, err := s.reestablishStreamAndResendBuffer(callCtx)
232 func (s *serverStreamingRetryingStream) reestablishStreamAndResendBuffer(callCtx context.Context) (…
236 newStream, err := s.streamerCall(callCtx)
238 logTrace(callCtx, "grpc_retry failed redialing new stream: %v", err)
243 logTrace(callCtx, "grpc_retry failed resending message: %v", err)
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/corlib/System.Runtime.Remoting.Messaging/ |
| H A D | ConstructionResponse.cs | 48 …internal ConstructionResponse(object resultObject, LogicalCallContext callCtx, IMethodCallMessage … in ConstructionResponse() argument
49 : base (resultObject, null, callCtx, msg) in ConstructionResponse()
|
| /dports/net-mgmt/promscale/promscale-0.6.2/vendor/google.golang.org/grpc/credentials/tls/certprovider/meshca/ |
| H A D | plugin.go | 192 callCtx, ctxCancel := context.WithTimeout(context.Background(), p.cfg.callTimeout)
193 …callCtx = metadata.NewOutgoingContext(callCtx, metadata.Pairs(locationMetadataKey, p.cfg.location))
194 resp, err := client.CreateCertificate(callCtx, req)
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/google.golang.org/grpc/credentials/tls/certprovider/meshca/ |
| H A D | plugin.go | 191 callCtx, ctxCancel := context.WithTimeout(context.Background(), p.cfg.callTimeout)
192 …callCtx = metadata.NewOutgoingContext(callCtx, metadata.Pairs(locationMetadataKey, p.cfg.location))
193 resp, err := client.CreateCertificate(callCtx, req)
|
| /dports/net/v2ray/v2ray-core-4.36.2/vendor/google.golang.org/grpc/credentials/tls/certprovider/meshca/ |
| H A D | plugin.go | 192 callCtx, ctxCancel := context.WithTimeout(context.Background(), p.cfg.callTimeout)
193 …callCtx = metadata.NewOutgoingContext(callCtx, metadata.Pairs(locationMetadataKey, p.cfg.location))
194 resp, err := client.CreateCertificate(callCtx, req)
|
| /dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/google.golang.org/grpc/credentials/tls/certprovider/meshca/ |
| H A D | plugin.go | 192 callCtx, ctxCancel := context.WithTimeout(context.Background(), p.cfg.callTimeout)
193 …callCtx = metadata.NewOutgoingContext(callCtx, metadata.Pairs(locationMetadataKey, p.cfg.location))
194 resp, err := client.CreateCertificate(callCtx, req)
|
| /dports/sysutils/gomplate/gomplate-3.9.0/vendor/google.golang.org/grpc/credentials/tls/certprovider/meshca/ |
| H A D | plugin.go | 192 callCtx, ctxCancel := context.WithTimeout(context.Background(), p.cfg.callTimeout)
193 …callCtx = metadata.NewOutgoingContext(callCtx, metadata.Pairs(locationMetadataKey, p.cfg.location))
194 resp, err := client.CreateCertificate(callCtx, req)
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/google.golang.org/grpc/grpc-go-1.34.0/credentials/tls/certprovider/meshca/ |
| H A D | plugin.go | 192 callCtx, ctxCancel := context.WithTimeout(context.Background(), p.cfg.callTimeout)
193 …callCtx = metadata.NewOutgoingContext(callCtx, metadata.Pairs(locationMetadataKey, p.cfg.location))
194 resp, err := client.CreateCertificate(callCtx, req)
|
| /dports/databases/litestream/litestream-0.3.6/vendor/google.golang.org/grpc/credentials/tls/certprovider/meshca/ |
| H A D | plugin.go | 192 callCtx, ctxCancel := context.WithTimeout(context.Background(), p.cfg.callTimeout)
193 …callCtx = metadata.NewOutgoingContext(callCtx, metadata.Pairs(locationMetadataKey, p.cfg.location))
194 resp, err := client.CreateCertificate(callCtx, req)
|
| /dports/net/grpcurl/grpcurl-1.8.5/vendor/google.golang.org/grpc/credentials/tls/certprovider/meshca/ |
| H A D | plugin.go | 192 callCtx, ctxCancel := context.WithTimeout(context.Background(), p.cfg.callTimeout)
193 …callCtx = metadata.NewOutgoingContext(callCtx, metadata.Pairs(locationMetadataKey, p.cfg.location))
194 resp, err := client.CreateCertificate(callCtx, req)
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/docker/docker/vendor/github.com/moby/buildkit/frontend/gateway/ |
| H A D | gateway.go | 182 callCtx: ctx,
251 callCtx context.Context member
260 ctx = tracing.ContextWithSpanFromContext(ctx, lbf.callCtx)
272 ctx = tracing.ContextWithSpanFromContext(ctx, lbf.callCtx)
306 ctx = tracing.ContextWithSpanFromContext(ctx, lbf.callCtx)
|
| /dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/cretz/bine/tests/ |
| H A D | tor_dialer_test.go | 37 callCtx, callCancel := context.WithTimeout(ctx, 30*time.Second)
39 resp, err := ctxhttp.Get(callCtx, client, url)
|
| /dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/cretz/bine/tests/ |
| H A D | tor_dialer_test.go | 37 callCtx, callCancel := context.WithTimeout(ctx, 30*time.Second)
39 resp, err := ctxhttp.Get(callCtx, client, url)
|
| /dports/net-mgmt/bind_exporter/bind_exporter-0.4.0/vendor/github.com/mwitkow/go-conntrack/example/ |
| H A D | server.go | 47 callCtx := conntrack.DialNameToContext(req.Context(), "google")
48 _, err := ctxhttp.Get(callCtx, http.DefaultClient, "https://www.google.comx")
|
| /dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/mwitkow/go-conntrack/example/ |
| H A D | server.go | 47 callCtx := conntrack.DialNameToContext(req.Context(), "google")
48 _, err := ctxhttp.Get(callCtx, http.DefaultClient, "https://www.google.comx")
|
| /dports/net-mgmt/pushgateway/pushgateway-1.4.2/vendor/github.com/mwitkow/go-conntrack/example/ |
| H A D | server.go | 47 callCtx := conntrack.DialNameToContext(req.Context(), "google")
48 _, err := ctxhttp.Get(callCtx, http.DefaultClient, "https://www.google.comx")
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/mwitkow/go-conntrack/example/ |
| H A D | server.go | 47 callCtx := conntrack.DialNameToContext(req.Context(), "google")
48 _, err := ctxhttp.Get(callCtx, http.DefaultClient, "https://www.google.comx")
|