Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 52 for rd (0.41 sec)

  1. cmd/metacache-walk_gen_test.go

    	}
    	en.Flush()
    }
    
    func BenchmarkDecodeWalkDirOptions(b *testing.B) {
    	v := WalkDirOptions{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	rd := msgp.NewEndlessReader(buf.Bytes(), b)
    	dc := msgp.NewReader(rd)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		err := v.DecodeMsg(dc)
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  2. cmd/site-replication-utils_gen_test.go

    	en.Flush()
    }
    
    func BenchmarkDecodeSiteResyncStatus(b *testing.B) {
    	v := SiteResyncStatus{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	rd := msgp.NewEndlessReader(buf.Bytes(), b)
    	dc := msgp.NewReader(rd)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		err := v.DecodeMsg(dc)
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Nov 14 15:16:40 UTC 2022
    - 2.4K bytes
    - Viewed (0)
  3. cmd/storage-rest-client.go

    		return nil, err
    	}
    
    	respReader, err := waitForHTTPResponse(respBody)
    	if err != nil {
    		return nil, toStorageErr(err)
    	}
    
    	rd := msgpNewReader(respReader)
    	defer readMsgpReaderPoolPut(rd)
    
    	readPartsResp := &ReadPartsResp{}
    	if err = readPartsResp.DecodeMsg(rd); err != nil {
    		return nil, toStorageErr(err)
    	}
    
    	return readPartsResp.Infos, nil
    }
    
    // RenameFile - renames a file.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 08 02:38:41 UTC 2025
    - 30.4K bytes
    - Viewed (0)
  4. cmd/batch-handlers.go

    	}
    	if err := gopts.SetMatchETag(srcObjInfo.ETag); err != nil {
    		return err
    	}
    	rd, objInfo, _, err := core.GetObject(ctx, srcBucket, srcObject, gopts)
    	if err != nil {
    		return ErrorRespToObjectError(err, srcBucket, srcObject, srcObjInfo.VersionID)
    	}
    	defer rd.Close()
    
    	hr, err := hash.NewReader(ctx, rd, objInfo.Size, "", "", objInfo.Size)
    	if err != nil {
    		return err
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.5K bytes
    - Viewed (0)
  5. src/cmd/asm/internal/asm/testdata/riscv64validation.s

    	VMNOTM		V3, X10				// ERROR "expected vector register in vd position"
    	VCPOPM		V2, V1				// ERROR "expected integer register in rd position"
    	VCPOPM		X11, X10			// ERROR "expected vector register in vs2 position"
    	VFIRSTM		V2, V1				// ERROR "expected integer register in rd position"
    	VFIRSTM		X11, X10			// ERROR "expected vector register in vs2 position"
    	VMSBFM		X10, V3				// ERROR "expected vector register in vs2 position"
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Wed May 21 14:19:19 UTC 2025
    - 31.6K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/xml/XmlEscapersTest.java

        assertEquals(
            "a&quot;b&lt;c&gt;d&amp;e&quot;f&apos;", xmlAttributeEscaper.escape("a\"b<c>d&e\"f'"));
        // Test '\t', '\n' and '\r' are escaped.
        assertEquals("a&#x9;b&#xA;c&#xD;d", xmlAttributeEscaper.escape("a\tb\nc\rd"));
      }
    
      // Helper to assert common properties of xml escapers.
      static void assertBasicXmlEscaper(
          CharEscaper xmlEscaper, boolean shouldEscapeQuotes, boolean shouldEscapeWhitespaceChars) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  7. cmd/server-main.go

    	}
    }
    
    func mergeServerCtxtFromConfigFile(configFile string, ctxt *serverCtxt) error {
    	rd, err := xioutil.ReadFile(configFile)
    	if err != nil {
    		return err
    	}
    
    	cfReader := bytes.NewReader(rd)
    
    	cv := config.ServerConfigVersion{}
    	if err = yaml.Unmarshal(rd, &cv); err != nil {
    		return err
    	}
    
    	switch cv.Version {
    	case "v1", "v2":
    	default:
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:18:36 UTC 2025
    - 35.9K bytes
    - Viewed (4)
  8. src/main/java/org/codelibs/fess/crawler/FessCrawlerThread.java

            if (childUrlSet != null) {
                // add an url
                try {
                    storeChildUrls(childUrlSet.stream().filter(rd -> StringUtil.isNotBlank(rd.getUrl())).collect(Collectors.toSet()),
                            urlQueue.getUrl(), urlQueue.getDepth() != null ? urlQueue.getDepth() + 1 : 1);
                } catch (final Throwable t) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 19.1K bytes
    - Viewed (0)
  9. cmd/admin-handlers-config-kv.go

    	}
    
    	vars := mux.Vars(r)
    
    	subSys := vars["subSys"]
    	key := vars["key"]
    
    	_, envOnly := r.Form["env"]
    
    	rd, err := GetHelp(subSys, key, envOnly)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	json.NewEncoder(w).Encode(rd)
    }
    
    // SetConfigHandler - PUT /minio/admin/v3/config
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15.7K bytes
    - Viewed (1)
  10. cmd/admin-handlers.go

    	owner := cred.AccessKey == globalActiveCred.AccessKey
    
    	// Set prefix value for "s3:prefix" policy conditionals.
    	r.Header.Set("prefix", "")
    
    	// Set delimiter value for "s3:delimiter" policy conditionals.
    	r.Header.Set("delimiter", SlashSeparator)
    
    	isAllowedAccess := func(bucketName string) (rd, wr bool) {
    		if globalIAMSys.IsAllowed(policy.Args{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
Back to top