Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 16 of 16 for psignal (0.14 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to top