- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for errResp (0.05 sec)
-
internal/grid/muxclient.go
err := m.send(msg) if err != nil { m.addErrorNonBlockingClose(errResp, err) } break reqLoop } // Grab a send token. sendReq: select { case <-m.ctx.Done(): m.addErrorNonBlockingClose(errResp, context.Cause(m.ctx)) errState = true continue case <-pingTimer: if !m.doPing(errResp) { errState = true continue } goto sendReq
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.9K bytes - Viewed (0) -
cmd/perf-tests.go
t := time.Now() r, _, _, err := c.GetObject(downloadsCtx, opts.bucketName, tmpObjName, gopts) if err != nil { errResp, ok := err.(minio.ErrorResponse) if ok && errResp.StatusCode == http.StatusNotFound { continue } if !contextCanceled(downloadsCtx) && !errors.Is(err, context.Canceled) { errOnce.Do(func() {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 11.8K bytes - Viewed (0) -
cmd/object-api-options.go
var argumentName string var argumentValue string var apiErr APIError var err error valid = true defer func() { if valid { return } errResp := objectAttributesErrorResponse{ ArgumentName: &argumentName, ArgumentValue: &argumentValue, APIErrorResponse: getAPIErrorResponse( ctx, apiErr, r.URL.Path,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 21 21:13:59 UTC 2024 - 14.4K bytes - Viewed (0) -
cmd/admin-handlers.go
var err error deadline, err = time.ParseDuration(dstr) if err != nil { errResp(err) return } } nsLock := objectAPI.NewNSLock(minioMetaBucket, "health-check-in-progress") lkctx, err := nsLock.GetLock(ctx, newDynamicTimeout(deadline, deadline)) if err != nil { // returns a locked lock errResp(err) return } defer nsLock.Unlock(lkctx)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 11:32:32 UTC 2024 - 99.7K bytes - Viewed (0) -
src/cmd/asm/internal/asm/pseudo_test.go
} for _, o := range strings.Split(s, ",") { res = append(res, lex.Tokenize(o)) } return res } func TestErroneous(t *testing.T) { type errtest struct { pseudo string operands string expected string } nonRuntimeTests := []errtest{ {"TEXT", "", "expect two or three operands for TEXT"}, {"TEXT", "%", "expect two or three operands for TEXT"},
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Tue Aug 29 07:48:38 UTC 2023 - 3.1K bytes - Viewed (0) -
cmd/storage-rest-client.go
errs[i] = toStorageErr(err) } return errs } dErrResp := &DeleteVersionsErrsResp{} decoder := msgpNewReader(reader) defer readMsgpReaderPoolPut(decoder) if err = dErrResp.DecodeMsg(decoder); err != nil { for i := range errs { errs[i] = toStorageErr(err) } return errs } for i, dErr := range dErrResp.Errs { if dErr != "" { errs[i] = toStorageErr(errors.New(dErr))
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Oct 13 13:07:21 UTC 2024 - 30.2K bytes - Viewed (0)