Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 111 - 120 of 1,365 for done (0.02 seconds)

  1. .github/workflows/labeler.yml

          contents: read
          pull-requests: write
        runs-on: ubuntu-latest
        steps:
        - uses: actions/labeler@v6
          if: ${{ github.event.action != 'labeled' && github.event.action != 'unlabeled' }}
        - run: echo "Done adding labels"
      # Run this after labeler applied labels
      check-labels:
        needs:
          - labeler
        permissions:
          pull-requests: read
        runs-on: ubuntu-latest
        steps:
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Tue Sep 09 09:11:44 GMT 2025
    - 828 bytes
    - Click Count (1)
  2. tests/compose.yml

              echo "Database initialized successfully";
              break;
            fi;
            echo "Waiting for database to be ready... ($$counter/12)";
            sleep 5;
            counter=$$(($$counter + 1));
          done;
          # timeout handling
          if [ $$counter -gt 20 ]; then
            echo "Error: Database failed to start within timeout";
            exit 1;
          fi;
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Mon Aug 04 04:07:30 GMT 2025
    - 1.9K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/util/concurrent/Futures.java

       * expect, but there are some subtleties. First, we do guarantee that, if the output future at
       * index n is done, the output future at index n-1 is also done. (But as usual with futures, some
       * listeners for future n may complete before some for future n-1.) However, it is possible, if
       * one input completes with result X and another later with result Y, for Y to come before X in
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 64.3K bytes
    - Click Count (0)
  4. cmd/speedtest.go

    			result.Version = Version
    			result.Concurrent = concurrency
    
    			select {
    			case ch <- result:
    			case <-ctx.Done():
    				return
    			}
    		}
    
    		for {
    			select {
    			case <-ctx.Done():
    				// If the client got disconnected stop the speedtest.
    				return
    			default:
    			}
    
    			sopts := speedTestOpts{
    				objectSize:      opts.objectSize,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 9.2K bytes
    - Click Count (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectionListener.kt

     *
     * All event methods must execute fast, without external locking, cannot throw exceptions,
     * attempt to mutate the event parameters, or be reentrant back into the client.
     * Any IO - writing to files or network should be done asynchronously.
     */
    internal abstract class ConnectionListener {
      /**
       * Invoked as soon as a call causes a connection to be started.
       */
      open fun connectStart(
        route: Route,
        call: Call,
      ) {}
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri May 30 21:28:20 GMT 2025
    - 2.2K bytes
    - Click Count (0)
  6. tests/prepared_stmt_test.go

    	}
    
    	if err := tx.Where("name=?", "zzjin").Delete(&User{}).Error; err != nil {
    		tx.Rollback()
    		t.Errorf("Failed to run one transaction, got error %v\n", err)
    	}
    
    	if err := tx.Create(&User{Name: "zzjin"}).Error; err != nil {
    		tx.Rollback()
    		t.Errorf("Failed to run one transaction, got error %v\n", err)
    	}
    
    	if err := tx.Commit().Error; err != nil {
    		t.Errorf("Failed to commit transaction, got error %v\n", err)
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Fri Apr 25 08:22:26 GMT 2025
    - 8K bytes
    - Click Count (0)
  7. src/bytes/reader_test.go

    	// See golang.org/issue/7856
    	r := NewReader([]byte{})
    	var wg sync.WaitGroup
    	for i := 0; i < 5; i++ {
    		wg.Add(2)
    		go func() {
    			defer wg.Done()
    			var buf [1]byte
    			r.Read(buf[:])
    		}()
    		go func() {
    			defer wg.Done()
    			r.Read(nil)
    		}()
    	}
    	wg.Wait()
    }
    
    func TestReaderWriteTo(t *testing.T) {
    	for i := 0; i < 30; i += 3 {
    		var l int
    		if i > 0 {
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon Dec 13 18:45:54 GMT 2021
    - 8K bytes
    - Click Count (0)
  8. cmd/bucket-replication-stats.go

    	if r == nil {
    		return
    	}
    	for {
    		select {
    		case <-ctx.Done():
    			return
    		case <-r.wTimer.C:
    			r.wlock.Lock()
    			r.workers.update()
    			r.wlock.Unlock()
    		}
    	}
    }
    
    func (r *ReplicationStats) collectQueueMetrics(ctx context.Context) {
    	if r == nil {
    		return
    	}
    
    	for {
    		select {
    		case <-ctx.Done():
    			return
    		case <-r.qTimer.C:
    			r.qCache.update()
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 13.6K bytes
    - Click Count (0)
  9. cmd/global-heal.go

    		}
    
    		if retErr != nil {
    			healingLogIf(ctx, fmt.Errorf("listing failed with: %v on bucket: %v", retErr, bucket))
    			continue
    		}
    
    		select {
    		// If context is canceled don't mark as done...
    		case <-ctx.Done():
    			return ctx.Err()
    		default:
    			tracker.bucketDone(bucket)
    			healingLogIf(ctx, tracker.update(ctx))
    		}
    	}
    	if retErr != nil {
    		return retErr
    	}
    
    	// Last sanity check
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Apr 04 13:49:12 GMT 2025
    - 16.2K bytes
    - Click Count (0)
  10. cmd/mrf.go

    		opCh: make(chan PartialOperation, mrfOpsQueueSize),
    	}
    }
    
    // Add a partial S3 operation (put/delete) when one or more disks are offline.
    func (m *mrfState) addPartialOp(op PartialOperation) {
    	if m == nil {
    		return
    	}
    
    	if atomic.LoadInt32(&m.closed) == 1 {
    		return
    	}
    
    	m.wg.Add(1)
    	defer m.wg.Done()
    
    	if atomic.LoadInt32(&m.closing) == 1 {
    		return
    	}
    
    	select {
    	case m.opCh <- op:
    	default:
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 6.5K bytes
    - Click Count (0)
Back to Top