- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 171 for stopCh (0.15 sec)
-
cmd/erasure-server-pool-rebalance.go
ignore = true stopFn(0, nil) break } if err != nil { failure = true rebalanceLogIf(ctx, err) stopFn(0, err) continue } if err = z.rebalanceObject(ctx, bucket, gr); err != nil { failure = true rebalanceLogIf(ctx, err) stopFn(version.Size, err) continue }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 03 15:45:54 UTC 2024 - 27.3K bytes - Viewed (0) -
cmd/sftp-server-driver.go
ContentType: mimedb.TypeByExtension(path.Ext(object)), DisableContentSha256: true, }) stopFn(oi.Size, err) pr.CloseWithError(err) wa.wg.Done() }() return wa, nil } func (f *sftpDriver) Filecmd(r *sftp.Request) (err error) { stopFn := globalSftpMetrics.log(r, f.AccessKey()) defer stopFn(0, err) clnt, err := f.getMinIOClient() if err != nil { return err }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Jun 05 07:51:13 UTC 2024 - 11.1K bytes - Viewed (0) -
cmd/utils.go
return p.records } // Stop the currently running benchmark. func (p profilerWrapper) Stop() ([]byte, error) { return p.stopFn() } // Extension returns the extension without dot prefix. func (p profilerWrapper) Extension() string { return p.ext } // Returns current profile data, returns error if there is no active // profiling in progress. Stops an active profile.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Jun 05 22:00:34 UTC 2024 - 31.9K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/Daemon.java
} /** * Stops the daemon, blocking until any current requests/connections have been satisfied. * <p> * This is the semantically the same as sending the daemon the Stop command. * <p> * This method does not quite conform to the semantics of the Stoppable contract in that it will NOT * wait for any executing builds to stop before returning. This is by design as we currently have no way of
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 12.9K bytes - Viewed (0) -
cmd/data-scanner.go
// Add non-compacted empty entry. f.updateCache.replaceHashed(h, &thisHash, dataUsageEntry{}) } } f.updateCurrentPath(folder.name) stopFn := globalScannerMetrics.log(scannerMetricScanFolder, f.root, folder.name) scanFolder(folder) stopFn(map[string]string{"type": "new"}) // Add new folders if this is new and we don't have existing. if !into.Compacted {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:43:17 UTC 2024 - 47.6K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DaemonStateCoordinator.java
} /** * Forcibly stops the daemon, even if it is busy. * * If the daemon is busy and the client is waiting for a response, it may receive “null” from the daemon as the connection may be closed by this method before the result is sent back. * * @see #requestStop(String reason) */ @Override public void stop() { stopNow("service stop"); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 17.1K bytes - Viewed (0) -
cmd/batch-expire.go
default: } stopFn := globalBatchJobsMetrics.trace(batchJobMetricExpire, ri.JobID, attempts) _, err := api.DeleteObject(ctx, exp.Bucket, encodeDirObject(exp.Name), ObjectOptions{ DeletePrefix: true, DeletePrefixObject: true, // use prefix delete on exact object (this is an optimization to avoid fan-out calls) }) if err != nil { stopFn(exp, err)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 13:50:53 UTC 2024 - 21.1K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/api/services/internal/DefaultBuildServicesRegistryTest.groovy
} def "an exception from stop action is rethrown"() { given: def provider = registerService("service", ServiceImpl) provider.beforeStopping { throw new UnsupportedOperationException("Don't stop") } when: buildFinished() then: thrown(Exception) } def "other stop actions run if one of them throws"() { given:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jun 06 19:15:46 UTC 2024 - 16.4K bytes - Viewed (0) -
cmd/ftp-server-driver.go
stopFn := globalFtpMetrics.log(ctx, fromObjPath, toObjPath) defer stopFn(0, err) return NotImplemented{} } // MakeDir implements ftpDriver func (driver *ftpDriver) MakeDir(ctx *ftp.Context, objPath string) (err error) { stopFn := globalFtpMetrics.log(ctx, objPath) defer stopFn(0, err) bucket, prefix := path2BucketObject(objPath)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 03 15:45:54 UTC 2024 - 14K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r65/ToolingApiShutdownCrossVersionSpec.groovy
def setup() { waitFor = new PollingConditions(timeout: 60, initialDelay: 0, factor: 1.25) toolingApi.requireIsolatedDaemons() } @TargetGradleVersion(">=6.5") def "disconnect during build stops daemon"() { setup: buildFile.text = """ task hang { doLast { ${server.callFromBuild("waiting")} } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 16 10:10:39 UTC 2024 - 11.5K bytes - Viewed (0)