Search Options

Results per page
Sort
Preferred Languages
Advance

Results 811 - 820 of 1,024 for Start (0.05 sec)

  1. fess-crawler/src/test/java/org/codelibs/fess/crawler/client/ftp/FtpClientTest.java

                String path = file.getAbsolutePath();
                ftpUser.setHomeDirectory(path);
    
                userManager.save(ftpUser);
            }
    
            FtpServer server = factory.createServer();
            server.start();
            return server;
        }
    
        public void test_doGet_root_dir() throws FtpException {
            FtpServer server = null;
            try {
                String username = "testuser";
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  2. cmd/data-scanner.go

    	scannerExcessObjectVersionsTotalSize = uatomic.NewInt64(1024 * 1024 * 1024 * 1024) // 1 TB
    	scannerExcessFolders                 = uatomic.NewInt64(50000)
    )
    
    // initDataScanner will start the scanner in the background.
    func initDataScanner(ctx context.Context, objAPI ObjectLayer) {
    	go func() {
    		r := rand.New(rand.NewSource(time.Now().UnixNano()))
    		// Run the data scanner in a loop
    		for {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  3. cmd/erasure-multipart.go

    			return result, nil
    		}
    		return result, toObjectErr(err, bucket, object, uploadID)
    	}
    
    	if len(partNums) == 0 {
    		return result, nil
    	}
    
    	start := objectPartIndexNums(partNums, partNumberMarker)
    	if start != -1 {
    		partNums = partNums[start+1:]
    	}
    
    	result.Parts = make([]PartInfo, 0, len(partNums))
    	partMetaPaths := make([]string, len(partNums))
    	for i, part := range partNums {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  4. cmd/encryption-v1.go

    	//    single part object) and total decrypted object size `decObjSize`
    	//
    	// 2. the (decrypted) start offset `off` and (decrypted)
    	//    length to read `length`
    	//
    	// These are the inputs to the rest of the algorithm below.
    
    	// Locate the part containing the start of the required range
    	var partEnd int
    	var cumulativeSum, encCumulativeSum int64
    	for i, size := range sizes {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:06:08 UTC 2024
    - 37.2K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/primitives/UnsignedLongs.java

       * separator}. For example, {@code join("-", 1, 2, 3)} returns the string {@code "1-2-3"}.
       *
       * @param separator the text that should appear between consecutive values in the resulting string
       *     (but not at the start or end)
       * @param array an array of unsigned {@code long} values, possibly empty
       */
      public static String join(String separator, long... array) {
        checkNotNull(separator);
        if (array.length == 0) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Aug 12 21:04:48 UTC 2024
    - 17.6K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/collect/TreeRangeMap.java

                    return endOfData();
                  } else if (entry.getUpperBound().compareTo(subRange.lowerBound) > 0) {
                    // this might not be true e.g. at the start of the iteration
                    return immutableEntry(entry.getKey().intersection(subRange), entry.getValue());
                  }
                }
                return endOfData();
              }
            };
          }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 22.9K bytes
    - Viewed (0)
  7. cmd/metacache-walk.go

    	}
    
    	if !skipAccessChecks(opts.Bucket) {
    		// Stat a volume entry.
    		if err = Access(volumeDir); err != nil {
    			return convertAccessError(err, errVolumeAccessDenied)
    		}
    	}
    
    	// Use a small block size to start sending quickly
    	w := newMetacacheWriter(wr, 16<<10)
    	w.reuseBlocks = true // We are not sharing results, so reuse buffers.
    	defer w.Close()
    	out, err := w.stream()
    	if err != nil {
    		return err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 01 05:17:37 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/smb1/SmbClient.java

        }
    
        protected ResponseData processRequest(final String uri, final boolean includeContent) {
            if (smbAuthenticationHolder == null) {
                init();
            }
    
            // start
            AccessTimeoutTarget accessTimeoutTarget = null;
            TimeoutTask accessTimeoutTask = null;
            if (accessTimeout != null) {
                accessTimeoutTarget = new AccessTimeoutTarget(Thread.currentThread());
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 18.9K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/cache/LocalCacheTest.java

            try {
              map.get(one, loader);
            } catch (ExecutionException e) {
              throw new RuntimeException(e);
            }
            doneSignal.countDown();
          }
        }.start();
    
        try {
          computingSignal.await();
        } catch (InterruptedException e) {
          throw new RuntimeException(e);
        }
    
        new Thread() {
          @Override
          public void run() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 110.6K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/cache/LocalCacheTest.java

            try {
              map.get(one, loader);
            } catch (ExecutionException e) {
              throw new RuntimeException(e);
            }
            doneSignal.countDown();
          }
        }.start();
    
        try {
          computingSignal.await();
        } catch (InterruptedException e) {
          throw new RuntimeException(e);
        }
    
        new Thread() {
          @Override
          public void run() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 112.3K bytes
    - Viewed (0)
Back to top