/dports/databases/hbase/hbase-1.2.1/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/ |
H A D | TimeLimitedRpcController.java | 35 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 D | RpcRetryingCaller.java | 83 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 D | HBaseAdmin.java | 344 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 D | ResultBoundedCompletionService.java | 49 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 D | StatsTrackingRpcRetryingCaller.java | 47 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 D | RpcRetryingCallerWithReadReplicas.java | 73 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 D | grpc_service.go | 50 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 D | grpc_service_unix_test.go | 55 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 D | grpc_service.go | 50 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 D | grpc_service_unix_test.go | 55 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 D | conn.go | 49 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 D | conn.go | 49 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 D | conn.go | 49 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 D | conn.go | 49 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 D | conn.go | 49 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 D | conn.go | 49 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 D | conn.go | 49 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 D | conn.go | 49 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 D | conn.go | 49 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 D | conn.go | 49 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 D | conn.go | 56 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 D | conn.go | 56 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 D | conn.go | 56 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 D | conn.go | 56 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 D | conn.go | 56 callTimeout time.Duration member 133 callTimeout time.Duration member 139 func NewConnManager(keepAlive, connectTimeout, callTimeout, argument 147 callTimeout: callTimeout, 253 callTimeout: c.callTimeout,
|