Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 301 - 310 of 644 for kuwait (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. docs/smb3-features/02-persistent-handles-design.md

                    new IOException("Failed to reconnect after " + maxRetries + " attempts"));
            }
            
            return CompletableFuture.supplyAsync(() -> {
                try {
                    // Wait before retry (except first attempt)
                    if (attempt > 0) {
                        Thread.sleep(retryDelay * attempt);
                    }
                    
                    // Create reconnect context
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 02:53:50 GMT 2025
    - 31.6K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/graph/ValueGraphTest.java

        ImmutableList.Builder<Future<?>> futures = ImmutableList.builder();
        for (int i = 0; i < threadCount; i++) {
          futures.add(
              executor.submit(
                  () -> {
                    barrier.await();
                    Integer first = graph.nodes().iterator().next();
                    for (Integer node : graph.nodes()) {
                      Set<Integer> unused = graph.successors(node);
                    }
                    /*
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 19:26:39 GMT 2026
    - 17.9K bytes
    - Click Count (0)
  3. cmd/bitrot-streaming.go

    		b.closeWithErr(err)
    	}
    	return n, err
    }
    
    func (b *streamingBitrotWriter) Close() error {
    	// Close the underlying writer.
    	// This will also flush the ring buffer if used.
    	err := b.iow.Close()
    
    	// Wait for all data to be written before returning else it causes race conditions.
    	// Race condition is because of io.PipeWriter implementation. i.e consider the following
    	// sequent of operations:
    	// 1) pipe.Write()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Jan 17 19:19:30 GMT 2025
    - 6.2K bytes
    - Click Count (0)
  4. cmd/batch-handlers.go

    				// persist in-memory state to disk after every 10secs.
    				batchLogIf(ctx, ri.updateAfter(ctx, api, 10*time.Second, job))
    
    				if wait := globalBatchConfig.ReplicationWait(); wait > 0 {
    					time.Sleep(wait)
    				}
    			}()
    		}
    		wk.Wait()
    
    		ri.RetryAttempts = attempts
    		ri.Complete = ri.ObjectsFailed == 0
    		ri.Failed = ri.ObjectsFailed > 0
    
    		globalBatchJobsMetrics.save(job.ID, ri)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 63.5K bytes
    - Click Count (1)
  5. src/main/java/jcifs/smb/SmbCopyUtil.java

                        synchronized (w) {
                            w.checkException();
                            while (!w.isReady()) {
                                try {
                                    w.wait();
                                } catch (final InterruptedException ie) {
                                    throw new SmbException(dest.getURL().toString(), ie);
                                }
                            }
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 16.6K bytes
    - Click Count (0)
  6. src/test/java/jcifs/tests/persistent/HandleInfoTest.java

            HandleInfo durableInfo = new HandleInfo("/test/file.txt", testGuid, testFileId, HandleType.DURABLE_V2, 100, // 100ms timeout
                    null);
    
            assertFalse(durableInfo.isExpired());
    
            // Wait for expiration
            try {
                Thread.sleep(150);
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
    
            assertTrue(durableInfo.isExpired());
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 21 04:51:33 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  7. cmd/namespace-lock_test.go

    		}
    
    		// lk2
    		lk2ch := make(chan struct{})
    		go func() {
    			defer close(lk2ch)
    			nsLk.lock(ctx, "volume", "path", "source", "opsID", false, 1*time.Millisecond)
    		}()
    		time.Sleep(1 * time.Millisecond) // wait for goroutine to advance; ref=2
    
    		// Unlock the 1st lock; ref=1 after this line
    		nsLk.unlock("volume", "path", false)
    
    		// Taking another lockMapMutex here allows queuing up additional lockers. This should
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3K bytes
    - Click Count (0)
  8. android/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
       * @param unit the time unit of the timeout argument
       * @throws TimeoutException if the service has not reached the given state within the deadline
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 10.8K bytes
    - Click Count (0)
  9. src/test/java/jcifs/internal/smb2/lease/DirectoryLeasingIntegrationTest.java

            directoryLeaseManager.updateDirectoryCache(directoryPath, files);
    
            assertTrue(entry.isComplete());
            assertFalse(entry.needsRefresh());
    
            // Wait for expiration
            Thread.sleep(100);
    
            assertTrue(entry.isExpired());
            assertTrue(entry.needsRefresh());
    
            // After expiration, cache should be treated as invalid by manager
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 23 01:47:47 GMT 2025
    - 14.2K bytes
    - Click Count (0)
  10. src/bytes/reader_test.go

    	var wg sync.WaitGroup
    	for i := 0; i < 5; i++ {
    		wg.Add(1)
    		go func(i int) {
    			defer wg.Done()
    			var buf [1]byte
    			r.ReadAt(buf[:], int64(i))
    		}(i)
    	}
    	wg.Wait()
    }
    
    func TestEmptyReaderConcurrent(t *testing.T) {
    	// Test for the race detector, to verify a Read that doesn't yield any bytes
    	// is okay to use from multiple goroutines. This was our historic behavior.
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Dec 13 18:45:54 GMT 2021
    - 8K bytes
    - Click Count (0)
Back to Top