- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 323 for Spread (0.04 sec)
-
cmd/erasure.go
// Otherwise same set of buckets get scanned across erasure sets always. // at any given point in time. This allows different buckets to be scanned // in different order per erasure set, this wider spread is needed when // there are lots of buckets with different order of objects in them. r := rand.New(rand.NewSource(time.Now().UnixNano())) permutes := r.Perm(len(buckets)) // Add new buckets first
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 16.1K bytes - Viewed (0) -
src/main/java/jcifs/smb1/util/DES.java
| (inBytes[inOff + i * 4 + 2] & 0xff) << 8 | inBytes[inOff + i * 4 + 3] & 0xff; } } /// Spread ints into bytes. /** * Converts integers to bytes after internal DES processing * @param inInts the input integer array * @param inOff the offset into the input array
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 22.7K bytes - Viewed (0) -
src/test/java/jcifs/util/AuthenticationRateLimiterTest.java
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 15.8K bytes - Viewed (0) -
cmd/endpoint-ellipses.go
// Figure out largest value of total_drives_in_erasure_set which results // in least number of total_drives/total_drives_erasure_set ratio. prevD := divisibleSize / setCounts[0] for _, cnt := range setCounts { if divisibleSize%cnt == 0 { d := divisibleSize / cnt if d <= prevD { prevD = d setSize = cnt } } } return setSize } // possibleSetCountsWithSymmetry returns symmetrical setCounts based on the
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 14.6K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.2.md
rollback. * <strong>Automated cluster management: </strong> * Kubernetes clusters can now span zones within a cloud provider. Pods from a service will be automatically spread across zones, enabling applications to tolerate zone failure. * Simplified way to run a container on every node (DaemonSet API (Beta) in the Extensions API group): Kubernetes can schedule a service (such as a logging
Registered: Fri Sep 05 09:05:11 UTC 2025 - Last Modified: Fri Dec 04 06:36:19 UTC 2020 - 41.4K bytes - Viewed (0) -
src/bytes/buffer.go
} var errUnreadByte = errors.New("bytes.Buffer: UnreadByte: previous operation was not a successful read") // UnreadByte unreads the last byte returned by the most recent successful // read operation that read at least one byte. If a write has happened since // the last read, if the last read returned an error, or if the read read zero // bytes, UnreadByte returns an error. func (b *Buffer) UnreadByte() error {
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Mon May 19 17:38:56 UTC 2025 - 16K bytes - Viewed (0) -
src/test/java/jcifs/netbios/LmhostsTest.java
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 18.2K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt
} /** Receive frames until there are no more. Invoked only by the reader thread. */ @Throws(IOException::class) fun loopReader(response: Response) { try { listener.onOpen(this@RealWebSocket, response) while (receivedCloseCode == -1) { // This method call results in one or more onRead* methods being called on this thread. reader!!.processNextFrame() } } catch (e: Exception) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 21.6K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/util/ThreadDumpUtilTest.java
// Verify that thread dump was processed assertFalse("Should capture some thread dump output", capturedOutput.isEmpty()); // Verify format - should contain "Thread:" entries boolean hasThreadEntry = capturedOutput.stream().anyMatch(line -> line.startsWith("Thread:")); assertTrue("Should contain Thread: entries", hasThreadEntry);
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jul 12 07:34:10 UTC 2025 - 15.5K bytes - Viewed (0) -
src/main/java/jcifs/util/transport/Transport.java
} /** * Cleans up the transport thread. * * @param timeout the maximum time to wait for thread cleanup in milliseconds * @throws TransportException if thread cleanup fails */ private synchronized void cleanupThread(final long timeout) throws TransportException { final Thread t = this.thread; if (t != null && Thread.currentThread() != t) { this.thread = null;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 27.8K bytes - Viewed (0)