- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 215 for deliver (0.48 sec)
-
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/apiserver/pkg/storage/cacher/cacher.go
case watch.Deleted: // Don't wrap Object for delete events - these are not to deliver any // events. Only wrap PrevObject. if object, err := newCachingObject(event.PrevObject); err == nil { // Update resource version of the object. // event.PrevObject is used to deliver DELETE watch events and // for them, we set resourceVersion to <current> instead of
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache.go
var oldest uint64 switch { case w.listResourceVersion > 0 && !w.removedEventSinceRelist: // If no event was removed from the buffer since last relist, the oldest watch // event we can deliver is one greater than the resource version of the list. oldest = w.listResourceVersion + 1 case size > 0: // If the previous condition is not satisfied: either some event was already
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 10:20:57 UTC 2024 - 26.2K bytes - Viewed (0) -
internal/grid/muxclient.go
// Spawn simple disconnect if requests == nil { go m.handleOneWayStream(responseCh, responses) return &Stream{responses: responseCh, Requests: nil, ctx: m.ctx, cancel: m.cancelFn, muxID: m.MuxID}, nil } // Deliver responses and send unblocks back to the server. go m.handleTwowayResponses(responseCh, responses) go m.handleTwowayRequests(responses, requests)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.9K bytes - Viewed (0) -
src/syscall/exec_linux.go
childTID uint64 // Where to store child TID, in child's memory (pid_t *) parentTID uint64 // Where to store child TID, in parent's memory (pid_t *) exitSignal uint64 // Signal to deliver to parent on child termination stack uint64 // Pointer to lowest byte of stack stackSize uint64 // Size of stack tls uint64 // Location of new TLS
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 07:45:37 UTC 2024 - 23K bytes - Viewed (0) -
src/net/http/transport.go
mu sync.Mutex // protects ctx, done and sending of the result ctx context.Context // context for dial, cleared after delivered or canceled cancelCtx context.CancelFunc done bool // true after delivered or canceled result chan connOrError // channel to deliver connection or error } type connOrError struct { pc *persistConn err error idleAt time.Time }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 91K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods_test.go
// delivered to the pod worker via HandlePodAdditions - there is no *known* scenario that can happen, but // we want to capture it in the metric. The more likely scenario is that a static pod with a predefined // UID is updated, which causes pod config to deliver DELETE -> ADD while the old pod is still shutting
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 198.8K bytes - Viewed (0) -
src/crypto/tls/conn.go
bytesSent int64 packetsSent int64 // retryCount counts the number of consecutive non-advancing records // received by Conn.readRecord. That is, records that neither advance the // handshake, nor deliver application data. Protected by in.Mutex. retryCount int // activeCall indicates whether Close has been call in the low bit. // the rest of the bits are the number of goroutines in Conn.Write. activeCall atomic.Int32
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 51.8K bytes - Viewed (0) -
pkg/kubelet/pod_workers_test.go
processed[types.UID("6-static")]; !reflect.DeepEqual(expected, actual) { t.Fatalf("unexpected sync pod calls: %s", cmp.Diff(expected, actual)) } // ensure 5-static exits when we deliver the event out of order channels.Channel("5-static").Release() drainAllWorkers(podWorkers) pod5 = podWorkers.podSyncStatuses[types.UID("5-static")] if !pod5.IsTerminated() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
src/text/template/exec_test.go
} func twoArgs(a, b string) string { return "twoArgs=" + a + b } func dddArg(a int, b ...string) string { return fmt.Sprintln(a, b) } // count returns a channel that will deliver n sequential 1-letter strings starting at "a" func count(n int) chan string { if n == 0 { return nil } c := make(chan string) go func() { for i := 0; i < n; i++ {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 22:23:55 UTC 2024 - 60.1K bytes - Viewed (0)