Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 152 for relocate (0.06 sec)

  1. guava/src/com/google/common/math/PairedStats.java

       *
       * <p><b>Note:</b> No guarantees are made regarding stability of the representation between
       * versions.
       */
      public byte[] toByteArray() {
        ByteBuffer buffer = ByteBuffer.allocate(BYTES).order(ByteOrder.LITTLE_ENDIAN);
        xStats.writeTo(buffer);
        yStats.writeTo(buffer);
        buffer.putDouble(sumOfProductsOfDeltas);
        return buffer.array();
      }
    
      /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue Jul 08 18:32:10 UTC 2025
    - 12.6K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/io/IoTestCase.java

        if (testDir != null) {
          return testDir;
        }
    
        URL testFileUrl = IoTestCase.class.getResource("testdata/i18n.txt");
        if (testFileUrl == null) {
          throw new RuntimeException("unable to locate testdata directory");
        }
    
        if (testFileUrl.getProtocol().equals("file")) {
          try {
            File testFile = new File(testFileUrl.toURI());
            testDir = testFile.getParentFile(); // the testdata directory
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  3. cmd/erasure-multipart.go

    	}
    
    	// Fetch buffer for I/O, returns from the pool if not allocates a new one and returns.
    	var buffer []byte
    	switch size := data.Size(); {
    	case size == 0:
    		buffer = make([]byte, 1) // Allocate at least a byte to reach EOF
    	case size >= fi.Erasure.BlockSize || size == -1:
    		if int64(globalBytePoolCap.Load().Width()) < fi.Erasure.BlockSize {
    			buffer = make([]byte, fi.Erasure.BlockSize, 2*fi.Erasure.BlockSize)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  4. src/main/java/jcifs/util/ServerResponseValidator.java

                throw new SmbException("Invalid command code: " + command);
            }
        }
    
        /**
         * Validate array size before allocation
         *
         * @param size array size to allocate
         * @param elementSize size of each element
         * @param maxElements maximum allowed elements
         * @throws SmbException if allocation would be too large
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 16.6K bytes
    - Viewed (0)
  5. src/test/java/jcifs/smb1/smb1/SmbComTransactionResponseTest.java

         * copied in a single call.
         */
        @Test
        public void readBytesWireFormat_succeedsWithSingleRead() {
            DummyResponse d = new DummyResponse();
            // Allocate a transaction buffer large enough for the copy
            byte[] tx = new byte[100];
            d.txn_buf = tx;
    
            // Set up a scenario where the full transaction is read in one call
            d.bufParameterStart = 0;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 12K bytes
    - Viewed (0)
  6. docs/site-replication/run-ssec-object-replication-with-compression.sh

    #	echo "BUG: Loading an SSE-C object to site with compression should fail. Succeeded though."
    #	exit_1
    #fi
    
    # Add replication site
    ./mc admin replicate add minio1 minio2 --insecure
    # sleep for replication to complete
    sleep 30
    
    # List the objects from source site
    echo "Objects from source instance"
    ./mc ls minio1/test-bucket --insecure
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Sep 24 08:03:58 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/io/SourceSinkFactories.java

          File file = getFile();
          Reader reader = new InputStreamReader(new FileInputStream(file), UTF_8);
          StringBuilder builder = new StringBuilder();
          CharBuffer buffer = CharBuffer.allocate(100);
          while (reader.read(buffer) != -1) {
            Java8Compatibility.flip(buffer);
            builder.append(buffer);
            Java8Compatibility.clear(buffer);
          }
          return builder.toString();
        }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 17.9K bytes
    - Viewed (0)
  8. docs/smb3-features/03-multi-channel-design.md

                baos.write(channel.getLocalInterface().getAddress().getAddress());
                baos.write(channel.getRemoteInterface().getAddress().getAddress());
                baos.write(ByteBuffer.allocate(8).putLong(System.currentTimeMillis()).array());
            } catch (IOException e) {
                // Should not happen with ByteArrayOutputStream
            }
            
            return baos.toByteArray();
        }
        
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 39.6K bytes
    - Viewed (0)
  9. guava/src/com/google/common/io/ByteStreams.java

          throws IOException {
        // Roughly size to match what has been read already. Some file systems, such as procfs, return 0
        // as their length. These files are very small, so it's wasteful to allocate an 8KB buffer.
        int initialBufferSize = min(BUFFER_SIZE, max(128, Integer.highestOneBit(totalLen) * 2));
        // Starting with an 8k buffer, double the size of each successive buffer. Smaller buffers
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 31.1K bytes
    - Viewed (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/ConnectionPoolTest.kt

        allocateAndLeakAllocation(poolApi, c1)
        awaitGarbageCollection()
        assertThat(pool.closeConnections(100L)).isEqualTo(0L)
        assertThat(c1.calls).isEmpty()
    
        // Can't allocate once a leak has been detected.
        assertThat(c1.noNewExchanges).isTrue()
      }
    
      @Test fun interruptStopsThread() {
        val taskRunnerThreads = mutableListOf<Thread>()
        val taskRunner =
          TaskRunner(
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 12.9K bytes
    - Viewed (0)
Back to top