- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 297 for chancap (0.14 sec)
-
guava/src/com/google/common/io/Closeables.java
* I/O resource, it should generally be safe in the case of a resource that's being used only for * reading, such as an {@code InputStream}. Unlike with writable resources, there's no chance that * a failure that occurs when closing the stream indicates a meaningful problem such as a failure * to flush all bytes to the underlying resource. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 17 14:35:11 UTC 2023 - 4.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/testing/promise/counting_test.go
t.Error("second Set() returned true") } }() goGetAndExpect(t, clock, counter, wr, gots, aval) counter.Add(1) // account for unblocking the receive on doneCh close(doneCh) time.Sleep(time.Second) // give it a chance to misbehave goGetAndExpect(t, clock, counter, wr, gots, aval) } func TestCountingWriteOnceCancel(t *testing.T) { oldTime := time.Now() cval := &oldTime clock, counter := testeventclock.NewFake(oldTime, 0, nil)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 10 14:37:53 UTC 2021 - 4.6K bytes - Viewed (0) -
maven-compat/src/main/java/org/apache/maven/artifact/resolver/ResolutionListenerForDepMgmt.java
* when the ResolutionListener interface deprecation of the manageArtifact * method (and the [yet to be done] addition of these methods to that * interface) has had a chance to propagate to all interested plugins. */ @Deprecated public interface ResolutionListenerForDepMgmt { void manageArtifactVersion(Artifact artifact, Artifact replacement);
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Nov 22 13:26:01 UTC 2022 - 1.5K bytes - Viewed (0) -
cmd/kube-apiserver/app/options/globalflags.go
limitations under the License. */ package options import ( "github.com/spf13/pflag" "k8s.io/component-base/cli/globalflag" // ensure libs have a chance to globally register their flags _ "k8s.io/apiserver/pkg/admission" ) // AddCustomGlobalFlags explicitly registers flags that internal packages register
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 07:44:58 UTC 2024 - 1.3K bytes - Viewed (0) -
src/cmd/cgo/internal/testcshared/testdata/main2.c
// Read a string from the file descriptor and print it. int main(void) { int i; ssize_t n; char buf[20]; struct timespec ts; // The descriptor will be initialized in a thread, so we have to // give a chance to get opened. for (i = 0; i < 200; i++) { n = read(fd, buf, sizeof buf); if (n >= 0) break; if (errno != EBADF && errno != EINVAL) { fprintf(stderr, "BUG: read: %s\n", strerror(errno));
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 12 11:59:56 UTC 2023 - 1.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/discovery/storageversionhash.go
func StorageVersionHash(group, version, kind string) string { gvk := group + "/" + version + "/" + kind bytes := sha256.Sum256([]byte(gvk)) // Assuming there are N kinds in the cluster, and the hash is X-byte long, // the chance of colliding hash P(N,X) approximates to 1-e^(-(N^2)/2^(8X+1)). // P(10,000, 8) ~= 2.7*10^(-12), which is low enough. // See https://en.wikipedia.org/wiki/Birthday_problem#Approximations.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 14 12:08:11 UTC 2023 - 1.3K bytes - Viewed (0) -
src/math/rand/v2/auto_test.go
package rand_test import ( . "math/rand/v2" "testing" ) // This test is first, in its own file with an alphabetically early name, // to try to make sure that it runs early. It has the best chance of // detecting deterministic seeding if it's the first test that runs. func TestAuto(t *testing.T) { // Pull out 10 int64s from the global source // and then check that they don't appear in that
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Oct 30 17:09:26 UTC 2023 - 1.1K bytes - Viewed (0) -
android/guava/src/com/google/common/io/Closeables.java
* I/O resource, it should generally be safe in the case of a resource that's being used only for * reading, such as an {@code InputStream}. Unlike with writable resources, there's no chance that * a failure that occurs when closing the stream indicates a meaningful problem such as a failure * to flush all bytes to the underlying resource. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 17 14:35:11 UTC 2023 - 4.7K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/gc-stress.go
} procs := runtime.GOMAXPROCS(-1) sink = make([][]byte, procs) for i := 0; i < procs; i++ { i := i go func() { for { sink[i] = make([]byte, 4<<10) } }() } // Increase the chance that we end up starting and stopping // mid-GC by only starting to trace after a few milliseconds. time.Sleep(5 * time.Millisecond) // Start tracing. if err := trace.Start(os.Stdout); err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 1.5K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/wait-on-pipe.go
go func() { var data [1]byte _, err := syscall.Read(rfd, data[:]) if err != nil { log.Fatalf("failed to read from pipe: %v", err) } done <- struct{}{} }() // Give the goroutine ample chance to block on the pipe. time.Sleep(10 * time.Millisecond) // Start tracing. if err := trace.Start(os.Stdout); err != nil { log.Fatalf("failed to start tracing: %v", err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 1.6K bytes - Viewed (0)