- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 189 for buffer_end (0.19 sec)
-
src/runtime/debug_test.go
// goroutine that's trying to stop the call worker. ogomaxprocs := runtime.GOMAXPROCS(8) ogcpercent := debug.SetGCPercent(-1) runtime.GC() // ready is a buffered channel so debugCallWorker won't block // on sending to it. This makes it less likely we'll catch // debugCallWorker while it's in the runtime. ready := make(chan *runtime.G, 1) var stop uint32 done := make(chan error)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 08 15:08:04 UTC 2023 - 8K bytes - Viewed (0) -
internal/grid/grid_test.go
} // local to remote, unbuffered t.Run("unbuffered", func(t *testing.T) { testHandler(t, handlerTest, false) }) t.Run("buffered", func(t *testing.T) { testHandler(t, handlerTest2, false) }) t.Run("buffered", func(t *testing.T) { testHandler(t, handlerTest2, true) }) } // testStreamDeadline will test if server
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 36.4K bytes - Viewed (0) -
internal/dsync/drwmutex.go
// does not exist in enough quorum nodes. func refreshLock(ctx context.Context, ds *Dsync, id, source string, quorum int) (bool, error) { restClnts, _ := ds.GetLockers() // Create buffered channel of size equal to total number of nodes. ch := make(chan refreshResult, len(restClnts)) var wg sync.WaitGroup args := LockArgs{ UID: id, } for index, c := range restClnts {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 19.7K bytes - Viewed (0) -
src/compress/lzw/writer.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package lzw import ( "bufio" "errors" "fmt" "io" ) // A writer is a buffered, flushable writer. type writer interface { io.ByteWriter Flush() error } const ( // A code is a 12 bit value, stored as a uint32 when encoding to avoid // type conversions when shifting bits.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 13:32:40 UTC 2024 - 7.9K bytes - Viewed (0) -
doc/go_mem.html
</p> <p> This rule generalizes the previous rule to buffered channels. It allows a counting semaphore to be modeled by a buffered channel: the number of items in the channel corresponds to the number of active uses, the capacity of the channel corresponds to the maximum number of simultaneous uses,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 04 15:54:42 UTC 2024 - 26.6K bytes - Viewed (0) -
src/net/http/server.go
// Any number of 1xx headers may be written, followed by at most // one 2xx-5xx header. 1xx headers are sent immediately, but 2xx-5xx // headers may be buffered. Use the Flusher interface to send // buffered data. The header map is cleared when 2xx-5xx headers are // sent, but not with 1xx headers. // // The server will automatically send a 100 (Continue) header
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 123.4K bytes - Viewed (0) -
test/chan/select5.go
func (a *arg) MustDefault() bool { return !a.def } func (a *arg) reset() { a.def = false a.nreset++ } const header = `// GENERATED BY select5.go; DO NOT EDIT package main // channel is buffered so test is single-goroutine. // we are not interested in the concurrency aspects // of select, just testing that the right calls happen. var c = make(chan int, 1) var nilch chan int var n = 1 var x int
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 02 13:43:18 UTC 2016 - 10K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/text/transform/transform.go
r.src1 += n } } // TODO: implement ReadByte (and ReadRune??). // Writer wraps another io.Writer by transforming the bytes read. // The user needs to call Close to flush unwritten bytes that may // be buffered. type Writer struct { w io.Writer t Transformer dst []byte // src[:n] contains bytes that have not yet passed through t. src []byte n int }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 13:01:26 UTC 2024 - 21.7K bytes - Viewed (0) -
pkg/log/config.go
}) // --vklog is non zero then KlogScope should be increased. // klog is a special case. if klogVerbose() { KlogScope.SetOutputLevel(DebugLevel) } return nil } // Sync flushes any buffered log entries. // Processes should normally take care to call Sync before exiting. func Sync() error { return funcs.Load().(patchTable).sync() } // Close implements io.Closer. func Close() error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Mar 26 20:38:10 UTC 2024 - 12.1K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 22:07:03 UTC 2024 - 12.3K bytes - Viewed (0)