Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 139 for doneSz (0.05 seconds)

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

  1. cmd/erasure-server-pool-rebalance.go

    		return ps.Participating && ps.Info.Status == rebalStarted
    	}
    	return false
    }
    
    func (z *erasureServerPools) rebalanceBuckets(ctx context.Context, poolIdx int) (err error) {
    	doneCh := make(chan error, 1)
    	defer xioutil.SafeClose(doneCh)
    
    	// Save rebalance.bin periodically.
    	go func() {
    		// Update rebalance.bin periodically once every 5-10s, chosen randomly
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 28.7K bytes
    - Click Count (0)
  2. cmd/data-scanner.go

    		size := actualSz
    		if i.heal.enabled {
    			done := globalScannerMetrics.time(scannerMetricHealCheck)
    			size = i.applyHealing(ctx, objAPI, oi)
    			done()
    
    			if healDeleteDangling {
    				done := globalScannerMetrics.time(scannerMetricCleanAbandoned)
    				err := objAPI.CheckAbandonedParts(ctx, i.bucket, i.objectPath(), madmin.HealOpts{Remove: healDeleteDangling})
    				done()
    				if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 45.5K bytes
    - Click Count (0)
  3. internal/store/store.go

    func StreamItems[I any](store Store[I], target Target, doneCh <-chan struct{}, logger logger) {
    	go func() {
    		keyCh := replayItems(store, doneCh, logger, target.Name())
    		sendItems(target, keyCh, doneCh, logger)
    	}()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  4. src/test/java/org/codelibs/curl/io/ContentOutputStreamTest.java

            assertFalse(cos.done);
            assertTrue(cos.isInMemory());
            cos.close();
            assertFalse(cos.done);
        }
    
        @Test
        public void inFile() throws IOException {
            ContentOutputStream cos = new ContentOutputStream(10, Curl.tmpDir);
            cos.write(new byte[] { 0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 0 });
            assertFalse(cos.done);
            assertFalse(cos.isInMemory());
    Created: Sat Dec 20 09:13:53 GMT 2025
    - Last Modified: Wed Nov 12 14:01:04 GMT 2025
    - 9.9K bytes
    - Click Count (0)
  5. samples/guide/src/main/java/okhttp3/recipes/UploadProgress.java

        final ProgressListener progressListener = new ProgressListener() {
          boolean firstUpdate = true;
    
          @Override public void update(long bytesWritten, long contentLength, boolean done) {
            if (done) {
              System.out.println("completed");
            } else {
              if (firstUpdate) {
                firstUpdate = false;
                if (contentLength == -1) {
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sat Aug 30 17:01:12 GMT 2025
    - 4.2K bytes
    - Click Count (1)
  6. internal/dsync/drwmutex.go

    					done = true
    				}
    			}
    		case <-ctx.Done():
    			// Capture timedout locks as failed or took too long
    			locksFailed++
    			if locksFailed > tolerance {
    				// We know that we are not going to get the lock anymore,
    				// so exit out and release any locks that did get acquired
    				done = true
    			}
    		}
    
    		if done {
    			break
    		}
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 20.3K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/curl/io/ContentOutputStream.java

     * <ul>
     *   <li>{@code logger} - Logger instance for logging warnings.</li>
     *   <li>{@code PREFIX} - Prefix for the temporary file name.</li>
     *   <li>{@code SUFFIX} - Suffix for the temporary file name.</li>
     *   <li>{@code done} - Flag indicating whether the file has been retrieved.</li>
     * </ul>
     *
     * <p>Constructors:</p>
     * <ul>
    Created: Sat Dec 20 09:13:53 GMT 2025
    - Last Modified: Thu Nov 20 13:34:13 GMT 2025
    - 3.9K bytes
    - Click Count (0)
  8. samples/guide/src/main/java/okhttp3/recipes/kt/UploadProgress.kt

          object : ProgressListener {
            private var firstUpdate = true
    
            override fun update(
              bytesWritten: Long,
              contentLength: Long,
              done: Boolean,
            ) {
              if (done) {
                println("completed")
              } else {
                if (firstUpdate) {
                  firstUpdate = false
                  if (contentLength == -1L) {
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sat Aug 30 17:01:12 GMT 2025
    - 3.8K bytes
    - Click Count (0)
  9. cmd/http-tracer_test.go

    	var wg sync.WaitGroup
    	for i := range numGoroutines {
    		wg.Add(1)
    		go func(id int) {
    			defer wg.Done()
    			for j := 0; j < opsPerGoroutine; j++ {
    				stats.Inc("TestAPI")
    			}
    		}(i)
    	}
    
    	for i := range numGoroutines / 2 {
    		wg.Add(1)
    		go func(id int) {
    			defer wg.Done()
    			for range opsPerGoroutine / 2 {
    				_ = stats.Load(false)
    			}
    		}(i)
    	}
    	wg.Wait()
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  10. internal/event/target/kafka_scram_client_contrib.go

    	response, err = x.ClientConversation.Step(challenge)
    	return response, err
    }
    
    // Done returns true if the conversation is completed or has errored.
    func (x *XDGSCRAMClient) Done() bool {
    	return x.ClientConversation.Done()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 3.2K bytes
    - Click Count (0)
Back to Top