- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 1,351 for routine (0.26 sec)
-
cmd/admin-handlers-pools.go
} var id string if id, err = pools.initRebalanceMeta(ctx, buckets); err != nil { writeErrorResponseJSON(ctx, w, toAPIError(ctx, err), r.URL) return } // Rebalance routine is run on the first node of any pool participating in rebalance. pools.StartRebalance() b, err := json.Marshal(struct { ID string `json:"id"` }{ID: id}) if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 10.9K bytes - Viewed (0) -
pkg/queue/instance.go
} q.cond.Signal() } func (q *queueImpl) Closed() <-chan struct{} { return q.closed } // get blocks until it can return a task to be processed. If shutdown = true, // the processing go routine should stop. func (q *queueImpl) get() (task *queueTask, shutdown bool) { q.cond.L.Lock() defer q.cond.L.Unlock() // wait for closing to be set, or a task to be pushed for !q.closing && len(q.tasks) == 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jul 21 16:30:36 UTC 2023 - 4.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/secure_serving.go
return tlsConfig, nil } // Serve runs the secure http server. It fails only if certificates cannot be loaded or the initial listen call fails. // The actual server loop (stoppable by closing stopCh) runs in a go routine, i.e. Serve does not block. // It returns a stoppedCh that is closed when all non-hijacked active requests have been processed. // It returns a listenerStoppedCh that is closed when the underlying http Server has stopped listening.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 12 20:54:07 UTC 2023 - 10.3K bytes - Viewed (0) -
guava/src/com/google/common/cache/CacheBuilder.java
* does). * * <p>Entries with keys that have been garbage collected may be counted in {@link Cache#size}, but * will never be visible to read or write operations; such entries are cleaned up as part of the * routine maintenance described in the class javadoc. * * @return this {@code CacheBuilder} instance (for chaining) * @throws IllegalStateException if the key strength was already set */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 15 16:12:13 UTC 2024 - 51.3K bytes - Viewed (0) -
pkg/proxy/config/config_test.go
func (h *ServiceHandlerMock) ValidateServices(t *testing.T, expectedServices []*v1.Service) { // We might get 1 or more updates for N service updates, because we // over write older snapshots of services from the producer go-routine // if the consumer falls behind. var services []*v1.Service for { select { case services = <-h.updated: if reflect.DeepEqual(services, expectedServices) { return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 14.3K bytes - Viewed (0) -
cmd/admin-handlers_test.go
return madmin.ServiceActionRestart case stopCmd: return madmin.ServiceActionStop } return madmin.ServiceActionRestart } // testServiceSignalReceiver - Helper function that simulates a // go-routine waiting on service signal. func testServiceSignalReceiver(cmd cmdType, t *testing.T) { expectedCmd := cmd.toServiceSignal() serviceCmd := <-globalServiceSignalCh if serviceCmd != expectedCmd {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 13.8K bytes - Viewed (0) -
cmd/kube-scheduler/app/testing/testserver.go
// // Note: we return a tear-down func instead of a stop channel because the later will leak temporary // // files that because Golang testing's call to os.Exit will not give a stop channel go routine // enough time to remove temporary files. func StartTestServer(ctx context.Context, customFlags []string) (result TestServer, err error) { logger := klog.FromContext(ctx) ctx, cancel := context.WithCancel(ctx)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 10:35:59 UTC 2023 - 5.2K bytes - Viewed (0) -
pkg/kubelet/logs/container_log_manager_test.go
}, } f.SetFakeContainers(testContainers) // Push the items into the queue for before starting the worker to avoid issue with the queue being empty. require.NoError(t, c.rotateLogs(ctx)) // Start a routine that can monitor the queue and shutdown the queue to trigger the retrun from the processQueueItems // Keeping the monitor duration smaller in order to keep the unwanted delay in the test to a minimal. go func() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 12.7K bytes - Viewed (0) -
pilot/pkg/xds/monitoring.go
versionTag = monitoring.CreateLabel("version") monServices = monitoring.NewGauge( "pilot_services", "Total services known to pilot.", ) // TODO: Update all the resource stats in separate routine // virtual services, destination rules, gateways, etc. xdsClients = monitoring.NewGauge( "pilot_xds", "Number of endpoints connected to this pilot using XDS.", ) xdsClientTrackerMutex = &sync.Mutex{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 6.7K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/CacheBuilder.java
* does). * * <p>Entries with keys that have been garbage collected may be counted in {@link Cache#size}, but * will never be visible to read or write operations; such entries are cleaned up as part of the * routine maintenance described in the class javadoc. * * @return this {@code CacheBuilder} instance (for chaining) * @throws IllegalStateException if the key strength was already set */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 15 16:12:13 UTC 2024 - 44.8K bytes - Viewed (0)