Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 431 - 440 of 494 for Selects (0.06 seconds)

  1. CHANGELOG.md

        `DurationUnit` which was a typealias in 1.5.x.
     *  Upgrade: [Okio 3.2.0][okio_3_2_0].
    
    
    ## Version 5.0.0-alpha.9
    
    _2022-06-16_
    
     *  New: Enforce label length limits in URLs. `HttpUrl` now rejects URLs whose domains aren't valid.
        This includes overly-long domain names (longer than 253 characters), overly-long labels (more
        than 63 characters between dots), and empty labels.
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Dec 05 16:02:59 GMT 2025
    - 36.2K bytes
    - Click Count (2)
  2. cmd/data-usage-cache.go

    // save the content of the cache to minioMetaBackgroundOpsBucket with the provided name.
    // Note that no locking is done when saving.
    func (d *dataUsageCache) save(ctx context.Context, store objectIO, name string) error {
    	select {
    	case <-ctx.Done():
    		return ctx.Err()
    	case maxConcurrentScannerSaves <- struct{}{}:
    	}
    
    	buf := bytebufferpool.Get()
    	defer func() {
    		<-maxConcurrentScannerSaves
    		buf.Reset()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.7K bytes
    - Click Count (0)
  3. internal/ringbuffer/ring_buffer_test.go

    		t.Errorf("got: %q; want: %q", result, "hello")
    	}
    }
    
    func timeout(after time.Duration) (cancel func()) {
    	c := time.After(after)
    	cc := make(chan struct{})
    	go func() {
    		select {
    		case <-cc:
    			return
    		case <-c:
    			buf := make([]byte, 1<<20)
    			stacklen := runtime.Stack(buf, true)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 26.7K bytes
    - Click Count (0)
  4. internal/config/config.go

    		return nil, Errorf("invalid number of arguments %s", s)
    	}
    	found := SubSystems.Contains(subSystemValue[0])
    	if !found {
    		// Check for sub-prefix only if the input value is only a
    		// single value, this rejects invalid inputs if any.
    		found = !SubSystems.FuncMatch(strings.HasPrefix, subSystemValue[0]).IsEmpty() && len(subSystemValue) == 1
    	}
    	if !found {
    		return nil, Errorf("unknown sub-system %s", s)
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 37.7K bytes
    - Click Count (0)
  5. docs/recipes.md

    [Moshi](https://github.com/square/moshi) is a handy API for converting between JSON and Java objects. Here we're using it to decode a JSON response from a GitHub API.
    
    Note that `ResponseBody.charStream()` uses the `Content-Type` response header to select which charset to use when decoding the response body. It defaults to `UTF-8` if no charset is specified.
    
    === ":material-language-kotlin: Kotlin"
        ```kotlin
          private val client = OkHttpClient()
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sat Aug 30 17:01:12 GMT 2025
    - 47.8K bytes
    - Click Count (0)
  6. doc/go_mem.html

    </p>
    
    <pre>
    var limit = make(chan int, 3)
    
    func main() {
    	for _, w := range work {
    		go func(w func()) {
    			limit &lt;- 1
    			w()
    			&lt;-limit
    		}(w)
    	}
    	select{}
    }
    </pre>
    
    <h3 id="locks">Locks</h3>
    
    <p>
    The <code>sync</code> package implements two lock data types,
    <code>sync.Mutex</code> and <code>sync.RWMutex</code>.
    </p>
    
    <p class="rule">
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Aug 05 15:41:37 GMT 2025
    - 26.6K bytes
    - Click Count (0)
  7. cmd/server-main.go

    	}
    
    	globalTrace.Publish(info)
    }
    
    func initServerConfig(ctx context.Context, newObject ObjectLayer) error {
    	t1 := time.Now()
    
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    
    	for {
    		select {
    		case <-ctx.Done():
    			// Retry was canceled successfully.
    			return fmt.Errorf("Initializing sub-systems stopped gracefully %w", ctx.Err())
    		default:
    		}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:18:36 GMT 2025
    - 35.9K bytes
    - Click Count (4)
  8. src/cmd/asm/internal/asm/parse.go

    	// <ABIxxx> (selecting text symbol with specific ABI).
    	noErrMsg := false
    	isStatic, abi := p.symRefAttrs(name, noErrMsg)
    	if isStatic {
    		return "", obj.ABI0, false // This function rejects static symbols.
    	}
    	tok = p.next()
    	if tok.ScanToken == '+' {
    		if p.next().ScanToken != scanner.Int {
    			return "", obj.ABI0, false
    		}
    		tok = p.next()
    	}
    	if tok.ScanToken != '(' {
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Wed Nov 12 03:59:40 GMT 2025
    - 37.3K bytes
    - Click Count (0)
  9. cmd/object-api-utils.go

    //
    // You should avoid the following characters in a key name because of
    // significant special handling for consistency across all
    // applications.
    //
    // Rejects strings with following characters.
    //
    // - Backslash ("\")
    //
    // additionally minio does not support object names with trailing SlashSeparator.
    func IsValidObjectName(object string) bool {
    	if len(object) == 0 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Jun 25 15:08:54 GMT 2025
    - 37.3K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/util/concurrent/Futures.java

       * {@code function} is invoked on each call to {@link Future#get() get()} on the returned future.
       *
       * <p>The returned {@code Future} reflects the input's cancellation state directly, and any
       * attempt to cancel the returned Future is likewise passed through to the input Future.
       *
    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)
Back to Top