- Sort Score
- Num 10 results
- Language All
Results 61 - 70 of 118 for Coroutine (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
doc/asm.html
</p> <h3 id="arm">ARM</h3> <p> The registers <code>R10</code> and <code>R11</code> are reserved by the compiler and linker. </p> <p> <code>R10</code> points to the <code>g</code> (goroutine) structure. Within assembler source code, this pointer must be referred to as <code>g</code>; the name <code>R10</code> is not recognized. </p> <p>
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Fri Nov 14 19:09:46 GMT 2025 - 36.5K bytes - Click Count (0) -
cmd/sftp-server-driver.go
} func (f *sftpDriver) Filewrite(r *sftp.Request) (w io.WriterAt, err error) { stopFn := globalSftpMetrics.log(r, f.AccessKey()) defer func() { if err != nil { // If there is an error, we never started the goroutine. stopFn(0, err) } }() flags := r.Pflags() if !flags.Write { // sanity check return nil, os.ErrInvalid } bucket, object := path2BucketObject(r.Filepath)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Feb 10 16:35:49 GMT 2025 - 11.6K bytes - Click Count (0) -
okhttp/build.gradle.kts
implementation(projects.okhttpIdnaMappingTable) implementation(projects.okhttpSse) implementation(projects.okhttpCoroutines) implementation(libs.kotlinx.coroutines.core) implementation(libs.squareup.moshi) implementation(libs.squareup.moshi.kotlin) implementation(libs.squareup.okio.fakefilesystem) implementation(libs.conscrypt.openjdk)
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sat Nov 01 12:18:11 GMT 2025 - 12.3K bytes - Click Count (0) -
cmd/erasure-server-pool-rebalance.go
if err != nil { rebalanceLogIf(ctx, fmt.Errorf("invalid workers value err: %v, defaulting to %d", err, len(pool.sets))) workerSize = len(pool.sets) } // Each decom worker needs one List() goroutine/worker // add that many extra workers. workerSize += len(pool.sets) wk, err := workers.New(workerSize) if err != nil { return err } for setIdx, set := range pool.sets {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 28.7K bytes - Click Count (0) -
src/bytes/reader_test.go
}(i) } wg.Wait() } func TestEmptyReaderConcurrent(t *testing.T) { // Test for the race detector, to verify a Read that doesn't yield any bytes // is okay to use from multiple goroutines. This was our historic behavior. // See golang.org/issue/7856 r := NewReader([]byte{}) var wg sync.WaitGroup for i := 0; i < 5; i++ { wg.Add(2) go func() { defer wg.Done() var buf [1]byte
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Mon Dec 13 18:45:54 GMT 2021 - 8K bytes - Click Count (0) -
README.md
which does not export it to module com.bigco.sdk) ``` The stable public API is based on the list of defined modules: - okhttp3 - okhttp3.brotli - okhttp3.coroutines - okhttp3.dnsoverhttps - okhttp3.java.net.cookiejar - okhttp3.logging - okhttp3.sse - okhttp3.tls - okhttp3.urlconnection - mockwebserver3 - mockwebserver3.junit4 - mockwebserver3.junit5
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Thu Oct 30 21:39:59 GMT 2025 - 9.5K bytes - Click Count (0) -
internal/s3select/csv/reader.go
const csvSplitSize = 128 << 10 // startReaders will read the header if needed and spin up a parser // and a number of workers based on GOMAXPROCS. // If an error is returned no goroutines have been started and r.err will have been set. func (r *Reader) startReaders(newReader func(io.Reader) *csv.Reader) error { if r.args.FileHeaderInfo != none { // Read column names // Get one line.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 8.8K bytes - Click Count (0) -
doc/godebug.md
[`tlssecpmlkem` setting](/pkg/crypto/tls/#Config.CurvePreferences). Go 1.26 added a new `tracebacklabels` setting that controls the inclusion of goroutine labels set through the the `runtime/pprof` package. Setting `tracebacklabels=1` includes these key/value pairs in the goroutine status header of runtime tracebacks and debug=2 runtime/pprof stack dumps. This format may change in the future. (see go.dev/issue/76349)
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Wed Dec 03 00:18:09 GMT 2025 - 24.7K bytes - Click Count (0) -
cmd/erasure-server-pool-decom.go
if err != nil { decomLogIf(ctx, fmt.Errorf("invalid workers value err: %v, defaulting to %d", err, len(pool.sets))) workerSize = len(pool.sets) } // Each decom worker needs one List() goroutine/worker // add that many extra workers. workerSize += len(pool.sets) wk, err := workers.New(workerSize) if err != nil { return err } var vc *versioning.VersioningCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 42.2K bytes - Click Count (1) -
doc/go_spec.html
<p> The function value and parameters are <a href="#Calls">evaluated as usual</a> in the calling goroutine, but unlike with a regular call, program execution does not wait for the invoked function to complete. Instead, the function begins executing independently in a new goroutine. When the function terminates, its goroutine also terminates. If the function has any return values, they are discarded when the function completes.
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Tue Dec 02 23:07:19 GMT 2025 - 286.5K bytes - Click Count (1)