Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for unbuffered (0.08 sec)

  1. doc/godebug.md

    enabled by default on listerners. Using multipathtcp="0" reverts to the
    pre-Go 1.24 behavior.
    
    ### Go 1.23
    
    Go 1.23 changed the channels created by package time to be unbuffered
    (synchronous), which makes correct use of the [`Timer.Stop`](/pkg/time/#Timer.Stop)
    and [`Timer.Reset`](/pkg/time/#Timer.Reset) method results much easier.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Oct 28 14:46:33 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  2. doc/go1.17_spec.html

    make(chan int, 100)
    </pre>
    
    <p>
    The capacity, in number of elements, sets the size of the buffer in the channel.
    If the capacity is zero or absent, the channel is unbuffered and communication
    succeeds only when both a sender and receiver are ready. Otherwise, the channel
    is buffered and communication succeeds without blocking if the buffer
    is not full (sends) or not empty (receives).
    A <code>nil</code> channel is never ready for communication.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 10 18:25:45 UTC 2024
    - 211.6K bytes
    - Viewed (0)
  3. src/bufio/bufio_test.go

    		t.Error("expected flush error, got nil")
    	}
    	if _, err := wr.ReadFrom(strings.NewReader("test2")); err == nil {
    		t.Fatal("expected error, got nil")
    	}
    	if buffered := wr.Buffered(); buffered != wantBuffered {
    		t.Fatalf("Buffered = %v; want %v", buffered, wantBuffered)
    	}
    }
    
    func BenchmarkReaderCopyOptimal(b *testing.B) {
    	// Optimal case is where the underlying reader implements io.WriterTo
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Nov 01 21:52:12 UTC 2024
    - 51.6K bytes
    - Viewed (0)
  4. guava/src/com/google/common/io/ByteSink.java

       *
       * @throws IOException if an I/O error occurs while opening the stream
       */
      public abstract OutputStream openStream() throws IOException;
    
      /**
       * Opens a new buffered {@link OutputStream} for writing to this sink. The returned stream is not
       * required to be a {@link BufferedOutputStream} in order to allow implementations to simply
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 28 16:55:09 UTC 2024
    - 5K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/io/CharSink.java

       *
       * @throws IOException if an I/O error occurs while opening the writer
       */
      public abstract Writer openStream() throws IOException;
    
      /**
       * Opens a new buffered {@link Writer} for writing to this sink. The returned stream is not
       * required to be a {@link BufferedWriter} in order to allow implementations to simply delegate to
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  6. cmd/xl-storage-disk-id-check.go

    	}
    	return n, err
    }
    
    // diskHealthReader provides a wrapper that will update disk health on
    // ctx, on every successful read.
    // This should only be used directly at the os/syscall level,
    // otherwise buffered operations may return false health checks.
    func diskHealthReader(ctx context.Context, r io.Reader) io.Reader {
    	// Check if context has a disk health check.
    	tracker, ok := ctx.Value(healthDiskCtxKey{}).(*healthDiskCtxValue)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  7. cmd/storage-rest-client.go

    }
    
    // where we keep old *Readers
    var readMsgpReaderPool = sync.Pool{New: func() interface{} { return &msgp.Reader{} }}
    
    // mspNewReader returns a *Reader that reads from the provided reader.
    // The reader will be buffered.
    // Return with readMsgpReaderPoolPut when done.
    func msgpNewReader(r io.Reader) *msgp.Reader {
    	p := readMsgpReaderPool.Get().(*msgp.Reader)
    	if p.R == nil {
    		p.R = xbufio.NewReaderSize(r, 32<<10)
    	} else {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/io/ByteSource.java

       *
       * @throws IOException if an I/O error occurs while opening the stream
       */
      public abstract InputStream openStream() throws IOException;
    
      /**
       * Opens a new buffered {@link InputStream} for reading from this source. The returned stream is
       * not required to be a {@link BufferedInputStream} in order to allow implementations to simply
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 26.2K bytes
    - Viewed (0)
  9. cmd/bucket-lifecycle.go

    		es.stats.missedExpiryTasks.Add(1)
    	}
    }
    
    // globalExpiryState is the per-node instance which manages all ILM expiry tasks.
    var globalExpiryState *expiryState
    
    // newExpiryState creates an expiryState with buffered channels allocated for
    // each ILM expiry task type.
    func newExpiryState(ctx context.Context, objAPI ObjectLayer, n int) *expiryState {
    	es := &expiryState{
    		ctx:    ctx,
    		objAPI: objAPI,
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  10. guava/src/com/google/common/io/ByteStreams.java

        byte[] buf = null;
    
        while (totalSkipped < n) {
          long remaining = n - totalSkipped;
          long skipped = skipSafely(in, remaining);
    
          if (skipped == 0) {
            // Do a buffered read since skipSafely could return 0 repeatedly, for example if
            // in.available() always returns 0 (the default).
            int skip = (int) min(remaining, BUFFER_SIZE);
            if (buf == null) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 29.7K bytes
    - Viewed (0)
Back to top