- Sort Score
- Num 10 results
- Language All
Results 1051 - 1060 of 1,452 for reach (0.03 seconds)
-
guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
* <li>If you override {@link #tearDown}, make sure to invoke {@code super.tearDown} within it. * This method is used to clear and check for thread assertion failures. * <li>All threads generated must be joined inside each test case method (or {@code fail} to do * so) before returning from the method. The {@code joinPool} method can be used to do this * when using Executors. * </ol> * * <p><b>Other notes</b> * * <ul>
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 8.8K bytes - Click Count (0) -
src/main/java/jcifs/smb1/smb1/ACE.java
* available online). * <p> * Direct ACEs are evaluated first in order. The SID of the user performing * the operation and the desired access bits are compared to the SID * and access mask of each ACE. If the SID matches, the allow/deny flags * and access mask are considered. If the ACE is a "deny" * ACE and <i>any</i> of the desired access bits match bits in the access
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 8.8K bytes - Click Count (0) -
src/test/java/jcifs/internal/CommonServerMessageBlockRequestTest.java
@Mock private CommonServerMessageBlockRequest splitRequest; @Mock private CommonServerMessageBlockRequest cancelRequest; @BeforeEach void setUp() { // Reset mocks before each test reset(request, nextRequest, splitRequest, cancelRequest); } @Test @DisplayName("Test isResponseAsync returns true when response is async") void testIsResponseAsyncTrue() { // GivenCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 12.1K bytes - Click Count (0) -
src/test/java/jcifs/EmptyIteratorTest.java
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 12K bytes - Click Count (0) -
cmd/xl-storage-format-v1.go
BLAKE2b512 ) // DefaultBitrotAlgorithm is the default algorithm used for bitrot protection. const ( DefaultBitrotAlgorithm = HighwayHash256S ) // ObjectPartInfo Info of each part kept in the multipart metadata // file after CompleteMultipartUpload() is called. type ObjectPartInfo struct { ETag string `json:"etag,omitempty" msg:"e"`
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Oct 22 15:30:50 GMT 2024 - 8.4K bytes - Click Count (0) -
guava/src/com/google/common/collect/Streams.java
characteristics, estimatedSize), isParallel) .onClose(() -> closeAll(streams)); } /** * Returns a stream in which each element is the result of passing the corresponding element of * each of {@code streamA} and {@code streamB} to {@code function}. * * <p>For example: * * {@snippet : * Streams.zip( * Stream.of("foo1", "foo2", "foo3"),Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 19:19:10 GMT 2026 - 36.4K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/ObjectCountHashMap.java
* index. * * <p>Its size must be a power of two. */ private transient int[] table; /** * Contains the logical entries, in the range of [0, size()). The high 32 bits of each long is the * smeared hash of the element, whereas the low 32 bits is the "next" pointer (pointing to the * next entry in the bucket chain). The pointers in [size(), entries.length) are all "null" * (UNSET). */
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Aug 09 01:14:59 GMT 2025 - 14.5K bytes - Click Count (0) -
src/main/java/jcifs/internal/witness/WitnessClient.java
WitnessAsyncNotifyMessage.WitnessNotificationResponse response = rpcClient.getAsyncNotifications(contextHandle); if (response != null) { // Process each notification message for (WitnessAsyncNotifyMessage.WitnessNotificationMessage message : response.getMessages()) { processAsyncNotificationMessage(registration, message);
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 20.8K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/tree/Smb2TreeConnectResponseTest.java
} @Test @DisplayName("Should handle all capability flags") void testAllCapabilityFlags() throws SMBProtocolDecodingException { // Test each capability flag individually int[] capabilityFlags = { Smb2TreeConnectResponse.SMB2_SHARE_CAP_DFS, Smb2TreeConnectResponse.SMB2_SHARE_CAP_CONTINUOUS_AVAILABILITY, Smb2TreeConnectResponse.SMB2_SHARE_CAP_SCALEOUT,Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 07:14:38 GMT 2025 - 19.3K bytes - Click Count (0) -
cmd/bucket-stats.go
func (rl ReplicationLatency) merge(other ReplicationLatency) (newReplLatency ReplicationLatency) { newReplLatency.UploadHistogram = rl.UploadHistogram.Merge(other.UploadHistogram) return newReplLatency } // Get upload latency of each object size range func (rl ReplicationLatency) getUploadLatency() (ret map[string]uint64) { ret = make(map[string]uint64) avg := rl.UploadHistogram.GetAvgData() for k, v := range avg {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 13.5K bytes - Click Count (0)