- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 42 for bCleanup (0.56 sec)
-
cmd/metrics-v2.go
Description: MetricDescription{ Namespace: nodeMetricNamespace, Subsystem: ilmSubsystem, Name: expiryMissedTierJournalTasks, Help: "Number of tier journal entries cleanup missed due to busy system", Type: counterMetric, }, } expNumWorkers := MetricV2{ Description: MetricDescription{ Namespace: nodeMetricNamespace, Subsystem: ilmSubsystem,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 132.6K bytes - Viewed (0) -
cmd/erasure-multipart.go
}, index) } g.Wait() } // Clean-up the old multipart uploads. Should be run in a Go routine. func (er erasureObjects) cleanupStaleUploads(ctx context.Context, expiry time.Duration) { // run multiple cleanup's local to this server. var wg sync.WaitGroup for _, disk := range er.getLocalDisks() { if disk != nil { wg.Add(1) go func(disk StorageAPI) { defer wg.Done()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 43K bytes - Viewed (0) -
cni/pkg/repair/repair_test.go
for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { mt := monitortest.New(t) tt.config.LabelPods = true c, err := NewRepairController(tt.client, tt.config) assert.NoError(t, err) t.Cleanup(func() { assert.NoError(t, c.queue.WaitForClose(time.Second)) }) stop := test.NewStop(t) tt.client.RunAndWait(stop) go c.Run(stop) kube.WaitForCacheSync("test", stop, c.queue.HasSynced)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Oct 24 03:31:28 GMT 2023 - 10.6K bytes - Viewed (0) -
cmd/erasure-sets.go
} wg.Wait() // start cleanup stale uploads go-routine. go s.cleanupStaleUploads(ctx) // start cleanup of deleted objects. go s.cleanupDeletedObjects(ctx) // Start the disk monitoring and connect routine. if !globalIsTesting { go s.monitorAndConnectEndpoints(ctx, defaultMonitorConnectEndpointInterval) } return s, nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 37.7K bytes - Viewed (5) -
src/cmd/cgo/internal/test/issue1435.go
// int i; // nts = argc; // t = calloc(nts, sizeof(pthread_t)); // pthread_mutex_init(&mu, NULL); // for (i = 0; i < nts; i++) { // pthread_create(&t[i], NULL, aFn, NULL); // } // } // // void cleanup(void) { // int i; // pthread_mutex_lock(&mu); // all_done = 1; // pthread_mutex_unlock(&mu); // for (i = 0; i < nts; i++) { // pthread_join(t[i], NULL); // } // pthread_mutex_destroy(&mu);
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Fri Jul 28 21:31:41 GMT 2023 - 7.5K bytes - Viewed (0) -
cmd/storage-rest_test.go
} } func newStorageRESTHTTPServerClient(t testing.TB) *storageRESTClient { // Grid with 2 hosts tg, err := grid.SetupTestGrid(2) if err != nil { t.Fatalf("SetupTestGrid: %v", err) } t.Cleanup(tg.Cleanup) prevHost, prevPort := globalMinioHost, globalMinioPort defer func() { globalMinioHost, globalMinioPort = prevHost, prevPort }() // tg[0] = local, tg[1] = remote // Remote URL
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 11.4K bytes - Viewed (0) -
cni/pkg/install/install.go
if _, err := in.installAll(ctx); err != nil { return err } installLog.Info("Istio CNI configuration and binaries validated/reinstalled.") } } // Cleanup remove Istio CNI's config, kubeconfig file, and binaries. func (in *Installer) Cleanup() error { installLog.Info("Cleaning up.") if len(in.cniConfigFilepath) > 0 && file.Exists(in.cniConfigFilepath) { if in.cfg.ChainedCNIPlugin {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 10.8K bytes - Viewed (0) -
cmd/metacache-walk.go
} diskHealthCheckOK(ctx, err) return err } diskHealthCheckOK(ctx, err) if len(entries) == 0 { return nil } dirObjects := make(map[string]struct{}) // Avoid a bunch of cleanup when joining. current = strings.Trim(current, SlashSeparator) for i, entry := range entries { if opts.Limit > 0 && objsReturned >= opts.Limit { return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 12.4K bytes - Viewed (0) -
cmd/object-api-interface.go
// Object operations. // GetObjectNInfo returns a GetObjectReader that satisfies the // ReadCloser interface. The Close method runs any cleanup // functions, so it must always be called after reading till EOF // // IMPORTANTLY, when implementations return err != nil, this // function MUST NOT return a non-nil ReadCloser.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 17K bytes - Viewed (0) -
internal/bucket/lifecycle/lifecycle.go
// No other conflicting actions apply to an expired object delete marker break } if !rule.Expiration.IsDaysNull() { // Specifying the Days tag will automatically perform ExpiredObjectDeleteMarker cleanup // once delete markers are old enough to satisfy the age criteria. // https://docs.aws.amazon.com/AmazonS3/latest/userguide/lifecycle-configuration-examples.html
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 17.5K bytes - Viewed (0)