- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 80 for qsub (0.29 sec)
-
cmd/namespace-lock.go
if err := newCtx.Err(); err == context.Canceled { return LockContext{ctx: ctx, cancel: func() {}}, err } return LockContext{ctx: ctx, cancel: func() {}}, OperationTimedOut{} } timeout.LogSuccess(UTCNow().Sub(start)) return LockContext{ctx: newCtx, cancel: cancel}, nil } // Unlock - block until write lock is released. func (di *distLockInstance) Unlock(lc LockContext) { if lc.cancel != nil { lc.cancel() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jun 05 23:56:35 GMT 2023 - 9.2K bytes - Viewed (0) -
internal/config/help.go
Sensitive bool `json:"-"` // Indicates if the value is a secret such as a password that shouldn't be // exposed by the server Secret bool `json:"-"` // Indicates if sub-sys supports multiple targets. MultipleTargets bool `json:"multipleTargets"` } // HelpKVS - implement order of keys help messages. type HelpKVS []HelpKV // Lookup - lookup a key from help kvs.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Jun 23 14:45:27 GMT 2023 - 2.8K bytes - Viewed (0) -
cmd/http-tracer.go
if funcName == "" { funcName = "<unknown>" } t := madmin.TraceInfo{ TraceType: tt, FuncName: funcName, NodeName: nodeName, Time: reqStartTime, Duration: reqEndTime.Sub(respRecorder.StartTime), Path: reqPath, HTTP: &madmin.TraceHTTPStats{ ReqInfo: madmin.TraceRequestInfo{ Time: reqStartTime, Proto: r.Proto, Method: r.Method,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 5.9K bytes - Viewed (0) -
cmd/typed-errors.go
// error returned in IAM service account var errIAMServiceAccountNotAllowed = errors.New("Specified service account action is not allowed") // error returned in IAM subsystem when IAM sub-system is still being initialized. var errIAMNotInitialized = errors.New("IAM sub-system is being initialized, please try again") // error returned when upload id not found var errUploadIDNotFound = errors.New("Specified Upload ID is not found")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.3K bytes - Viewed (0) -
src/archive/tar/format.go
// ChangeTime | n/a | unlimited | int89 // Devmajor/Devminor | uint21 | uint21 | uint57 // ------------------+--------+-----------+---------- // string encoding | ASCII | UTF-8 | binary // sub-second times | no | yes | no // sparse files | no | yes | yes // // The table's upper portion shows the [Header] fields, where each format reports
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 11.3K bytes - Viewed (0) -
internal/bucket/bandwidth/measurement.go
m.lock.Lock() defer func() { m.startTime = endTime m.lock.Unlock() }() if m.startTime.IsZero() { return } if endTime.Before(m.startTime) { return } duration := endTime.Sub(m.startTime) bytesSinceLastWindow := atomic.SwapUint64(&m.bytesSinceLastWindow, 0) if m.expMovingAvg == 0 { // Should address initial calculation and should be fine for resuming from 0
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Jun 03 20:41:51 GMT 2023 - 2.9K bytes - Viewed (0) -
src/archive/zip/reader.go
parseExtras: for extra := readBuf(f.Extra); len(extra) >= 4; { // need at least tag and size fieldTag := extra.uint16() fieldSize := int(extra.uint16()) if len(extra) < fieldSize { break } fieldBuf := extra.sub(fieldSize) switch fieldTag { case zip64ExtraID: f.zip64 = true // update directory values from the zip64 extra block. // They should only be consulted if the sizes read earlier
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 27.7K bytes - Viewed (0) -
internal/s3select/sql/timestampfuncs.go
func dateDiff(timePart string, ts1, ts2 time.Time) (*Value, error) { if ts2.Before(ts1) { v, err := dateDiff(timePart, ts2, ts1) if err == nil { v.negate() } return v, err } duration := ts2.Sub(ts1) y1, m1, d1 := ts1.Date() y2, m2, d2 := ts2.Date() switch timePart { case timePartYear: dy := int64(y2 - y1) if m2 > m1 || (m2 == m1 && d2 >= d1) { return FromInt(dy), nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 4.8K bytes - Viewed (0) -
cmd/consolelogger.go
console *console.Target nodeName string logBuf *ring.Ring } // NewConsoleLogger - creates new HTTPConsoleLoggerSys with all nodes subscribed to // the console logging pub sub system func NewConsoleLogger(ctx context.Context, w io.Writer) *HTTPConsoleLoggerSys { return &HTTPConsoleLoggerSys{ pubsub: pubsub.New[log.Info, madmin.LogMask](8), console: console.New(w),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.5K bytes - Viewed (0) -
internal/config/api/api.go
package api import ( "encoding/json" "errors" "fmt" "math" "strconv" "strings" "time" "github.com/minio/minio/internal/config" "github.com/minio/pkg/v2/env" ) // API sub-system constants const ( apiRequestsMax = "requests_max" apiRequestsDeadline = "requests_deadline" apiClusterDeadline = "cluster_deadline" apiCorsAllowOrigin = "cors_allow_origin"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 01:08:07 GMT 2024 - 11.1K bytes - Viewed (1)