- Sort Score
- Result 10 results
- Languages All
Results 331 - 340 of 856 for umount (0.05 sec)
-
src/test/java/org/codelibs/core/timer/TimeoutManagerTest.java
assertNull(TimeoutManager.getInstance().thread); Thread.sleep(10); int count = expiredCount; task.stop(); TimeoutManager.getInstance().start(); assertNotNull(TimeoutManager.getInstance().thread); Thread.sleep(2000); assertEquals(count, expiredCount); assertEquals(1, TimeoutManager.getInstance().getTimeoutTaskCount()); task.cancel();
Registered: Fri Nov 01 20:58:10 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 2.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java
} } private static final class CountingRunnable implements Runnable { int count; @Override public void run() { count++; } void assertNotRun() { assertEquals(0, count); } void assertRun() { assertEquals(1, count); } } private static void assertSetAsynchronously(AbstractFuture<Integer> future) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 21 15:41:36 UTC 2024 - 15.5K bytes - Viewed (0) -
android/guava/src/com/google/common/primitives/ImmutableDoubleArray.java
ensureRoomFor(values.length()); System.arraycopy(values.array, values.start, array, count, values.length()); count += values.length(); return this; } private void ensureRoomFor(int numberToAdd) { int newCount = count + numberToAdd; // TODO(kevinb): check overflow now? if (newCount > array.length) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 18:05:56 UTC 2024 - 23K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Settings.kt
* Settings are [connection][Http2Connection] scoped. */ class Settings { /** Bitfield of which flags that values. */ private var set: Int = 0 /** Flag values. */ private val values = IntArray(COUNT) /** Returns -1 if unset. */ val headerTableSize: Int get() { val bit = 1 shl HEADER_TABLE_SIZE return if (bit and set != 0) values[HEADER_TABLE_SIZE] else -1 }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.8K bytes - Viewed (0) -
src/main/java/jcifs/smb1/dcerpc/msrpc/MsrpcDfsRootEnum.java
} public FileEntry[] getEntries() { netdfs.DfsEnumArray200 a200 = (netdfs.DfsEnumArray200)info.e; SmbShareInfo[] entries = new SmbShareInfo[a200.count]; for (int i = 0; i < a200.count; i++) { entries[i] = new SmbShareInfo(a200.s[i].dfs_name, 0, null); } return entries; }
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 1.6K bytes - Viewed (0) -
internal/config/storageclass/help.go
} Help = config.HelpKVS{ config.HelpKV{ Key: ClassStandard, Description: `set the parity count for default standard storage class` + defaultHelpPostfix(ClassStandard), Optional: true, Type: "string", }, config.HelpKV{ Key: ClassRRS, Description: `set the parity count for reduced redundancy storage class` + defaultHelpPostfix(ClassRRS), Optional: true, Type: "string",
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Mar 26 22:06:19 UTC 2024 - 1.8K bytes - Viewed (0) -
common/config/.golangci-format.yml
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Apr 05 03:02:37 UTC 2024 - 2K bytes - Viewed (0) -
cmd/bucket-metadata-sys.go
func (sys *BucketMetadataSys) init(ctx context.Context, buckets []string) { count := globalEndpoints.ESCount() * 10 for { if len(buckets) < count { sys.concurrentLoad(ctx, buckets) break } sys.concurrentLoad(ctx, buckets[:count]) buckets = buckets[count:] } sys.Lock() sys.initialized = true sys.Unlock() if globalIsDistErasure {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 28 15:32:18 UTC 2024 - 20.4K bytes - Viewed (0) -
docs/distributed/decom-encrypted-kes.sh
expanded_policy_count=$(./mc admin policy list myminio/ | wc -l) if [ "$user_count" -ne "$expanded_user_count" ]; then echo "BUG: original user count differs from expanded setup" exit 1 fi if [ "$policy_count" -ne "$expanded_policy_count" ]; then echo "BUG: original policy count differs from expanded setup" exit 1 fi ./mc version info myminio/versioned | grep -q "versioning is enabled" ret=$? if [ $ret -ne 0 ]; then
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon May 27 19:17:46 UTC 2024 - 7.1K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/base/JoinerBenchmark.java
@Param({"3", "30", "300"}) int count; @Param({"0", "1", "16", "32", "100"}) int componentLength; private Iterable<String> components; @BeforeExperiment void setUp() { String component = Strings.repeat("a", componentLength); String[] raw = new String[count]; Arrays.fill(raw, component); components = Arrays.asList(raw); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 4.9K bytes - Viewed (0)