- Sort Score
- Result 10 results
- Languages All
Results 41 - 47 of 47 for goroutines (0.13 sec)
-
src/crypto/tls/handshake_client_test.go
<-stdout.handshakeComplete } // OpenSSL will try to interleave application data and // a renegotiation if we send both concurrently. // Therefore: ask OpensSSL to start a renegotiation, run // a goroutine to call client.Read and thus process the // renegotiation request, watch for OpenSSL's stdout to // indicate that the handshake is complete and, // finally, have OpenSSL write something to cause
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 88.7K bytes - Viewed (0) -
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) -
src/cmd/link/internal/loader/loader.go
// has a linkname (push). // If a name is in this map, it is allowed only in listed packages, // even if it has a linknamed definition. var blockedLinknames = map[string][]string{ // coroutines "runtime.coroswitch": {"iter"}, "runtime.newcoro": {"iter"}, // weak references "internal/weak.runtime_registerWeakPointer": {"internal/weak"},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 20:26:10 UTC 2024 - 81.5K bytes - Viewed (0) -
src/cmd/link/internal/ld/lib.go
ctxt.loader.SymName(froms[0]), froms[0]) } } } // If needed, create the __CTOR_LIST__ and __DTOR_LIST__ // symbols (referenced by some of the mingw support library // routines). Creation of these symbols is normally done by the // linker if not already present. want := []string{"__CTOR_LIST__", "__DTOR_LIST__"} isunresolved := symbolsAreUnresolved(ctxt, want) for k, w := range want {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 21 18:45:27 UTC 2024 - 88.6K bytes - Viewed (0) -
src/cmd/vendor/github.com/ianlancetaylor/demangle/demangle.go
} } // The doDemangle function is the entry point into the demangler proper. func doDemangle(name string, options ...Option) (ret AST, err error) { // When the demangling routines encounter an error, they panic // with a value of type demangleErr. defer func() { if r := recover(); r != nil { if de, ok := r.(demangleErr); ok { ret = nil err = de return }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 31 19:48:28 UTC 2024 - 94.1K bytes - Viewed (0)