Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 327 for finish (0.28 sec)

  1. cni/pkg/nodeagent/server_test.go

    	if f.testWG != nil {
    		defer f.testWG.Done()
    	}
    	args := f.Called(ambientPods)
    	return args.Error(0)
    }
    
    // Custom "wait group with timeout" for waiting for fakeServer calls in a goroutine to finish
    type WaitGroup struct {
    	count int32
    	done  chan struct{}
    }
    
    func NewWaitGroup() *WaitGroup {
    	return &WaitGroup{
    		done: make(chan struct{}),
    	}
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 7.8K bytes
    - Viewed (0)
  2. docs/distributed/decom-compressed-sse-s3.sh

    ./mc admin decom start myminio/ http://localhost:9000/tmp/xl/{1...10}/disk{0...1}
    
    until $(./mc admin decom status myminio/ | grep -q Complete); do
    	echo "waiting for decom to finish..."
    	sleep 1
    done
    
    kill $pid_1
    kill $pid_2
    
    sleep 5
    
    (minio server --address ":9001" http://localhost:9001/tmp/xl/{11...30}/disk{0...3} 2>&1 >/tmp/removed.log) &
    pid=$!
    
    sleep 30
    
    Shell Script
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 4.4K bytes
    - Viewed (0)
  3. docs/distributed/decom-encrypted.sh

    ./mc admin decom start myminio/ http://localhost:9000/tmp/xl/{1...10}/disk{0...1}
    
    until $(./mc admin decom status myminio/ | grep -q Complete); do
    	echo "waiting for decom to finish..."
    	sleep 1
    done
    
    kill $pid_1
    kill $pid_2
    
    sleep 5
    
    (minio server --address ":9001" http://localhost:9001/tmp/xl/{11...30}/disk{0...3} 2>&1 >/tmp/removed.log) &
    pid=$!
    
    sleep 30
    
    Shell Script
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/collect/QueuesTest.java

      @Override
      public void setUp() {
        threadPool = newCachedThreadPool();
      }
    
      @Override
      public void tearDown() throws InterruptedException {
        threadPool.shutdown();
        assertTrue("Some worker didn't finish in time", threadPool.awaitTermination(10, SECONDS));
      }
    
      private static <T> int drain(
          BlockingQueue<T> q,
          Collection<? super T> buffer,
          int maxElements,
          long timeout,
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 12K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/FluentFuture.java

      }
    
      /**
       * Returns a future that delegates to this future but will finish early (via a {@link
       * TimeoutException} wrapped in an {@link ExecutionException}) if the specified timeout expires.
       * If the timeout expires, not only will the output future finish, but also the input future
       * ({@code this}) will be cancelled and interrupted.
       *
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 11 19:08:44 GMT 2023
    - 18.7K bytes
    - Viewed (0)
  6. cmd/admin-heal-ops.go

    	// time-duration to keep heal sequence state after it
    	// completes.
    	keepHealSeqStateDuration = time.Minute * 10
    
    	// nopHeal is a no operating healing action to
    	// wait for the current healing operation to finish
    	nopHeal = ""
    )
    
    var (
    	errHealIdleTimeout   = fmt.Errorf("healing results were not consumed for too long")
    	errHealStopSignalled = fmt.Errorf("heal stop signaled")
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.1K bytes
    - Viewed (1)
  7. guava-tests/test/com/google/common/collect/QueuesTest.java

      @Override
      public void setUp() {
        threadPool = newCachedThreadPool();
      }
    
      @Override
      public void tearDown() throws InterruptedException {
        threadPool.shutdown();
        assertTrue("Some worker didn't finish in time", threadPool.awaitTermination(10, SECONDS));
      }
    
      private static <T> int drain(
          BlockingQueue<T> q,
          Collection<? super T> buffer,
          int maxElements,
          long timeout,
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 12K bytes
    - Viewed (0)
  8. internal/grid/README.md

            grid.PutByteBuffer(result)
            return nil
        })
    ```
    
    Context cancellation and timeouts are propagated to the handler. 
    The client does not wait for the remote handler to finish before returning.
    Returning any error will also cancel the stream remotely.
    
    CAREFUL: When utilizing two-way communication, it is important to ensure that the remote handler is not blocked on a send.
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 9.4K bytes
    - Viewed (0)
  9. docs/debugging/s3-verify/main.go

    	srcSha256 := sha256.New()
    	tgtSha256 := sha256.New()
    
    	for {
    		srcSha256.Reset()
    		tgtSha256.Reset()
    
    		srcEOF = !srcOk
    		tgtEOF = !tgtOk
    
    		// No objects from source AND target: Finish
    		if srcEOF && tgtEOF {
    			break
    		}
    
    		if !srcEOF && srcCtnt.Err != nil {
    			log.Fatal(srcCtnt.Err)
    		}
    
    		if !tgtEOF && tgtCtnt.Err != nil {
    			log.Fatal(tgtCtnt.Err)
    		}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jun 22 15:12:47 GMT 2022
    - 8.4K bytes
    - Viewed (0)
  10. maven-compat/src/main/java/org/apache/maven/repository/legacy/resolver/DefaultLegacyArtifactCollector.java

                    } catch (ArtifactResolutionException e) {
                        result.addMetadataResolutionException(e);
                    }
                }
    
                fireEvent(ResolutionListener.FINISH_PROCESSING_CHILDREN, listeners, node);
            }
        }
    
        private void manageArtifact(
                ResolutionNode node, ManagedVersionMap managedVersions, List<ResolutionListener> listeners) {
    Java
    - Registered: Sun May 05 03:35:11 GMT 2024
    - Last Modified: Wed Sep 06 11:28:54 GMT 2023
    - 36.7K bytes
    - Viewed (0)
Back to top