Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 23 for max_bytes (0.14 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache.cc

      return new_entry;
    }
    
    // Remove blocks from the cache until we do not exceed our maximum size.
    void RamFileBlockCache::Trim() {
      while (!lru_list_.empty() && cache_size_ > max_bytes_) {
        RemoveBlock(block_map_.find(lru_list_.back()));
      }
    }
    
    /// Move the block to the front of the LRU list if it isn't already there.
    void RamFileBlockCache::UpdateLRU(const Key& key,
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Jul 16 01:39:09 UTC 2020
    - 11.1K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top