Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 21 for spent (0.44 sec)

  1. pkg/controller/garbagecollector/garbagecollector_test.go

    	gc.absentOwnerCache = NewReferenceCache(2)
    	gc.attemptToDeleteItem(context.TODO(), podToGCNode(rc1Pod1))
    	gc.attemptToDeleteItem(context.TODO(), podToGCNode(rc2Pod1))
    	// rc1 should already be in the cache, no request should be sent. rc1 should be promoted in the UIDCache
    	gc.attemptToDeleteItem(context.TODO(), podToGCNode(rc1Pod2))
    	// after this call, rc2 should be evicted from the UIDCache
    	gc.attemptToDeleteItem(context.TODO(), podToGCNode(rc3Pod1))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 111.6K bytes
    - Viewed (0)
  2. src/cmd/vendor/golang.org/x/sys/windows/zsyscall_windows.go

    		err = errnoErr(e1)
    	}
    	return
    }
    
    func WSASend(s Handle, bufs *WSABuf, bufcnt uint32, sent *uint32, flags uint32, overlapped *Overlapped, croutine *byte) (err error) {
    	r1, _, e1 := syscall.Syscall9(procWSASend.Addr(), 7, uintptr(s), uintptr(unsafe.Pointer(bufs)), uintptr(bufcnt), uintptr(unsafe.Pointer(sent)), uintptr(flags), uintptr(unsafe.Pointer(overlapped)), uintptr(unsafe.Pointer(croutine)), 0, 0)
    	if r1 == socket_error {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 195.8K bytes
    - Viewed (0)
  3. src/net/http/transport_test.go

    	ts := newClientServerTest(t, mode, HandlerFunc(func(rw ResponseWriter, req *Request) {
    		if req.Method == "HEAD" {
    			if g := req.Header.Get("Accept-Encoding"); g != "" {
    				t.Errorf("HEAD request sent with Accept-Encoding of %q; want none", g)
    			}
    			return
    		}
    		if g, e := req.Header.Get("Accept-Encoding"), "gzip"; g != e {
    			t.Errorf("Accept-Encoding = %q, want %q", g, e)
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 06 21:59:21 UTC 2024
    - 192.6K bytes
    - Viewed (0)
  4. src/database/sql/sql.go

    			db.openNewConnection(ctx)
    		}
    	}
    }
    
    // Open one new connection
    func (db *DB) openNewConnection(ctx context.Context) {
    	// maybeOpenNewConnections has already executed db.numOpen++ before it sent
    	// on db.openerCh. This function must execute db.numOpen-- if the
    	// connection fails or is closed before returning.
    	ci, err := db.connector.Connect(ctx)
    	db.mu.Lock()
    	defer db.mu.Unlock()
    	if db.closed {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:16:53 UTC 2024
    - 103.6K bytes
    - Viewed (0)
  5. tests/integration/pilot/common/routing.go

    				ProxyProtocolVersion: 1,
    				Check: check.Each(
    					func(r echoClient.Response) error {
    						body := r.RawContent
    						ok := strings.Contains(body, "PROXY TCP4")
    						if ok {
    							return fmt.Errorf("sent proxy protocol header, and it was echoed back")
    						}
    						return nil
    					}),
    			},
    		})
    	}
    	return cases
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 21:52:51 UTC 2024
    - 135.9K bytes
    - Viewed (0)
  6. src/reflect/value.go

    	v.mustBe(Chan)
    	v.mustBeExported()
    	return v.recv(true)
    }
    
    // TrySend attempts to send x on the channel v but will not block.
    // It panics if v's Kind is not [Chan].
    // It reports whether the value was sent.
    // As in Go, x's value must be assignable to the channel's element type.
    func (v Value) TrySend(x Value) bool {
    	v.mustBe(Chan)
    	v.mustBeExported()
    	return v.send(x, true)
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 21:17:41 UTC 2024
    - 119.9K bytes
    - Viewed (0)
  7. src/cmd/go/alldocs.go

    //	    See also -skip.
    //
    //	-short
    //	    Tell long-running tests to shorten their run time.
    //	    It is off by default but set during all.bash so that installing
    //	    the Go tree can run a sanity check but not spend time running
    //	    exhaustive tests.
    //
    //	-shuffle off,on,N
    //	    Randomize the execution order of tests and benchmarks.
    //	    It is off by default. If -shuffle is set to on, then it will seed
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 11 16:54:28 UTC 2024
    - 142.4K bytes
    - Viewed (0)
  8. pkg/controller/job/job_controller_test.go

    	manager.podStoreSynced = alwaysReady
    	manager.jobStoreSynced = alwaysReady
    
    	var testJob batch.Job
    	received := make(chan struct{})
    
    	// The update sent through the fakeWatcher should make its way into the workqueue,
    	// and eventually into the syncHandler.
    	manager.syncHandler = func(ctx context.Context, key string) error {
    		defer close(received)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
  9. pkg/controller/podautoscaler/horizontal_test.go

    		timeoutTime := time.Now().Add(2 * time.Second)
    		for now := time.Now(); timeoutTime.After(now); now = time.Now() {
    			sleepUntil := timeoutTime.Sub(now)
    			select {
    			case <-tc.processed:
    				// drain the chan of any sent events to keep it from filling before the timeout
    			case <-time.After(sleepUntil):
    				// timeout reached, ready to verifyResults
    			}
    		}
    	} else {
    		// Wait for HPA to be processed.
    		<-tc.processed
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 14:24:16 UTC 2024
    - 199.3K bytes
    - Viewed (0)
  10. pkg/kubelet/kubelet.go

    				file.ServeHTTP(w, req)
    			}))
    		} else {
    			kl.logServer = http.StripPrefix("/logs/", file)
    		}
    	}
    	if kl.kubeClient == nil {
    		klog.InfoS("No API server defined - no node status update will be sent")
    	}
    
    	// Start the cloud provider sync manager
    	if kl.cloudResourceSyncManager != nil {
    		go kl.cloudResourceSyncManager.Run(wait.NeverStop)
    	}
    
    	if err := kl.initializeModules(); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
Back to top