- Sort Score
- Result 10 results
- Languages All
Results 31 - 37 of 37 for goroutines (0.22 sec)
-
pkg/controller/job/job_controller.go
jm.updateStatusHandler = jm.updateJobStatus jm.patchJobHandler = jm.patchJob jm.syncHandler = jm.syncJob metrics.Register() return jm, nil } // Run the main goroutine responsible for watching and syncing jobs. func (jm *Controller) Run(ctx context.Context, workers int) { defer utilruntime.HandleCrash() logger := klog.FromContext(ctx) // Start events processing pipeline.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
cmd/iam-store.go
} c.updatedAt = time.Now() return nil } // IAMStorageAPI defines an interface for the IAM persistence layer type IAMStorageAPI interface { // The role of the read-write lock is to prevent go routines from // concurrently reading and writing the IAM storage. The (r)lock() // functions return the iamCache. The cache can be safely written to // only when returned by `lock()`. lock() *iamCache unlock()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 75.8K bytes - Viewed (0) -
cmd/erasure-object.go
if onlineDisks[index] == nil { return errDiskNotFound } return onlineDisks[index].UpdateMetadata(ctx, bucket, object, fi, opts) }, index) } // Wait for all the routines. mErrs := g.Wait() return reduceWriteQuorumErrs(ctx, mErrs, objectOpIgnoredErrs, fi.WriteQuorum(er.defaultWQuorum())) } // updateObjectMeta will update the metadata of a file.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 78.6K bytes - Viewed (0) -
cmd/bucket-replication.go
defer p.mrfMU.Unlock() if !p.initialized() { return errServerNotInitialized } mrfRec, err := p.loadMRF() if err != nil { return err } // queue replication heal in a goroutine to avoid holding up mrf save routine go func() { for vID, e := range mrfRec.Entries { ctx, cancel := context.WithTimeout(p.ctx, time.Second) // Do not waste more than a second on this.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 114.4K bytes - Viewed (0) -
cmd/object-handlers_test.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 161.9K bytes - Viewed (0) -
src/cmd/compile/internal/ssagen/ssa.go
func (s *state) entryNewValue2A(op ssa.Op, t *types.Type, aux ssa.Aux, arg0, arg1 *ssa.Value) *ssa.Value { return s.entryBlock().NewValue2A(src.NoXPos, op, t, aux, arg0, arg1) } // const* routines add a new const value to the entry block. func (s *state) constSlice(t *types.Type) *ssa.Value { return s.f.ConstSlice(t) } func (s *state) constInterface(t *types.Type) *ssa.Value { return s.f.ConstInterface(t)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 19:44:43 UTC 2024 - 284.9K bytes - Viewed (0) -
RELEASE.md
* VectorExponential added to distributions. * Add a bitwise module with bitwise_and, bitwise_or, bitwise_xor, and invert functions. * Add fixed-grid ODE integration routines. * Allow passing bounds to ScipyOptimizerInterface. * Correctness fixes for fft_length parameter to `tf.spectral.rfft` & `tf.spectral.irfft`.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Jun 11 23:24:08 UTC 2024 - 730.3K bytes - Viewed (0)