- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 88 for readArg (0.14 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go
} // Create a number of watchers that will not be reading any result. nonReadingWatchers := 50 for i := 0; i < nonReadingWatchers; i++ { watcher, err := store.Watch(ctx, "/pods/test-ns", options) if err != nil { t.Fatalf("Unexpected error: %v", err) } defer watcher.Stop() } // Create a second watcher that will be reading result. readingWatcher, err := store.Watch(ctx, "/pods/test-ns", options)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 63.8K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_container.go
data, _, err := tail.ReadAtMost(path, kubecontainer.MaxContainerTerminationMessageLength) if err != nil { if os.IsNotExist(err) { return "", fallbackToLogs } return fmt.Sprintf("Error on reading termination log %s: %v", path, err), false } return string(data), (fallbackToLogs && len(data) == 0) } return "", fallbackToLogs }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 54.7K bytes - Viewed (0) -
src/crypto/tls/handshake_server_test.go
// TestHandshakeServerUnsupportedKeyShare tests a client that sends a key share // that's not in the supported groups list. func TestHandshakeServerUnsupportedKeyShare(t *testing.T) { pk, _ := ecdh.X25519().GenerateKey(rand.Reader) clientHello := &clientHelloMsg{ vers: VersionTLS12, random: make([]byte, 32), supportedVersions: []uint16{VersionTLS13}, cipherSuites: []uint16{TLS_CHACHA20_POLY1305_SHA256},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 03 14:56:25 UTC 2024 - 64.7K bytes - Viewed (0) -
src/runtime/mbitmap.go
// // There can be read-write races between heapSetType and things // that read the heap metadata like scanobject. However, since // heapSetType is only used for objects that have not yet been // made reachable, readers will ignore bits being modified by this // function. This does mean this function cannot transiently modify // shared memory that belongs to neighboring objects. Also, on weakly-ordered
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 00:18:55 UTC 2024 - 60K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
server.enqueue(MockResponse(body = "A")) client = client.newBuilder() .readTimeout(Duration.ofSeconds(1)) .build() // Make a call expecting a timeout reading the response headers. val call1 = client.newCall(Request(server.url("/"))) assertFailsWith<SocketTimeoutException> { call1.execute() }.also { expected ->
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 75.3K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Futures.java
/* * requireNonNull is safe because we accepted an Iterable of non-null Future instances, and we * don't overwrite an element in the array until after reading it. */ ListenableFuture<? extends T> inputFuture = requireNonNull(inputFutures[inputFutureIndex]); // Null out our reference to this future, so it can be GCed
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 64.1K bytes - Viewed (0) -
tensorflow/compiler/jit/mark_for_compilation_pass_test.cc
GetClusterSets(*graph, &cluster_names); ASSERT_EQ(cluster_sets.size(), 1); std::vector<string> expected_clustered_nodes_a = { "AssignmentW1", "ConstN0", "ReadR0", "ValueToAssignW1"}; ASSERT_EQ(cluster_sets[cluster_names[0]], expected_clustered_nodes_a); } TEST(XlaCompilationTest, IllegalCycle_UsefulErrorMessage) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Feb 14 10:11:10 UTC 2024 - 79.6K bytes - Viewed (0) -
src/cmd/compile/internal/syntax/parser.go
} func (p *parser) init(file *PosBase, r io.Reader, errh ErrorHandler, pragh PragmaHandler, mode Mode) { p.top = true p.file = file p.errh = errh p.mode = mode p.pragh = pragh p.scanner.init( r, // Error and directive handler for scanner. // Because the (line, col) positions passed to the // handler is always at or after the current reading // position, it is safe to use the most recent position
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 19:19:55 UTC 2024 - 62.9K bytes - Viewed (0) -
pkg/apis/core/v1/defaults_test.go
featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, feature, featuresEnabled) } } // New defaults under PodTemplateSpec are only acceptable if they would not be applied when reading data from a previous release. // Forbidden: adding a new field `MyField *bool` and defaulting it to a non-nil value // Forbidden: defaulting an existing field `MyField *bool` when it was previously not defaulted
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 84.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
watchFn func(_ context.Context, _ string, _ storage.ListOptions) (watch.Interface, error) // use getRequestWatchProgressCounter when reading // the value of the counter requestWatchProgressCounter int } func (d *dummyStorage) RequestWatchProgress(ctx context.Context) error { d.Lock() defer d.Unlock() d.requestWatchProgressCounter++
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0)