- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 866 for cancel3b (0.3 sec)
-
subprojects/core/src/main/java/org/gradle/internal/work/AsyncWorkCompletion.java
*/ void waitForCompletion(); /** * Returns true if the work item is completed. */ boolean isComplete(); /** * Cancels this work item. */ void cancel();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 14 16:55:12 UTC 2018 - 1017 bytes - Viewed (0) -
src/net/tcpsock_unix_test.go
} // Issue 19289. // Test that a canceled Dial does not cause a subsequent Dial to succeed. func TestTCPSpuriousConnSetupCompletionWithCancel(t *testing.T) { mustHaveExternalNetwork(t) defer dnsWaitGroup.Wait() t.Parallel() const tries = 10000 var wg sync.WaitGroup wg.Add(tries * 2) sem := make(chan bool, 5) for i := 0; i < tries; i++ { sem <- true ctx, cancel := context.WithCancel(context.Background())
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 2.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RoutePlanner.kt
fun connectTcp(): ConnectResult fun connectTlsEtc(): ConnectResult fun handleSuccess(): RealConnection fun cancel() /** * Returns a plan to attempt if canceling this plan was a mistake! The returned plan is not * canceled, even if this plan is canceled. */ fun retry(): Plan? } /** * What to do once a plan has executed. *
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Dec 20 23:27:07 UTC 2023 - 4.2K bytes - Viewed (0) -
cmd/erasure-metadata-utils_test.go
t.Errorf("Test: Expect \"nil\" but failed \"%#v\"", hashedOrder) } } func TestShuffleDisks(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() nDisks := 16 disks, err := getRandomDisks(nDisks) if err != nil { t.Fatal(err) } objLayer, _, err := initObjectLayer(ctx, mustGetPoolEndpoints(0, disks...))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 7.4K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/ConditionalExecution.java
*/ void complete(); /** * Whether this execution has been completed or not. */ boolean isComplete(); /** * Cancels this execution. */ void cancel();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 1.2K bytes - Viewed (0) -
src/database/sql/sql_test.go
} if index == 2 && err != context.Canceled { t.Fatalf("Scan: %v; want context.Canceled", err) } got = append(got, r) index++ } select { case <-ctx.Done(): if err := ctx.Err(); err != context.Canceled { t.Fatalf("context err = %v; want context.Canceled", err) } default: t.Fatalf("context err = nil; want context.Canceled") } want := []row{ {age: 1, name: "Alice"},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 111.6K bytes - Viewed (0) -
src/crypto/tls/quic.go
eventArr [8]QUICEvent started bool signalc chan struct{} // handshake data is available to be read blockedc chan struct{} // handshake is waiting for data, closed when done cancelc <-chan struct{} // handshake has been canceled cancel context.CancelFunc waitingForDrain bool // readbuf is shared between HandleData and the handshake goroutine. // HandshakeCryptoData passes ownership to the handshake goroutine by
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 17:23:54 UTC 2024 - 15.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/validating/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: Wed Aug 23 20:24:12 UTC 2023 - 13K bytes - Viewed (0) -
pkg/config/analysis/local/context.go
func NewContext(stores map[cluster.ID]model.ConfigStore, cancelCh <-chan struct{}, collectionReporter CollectionReporterFn) analysis.Context { return &istiodContext{ stores: stores, cancelCh: cancelCh, messages: map[string]*diag.Messages{}, collectionReporter: collectionReporter, found: map[key]*resource.Instance{},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 08:32:06 UTC 2024 - 6.3K bytes - Viewed (0) -
.github/workflows/go-fips.yml
name: FIPS Build Test 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: build: name: Go BoringCrypto ${{ matrix.go-version }} on ${{ matrix.os }} runs-on: ${{ matrix.os }} strategy:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 1.5K bytes - Viewed (0)