Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for Rec (0.16 sec)

  1. cmd/admin-handlers_test.go

    	if err != nil {
    		t.Fatalf("Failed to build service status request %v", err)
    	}
    
    	rec := httptest.NewRecorder()
    	adminTestBed.router.ServeHTTP(rec, req)
    
    	resp, _ := io.ReadAll(rec.Body)
    	if rec.Code != http.StatusOK {
    		t.Errorf("Expected to receive %d status code but received %d. Body (%s)",
    			http.StatusOK, rec.Code, string(resp))
    	}
    
    	result := &serviceResult{}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 13.8K bytes
    - Viewed (0)
  2. cmd/generic-handlers.go

    		defer func() {
    			if rec := recover(); rec == logger.ErrCritical { // handle
    				stack := debug.Stack()
    				logger.Error("critical: \"%s %s\": %v\n%s", r.Method, r.URL, rec, string(stack))
    				writeErrorResponse(r.Context(), w, errorCodes.ToAPIErr(ErrInternalError), r.URL)
    				return
    			} else if rec != nil {
    				stack := debug.Stack()
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 11 01:08:52 GMT 2024
    - 20.7K bytes
    - Viewed (0)
  3. cmd/bucket-handlers_test.go

    		// Call the ServeHTTP to execute the handler.
    		apiRouter.ServeHTTP(rec, req)
    		if rec.Code != testCase.expectedRespStatus {
    			t.Errorf("Test %d: %s: Expected the response status to be `%d`, but instead found `%d`", i+1, instanceType, testCase.expectedRespStatus, rec.Code)
    		}
    		if !bytes.Equal(testCase.locationResponse, rec.Body.Bytes()) && testCase.shouldPass {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 39.5K bytes
    - Viewed (2)
  4. cmd/metacache.go

    	id           string     `msg:"id"`
    	error        string     `msg:"err"`
    	root         string     `msg:"root"`
    	fileNotFound bool       `msg:"fnf"`
    	status       scanStatus `msg:"stat"`
    	recursive    bool       `msg:"rec"`
    	dataVersion  uint8      `msg:"v"`
    }
    
    func (m *metacache) finished() bool {
    	return !m.ended.IsZero()
    }
    
    // worthKeeping indicates if the cache by itself is worth keeping.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 5K bytes
    - Viewed (0)
  5. cmd/bucket-lifecycle-handlers_test.go

    		// Call the ServeHTTP to execute the handler.
    		apiRouter.ServeHTTP(rec, req)
    		if rec.Code != testCase.expectedRespStatus {
    			t.Errorf("Test %d: %s: Expected the response status to be `%d`, but instead found `%d`", i+1, instanceType, testCase.expectedRespStatus, rec.Code)
    		}
    		if testCase.shouldPass && !bytes.Equal(testCase.lifecycleResponse, rec.Body.Bytes()) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Jun 13 20:52:33 GMT 2023
    - 11.2K bytes
    - Viewed (0)
  6. cmd/test-utils_test.go

    	}
    	if len(partSizes) > 1 {
    		asMultipart = true
    	}
    
    	checkRespErr := func(rec *httptest.ResponseRecorder, exp int) {
    		t.Helper()
    		if rec.Code != exp {
    			b, err := io.ReadAll(rec.Body)
    			t.Fatalf("Expected: %v, Got: %v, Body: %s, err: %v", exp, rec.Code, string(b), err)
    		}
    	}
    
    	if !asMultipart {
    		srcData := NewDummyDataGen(partSizes[0], 0)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:06:57 GMT 2024
    - 75.7K bytes
    - Viewed (0)
  7. internal/s3select/sql/jsonpath_test.go

    			recs, err := getJSONStructs(b)
    			if err != nil || len(recs) != 3 {
    				t.Fatalf("%v or length was not 3", err)
    			}
    
    			for j, rec := range recs {
    				// fmt.Println(rec)
    				r, _, err := jsonpathEval(jp.PathExpr, rec)
    				if err != nil {
    					t.Errorf("Error: %d %d %v", i, j, err)
    				}
    				if !reflect.DeepEqual(r, tc.res[j]) {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 2.8K bytes
    - Viewed (0)
  8. internal/s3select/simdj/reader_amd64_test.go

    					dst <- *o
    				default:
    					t.Fatal("unexpected type:", typ.String())
    				}
    			}
    			refDec := json.NewReader(io.NopCloser(bytes.NewBuffer(ref)), &json.ReaderArgs{ContentType: "json"})
    
    			for {
    				rec, err := dec.Read(nil)
    				if err == io.EOF {
    					break
    				}
    				if err != nil {
    					t.Error(err)
    				}
    				want, err := refDec.Read(nil)
    				if err != nil {
    					t.Error(err)
    				}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 3.9K bytes
    - Viewed (0)
  9. cmd/object-handlers_test.go

    		}
    
    		apiRouter.ServeHTTP(rec, req)
    
    		// Check response code (we make only valid requests in
    		// this test)
    		if rec.Code != http.StatusPartialContent && rec.Code != http.StatusOK {
    			bd, err1 := io.ReadAll(rec.Body)
    			t.Fatalf("%s Object: %s Case %d ByteRange: %s: Got response status `%d` and body: %s,%v",
    				instanceType, object, i+1, byteRange, rec.Code, string(bd), err1)
    		}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 160K bytes
    - Viewed (0)
  10. cmd/metacache_gen.go

    		case "stat":
    			{
    				var zb0002 uint8
    				zb0002, err = dc.ReadUint8()
    				if err != nil {
    					err = msgp.WrapError(err, "status")
    					return
    				}
    				z.status = scanStatus(zb0002)
    			}
    		case "rec":
    			z.recursive, err = dc.ReadBool()
    			if err != nil {
    				err = msgp.WrapError(err, "recursive")
    				return
    			}
    		case "v":
    			z.dataVersion, err = dc.ReadUint8()
    			if err != nil {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Nov 08 18:26:08 GMT 2021
    - 10K bytes
    - Viewed (0)
Back to top