- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for readLine (0.21 sec)
-
cmd/xl-storage-format-v2_gen.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:43:43 GMT 2024 - 53.8K bytes - Viewed (0) -
cmd/erasure-object.go
if !opts.NoAuditLog { auditObjectErasureSet(ctx, object, &er) } if !opts.NoLock { // Lock the object before reading. lk := er.NewNSLock(bucket, object) lkctx, err := lk.GetRLock(ctx, globalOperationTimeout) if err != nil { return ObjectInfo{}, err } ctx = lkctx.Context() defer lk.RUnlock(lkctx) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
cmd/erasure-server-pool.go
return &GetObjectReader{ ObjInfo: objInfo, }, toObjectErr(errMethodNotAllowed, bucket, object) } return nil, err } // check preconditions before reading the stream. if checkPrecondFn != nil && checkPrecondFn(objInfo) { return nil, PreConditionFailed{} } opts.NoLock = true gr, err = z.serverPools[zIdx].GetObjectNInfo(ctx, bucket, object, rs, h, opts)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
cmd/api-errors.go
Description: "Client disconnected before response was ready", HTTPStatusCode: 499, // No official code, use nginx value. }, ErrTooManyRequests: { Code: "TooManyRequests", Description: "Deadline exceeded while waiting in incoming queue, please reduce your request rate", HTTPStatusCode: http.StatusServiceUnavailable, }, ErrUnsupportedMetadata: { Code: "InvalidArgument",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 91.4K bytes - Viewed (7) -
cmd/iam.go
} select { case <-sys.configLoaded: default: xioutil.SafeClose(sys.configLoaded) } return nil } // Init - initializes config system by reading entries from config/iam func (sys *IAMSys) Init(ctx context.Context, objAPI ObjectLayer, etcdClient *etcd.Client, iamRefreshInterval time.Duration) { bootstrapTraceMsg("IAM initialization started") globalServerConfigMu.RLock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 71.1K bytes - Viewed (1) -
cmd/xl-storage.go
// for io.EOF. // // If an EOF happens after reading some but not all the bytes, // ReadFile returns ErrUnexpectedEOF. // // If the BitrotVerifier is not nil or not verified ReadFile // tries to verify whether the disk has bitrot. // // Additionally ReadFile also starts reading from an offset. ReadFile // semantics are same as io.ReadFull.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0) -
cmd/bucket-stats_gen.go
err = za0002.DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "Stats", za0001) return } z.Stats[za0001] = za0002 } case "Timestamp": z.Timestamp, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "Timestamp") return } default: err = dc.Skip() if err != nil { err = msgp.WrapError(err) return } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 57.5K bytes - Viewed (0) -
cmd/iam-store.go
return nil } // IAMStorageAPI defines an interface for the IAM persistence layer type IAMStorageAPI interface { // The role of the read-write lock is to prevent go routines from // concurrently reading and writing the IAM storage. The (r)lock() // functions return the iamCache. The cache can be safely written to // only when returned by `lock()`. lock() *iamCache unlock() rlock() *iamCache runlock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2) -
cmd/test-utils_test.go
} // httptest Recorder to capture all the response by the http handler. rec := httptest.NewRecorder() // reading the body to preserve it so that it can be used again for second attempt of sending unsigned HTTP request. // If the body is read in the handler the same request cannot be made use of. buf, err := io.ReadAll(anonReq.Body)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0) -
go.sum
github.com/chromedp/sysutil v1.0.0/go.mod h1:kgWmDdq8fTzXYcKIBqIYvRRTnYb9aNS9moAV0xufSww= github.com/chzyer/logex v1.2.1/go.mod h1:JLbx6lG2kDbNRFnfkgvh4eRJRPX1QCoOIWomwysCBrQ= github.com/chzyer/readline v1.5.1/go.mod h1:Eh+b79XXUwfKfcPLepksvw2tcLE/Ct21YObkaSkeBlk= github.com/chzyer/test v1.0.0/go.mod h1:2JlltgoNkt4TW/z9V/IzDdFaMTM2JPIi26O1pF38GC8=
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 12:41:13 GMT 2024 - 84.2K bytes - Viewed (0)