Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 159 for allocates (0.64 sec)

  1. docs/smb3-features/05-rdma-smb-direct-design.md

            this.totalAllocated = new AtomicLong();
            this.totalReleased = new AtomicLong();
            
            // Pre-allocate buffer pool
            initializeBufferPool();
        }
        
        private void initializeBufferPool() {
            // Allocate send buffers
            for (int i = 0; i < initialSendBuffers; i++) {
                try {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 35.9K bytes
    - Viewed (0)
  2. guava-testlib/src/com/google/common/testing/FreshValueGenerator.java

        return CharBuffer.allocate(generateInt());
      }
    
      @Generates
      ByteBuffer generateByteBuffer() {
        return ByteBuffer.allocate(generateInt());
      }
    
      @Generates
      ShortBuffer generateShortBuffer() {
        return ShortBuffer.allocate(generateInt());
      }
    
      @Generates
      IntBuffer generateIntBuffer() {
        return IntBuffer.allocate(generateInt());
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 28.7K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/hash/AbstractNonStreamingHashFunction.java

      }
    
      @Override
      public HashCode hashInt(int input) {
        return hashBytes(ByteBuffer.allocate(4).order(ByteOrder.LITTLE_ENDIAN).putInt(input).array());
      }
    
      @Override
      public HashCode hashLong(long input) {
        return hashBytes(ByteBuffer.allocate(8).order(ByteOrder.LITTLE_ENDIAN).putLong(input).array());
      }
    
      @Override
      public HashCode hashUnencodedChars(CharSequence input) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  4. guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

              .put(Buffer.class, ByteBuffer.allocate(0))
              .put(CharBuffer.class, CharBuffer.allocate(0))
              .put(ByteBuffer.class, ByteBuffer.allocate(0))
              .put(ShortBuffer.class, ShortBuffer.allocate(0))
              .put(IntBuffer.class, IntBuffer.allocate(0))
              .put(LongBuffer.class, LongBuffer.allocate(0))
              .put(FloatBuffer.class, FloatBuffer.allocate(0))
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 21.4K bytes
    - Viewed (0)
  5. src/packaging/common/packaging.properties

    # like in rpm/packaging.properties and deb/packaging.properties.
    
    # Environment file
    packaging.env.file=
    
    # Default configuration directory and file to use in bin/plugin script
    
    # Default values for min/max heap memory allocated to fess java process
    packaging.fess.heap.min=256m
    packaging.fess.heap.max=1g
    
    # Specifies the maximum file descriptor number
    packaging.os.max.open.files=65535
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Dec 10 01:24:02 UTC 2015
    - 797 bytes
    - Viewed (0)
  6. guava/src/com/google/common/hash/AbstractByteHasher.java

            update(b.get());
          }
        }
      }
    
      /** Updates the sink with the given number of bytes from the buffer. */
      @SuppressWarnings("ByteBufferBackingArray") // We created the array with ByteBuffer.allocate().
      @CanIgnoreReturnValue
      private Hasher update(ByteBuffer scratch, int bytes) {
        try {
          update(scratch.array(), 0, bytes);
        } finally {
          Java8Compatibility.clear(scratch);
        }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 12:40:17 UTC 2025
    - 3.9K bytes
    - Viewed (0)
  7. src/test/java/jcifs/smb1/smb1/SmbComNegotiateResponseTest.java

            response = new SmbComNegotiateResponse(serverData);
        }
    
        @Test
        void testReadParameterWordsWireFormat() {
            // Prepare a byte array with sample parameter words
            ByteBuffer buffer = ByteBuffer.allocate(34);
            buffer.order(ByteOrder.LITTLE_ENDIAN);
            buffer.putShort((short) 0); // dialectIndex
            buffer.put((byte) 0x0F); // securityMode (user, encrypted, sigs enabled, sigs required)
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  8. cmd/benchmark-utils_test.go

    	// md5sum of the data to written is required as input for PutObject.
    
    	md5hex := getMD5Hash(textData)
    	sha256hex := ""
    
    	// benchmark utility which helps obtain number of allocations and bytes allocated per ops.
    	b.ReportAllocs()
    	// the actual benchmark for PutObject starts here. Reset the benchmark timer.
    
    	for i := 0; b.Loop(); i++ {
    		// insert the object.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  9. src/main/java/jcifs/internal/smb2/rdma/tcp/TcpRdmaConnection.java

            }
    
            try {
                socket.setSoTimeout(timeout);
    
                // First, read the header to determine message size
                ByteBuffer headerBuffer = ByteBuffer.allocate(4);
                while (headerBuffer.hasRemaining()) {
                    int read = socketChannel.read(headerBuffer);
                    if (read < 0) {
                        throw new IOException("Connection closed by peer");
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 8.8K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/collect/ImmutableListCopyOfConcurrentlyModifiedInputTest.java

                  throw new AssertionError(e);
                }
              }
    
              private void mutateDelegate() {
                allStates.add(ImmutableList.copyOf(delegate));
                remainingActions.next().perform(delegate);
                allStates.add(ImmutableList.copyOf(delegate));
              }
            };
    
        @SuppressWarnings("unchecked")
        ConcurrentlyMutatedList<Integer> list =
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 6.6K bytes
    - Viewed (0)
Back to top