- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 866 for cancel3b (0.39 sec)
-
cmd/perf-tests.go
continue } info := info wg.Add(connectionsPerPeer) for i := 0; i < connectionsPerPeer; i++ { go func() { defer wg.Done() ctx, cancel := context.WithTimeout(ctx, duration+10*time.Second) defer cancel() perfNetRequest( ctx, info.DeploymentID, adminPathPrefix+adminAPIVersionPrefix+adminAPISiteReplicationDevNull, r, ) }() } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 11.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/mutating/dispatcher.go
defer span.End(500 * time.Millisecond) // if the webhook has a specific timeout, wrap the context to apply it if h.TimeoutSeconds != nil { var cancel context.CancelFunc ctx, cancel = context.WithTimeout(ctx, time.Duration(*h.TimeoutSeconds)*time.Second) defer cancel() } r := client.Post().Body(request) // if the context has a deadline, set it as a parameter to inform the backend
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 19.6K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
TotalSize int64 `json:"totalSize" msg:"ts"` CurrentSize int64 `json:"currentSize" msg:"cs"` Complete bool `json:"complete" msg:"cmp"` Failed bool `json:"failed" msg:"fl"` Canceled bool `json:"canceled" msg:"cnl"` // Internal information. QueuedBuckets []string `json:"-" msg:"bkts"` DecommissionedBuckets []string `json:"-" msg:"dbkts"` // Last bucket/object decommissioned.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 06 14:30:43 UTC 2024 - 41.5K bytes - Viewed (1) -
.github/workflows/iam-integrations.yaml
name: IAM integration on: pull_request: branches: - master # This ensures that previous jobs for the PR are canceled when the PR is # updated. concurrency: group: ${{ github.workflow }}-${{ github.head_ref }} cancel-in-progress: true permissions: contents: read jobs: iam-matrix-test: name: "[Go=${{ matrix.go-version }}|ldap=${{ matrix.ldap }}|etcd=${{ matrix.etcd }}|openid=${{ matrix.openid }}]"
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 4.1K bytes - Viewed (0) -
src/cmd/go/internal/script/state.go
if k, v, ok := strings.Cut(kv, "="); ok { envMap[k] = v } } s := &State{ ctx: ctx, cancel: cancel, workdir: absWork, pwd: absWork, env: env, envMap: envMap, } s.Setenv("PWD", absWork) return s, nil } // CloseAndWait cancels the State's Context and waits for any background commands to // finish. If any remaining background command ended in an unexpected state,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jan 31 20:33:02 UTC 2023 - 6.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
this.state = state; } @Override public boolean cancel(boolean interruptIfRunning) { InCompletionOrderState<T> localState = state; if (super.cancel(interruptIfRunning)) { /* * requireNonNull is generally safe: If cancel succeeded, then this Future was still * pending, so its `state` field hasn't been nulled out yet. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 59.6K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/internal/RealEventSource.kt
} } catch (e: Exception) { val exception = when { canceled -> IOException("canceled", e) else -> e } listener.onFailure(this, exception, response) return } if (canceled) { listener.onFailure(this, IOException("canceled"), response) } else { listener.onClosed(this) } } }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 01 14:21:25 UTC 2024 - 22.1K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/Interceptor.kt
* when responses are of an unexpected type or cannot be decoded. * * Other exception types cancel the current call: * * * For synchronous calls made with [Call.execute], the exception is propagated to the caller. * * * For asynchronous calls made with [Call.enqueue], an [IOException] is propagated to the caller * indicating that the call was canceled. The interceptor's exception is delivered to the current
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.5K bytes - Viewed (0) -
cmd/consolelogger.go
if ok { if (lg.Entry != log.Entry{}) { logs = append(logs, lg.Entry) } } } }) sys.RUnlock() return } // Cancel - cancels the target func (sys *HTTPConsoleLoggerSys) Cancel() { } // Type - returns type of the target func (sys *HTTPConsoleLoggerSys) Type() types.TargetType { return types.TargetConsole }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.5K bytes - Viewed (0)