- Sort Score
- Result 10 results
- Languages All
Results 551 - 560 of 798 for NEXT (0.07 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)