Search Options

Results per page
Sort
Preferred Languages
Advance

Results 381 - 390 of 561 for doneSz (0.06 sec)

  1. internal/ioutil/ioutil.go

    	defer cancel()
    
    	c := make(chan ioret[V], 1)
    	go func() {
    		v, err := work(ctx)
    		c <- ioret[V]{val: v, err: err}
    	}()
    
    	select {
    	case v := <-c:
    		return v.val, v.err
    	case <-ctx.Done():
    		var zero V
    		return zero, ctx.Err()
    	}
    }
    
    // DeadlineWorker implements the deadline/timeout resiliency pattern.
    type DeadlineWorker struct {
    	timeout time.Duration
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 11.1K bytes
    - Viewed (0)
  2. cmd/utils.go

    }
    
    func ptr[T any](a T) *T {
    	return &a
    }
    
    // sleepContext sleeps for d duration or until ctx is done.
    func sleepContext(ctx context.Context, d time.Duration) error {
    	select {
    	case <-ctx.Done():
    		return ctx.Err()
    	case <-time.After(d):
    	}
    	return nil
    }
    
    // helper type to return either item or error.
    type itemOrErr[V any] struct {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 33K bytes
    - Viewed (0)
  3. cmd/object-handlers_test.go

    	bytesData := []struct {
    		byteData []byte
    	}{
    		{generateBytesData(6 * humanize.MiByte)},
    	}
    	// set of inputs for uploading the objects before tests for downloading is done.
    	putObjectInputs := []struct {
    		bucketName    string
    		objectName    string
    		contentLength int64
    		textData      []byte
    		metaData      map[string]string
    	}{
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 163.1K bytes
    - Viewed (0)
  4. docs/pt/docs/_llm-test.md

    //// tab | Teste
    
    Aqui estão algumas coisas envolvidas em elementos HTML "abbr" (algumas são inventadas):
    
    ### O abbr fornece uma frase completa { #the-abbr-gives-a-full-phrase }
    
    * <abbr title="Getting Things Done – Fazer as Coisas">GTD</abbr>
    * <abbr title="menos que"><code>lt</code></abbr>
    * <abbr title="XML Web Token – Token Web XML">XWT</abbr>
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Dec 17 10:17:03 UTC 2025
    - 12.4K bytes
    - Viewed (0)
  5. helm-releases/minio-5.0.6.tgz

    $SECRET" ; $MC_COMMAND ; STATUS=$? ; until [ $STATUS = 0 ] do ATTEMPTS=`expr $ATTEMPTS + 1` ; echo \"Failed attempts: $ATTEMPTS\" ; if [ $ATTEMPTS -gt $LIMIT ]; then exit 1 ; fi ; sleep 2 ; # 1 second intervals between attempts $MC_COMMAND ; STATUS=$? ; done ; set -e ; # reset `e` as active return 0 } # checkBucketExists ($bucket) # Check if the bucket exists, by using the exit code of `mc ls` checkBucketExists() { BUCKET=$1 CMD=$(${MC} stat myminio/$BUCKET > /dev/null 2>&1) return $? } # createBucket...
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Feb 13 06:53:06 UTC 2023
    - 20.3K bytes
    - Viewed (0)
  6. internal/grid/benchmark_test.go

    				for i := range responses {
    					toSend := GetByteBuffer()[:0]
    					toSend = append(toSend, byte(i))
    					toSend = append(toSend, payload...)
    					select {
    					case <-ctx.Done():
    						return nil
    					case out <- toSend:
    					}
    				}
    				return nil
    			},
    
    			Subroute:    "some-subroute",
    			OutCapacity: 1, // Only one message buffered.
    			InCapacity:  0,
    		}))
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.5K bytes
    - Viewed (0)
  7. docs/en/docs/alternatives.md

    This isn't even Python, NestJS is a JavaScript (TypeScript) NodeJS framework inspired by Angular.
    
    It achieves something somewhat similar to what can be done with Flask-apispec.
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sat Oct 11 17:48:49 UTC 2025
    - 23.6K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/collect/ConcurrentHashMultisetTest.java

        int countToRemove = 30;
        AtomicInteger current = new AtomicInteger(countToRemove);
    
        when(backingMap.get(KEY)).thenReturn(current);
        // it's ok if removal fails: another thread may have done the remove
        when(backingMap.remove(KEY, current)).thenReturn(false);
    
        assertEquals(countToRemove, multiset.remove(KEY, countToRemove));
        assertEquals(0, current.get());
      }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Dec 08 22:42:14 UTC 2025
    - 16.3K bytes
    - Viewed (0)
  9. internal/config/identity/plugin/config.go

    			isConnected := o.checkConnectivity(o.shutdownCtx)
    			if isConnected {
    				o.serviceMetrics.setConnSuccess(now)
    			} else {
    				o.serviceMetrics.setConnFailure(now)
    			}
    		case <-o.shutdownCtx.Done():
    			return
    		}
    	}
    }
    
    // Metrics contains metrics about the authentication plugin service.
    type Metrics struct {
    	LastReachableSecs, LastUnreachableSecs float64
    
    	// Last whole minute stats
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.3K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/reflect/TypeResolver.java

        } else if (type instanceof WildcardType) {
          return resolveWildcardType((WildcardType) type);
        } else {
          // if Class<?>, no resolution needed, we are done.
          return type;
        }
      }
    
      @CanIgnoreReturnValue
      Type[] resolveTypesInPlace(Type[] types) {
        for (int i = 0; i < types.length; i++) {
          types[i] = resolveType(types[i]);
        }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 22:30:05 UTC 2025
    - 25.3K bytes
    - Viewed (0)
Back to top