- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 75 for started (0.14 sec)
-
cmd/erasure-server-pool-rebalance.go
rebalStopped rebalFailed ) type rebalanceInfo struct { StartTime time.Time `msg:"startTs"` // Time at which rebalance-start was issued EndTime time.Time `msg:"stopTs"` // Time at which rebalance operation completed or rebalance-stop was called Status rebalStatus `msg:"status"` // Current state of rebalance operation. One of Started|Stopped|Completed|Failed. }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K bytes - Viewed (0) -
cmd/globals.go
globalHTTPStats = newHTTPStats() // Global bucket network and API statistics globalBucketConnStats = newBucketConnStats() globalBucketHTTPStats = newBucketHTTPStats() // Time when the server is started globalBootTime = UTCNow() globalActiveCred auth.Credentials globalSiteReplicatorCred siteReplicatorCred // Captures if root credentials are set via ENV. globalCredViaEnv bool
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 16.5K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
dctx, dcancel := context.WithCancel(ctx) started := time.Now() go func() { timeout := time.NewTimer(globalDriveConfig.GetMaxTimeout()) select { case <-dctx.Done(): if !timeout.Stop() { <-timeout.C } case <-timeout.C: spent := time.Since(started) goOffline(fmt.Errorf("unable to write+read for %v", spent.Round(time.Millisecond)), spent)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
internal/s3select/message.go
close(writer.payloadCh) // Wait until the `start` go-routine is done. <-writer.doneCh return nil } } func (writer *messageWriter) FinishWithError(errorCode, errorMessage string) error { select { case <-writer.doneCh: return fmt.Errorf("messageWriter is done") case writer.errCh <- newErrorMessage([]byte(errorCode), []byte(errorMessage)): // Wait until the `start` go-routine is done. <-writer.doneCh
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 15.2K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
sha256hex = "" } var forceMD5 []byte // Optimization: If SSE-KMS and SSE-C did not request Content-Md5. Use uuid as etag. Optionally enable this also // for server that is started with `--no-compat`. if !etag.ContentMD5Requested(r.Header) && (crypto.S3KMS.IsEncrypted(mi.UserDefined) || crypto.SSEC.IsRequested(r.Header) || !globalServerCtxt.StrictS3Compat) { forceMD5 = mustGetUUIDBytes() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 39K bytes - Viewed (0) -
internal/grid/grid_test.go
started := time.Now() dl, _ := ctx.Deadline() if testing.Verbose() { fmt.Println(GetCaller(ctx).Name, "Server deadline:", time.Until(dl)) } <-ctx.Done() serverCanceled <- time.Since(started) if testing.Verbose() { fmt.Println(GetCaller(ctx).Name, "Server Context canceled with", ctx.Err(), "after", time.Since(started)) } return nil },
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0) -
cmd/metacache_gen.go
case "end": z.ended, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "ended") return } case "st": z.started, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "started") return } case "lh": z.lastHandout, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "lastHandout") return } case "u":
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 08 18:26:08 GMT 2021 - 10K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops_gen.go
return } case "Endpoint": z.Endpoint, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "Endpoint") return } case "Started": z.Started, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "Started") return } case "LastUpdate": z.LastUpdate, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "LastUpdate") return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Feb 28 17:05:40 GMT 2024 - 21.5K bytes - Viewed (0) -
update-credits.sh
for any such Derivative Works as a whole, provided Your use, reproduction, and distribution of the Work otherwise complies with the conditions stated in this License. 5. Submission of Contributions. Unless You explicitly state otherwise, any Contribution intentionally submitted for inclusion in the Work by You to the Licensor shall be under the terms and conditions of
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Aug 11 05:08:38 GMT 2023 - 11.4K bytes - Viewed (0) -
cmd/admin-heal-ops.go
"(use force-start option to stop and start afresh). " + fmt.Sprintf("The heal was started by IP %s at %s, token is %s", h.clientAddress, h.startTime.Format(http.TimeFormat), h.clientToken) return nil, errorCodes.ToAPIErr(ErrHealAlreadyRunning), errMsg } } ahs.Lock() defer ahs.Unlock() // Check if new heal sequence to be started overlaps with any // existing, running sequence
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1)