- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,191 for differ (0.04 sec)
-
guava/src/com/google/common/io/ByteStreams.java
* then sequentially accessing it could result in other processes dying. This is solvable * via madvise(2), but that obviously doesn't exist in java. * <li>Ordinary copy. Kernel copies bytes into a kernel buffer, from a kernel buffer into a * userspace buffer (byte[] or ByteBuffer), then copies them from that buffer into the * destination channel. * </ol>
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Jul 17 15:26:41 UTC 2025 - 31.1K bytes - Viewed (0) -
src/bytes/reader_test.go
// See golang.org/issue/7856 r := NewReader([]byte{}) var wg sync.WaitGroup for i := 0; i < 5; i++ { wg.Add(2) go func() { defer wg.Done() var buf [1]byte r.Read(buf[:]) }() go func() { defer wg.Done() r.Read(nil) }() } wg.Wait() } func TestReaderWriteTo(t *testing.T) { for i := 0; i < 30; i += 3 { var l int if i > 0 {
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Mon Dec 13 18:45:54 UTC 2021 - 8K bytes - Viewed (0) -
cmd/admin-handlers.go
return } defer nsLock.Unlock(lkctx) healthCtx, healthCancel := context.WithTimeout(lkctx.Context(), deadline) defer healthCancel() go fetchHealthInfo(healthCtx, objectAPI, &query, healthInfoCh, healthInfo) setCommonHeaders(w) setEventStreamHeaders(w) w.WriteHeader(http.StatusOK) ticker := time.NewTicker(5 * time.Second) defer ticker.Stop() for { select {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 99.6K bytes - Viewed (0) -
tests/lru_test.go
} if !reflect.DeepEqual(lc.Keys(), []string{"key1"}) { t.Fatalf("value differs from expected") } if lc.Resize(0) != 0 { t.Fatalf("evicted count differs from expected") } if lc.Resize(2) != 0 { t.Fatalf("evicted count differs from expected") } lc.Add("key2", "val2") if lc.Resize(1) != 1 { t.Fatalf("evicted count differs from expected") } } func TestLRUEdgeCases(t *testing.T) {
Registered: Sun Sep 07 09:35:13 UTC 2025 - Last Modified: Sun May 25 07:40:40 UTC 2025 - 10.4K bytes - Viewed (0) -
cmd/bitrot-streaming.go
if len(p) == 0 { return 0, nil } if b.finished { return 0, errors.New("bitrot write not allowed") } if int64(len(p)) > b.shardSize { return 0, errors.New("unexpected bitrot buffer size") } if int64(len(p)) < b.shardSize { b.finished = true } b.h.Reset() b.h.Write(p) hashBytes := b.h.Sum(nil) _, err := b.iow.Write(hashBytes) if err != nil { b.closeWithErr(err)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Jan 17 19:19:30 UTC 2025 - 6.2K bytes - Viewed (0) -
cmd/test-utils_test.go
secretKey, signature string, currTime time.Time) (*http.Request, error, ) { regionStr := globalSite.Region() var stream []byte var buffer []byte body.Seek(0, 0) for { buffer = make([]byte, chunkSize) n, err := body.Read(buffer) if err != nil && err != io.EOF { return nil, err } // Get scope. scope := strings.Join([]string{ currTime.Format(yyyymmdd),
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 77K bytes - Viewed (0) -
docs/distributed/decom-encrypted-sse-s3.sh
expanded_policy_count=$(./mc admin policy list myminio/ | wc -l) if [ $user_count -ne $expanded_user_count ]; then echo "BUG: original user count differs from expanded setup" exit 1 fi if [ $policy_count -ne $expanded_policy_count ]; then echo "BUG: original policy count differs from expanded setup" exit 1 fi ./mc version info myminio/versioned | grep -q "versioning is enabled" ret=$? if [ $ret -ne 0 ]; then
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon May 27 19:17:46 UTC 2024 - 4.5K bytes - Viewed (0) -
cmd/streaming-signature-v4.go
} if b != '\n' { cr.err = errMalformedEncoding return n, cr.err } if cap(cr.buffer) < size { cr.buffer = make([]byte, size) } else { cr.buffer = cr.buffer[:size] } // Now, we read the payload and compute its SHA-256 hash. _, err = io.ReadFull(cr.reader, cr.buffer) if err == io.EOF && size != 0 { err = io.ErrUnexpectedEOF } if err != nil && err != io.EOF {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 18.2K bytes - Viewed (0) -
okhttp-tls/src/test/java/okhttp3/tls/internal/der/DerCertificatesTest.kt
) return CertificateAdapters.subjectPublicKeyInfo.toDer(subjectPublicKeyInfo) } /** Returns a byte string that differs from this one by one bit. */ private fun ByteString.offByOneBit(): ByteString = Buffer() .write(this, 0, size - 1) .writeByte(this[size - 1].toInt() xor 1) .readByteString() private fun date(s: String): Date =
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 43.9K bytes - Viewed (0) -
cmd/metacache-stream_test.go
t.Errorf("entry %d, want %q, got %q", i, want, gotObj.name) } } } func Test_newMetacacheStream(t *testing.T) { r := loadMetacacheSample(t) var buf bytes.Buffer w := newMetacacheWriter(&buf, 1<<20) defer w.Close() err := r.readFn(func(object metaCacheEntry) bool { err := w.write(object) if err != nil { t.Fatal(err) } return true }) r.Close() if err != io.EOF {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Apr 09 14:28:39 UTC 2025 - 15K bytes - Viewed (0)