Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 523 for kuwait (0.03 sec)

  1. android/guava/src/com/google/common/collect/Queues.java

       * numElements} elements are not available, it will wait for them up to the specified timeout.
       *
       * @param q the blocking queue to be drained
       * @param buffer where to add the transferred elements
       * @param numElements the number of elements to be waited for
       * @param timeout how long to wait before giving up
       * @return the number of elements transferred
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 18.3K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt

      }
    
      /** For testing: force this web socket to release its threads. */
      @Throws(InterruptedException::class)
      fun tearDown() {
        taskQueue.shutdown()
        taskQueue.idleLatch().await(10, TimeUnit.SECONDS)
      }
    
      @Synchronized fun sentPingCount(): Int = sentPingCount
    
      @Synchronized fun receivedPingCount(): Int = receivedPingCount
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 21.6K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/DuplexTest.kt

            override fun responseHeadersEnd(
              call: Call,
              response: Response,
            ) {
              try {
                // Wait for the server to send the duplex response before acting on the 301 response
                // and resetting the stream.
                duplexResponseSent.await()
              } catch (e: InterruptedException) {
                throw AssertionError()
              }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 24.8K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/Service.java

       */
      void awaitRunning();
    
      /**
       * Waits for the {@link Service} to reach the {@linkplain State#RUNNING running state} for no more
       * than the given time.
       *
       * @param timeout the maximum time to wait
       * @throws TimeoutException if the service has not reached the given state within the deadline
       * @throws IllegalStateException if the service reaches a state from which it is not possible to
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  5. fess-crawler/src/main/java/org/codelibs/fess/crawler/Crawler.java

            awaitTermination(0);
        }
    
        /**
         * Waits for the crawling process to terminate for a specified duration.
         * @param millis The maximum time to wait in milliseconds. A value of 0 means wait indefinitely.
         */
        public void awaitTermination(final long millis) {
            if (parentThread != null) {
                try {
                    parentThread.join(millis);
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 14K bytes
    - Viewed (0)
  6. cmd/data-usage.go

    		return map[string]uint64{}, nil
    	}
    
    	cache := dataUsageCache{}
    
    	prefixUsageCache.InitOnce(30*time.Second,
    		// No need to fail upon Update() error, fallback to old value.
    		cachevalue.Opts{ReturnLastGood: true, NoWait: true},
    		func(ctx context.Context) (map[string]uint64, error) {
    			m := make(map[string]uint64)
    			for _, pool := range z.serverPools {
    				for _, er := range pool.sets {
    					// Load bucket usage prefixes
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  7. cmd/perf-tests.go

    				atomic.AddUint64(&totalBytesWritten, uint64(info.Size))
    				objCountPerThread[i]++
    				mu.Lock()
    				uploadTimes = append(uploadTimes, response)
    				mu.Unlock()
    			}
    		}(i)
    	}
    	wg.Wait()
    
    	// We already saw write failures, no need to proceed into read's
    	if retError != "" {
    		return SpeedTestResult{
    			Uploads:     totalBytesWritten,
    			Downloads:   totalBytesRead,
    			UploadTimes: uploadTimes,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.7K bytes
    - Viewed (0)
  8. .github/dependabot.yml

    version: 2
    updates:
    # TODO(b/170636568): Enable Maven updates? Perhaps wait until we can more
    # easily import the generated PRs into our internal repo.
    #  - package-ecosystem: "maven"
    #    directory: "/"
    #    schedule:
    #      interval: "weekly"
    #    groups:
    #      dependencies:
    #        applies-to: version-updates
    #        patterns:
    #          - "*"
    #  - package-ecosystem: "maven"
    #    directory: "/android"
    #    schedule:
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Mar 21 21:15:53 UTC 2025
    - 762 bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

       * than the given time. The manager will become healthy after all the component services have
       * reached the {@linkplain State#RUNNING running} state.
       *
       * @param timeout the maximum time to wait
       * @throws TimeoutException if not all of the services have finished starting within the deadline
       * @throws IllegalStateException if the service manager reaches a state from which it cannot
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 33.2K bytes
    - Viewed (1)
  10. cmd/untar.go

    				return err
    			}
    		}
    
    		header, err := tarReader.Next()
    		switch {
    		// if no more files are found return
    		case err == io.EOF:
    			wg.Wait()
    			return asyncErr
    
    		// return any other error
    		case err != nil:
    			wg.Wait()
    			extra := ""
    			if n > 0 {
    				extra = fmt.Sprintf(" after %d successful object(s)", n)
    			}
    			return fmt.Errorf("tar file error: %w%s", err, extra)
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 6K bytes
    - Viewed (2)
Back to top