- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 101 for Goroutines (0.18 sec)
-
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>
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Tue Nov 28 19:15:27 UTC 2023 - 36.3K bytes - Viewed (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)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon Feb 10 16:35:49 UTC 2025 - 11.6K bytes - Viewed (0) -
tensorflow/c/c_api_experimental.cc
// CPU tensor to GPU). // Setting a larger thread pool does not help with the Swift caller, as we use // a different TFE context for each thread of execution (for running graph // functions, and their send/recvs corountines). config.set_inter_op_parallelism_threads(1); TF_Buffer* ret = TF_NewBuffer(); TF_CHECK_OK(MessageToBuffer(config, ret)); return ret; }
Registered: Tue Sep 09 12:39:10 UTC 2025 - Last Modified: Mon Aug 18 03:53:25 UTC 2025 - 29.5K bytes - Viewed (0) -
cmd/bucket-metadata-sys.go
"load-bucket-metadata-"+buckets[index], logger.WarningKind) } } // Hold lock here to update in-memory map at once, // instead of serializing the Go routines. sys.Lock() for i, meta := range bucketMetas { if errs[i] != nil { continue } sys.metadataMap[buckets[i]] = meta } sys.Unlock() for i, meta := range bucketMetas {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 20.4K bytes - Viewed (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 {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Thu Sep 04 20:47:24 UTC 2025 - 28.9K bytes - Viewed (0) -
cmd/testdata/decryptObjectInfo.json.zst
Sealed-Key":"IAAfAO9a/NaH0+0MKscdm+NL+AbVJkA78wAeP/+yJutEhk6EpDuvTRUpbzl==","X-Minio-Internal-Server-Side-Encryption-Seal-Algorithm":"DAREv2-HMAC-SHA256","content-type":"application/octet-stream"}},{"Bucket":"buck1","Name":"go_113/src/cmd/trace/goroutines.go","UserDef":{"X-Minio-Internal-Server-Side-Encryption-Iv":"X3+eO4vJp/nKeywGLAy+kjPz6MYWHUc1Qc+Aw5bf6ng=","X-Minio-Internal-Server-Side-Encryption-S3-Kms-Key-Id":"my-minio-key","X-Minio-Internal-Server-Side-Encryption-S3-Kms-Sealed-Key":"IAAfA...
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Thu Oct 29 16:34:20 UTC 2020 - 164K bytes - Viewed (0) -
lib/wasm/wasm_exec.js
// may synchronously trigger a Go event handler. This makes Go code get executed in the middle of the imported // function. A goroutine can switch to a new stack if the current stack is too small (see morestack function). // This changes the SP, thus we have to update the SP used by the imported function. // func wasmExit(code int32)
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Sun Dec 08 15:34:47 UTC 2024 - 16.6K bytes - Viewed (0) -
cmd/erasure-sets.go
g := errgroup.WithNErrs(len(s.sets)) for index := range s.sets { g.Go(func() error { storageInfos[index] = s.sets[index].StorageInfo(ctx) return nil }, index) } // Wait for the go routines. g.Wait() for _, lstorageInfo := range storageInfos { storageInfo.Disks = append(storageInfo.Disks, lstorageInfo.Disks...) } return storageInfo }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 37K bytes - Viewed (1) -
cmd/metrics-v3-types.go
err = mg.bucketLoader(GlobalContext, metricValues, mg.cache, mg.buckets) } else { err = mg.loader(GlobalContext, metricValues, mg.cache) } // There is no way to handle errors here, so we panic the current goroutine // and the Metrics API handler returns a 500 HTTP status code. This should // normally not happen, and usually indicates a bug. logger.CriticalIf(GlobalContext, errors.Wrap(err, "failed to get metrics"))
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Feb 28 19:33:08 UTC 2025 - 15.6K bytes - Viewed (0) -
misc/go_android_exec/main.go
// passed on, the hanging adb subprocess will hold them open and // go test will hang forever. // // Avoid that by wrapping stderr, breaking the short circuit and // forcing cmd.Run to use another pipe and goroutine to pass // along stderr from adb. cmd.Stderr = struct{ io.Writer }{os.Stderr} err := cmd.Run() // Before we process err, flush any further output and get the exit code. exitCode, err2 := filter.Finish()
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Mon Aug 21 17:46:57 UTC 2023 - 15.3K bytes - Viewed (0)