- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 43 for calling (0.15 sec)
-
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
* deterministic. * * This class ensures that at most one thread is running at a time. This is initially the JUnit test * thread, which yields its execution privilege while calling [runTasks], [runNextTask], or * [advanceUntil]. These functions don't return until the task threads are all idle. * * Task threads release their execution privilege in these ways: *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 12.6K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
err = addPodToHostNSIpset(pod, podIPs, &s.hostsideProbeIPSet) if err != nil { log.Errorf("failed to add pod to ipset: %s/%s %v", pod.Namespace, pod.Name, err) return err } log.Debug("calling CreateInpodRules") if err := s.netnsRunner(openNetns, func() error { return s.iptablesConfigurator.CreateInpodRules(&HostProbeSNATIP) }); err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
cmd/object-api-listobjects_test.go
} } } } }) } } // Wrapper for calling ListObjectsOnVersionedBuckets tests for both // Erasure multiple disks and single node setup. func TestListObjectsOnVersionedBuckets(t *testing.T) { ExecObjectLayerTest(t, testListObjectsOnVersionedBuckets) } // Wrapper for calling ListObjects tests for both Erasure multiple // disks and single node setup.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 11:07:40 GMT 2024 - 73.1K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Sets.java
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed May 01 18:44:57 GMT 2024 - 77.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
} if (queue.futureTasks.isNotEmpty()) { readyQueues.add(queue) } } /** * Returns an immediately-executable task for the calling thread to execute, sleeping as necessary * until one is ready. If there are no ready queues, or if other threads have everything under
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 10.6K bytes - Viewed (0) -
cmd/object-handlers_test.go
type Fault int const ( None Fault = iota MissingContentLength TooBigObject TooBigDecodedLength BadSignature BadMD5 MissingUploadID ) // Wrapper for calling HeadObject API handler tests for both Erasure multiple disks and FS single drive setup. func TestAPIHeadObjectHandler(t *testing.T) { ExecObjectLayerAPITest(t, testAPIHeadObjectHandler, []string{"HeadObject"}) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 160K bytes - Viewed (0) -
internal/rest/client.go
_ int32 // For 64 bits alignment lastConn int64 // HealthCheckFn is the function set to test for health. // If not set the client will not keep track of health. // Calling this returns true or false if the target // is online or offline. HealthCheckFn func() bool // HealthCheckRetryUnit will be used to calculate the exponential // backoff when trying to reconnect to an offline node
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 14.4K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
assert.NoError(t, err) fakeIPSetDeps.AssertExpectations(t) } // for tests that call `runtime.GC()` - we have no control over when the GC is actually scheduled, // and it is flake-prone to check for closure after calling it, this retries for a bit to make // sure the netns is closed eventually. func assertNSClosed(t *testing.T, closed *atomic.Bool) { for i := 0; i < 5; i++ { if closed.Load() { return }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
cmd/sts-handlers_test.go
Options: cr.STSAssumeRoleOptions{ AccessKey: accessKey, SecretKey: secretKey, Location: "", }, } value, err := assumeRole.Retrieve() if err != nil { c.Fatalf("err calling assumeRole: %v", err) } minioClient, err := minio.New(s.endpoint, &minio.Options{ Creds: cr.NewStaticV4(value.AccessKeyID, value.SecretAccessKey, value.SessionToken), Secure: s.secure,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 15:50:16 GMT 2024 - 85.7K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Multimaps.java
* type {@code K}. Using an {@code EntryTransformer} key type for which this may not hold, such as * {@code ArrayList}, may risk a {@code ClassCastException} when calling methods on the * transformed multimap. * * @since 7.0 */ public static < K extends @Nullable Object, V1 extends @Nullable Object, V2 extends @Nullable Object>
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed May 01 18:44:57 GMT 2024 - 86.4K bytes - Viewed (0)