- Sort Score
- Result 10 results
- Languages All
Results 11 - 16 of 16 for psignal (0.14 sec)
-
pkg/kubelet/kubelet_test.go
checkPodStatus(t, kl, missingPod, v1.PodPending) checkPodStatus(t, kl, failedPod, v1.PodFailed) } // TODO(filipg): This test should be removed once StatusSyncer can do garbage collection without external signal. func TestPurgingObsoleteStatusMapEntries(t *testing.T) { ctx := context.Background() testKubelet := newTestKubelet(t, false /* controllerAttachDetachEnabled */) defer testKubelet.Cleanup()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
syncErr = fmt.Errorf("error killing pod: %w", err) utilruntime.HandleError(syncErr) } } else { // There was no error killing the pod, but the pod cannot be run. // Return an error to signal that the sync loop should back off. syncErr = fmt.Errorf("pod cannot be run: %v", runnable.Message) } return false, syncErr }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
src/database/sql/sql_test.go
setHookOpenErr(func() error { // Wait for all connections to enqueue. opening.Wait() return errOffline }) for i := 0; i < tryOpen; i++ { go func() { opening.Done() // signal one connection is in flight _, err := db.Exec("will never run") errs <- err }() } opening.Wait() // wait for all workers to begin running const timeout = 5 * time.Second
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 111.6K bytes - Viewed (0) -
src/cmd/link/internal/ld/data.go
copy(data, prefix) data[len(prefix)] = byte(ctxt.Arch.PtrSize) data[len(prefix)+1] = 0 if ctxt.Arch.ByteOrder == binary.BigEndian { data[len(prefix)+1] = 1 } data[len(prefix)+1] |= 2 // signals new pointer-free format data = appendString(data, strdata["runtime.buildVersion"]) data = appendString(data, strdata["runtime.modinfo"]) // MacOS linker gets very upset if the size os not a multiple of alignment.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 12 15:10:50 UTC 2024 - 100.5K bytes - Viewed (1) -
src/cmd/internal/obj/x86/asm6.go
if !yt.match(args) { // "xo" is always zero for VEX/EVEX encoded insts. z += int(yt.zoffset) + xo } else { if p.Scond != 0 && !evexZcase(yt.zcase) { // Do not signal error and continue to search // for matching EVEX-encoded form. z += int(yt.zoffset) continue } switch o.prefix { case Px1: // first option valid only in 32-bit mode
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 15:44:14 UTC 2024 - 146.9K bytes - Viewed (0) -
src/net/http/transport_test.go
reqerrc := make(chan error, 1) go func() { defer wg.Done() ctx := httptrace.WithClientTrace(context.Background(), &httptrace.ClientTrace{ PutIdleConn: func(error) { // Signal that the idle conn has been returned to the pool, // and wait for the order to proceed. ch := make(chan struct{}) putidlec <- ch close(putidlec) // panic if PutIdleConn runs twice for some reason
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 192.6K bytes - Viewed (0)