- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for lrab (0.04 sec)
-
guava/src/com/google/common/util/concurrent/AbstractService.java
} finally { monitor.leave(); } } else { // It is possible due to races that we are currently in the expected state even though we // timed out. e.g. if we weren't event able to grab the lock within the timeout we would never // even check the guard. I don't think we care too much about this use case but it could lead // to a confusing error message.
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Feb 19 21:24:11 UTC 2025 - 20.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractService.java
} finally { monitor.leave(); } } else { // It is possible due to races that we are currently in the expected state even though we // timed out. e.g. if we weren't event able to grab the lock within the timeout we would never // even check the guard. I don't think we care too much about this use case but it could lead // to a confusing error message.
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Feb 19 21:24:11 UTC 2025 - 20.3K bytes - Viewed (0) -
api/maven-api-cli/src/main/java/org/apache/maven/api/cli/ParserRequest.java
OutputStream stdErr(); /** * Returns {@code true} if this call happens in "embedded" mode, for example by another application that * embeds Maven. When running in "embedded" mode, Maven will not try to grab system terminal and will use * provided {@link #stdIn()} or {@link InputStream#nullInputStream()} as standard in stream. */ boolean embedded(); /**
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Sat Jun 07 06:22:47 UTC 2025 - 15.9K bytes - Viewed (0) -
docs/SMB3_IMPLEMENTATION_PLAN.md
- **Phases 1-2**: 2-3 months (High priority) - **Phases 3-4**: 2 months (Medium priority) - **Phases 5-6**: 2-3 months (Low priority) ### Infrastructure - Windows Server test lab - RDMA-capable test hardware - Continuous integration environment - Performance testing infrastructure ## Success Metrics 1. **Functional Completeness**: All features pass Windows Protocol Test Suite
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 10.7K bytes - Viewed (0) -
cmd/metacache-set.go
fds := opts.fallbackDisks fallback := func(err error) StorageAPI { if _, ok := err.(StorageErr); ok { // Attempt to grab a fallback disk fdMu.Lock() defer fdMu.Unlock() if len(fds) == 0 { return nil } fdsCopy := fds for _, fd := range fdsCopy { // Grab a fallback disk fds = fds[1:] if fd != nil && fd.IsOnline() { return fd } } }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 30.7K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/DefaultWagonManager.java
String checksumFileExtension, Wagon wagon) throws ResourceDoesNotExistException, TransferFailedException, AuthorizationException { try { // grab it first, because it's about to change... String actualChecksum = checksumObserver.getActualChecksum(); File tempChecksumFile = new File(tempDestination + checksumFileExtension + ".tmp");
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Sat Apr 05 11:52:05 UTC 2025 - 29.9K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
a.Total = atomic.LoadInt64(&old.Total) a.N = atomic.LoadInt64(&old.N) e.mu.Lock() e.addAll(t-1, a) e.mu.Unlock() acc = newAcc } else { // We may be able to grab the new accumulator by yielding. runtime.Gosched() acc = e.cached.Load() } } atomic.AddInt64(&acc.N, 1) atomic.AddInt64(&acc.Total, int64(value)) atomic.AddInt64(&acc.Size, sz) }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Apr 25 05:41:04 UTC 2025 - 34.5K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
if (protocolNegotiationEnabled) { Platform.get().configureTlsExtensions(sslSocket, null, protocols) } sslSocket.startHandshake() // Wait until after handshake to grab the buffered socket socket = MockWebServerSocket(sslSocket) if (protocolNegotiationEnabled) { val protocolString = Platform.get().getSelectedProtocol(sslSocket) protocol =
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 02 20:36:00 UTC 2025 - 40.3K bytes - Viewed (0) -
cmd/data-scanner.go
// If the factor is updated the sleep will be done again with the new factor. func (d *dynamicSleeper) Sleep(ctx context.Context, base time.Duration) { for { // Grab current values d.mu.RLock() minWait, maxWait := d.minSleep, d.maxSleep factor := d.factor cycle := d.cycle d.mu.RUnlock() // Don't sleep for really small amount of time
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 45.5K bytes - Viewed (0) -
configure.py
'errors.\n' % (android_ndk_home_path, ndk_version, _SUPPORTED_ANDROID_NDK_VERSIONS)) write_action_env_to_bazelrc('ANDROID_NDK_VERSION', ndk_version) # Now grab the NDK API level to use. Note that this is different from the # SDK API level, as the NDK API level is effectively the *min* target SDK # version. meta = open(os.path.join(android_ndk_home_path, 'meta/platforms.json'))
Registered: Tue Sep 09 12:39:10 UTC 2025 - Last Modified: Wed Apr 30 15:18:54 UTC 2025 - 48.3K bytes - Viewed (0)