- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for max_bytes (0.13 sec)
-
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/locklistener/FileLockPacketPayload.java
import java.io.EOFException; import java.io.IOException; import static org.gradle.cache.internal.locklistener.FileLockPacketType.UNKNOWN; public class FileLockPacketPayload { public static final int MAX_BYTES = 1 + 8 + 1; // protocolVersion + lockId + type private static final byte PROTOCOL_VERSION = 1; private static final ImmutableList<FileLockPacketType> TYPES = ImmutableList.copyOf(FileLockPacketType.values());
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:08:47 UTC 2023 - 3.3K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/gcs_filesystem.h
uint64_t block_size, size_t max_bytes, uint64_t max_staleness, uint64_t stat_cache_max_age, size_t stat_cache_max_entries); } GCSFile; // This function is used to initialize a filesystem without the need of setting // manually environement variables. void InitTest(TF_Filesystem* filesystem, bool compose, uint64_t block_size, size_t max_bytes, uint64_t max_staleness,
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon Aug 31 04:37:41 UTC 2020 - 5.2K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/locklistener/FileLockPacketPayloadTest.groovy
def "encodes lock id and type"() { when: def bytes = FileLockPacketPayload.encode(42, LOCK_RELEASE_CONFIRMATION) then: bytes.length == FileLockPacketPayload.MAX_BYTES bytes == [1, 0, 0, 0, 0, 0, 0, 0, 42, 3] as byte[] } def "decodes payloads without type"() { when: def payload = FileLockPacketPayload.decode([1, 0, 0, 0, 0, 0, 0, 0, 42, 1] as byte[], 9)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:08:47 UTC 2023 - 2K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/locklistener/FileLockCommunicator.java
} return pingSentSuccessfully; } public DatagramPacket receive() throws GracefullyStoppedException { try { byte[] bytes = new byte[FileLockPacketPayload.MAX_BYTES]; DatagramPacket packet = new DatagramPacket(bytes, bytes.length); socket.receive(packet); return packet; } catch (IOException e) { if (!stopped) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:49 UTC 2024 - 5.9K bytes - Viewed (0) -
cmd/prune-junit-xml/prunexml.go
testcase.SkipMessage.Message = head + "[...clipped...]" + tail } } if testcase.Failure != nil { if len(testcase.Failure.Contents) > maxBytes { fmt.Printf("clipping failure message in test case : %s\n", testcase.Name) head := testcase.Failure.Contents[:maxBytes/2] tail := testcase.Failure.Contents[len(testcase.Failure.Contents)-maxBytes/2:] testcase.Failure.Contents = head + "[...clipped...]" + tail
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 06 12:26:00 UTC 2023 - 4.4K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/serializer/streaming/streaming.go
if n == 0 { return nil, nil, fmt.Errorf("got short buffer with n=0, base=%d, cap=%d", base, cap(d.buf)) } if d.resetRead { continue } // double the buffer size up to maxBytes if len(d.buf) < d.maxBytes { base += n d.buf = append(d.buf, make([]byte, len(d.buf))...) continue } // must read the rest of the frame (until we stop getting ErrShortBuffer) d.resetRead = true
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 25 14:51:36 UTC 2023 - 3.7K bytes - Viewed (0) -
src/runtime/tracetype.go
// The maximum number of bytes required to hold the encoded type. maxBytes := 1 + 5*traceBytesPerNumber + len(typName) // Estimate the size of this record. This // bound is pretty loose, but avoids counting // lots of varint sizes. // // Add 1 because we might also write a traceAllocFreeTypesBatch byte. var flushed bool w, flushed = w.ensure(1 + maxBytes) if flushed { // Annotate the batch as containing types.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 20:31:27 UTC 2024 - 2.3K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/allocator_test.go
*/ package runtime import ( "math/rand" "testing" ) func TestAllocatorRandomInputs(t *testing.T) { maxBytes := 5 * 1000000 // 5 MB iterations := rand.Intn(10000) + 10 target := &Allocator{} for i := 0; i < iterations; i++ { bytesToAllocate := rand.Intn(maxBytes) buff := target.Allocate(uint64(bytesToAllocate)) if cap(buff) < bytesToAllocate {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 23 13:38:29 UTC 2022 - 2.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/util/MemoryUtil.java
final long freeBytes = runtime.freeMemory(); final long maxBytes = runtime.maxMemory(); final long totalBytes = runtime.totalMemory(); final long usedBytes = totalBytes - freeBytes; return "Mem:{used " + byteCountToDisplaySize(usedBytes) + ", heap " + byteCountToDisplaySize(totalBytes) + ", max " + byteCountToDisplaySize(maxBytes) + "}"; }
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 4.6K bytes - Viewed (0) -
src/internal/fuzz/mutator.go
case x < 99: return m.rand(min(32, n)) + 1 default: return m.rand(n) + 1 } } // mutate performs several mutations on the provided values. func (m *mutator) mutate(vals []any, maxBytes int) { // TODO(katiehockman): pull some of these functions into helper methods and // test that each case is working as expected. // TODO(katiehockman): perform more types of mutations for []byte.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 20:01:34 UTC 2023 - 6.6K bytes - Viewed (0)