Search Options

Results per page
Sort
Preferred Languages
Advance

Results 621 - 630 of 684 for consume (0.08 sec)

  1. cmd/erasure-sets.go

    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio-go/v7/pkg/set"
    	"github.com/minio/minio-go/v7/pkg/tags"
    	"github.com/minio/minio/internal/dsync"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/pkg/v3/console"
    	"github.com/minio/pkg/v3/sync/errgroup"
    )
    
    // setsDsyncLockers is encapsulated type for Close()
    type setsDsyncLockers [][]dsync.NetLocker
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  2. cmd/data-usage-cache.go

    		d.replaceHashed(path, nil, *flat)
    		return
    	}
    	total := d.totalChildrenRec(path.Key())
    	if total < limit {
    		return
    	}
    
    	// Appears to be printed with _MINIO_SERVER_DEBUG=off
    	// console.Debugf(" %d children found, compacting %v\n", total, path)
    
    	leaves := make([]struct {
    		objects uint64
    		path    dataUsageHash
    	}, total)
    	// Collect current leaves that have children.
    	leaves = leaves[:0]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  3. src/bytes/buffer.go

    }
    
    // ReadRune reads and returns the next UTF-8-encoded
    // Unicode code point from the buffer.
    // If no bytes are available, the error returned is io.EOF.
    // If the bytes are an erroneous UTF-8 encoding, it
    // consumes one byte and returns U+FFFD, 1.
    func (b *Buffer) ReadRune() (r rune, size int, err error) {
    	if b.empty() {
    		// Buffer is empty, reset to recover space.
    		b.Reset()
    		return 0, 0, io.EOF
    	}
    	c := b.buf[b.off]
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Oct 29 16:47:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  4. src/bufio/scan_test.go

    	buf.Reset()
    	doCR := lineNum%5 == 0
    	if doCR {
    		n--
    	}
    	for i := 0; i < n-1; i++ { // Stop early for \n.
    		c := 'a' + byte(lineNum+i)
    		if c == '\n' || c == '\r' { // Don't confuse us.
    			c = 'N'
    		}
    		buf.WriteByte(c)
    	}
    	if addNewline {
    		if doCR {
    			buf.WriteByte('\r')
    		}
    		buf.WriteByte('\n')
    	}
    }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Sep 22 16:22:42 UTC 2023
    - 14.3K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/RateLimiter.java

      }
    
      /**
       * Reserves the given number of permits from this {@code RateLimiter} for future use, returning
       * the number of microseconds until the reservation can be consumed.
       *
       * @return time in microseconds to wait until the resource can be acquired, never negative
       */
      final long reserve(int permits) {
        checkPermits(permits);
        synchronized (mutex()) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 21.6K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/RateLimiter.java

      }
    
      /**
       * Reserves the given number of permits from this {@code RateLimiter} for future use, returning
       * the number of microseconds until the reservation can be consumed.
       *
       * @return time in microseconds to wait until the resource can be acquired, never negative
       */
      final long reserve(int permits) {
        checkPermits(permits);
        synchronized (mutex()) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  7. guava/src/com/google/common/collect/Synchronized.java

    import java.util.Set;
    import java.util.SortedMap;
    import java.util.SortedSet;
    import java.util.Spliterator;
    import java.util.function.BiConsumer;
    import java.util.function.BiFunction;
    import java.util.function.Consumer;
    import java.util.function.Function;
    import java.util.function.Predicate;
    import java.util.function.UnaryOperator;
    import java.util.stream.Stream;
    import javax.annotation.CheckForNull;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 57.2K bytes
    - Viewed (0)
  8. cmd/config-current.go

    			configLogIf(ctx, fmt.Errorf("Unable to parse subnet configuration: %w", err))
    		} else {
    			globalSubnetConfig.Update(subnetConfig, globalIsCICD)
    			globalSubnetConfig.ApplyEnv() // update environment settings for Console UI
    		}
    	case config.CallhomeSubSys:
    		callhomeCfg, err := callhome.LookupConfig(s[config.CallhomeSubSys][config.Default])
    		if err != nil {
    			configLogIf(ctx, fmt.Errorf("Unable to load callhome config: %w", err))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 30.1K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

      /**
       * Settings we receive from the peer. Changes to the field are guarded by this. The instance is
       * never mutated once it has been assigned.
       */
      var peerSettings = DEFAULT_SETTINGS
    
      /** The bytes consumed and acknowledged by the application. */
      val readBytes: WindowCounter = WindowCounter(streamId = 0)
    
      /** The total number of bytes produced by the application. */
      var writeBytesTotal = 0L
        private set
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  10. docs/ja/docs/tutorial/security/first-steps.md

    例えば、`pip install python-multipart`。
    
    これは、**OAuth2**が `ユーザー名` や `パスワード` を送信するために、「フォームデータ」を使うからです。
    
    ///
    
    例を実行します:
    
    <div class="termy">
    
    ```console
    $ uvicorn main:app --reload
    
    <span style="color: green;">INFO</span>:     Uvicorn running on http://127.0.0.1:8000 (Press CTRL+C to quit)
    ```
    
    </div>
    
    ## 確認
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 10.5K bytes
    - Viewed (0)
Back to top