- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 866 for cancel3b (0.16 sec)
-
tensorflow/cc/training/queue_runner_test.cc
using ops::QueueDequeue; using ops::QueueEnqueue; using ops::RandomNormal; using ops::Square; using ops::Variable; constexpr char kAssignOpName[] = "assign"; constexpr char kCancelOp0[] = "cancel0"; constexpr char kCancelOp1[] = "cancel1"; constexpr char kCloseOp0[] = "close0"; constexpr char kCloseOp1[] = "close1"; constexpr char kCountUpToOpName[] = "count"; constexpr char kDequeueOp0[] = "dequeue0";
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Sep 21 06:27:51 UTC 2019 - 14.7K bytes - Viewed (0) -
internal/logger/target/http/http.go
atomic.AddInt64(&h.failedMessages, 1) return errors.New("log buffer full") } return nil } // Cancel - cancels the target. // All queued messages are flushed and the function returns afterwards. // All messages sent to the target after this function has been called will be dropped. func (h *Target) Cancel() { atomic.StoreInt32(&h.status, statusClosed) h.storeCtxCancel() // Wait for messages to be sent...
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jun 02 03:03:39 UTC 2024 - 14.9K bytes - Viewed (0) -
.github/workflows/replication.yaml
name: MinIO advanced tests 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: replication-test: name: Advanced Tests with Go ${{ matrix.go-version }} runs-on: ubuntu-latest strategy:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 1.9K bytes - Viewed (0) -
cmd/batch-handlers.go
} return nil } // delete canceler from the map, cancel job if requested func (j *BatchJobPool) canceler(jobID string, cancel bool) error { if j == nil { return errInvalidArgument } j.jmu.Lock() defer j.jmu.Unlock() if canceler, ok := j.jobCancelers[jobID]; ok { if cancel { canceler() } } delete(j.jobCancelers, jobID) return nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 03:13:30 UTC 2024 - 56K bytes - Viewed (0) -
internal/dsync/dsync_test.go
ctx, cancel := context.WithCancel(context.Background()) if !dm.GetLock(ctx, cancel, id, source, Options{Timeout: 5 * time.Minute}) { t.Fatal("GetLock() should be successful") } // Make it run twice. timer := time.NewTimer(testDrwMutexRefreshInterval * 2) select { case <-ctx.Done(): t.Fatal("Lock context canceled which is not expected") case <-timer.C: }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Dec 24 03:49:07 UTC 2022 - 11K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/wait.go
// loopConditionUntilContext. func waitForWithContext(ctx context.Context, wait waitWithContextFunc, fn ConditionWithContextFunc) error { waitCtx, cancel := context.WithCancel(context.Background()) defer cancel() c := wait(waitCtx) for { select { case _, open := <-c: ok, err := runConditionWithCrashProtectionWithContext(ctx, fn) if err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 19:14:11 UTC 2023 - 7.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/EventListener.kt
) { } /** * Invoked when a call is canceled. * * Like all methods in this interface, this is invoked on the thread that triggered the event. But * while other events occur sequentially; cancels may occur concurrently with other events. For * example, thread A may be executing [responseBodyStart] while thread B executes [canceled]. * Implementations must support such concurrent calls. *
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 15.2K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/api/DaemonStateControl.java
/** * Returns the current state of the daemon * * @return The current state of the daemon */ State getState(); /** * Requests that a running build be canceled. Note that this method does NOT block until the operation has been cancelled. */ void requestCancel(); /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sun May 05 22:24:02 UTC 2024 - 3.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/controller/controller.go
kmsPluginCloseGracePeriod = minKMSPluginCloseGracePeriod } // really make sure that the immediate check does not hang var cancel context.CancelFunc ctx, cancel = context.WithTimeout(ctx, kmsPluginCloseGracePeriod) defer cancel() pollErr := wait.PollImmediateWithContext(ctx, 100*time.Millisecond, kmsPluginCloseGracePeriod, func(ctx context.Context) (bool, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.5K bytes - Viewed (0) -
src/os/exec/exec_test.go
} func TestCancelErrors(t *testing.T) { t.Parallel() // If Cancel returns a non-ErrProcessDone error and the process // exits successfully, Wait should wrap the error from Cancel. t.Run("success after error", func(t *testing.T) { t.Parallel() ctx, cancel := context.WithCancel(context.Background()) defer cancel() cmd := helperCommandContext(t, ctx, "pipetest")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 20:13:53 UTC 2024 - 48.4K bytes - Viewed (0)