Search Options

Results per page
Sort
Preferred Languages
Advance

Results 551 - 560 of 798 for NEXT (0.07 sec)

  1. src/main/java/jcifs/smb1/smb1/AndXServerMessageBlock.java

             * response will not read a batched command and therefore
             * the 'received' member of the response object will not
             * be set to true indicating the send and sendTransaction
             * methods that the next part should be sent. This is a
             * very indirect and simple batching control mechanism.
             */
    
            if( andx == null || USE_BATCHING == false ||
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 11.3K bytes
    - Viewed (0)
  2. cmd/benchmark-utils_test.go

    	b.ReportAllocs()
    	// the actual benchmark for PutObject starts here. Reset the benchmark timer.
    	b.ResetTimer()
    
    	b.RunParallel(func(pb *testing.PB) {
    		i := 0
    		for pb.Next() {
    			// insert the object.
    			objInfo, err := obj.PutObject(context.Background(), bucket, "object"+strconv.Itoa(i),
    				mustGetPutObjReader(b, bytes.NewReader(textData), int64(len(textData)), md5hex, sha256hex), ObjectOptions{})
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Dec 23 15:46:00 UTC 2022
    - 8.2K bytes
    - Viewed (0)
  3. cmd/batch-expire.go

    		if count == 0 {
    			break
    		}
    		if count > maxDeleteList {
    			count = maxDeleteList
    		}
    		_, errs := api.DeleteObjects(ctx, r.Bucket, objsToDel[:count], opts)
    		allErrs = append(allErrs, errs...)
    		// Next batch of deletion
    		objsToDel = objsToDel[count:]
    	}
    
    	return allErrs
    }
    
    const (
    	batchExpireName                 = "batch-expire.bin"
    	batchExpireFormat               = 1
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/app/web/base/FessSearchAction.java

    import org.dbflute.optional.OptionalThing;
    import org.lastaflute.web.login.LoginManager;
    import org.lastaflute.web.response.ActionResponse;
    import org.lastaflute.web.response.HtmlResponse;
    import org.lastaflute.web.response.next.HtmlNext;
    import org.lastaflute.web.ruts.process.ActionRuntime;
    
    import jakarta.annotation.Resource;
    import jakarta.servlet.http.HttpServletRequest;
    import jakarta.servlet.http.HttpSession;
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 10K bytes
    - Viewed (0)
  5. cmd/metacache-stream_test.go

    	}
    }
    
    func Test_metacacheReader_next(t *testing.T) {
    	r := loadMetacacheSample(t)
    	defer r.Close()
    	for i, want := range loadMetacacheSampleNames {
    		gotObj, err := r.next()
    		if err != nil {
    			t.Fatal(err)
    		}
    		if gotObj.name != want {
    			t.Errorf("entry %d, want %q, got %q", i, want, gotObj.name)
    		}
    	}
    }
    
    func Test_metacacheReader_peek(t *testing.T) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 15K bytes
    - Viewed (0)
  6. guava/src/com/google/common/collect/ImmutableCollection.java

       *
       * @since 2.0
       */
      public ImmutableList<E> asList() {
        switch (size()) {
          case 0:
            return ImmutableList.of();
          case 1:
            return ImmutableList.of(iterator().next());
          default:
            return new RegularImmutableAsList<>(this, toArray());
        }
      }
    
      /**
       * Returns {@code true} if this immutable collection's implementation contains references to
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Aug 12 16:59:15 UTC 2024
    - 18.8K bytes
    - Viewed (0)
  7. guava/src/com/google/common/collect/Queues.java

       * ...
       * synchronized (queue) {  // Must synchronize on queue!
       *   Iterator<E> i = queue.iterator(); // Must be in synchronized block
       *   while (i.hasNext()) {
       *     foo(i.next());
       *   }
       * }
       * }</pre>
       *
       * <p>Failure to follow this advice may result in non-deterministic behavior.
       *
       * <p>The returned queue will be serializable if the specified queue is serializable.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 26 14:11:14 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  8. cmd/erasure-healing-common_test.go

    		}
    		if diskIndex != 0 && disk == nil {
    			t.Errorf("Drive erroneously filtered, driveIndex: %d", diskIndex)
    		}
    	}
    	partsMetadata[0] = partsMetadataBackup // Revert before going to the next test
    
    	// Test 3: Not synchronized DataDir
    	partsMetadataBackup = partsMetadata[1]
    	partsMetadata[1].DataDir = "foo-random"
    
    	errs = make([]error, len(erasureDisks))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 15:19:10 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt

            override fun runOnce(): Long {
              block()
              return -1L
            }
          },
          delayNanos,
        )
      }
    
      /** Returns a latch that reaches 0 when the queue is next idle. */
      fun idleLatch(): CountDownLatch {
        taskRunner.lock.withLock {
          // If the queue is already idle, that's easy.
          if (activeTask == null && futureTasks.isEmpty()) {
            return CountDownLatch(0)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/collect/RegularContiguousSet.java

          final C last = last();
    
          @Override
          @CheckForNull
          protected C computeNext(C previous) {
            return equalsOrThrow(previous, last) ? null : domain.next(previous);
          }
        };
      }
    
      @GwtIncompatible // NavigableSet
      @Override
      public UnmodifiableIterator<C> descendingIterator() {
        return new AbstractSequentialIterator<C>(last()) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 22 21:19:52 UTC 2024
    - 8.4K bytes
    - Viewed (0)
Back to top