Home
last modified time | relevance | path

Searched refs:callTimeout (Results 1 – 25 of 121) sorted by relevance

12345

/dports/databases/hbase/hbase-1.2.1/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/
H A DTimeLimitedRpcController.java35 protected volatile Integer callTimeout; field in TimeLimitedRpcController
46 if (callTimeout != null) { in getCallTimeout()
47 return callTimeout; in getCallTimeout()
53 public void setCallTimeout(int callTimeout) { in setCallTimeout() argument
54 this.callTimeout = callTimeout; in setCallTimeout()
58 return callTimeout != null; in hasCallTimeout()
111 callTimeout = null; in reset()
/dports/databases/hbase/hbase-1.2.1/hbase-client/src/main/java/org/apache/hadoop/hbase/client/
H A DRpcRetryingCaller.java83 private int getRemainingTime(int callTimeout) { in getRemainingTime() argument
84 if (callTimeout <= 0) { in getRemainingTime()
87 if (callTimeout == Integer.MAX_VALUE) return Integer.MAX_VALUE; in getRemainingTime()
88 int remainingTime = (int) (callTimeout - in getRemainingTime()
115 public T callWithRetries(RetryingCallable<T> callable, int callTimeout) in callWithRetries() argument
126 return callable.call(getRemainingTime(callTimeout)); in callWithRetries()
156 if (duration > callTimeout) { in callWithRetries()
157 String msg = "callTimeout=" + callTimeout + ", callDuration=" + duration + in callWithRetries()
194 public T callWithoutRetries(RetryingCallable<T> callable, int callTimeout) in callWithoutRetries() argument
200 return callable.call(callTimeout); in callWithoutRetries()
H A DHBaseAdmin.java344 controller.setCallTimeout(callTimeout); in abortProcedureAsync()
438 controller.setCallTimeout(callTimeout); in listTables()
519 controller.setCallTimeout(callTimeout);
1589 controller.setCallTimeout(callTimeout);
1661 controller.setCallTimeout(callTimeout);
1712 controller.setCallTimeout(callTimeout);
1763 controller.setCallTimeout(callTimeout);
2240 controller.setCallTimeout(callTimeout);
2279 controller.setCallTimeout(callTimeout);
2315 controller.setCallTimeout(callTimeout);
[all …]
H A DResultBoundedCompletionService.java49 private final int callTimeout; field in ResultBoundedCompletionService.QueueingFuture
54 public QueueingFuture(RetryingCallable<T> future, int callTimeout) { in QueueingFuture() argument
56 this.callTimeout = callTimeout; in QueueingFuture()
65 result = this.retryingCaller.callWithRetries(future, callTimeout); in run()
144 public void submit(RetryingCallable<V> task, int callTimeout, int id) { in submit() argument
145 QueueingFuture<V> newFuture = new QueueingFuture<V>(task, callTimeout); in submit()
H A DStatsTrackingRpcRetryingCaller.java47 public T callWithRetries(RetryingCallable<T> callable, int callTimeout) in callWithRetries() argument
49 T result = super.callWithRetries(callable, callTimeout); in callWithRetries()
54 public T callWithoutRetries(RetryingCallable<T> callable, int callTimeout) in callWithoutRetries() argument
56 T result = super.callWithRetries(callable, callTimeout); in callWithoutRetries()
H A DRpcRetryingCallerWithReadReplicas.java73 private final int callTimeout; field in RpcRetryingCallerWithReadReplicas
81 ExecutorService pool, int retries, int callTimeout, in RpcRetryingCallerWithReadReplicas() argument
90 this.callTimeout = callTimeout; in RpcRetryingCallerWithReadReplicas()
149 public Result call(int callTimeout) throws Exception {
160 controller.setCallTimeout(callTimeout);
292 cs.submit(callOnReplica, callTimeout, id); in addCallsForReplica()
/dports/sysutils/kubectl/kubernetes-1.22.2/staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/
H A Dgrpc_service.go50 callTimeout time.Duration member
56 func NewGRPCService(endpoint string, callTimeout time.Duration) (Service, error) {
64 s := &gRPCService{callTimeout: callTimeout}
141 ctx, cancel := context.WithTimeout(context.Background(), g.callTimeout)
154 ctx, cancel := context.WithTimeout(context.Background(), g.callTimeout)
H A Dgrpc_service_unix_test.go55 callTimeout := 3 * time.Second
58 service, err := NewGRPCService(s.endpoint, callTimeout)
64 time.Sleep(callTimeout / 2)
86 callTimeout time.Duration
93 callTimeout: 0 * time.Second,
99 callTimeout: 0 * time.Second,
106 callTimeout: 6 * time.Second,
111 callTimeout: 3 * time.Second,
139 service, err = NewGRPCService(socketName.endpoint, tt.callTimeout)
/dports/sysutils/helm/helm-3.5.2/vendor/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/
H A Dgrpc_service.go50 callTimeout time.Duration member
56 func NewGRPCService(endpoint string, callTimeout time.Duration) (Service, error) {
64 s := &gRPCService{callTimeout: callTimeout}
141 ctx, cancel := context.WithTimeout(context.Background(), g.callTimeout)
154 ctx, cancel := context.WithTimeout(context.Background(), g.callTimeout)
H A Dgrpc_service_unix_test.go55 callTimeout := 3 * time.Second
58 service, err := NewGRPCService(s.endpoint, callTimeout)
64 time.Sleep(callTimeout / 2)
86 callTimeout time.Duration
93 callTimeout: 0 * time.Second,
99 callTimeout: 0 * time.Second,
106 callTimeout: 6 * time.Second,
111 callTimeout: 3 * time.Second,
139 service, err = NewGRPCService(socketName.endpoint, tt.callTimeout)
/dports/net-mgmt/zabbix5-frontend/zabbix-5.0.19/src/go/plugins/oracle/
H A Dconn.go49 callTimeout time.Duration member
122 callTimeout time.Duration member
128 func NewConnManager(keepAlive, connectTimeout, callTimeout, argument
136 callTimeout: callTimeout,
231 callTimeout: c.callTimeout,
/dports/net-mgmt/zabbix5-proxy/zabbix-5.0.19/src/go/plugins/oracle/
H A Dconn.go49 callTimeout time.Duration member
122 callTimeout time.Duration member
128 func NewConnManager(keepAlive, connectTimeout, callTimeout, argument
136 callTimeout: callTimeout,
231 callTimeout: c.callTimeout,
/dports/net-mgmt/zabbix54-server/zabbix-5.4.9/src/go/plugins/oracle/
H A Dconn.go49 callTimeout time.Duration member
122 callTimeout time.Duration member
128 func NewConnManager(keepAlive, connectTimeout, callTimeout, argument
136 callTimeout: callTimeout,
231 callTimeout: c.callTimeout,
/dports/net-mgmt/zabbix54-proxy/zabbix-5.4.9/src/go/plugins/oracle/
H A Dconn.go49 callTimeout time.Duration member
122 callTimeout time.Duration member
128 func NewConnManager(keepAlive, connectTimeout, callTimeout, argument
136 callTimeout: callTimeout,
231 callTimeout: c.callTimeout,
/dports/net-mgmt/zabbix5-agent/zabbix-5.0.19/src/go/plugins/oracle/
H A Dconn.go49 callTimeout time.Duration member
122 callTimeout time.Duration member
128 func NewConnManager(keepAlive, connectTimeout, callTimeout, argument
136 callTimeout: callTimeout,
231 callTimeout: c.callTimeout,
/dports/net-mgmt/zabbix54-agent/zabbix-5.4.9/src/go/plugins/oracle/
H A Dconn.go49 callTimeout time.Duration member
122 callTimeout time.Duration member
128 func NewConnManager(keepAlive, connectTimeout, callTimeout, argument
136 callTimeout: callTimeout,
231 callTimeout: c.callTimeout,
/dports/net-mgmt/zabbix5-server/zabbix-5.0.19/src/go/plugins/oracle/
H A Dconn.go49 callTimeout time.Duration member
122 callTimeout time.Duration member
128 func NewConnManager(keepAlive, connectTimeout, callTimeout, argument
136 callTimeout: callTimeout,
231 callTimeout: c.callTimeout,
/dports/net-mgmt/zabbix5-java/zabbix-5.0.19/src/go/plugins/oracle/
H A Dconn.go49 callTimeout time.Duration member
122 callTimeout time.Duration member
128 func NewConnManager(keepAlive, connectTimeout, callTimeout, argument
136 callTimeout: callTimeout,
231 callTimeout: c.callTimeout,
/dports/net-mgmt/zabbix54-frontend/zabbix-5.4.9/src/go/plugins/oracle/
H A Dconn.go49 callTimeout time.Duration member
122 callTimeout time.Duration member
128 func NewConnManager(keepAlive, connectTimeout, callTimeout, argument
136 callTimeout: callTimeout,
231 callTimeout: c.callTimeout,
/dports/net-mgmt/zabbix54-java/zabbix-5.4.9/src/go/plugins/oracle/
H A Dconn.go49 callTimeout time.Duration member
122 callTimeout time.Duration member
128 func NewConnManager(keepAlive, connectTimeout, callTimeout, argument
136 callTimeout: callTimeout,
231 callTimeout: c.callTimeout,
/dports/net-mgmt/zabbix5-proxy/zabbix-5.0.19/src/go/plugins/postgres/
H A Dconn.go56 callTimeout time.Duration member
133 callTimeout time.Duration member
139 func NewConnManager(keepAlive, connectTimeout, callTimeout, argument
147 callTimeout: callTimeout,
253 callTimeout: c.callTimeout,
/dports/net-mgmt/zabbix54-proxy/zabbix-5.4.9/src/go/plugins/postgres/
H A Dconn.go56 callTimeout time.Duration member
133 callTimeout time.Duration member
139 func NewConnManager(keepAlive, connectTimeout, callTimeout, argument
147 callTimeout: callTimeout,
253 callTimeout: c.callTimeout,
/dports/net-mgmt/zabbix54-server/zabbix-5.4.9/src/go/plugins/postgres/
H A Dconn.go56 callTimeout time.Duration member
133 callTimeout time.Duration member
139 func NewConnManager(keepAlive, connectTimeout, callTimeout, argument
147 callTimeout: callTimeout,
253 callTimeout: c.callTimeout,
/dports/net-mgmt/zabbix5-agent/zabbix-5.0.19/src/go/plugins/postgres/
H A Dconn.go56 callTimeout time.Duration member
133 callTimeout time.Duration member
139 func NewConnManager(keepAlive, connectTimeout, callTimeout, argument
147 callTimeout: callTimeout,
253 callTimeout: c.callTimeout,
/dports/net-mgmt/zabbix54-agent/zabbix-5.4.9/src/go/plugins/postgres/
H A Dconn.go56 callTimeout time.Duration member
133 callTimeout time.Duration member
139 func NewConnManager(keepAlive, connectTimeout, callTimeout, argument
147 callTimeout: callTimeout,
253 callTimeout: c.callTimeout,

12345