Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 323 for Spread (0.04 sec)

  1. 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)
  2. 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)
  3. src/test/java/jcifs/util/AuthenticationRateLimiterTest.java

                    });
                }
    
                // Start all threads
                for (Thread t : threads) {
                    t.start();
                }
    
                // Wait for completion
                for (Thread t : threads) {
                    t.join();
                }
    
                // Verify thread safety - no unexpected exceptions
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. src/test/java/jcifs/netbios/LmhostsTest.java

                                return -1;
                            }
                            int toRead = Math.min(length, remaining);
                            System.arraycopy(includeContent, index[0], buffer, offset, toRead);
                            index[0] += toRead;
                            return toRead;
                        });
                    })) {
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 18.2K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. 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)
Back to top