- Sort Score
- Result 10 results
- Languages All
Results 271 - 280 of 301 for Swapper (0.07 sec)
-
cmd/xl-storage-disk-id-check.go
} n, err := d.w.Write(p) if err == nil && n == len(p) { d.tracker.logSuccess() } return n, err } // diskHealthReader provides a wrapper that will update disk health on // ctx, on every successful read. // This should only be used directly at the os/syscall level, // otherwise buffered operations may return false health checks.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:56:26 UTC 2024 - 34.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
/* * Wait not just until the Future's value is set (as in future.get()) but * also until ListeningScheduledExecutorService's wrapper task is done * executing listeners, as detected by yielding control to afterExecute. */ completed.await(); assertTrue(future.isDone()); assertThat(future.get()).isEqualTo(42);
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 28.1K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ImmutableSortedMap.java
import java.util.stream.Collectors; import javax.annotation.CheckForNull; import org.checkerframework.checker.nullness.qual.Nullable; /** * GWT emulated version of {@link com.google.common.collect.ImmutableSortedMap}. It's a thin wrapper * around a {@link java.util.TreeMap}. * * @author Hayward Chan */ @ElementTypesAreNonnullByDefault public final class ImmutableSortedMap<K, V> extends ForwardingImmutableMap<K, V> implements SortedMap<K, V> {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Feb 27 19:19:19 UTC 2024 - 16.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java
protected void insertBulkData(final FessConfig fessConfig, final String configIndex, final String dataPath) { try { final BulkRequestBuilder builder = client.prepareBulk(); final ObjectMapper mapper = new ObjectMapper(); final String userIndex = fessConfig.getIndexUserIndex() + ".user"; Arrays.stream(FileUtil.readUTF8(dataPath).split("\n")).map(line -> line//
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Sun Oct 20 02:08:03 UTC 2024 - 86.1K bytes - Viewed (0) -
cmd/erasure-metadata.go
if fi.Deleted { return fi.ReplicationState.CompositeReplicationStatus() } return replication.StatusType("") } // GetInternalReplicationState is a wrapper method to fetch internal replication state from the map m func GetInternalReplicationState(m map[string][]byte) ReplicationState { m1 := make(map[string]string, len(m)) for k, v := range m { m1[k] = string(v) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 21.3K bytes - Viewed (0) -
cmd/erasure-object.go
case mrfCheck <- fi.ShallowCopy(): case <-ctx.Done(): return fi, onlineMeta, onlineDisks, toObjectErr(ctx.Err(), bucket, object) } return fi, onlineMeta, onlineDisks, nil } // getObjectInfo - wrapper for reading object metadata and constructs ObjectInfo. func (er erasureObjects) getObjectInfo(ctx context.Context, bucket, object string, opts ObjectOptions) (objInfo ObjectInfo, err error) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 78.8K bytes - Viewed (0) -
docs/en/docs/tutorial/sql-databases.md
/// tip You could use any other SQL or NoSQL database library you want (in some cases called <abbr title="Object Relational Mapper, a fancy term for a library where some classes represent SQL tables and instances represent rows in those tables">"ORMs"</abbr>), FastAPI doesn't force you to use anything. 😎 ///
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Wed Oct 09 19:44:42 UTC 2024 - 14.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
// one is still running. // // Now, maybe we could tweak our implementation to not start the next task until the // callable actually completes. (We could detect completion in our wrapper // `AsyncCallable task`.) However, our contract also promises: // // 2. not to cancel any Future the user returned from an AsyncCallable //
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 22.1K bytes - Viewed (0) -
cmd/object-api-utils_test.go
b.Run("PathJoin", func(b *testing.B) { b.ResetTimer() b.ReportAllocs() for i := 0; i < b.N; i++ { pathJoin("volume", "path/path/path") } }) } // Wrapper func TestPathTraversalExploit(t *testing.T) { if runtime.GOOS != globalWindowsOSName { t.Skip() } defer DetectTestLeak(t)() ExecExtendedObjectLayerAPITest(t, testPathTraversalExploit, []string{"PutObject"})
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 08 15:29:58 UTC 2024 - 24.1K bytes - Viewed (0) -
doc/asm.html
<br> (For <code>DATA</code> and <code>GLOBL</code> items.) This data contains no pointers and therefore does not need to be scanned by the garbage collector. </li> <li> <code>WRAPPER</code> = 32 <br> (For <code>TEXT</code> items.) This is a wrapper function and should not count as disabling <code>recover</code>. </li> <li> <code>NEEDCTXT</code> = 64 <br> (For <code>TEXT</code> items.)
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Tue Nov 28 19:15:27 UTC 2023 - 36.3K bytes - Viewed (0)