Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for unbuffered (0.18 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. 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)
  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. 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)
  5. 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)
  6. 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)
Back to top