- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for max_bytes (0.12 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) -
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) -
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) -
src/go/internal/gcimporter/iimport.go
case types.Int32, types.Uint32: maxBytes = 4 default: maxBytes = 8 } return } func (r *importReader) mpint(x *big.Int, typ *types.Basic) { signed, maxBytes := intSize(typ) maxSmall := 256 - maxBytes if signed { maxSmall = 256 - 2*maxBytes } if maxBytes == 1 { maxSmall = 256 } n, _ := r.declReader.ReadByte() if uint(n) < maxSmall { v := int64(n)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 19.2K 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/crypto/tls/ticket.go
authenticated := encrypted[:len(encrypted)-sha256.Size] macBytes := encrypted[len(encrypted)-sha256.Size:] for _, key := range ticketKeys { mac := hmac.New(sha256.New, key.hmacKey[:]) mac.Write(authenticated) expected := mac.Sum(nil) if subtle.ConstantTimeCompare(macBytes, expected) != 1 { continue } block, err := aes.NewCipher(key.aesKey[:])
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 17:23:54 UTC 2024 - 12.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) -
cmd/metrics-resource.go
percUtil MetricName = "perc_util" usedInodes MetricName = "used_inodes" // network stats interfaceRxBytes MetricName = "rx_bytes" interfaceRxErrors MetricName = "rx_errors" interfaceTxBytes MetricName = "tx_bytes" interfaceTxErrors MetricName = "tx_errors" // cpu stats cpuUser MetricName = "user" cpuSystem MetricName = "system" cpuIOWait MetricName = "iowait"
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 17 15:15:13 UTC 2024 - 17.2K bytes - Viewed (0) -
src/runtime/tracestack.go
// it contains N frames. maxBytes := 1 + (2+4*len(frames))*traceBytesPerNumber // 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 traceEvStacks. var flushed bool w, flushed = w.ensure(1 + maxBytes) if flushed { w.byte(byte(traceEvStacks)) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 21 14:38:56 UTC 2024 - 11K bytes - Viewed (0)