Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for lrab (0.02 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top