Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 1,156 for _start (0.09 sec)

  1. android/guava-tests/test/com/google/common/io/MultiInputStreamTest.java

      private void joinHelper(Integer... spans) throws Exception {
        List<ByteSource> sources = new ArrayList<>();
        int start = 0;
        for (Integer span : spans) {
          sources.add(newByteSource(start, span));
          start += span;
        }
        ByteSource joined = ByteSource.concat(sources);
        assertTrue(newByteSource(0, start).contentEquals(joined));
      }
    
      public void testReadSingleByte() throws Exception {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  2. cmd/metrics-v3-replication.go

    		"Maximum number of active replication workers seen since server start")
    	replicationMaxQueuedBytesMD = NewGaugeMD(replicationMaxQueuedBytes,
    		"Maximum number of bytes queued for replication since server start")
    	replicationMaxQueuedCountMD = NewGaugeMD(replicationMaxQueuedCount,
    		"Maximum number of objects queued for replication since server start")
    	replicationMaxDataTransferRateMD = NewGaugeMD(replicationMaxDataTransferRate,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/collect/TreeRangeSet.java

          } else if (lowerBoundWindow.lowerBound.isLessThan(restriction.lowerBound)) {
            // starts at the first range with upper bound strictly greater than restriction.lowerBound
            completeRangeItr =
                rangesByUpperBound.tailMap(restriction.lowerBound, false).values().iterator();
          } else {
            // starts at the first range with lower bound above lowerBoundWindow.lowerBound
            completeRangeItr =
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 32.3K bytes
    - Viewed (0)
  4. cmd/sftp-server.go

    		}
    	}
    	if len(filteredAlgos) == 0 {
    		logger.Fatal(fmt.Errorf("no valid algorithms passed to --sftp=%s\nValid algorithms: %v", arg, strings.Join(allowed, ", ")), "unable to start SFTP server")
    	}
    	return filteredAlgos
    }
    
    func startSFTPServer(args []string) {
    	var (
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.5K bytes
    - Viewed (0)
  5. src/main/java/jcifs/smb1/smb1/Trans2QueryFSInformationResponse.java

            info.bytesPerSect = readInt2(buffer, bufferIndex);
            bufferIndex += 4;
    
            this.info = info;
    
            return bufferIndex - start;
        }
    
        int readSmbQueryFSSizeInfoWireFormat(final byte[] buffer, int bufferIndex) {
            final int start = bufferIndex;
    
            final SmbInfoAllocation info = new SmbInfoAllocation();
    
            info.alloc = readInt8(buffer, bufferIndex);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 5.1K bytes
    - Viewed (0)
  6. src/main/java/jcifs/internal/smb2/nego/EncryptionNegotiateContext.java

                }
            }
            return dstIndex - start;
        }
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.Decodable#decode(byte[], int, int)
         */
        @Override
        public int decode(final byte[] buffer, int bufferIndex, final int len) throws SMBProtocolDecodingException {
            final int start = bufferIndex;
            final int nciphers = SMBUtil.readInt2(buffer, bufferIndex);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 3.8K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/primitives/Longs.java

        final long[] array;
        final int start;
        final int end;
    
        LongArrayAsList(long[] array) {
          this(array, 0, array.length);
        }
    
        LongArrayAsList(long[] array, int start, int end) {
          this.array = array;
          this.start = start;
          this.end = end;
        }
    
        @Override
        public int size() {
          return end - start;
        }
    
        @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 29.1K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/rank/fusion/RankFusionProcessor.java

                }
                int start = startPosition - offset;
                if (start < 0) {
                    start = 0;
                }
                if (logger.isDebugEnabled()) {
                    logger.debug("start:{} -> start:{} with offset:{}.", startPosition, start, offset);
                }
                final SearchRequestParams reqParams = new SearchRequestParamsWrapper(params, start, pageSize);
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 24.8K bytes
    - Viewed (0)
  9. guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

        // get called correctly.
        for (int i = 0; i < 20; i++) {
    
          // Right in the middle start up a thread to close the latch.
          if (i == 10) {
            new Thread(() -> latch.countDown()).start();
          }
    
          future.addListener(listenerLatch::countDown, exec);
        }
    
        assertSame(Boolean.TRUE, future.get());
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  10. src/main/java/jcifs/internal/smb2/nego/CompressionNegotiateContext.java

                dstIndex += 2;
            }
    
            return dstIndex - start;
        }
    
        @Override
        public int decode(byte[] buffer, int bufferIndex, int len) throws SMBProtocolDecodingException {
            if (len < 8) {
                throw new SMBProtocolDecodingException("Invalid compression context length: " + len);
            }
    
            int start = bufferIndex;
    
            // Read compression count
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 7.5K bytes
    - Viewed (0)
Back to top