- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 1,302 for deliver (0.25 sec)
-
cluster/addons/calico-policy-controller/ippool-crd.yaml
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 07 20:48:43 UTC 2021 - 4.2K bytes - Viewed (0) -
tests/integration/security/sds_ingress/ingress_test.go
// verify that TLS connection could establish to deliver HTTPS request. // (2) Rotates key/cert by deleting the secret generated in (1) and // replacing it a new secret with a different server key/cert. // (3) verify that client using older CA cert gets a 404 response // (4) verify that client using the newer CA cert is able to establish TLS connection // to deliver the HTTPS request. func TestSingleTlsGateway_SecretRotation(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 32.7K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/dispatch/AsyncDispatchTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 6.5K bytes - Viewed (0) -
src/os/signal/signal_test.go
// have been delivered by the OS. func quiesce() { // The kernel will deliver a signal as a thread returns // from a syscall. If the only active thread is sleeping, // and the system is busy, the kernel may not get around // to waking up a thread to catch the signal. // We try splitting up the sleep to give the kernel // many chances to deliver the signal. start := time.Now()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Nov 09 15:34:56 UTC 2023 - 27.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cache_watcher.go
close(c.done) } } func (c *cacheWatcher) nonblockingAdd(event *watchCacheEvent) bool { // if the bookmarkAfterResourceVersion hasn't been seen // we will try to deliver a bookmark event every second. // the following check will discard a bookmark event // if it is < than the bookmarkAfterResourceVersion // so that we don't pollute the input channel
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 12:22:41 UTC 2023 - 18.7K bytes - Viewed (0) -
src/runtime/os_aix.go
//go:nosplit func (c *sigctxt) fixsigcode(sig uint32) { switch sig { case _SIGPIPE: // For SIGPIPE, c.sigcode() isn't set to _SI_USER as on Linux. // Therefore, raisebadsignal won't raise SIGPIPE again if // it was deliver in a non-Go thread. c.set_sigcode(_SI_USER) } } //go:nosplit //go:nowritebarrierrec func sigaddset(mask *sigset, i int) { (*mask)[(i-1)/64] |= 1 << ((uint32(i) - 1) & 63) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 8.9K bytes - Viewed (0) -
docs/contribute/concurrency.md
### Threads #### Application's calling thread The application-layer must block on writing I/O. We can't return from a write until we've pushed its bytes onto the socket. Otherwise, if the write fails we are unable to deliver its IOException to the application. We would have told the application layer that the write succeeded, but it didn't!
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Feb 06 16:35:36 UTC 2022 - 7K bytes - Viewed (0) -
src/image/jpeg/reader_test.go
f, err := os.Open(filename) if err != nil { return nil, err } defer f.Close() return Decode(f) } type eofReader struct { data []byte // deliver from Read without EOF dataEOF []byte // then deliver from Read with EOF on last chunk lenAtEOF int } func (r *eofReader) Read(b []byte) (n int, err error) { if len(r.data) > 0 { n = copy(b, r.data) r.data = r.data[n:]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 25 00:46:29 UTC 2024 - 24.4K bytes - Viewed (0) -
pkg/kubelet/config/config.go
// PodConfigNotificationSnapshot delivers the full configuration as a SET whenever // any change occurs. PodConfigNotificationSnapshot // PodConfigNotificationSnapshotAndUpdates delivers an UPDATE and DELETE message whenever pods are // changed, and a SET message if there are any additions or removals. PodConfigNotificationSnapshotAndUpdates
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 16.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/mux.go
incoming chan Event stopped chan struct{} // How large to make watcher's channel. watchQueueLength int // If one of the watch channels is full, don't wait for it to become empty. // Instead just deliver it to the watchers that do have space in their // channels and move on to the next event. // It's more fair to do this on a per-watcher basis than to do it on the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 16 15:26:36 UTC 2022 - 9.4K bytes - Viewed (0)