Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for errResp (0.08 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. api/go1.txt

    pkg flag, type FlagSet struct, Usage func()
    pkg flag, type Value interface { Set, String }
    pkg flag, type Value interface, Set(string) error
    pkg flag, type Value interface, String() string
    pkg flag, var ErrHelp error
    pkg flag, var Usage func()
    pkg fmt, func Errorf(string, ...interface{}) error
    pkg fmt, func Fprint(io.Writer, ...interface{}) (int, error)
    pkg fmt, func Fprintf(io.Writer, string, ...interface{}) (int, error)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Aug 14 18:58:28 UTC 2013
    - 1.7M bytes
    - Viewed (0)
Back to top