- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 178 for Signals (0.11 sec)
-
src/runtime/stubs.go
func gcWriteBarrier8() func duffzero() func duffcopy() // Called from linker-generated .initarray; declared for go vet; do NOT call from Go. func addmoduledata() // Injected by the signal handler for panicking signals. // Initializes any registers that have fixed meaning at calls but // are scratch in bodies and calls sigpanic. // On many platforms it just jumps to sigpanic. func sigpanic0()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 20.2K bytes - Viewed (0) -
staging/src/k8s.io/api/batch/v1/types.go
// job should be run with. Setting to null means that the success of any // pod signals the success of all pods, and allows parallelism to have any positive // value. Setting to 1 means that parallelism is limited to 1 and the success of that // pod signals the success of the job. // More info: https://kubernetes.io/docs/concepts/workloads/controllers/jobs-run-to-completion/ // +optional
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 18:37:07 UTC 2024 - 40.6K bytes - Viewed (0) -
pkg/apis/batch/types.go
// job should be run with. Setting to null means that the success of any // pod signals the success of all pods, and allows parallelism to have any positive // value. Setting to 1 means that parallelism is limited to 1 and the success of that // pod signals the success of the job. // +optional Completions *int32
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 12:01:28 UTC 2024 - 33K bytes - Viewed (0) -
src/internal/coverage/cfile/emit.go
cfw := encodecounter.NewCoverageDataWriter(w, coverage.CtrULeb128) if err := cfw.Write(finalHash, capturedOsArgs, s); err != nil { return err } return nil } // MarkProfileEmitted signals the coverage machinery that // coverage data output files have already been written out, and there // is no need to take any additional action at exit time. This
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 09:57:47 UTC 2024 - 18.9K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/tasks/bundling/ConcurrentArchiveIntegrationTest.groovy
${server.callFromBuild("wait")} archiveOperations.tarTree(parameters.archiveFile).visit { fcd -> // This signals that the extraction has started. We're inside the lock at this point. ${server.callFromBuild("extract")} println "Extracting for thread " + parameters.index.get()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 20 17:32:21 UTC 2024 - 28.6K bytes - Viewed (0) -
pilot/pkg/xds/discovery.go
// Get the next proxy to push. This will block if there are no updates required. client, push, shuttingdown := queue.Dequeue() if shuttingdown { return } recordPushTriggers(push.Reason) // Signals that a push is done by reading from the semaphore, allowing another send on it. doneFunc := func() { queue.MarkDone(client) <-semaphore } proxiesQueueTime.Record(time.Since(push.Start).Seconds())
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 20:21:09 UTC 2024 - 19K bytes - Viewed (0) -
src/runtime/runtime2.go
const ( _SigNotify = 1 << iota // let signal.Notify have signal, even if from kernel _SigKill // if signal.Notify doesn't take it, exit quietly _SigThrow // if signal.Notify doesn't take it, exit loudly _SigPanic // if the signal is from the kernel, panic _SigDefault // if the signal isn't explicitly requested, don't monitor it
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 47.9K bytes - Viewed (0) -
src/crypto/tls/handshake_server.go
} if c.vers >= VersionTLS12 { certReq.hasSignatureAlgorithm = true certReq.supportedSignatureAlgorithms = supportedSignatureAlgorithms() } // An empty list of certificateAuthorities signals to // the client that it may send any certificate in response // to our request. When we know the CAs we trust, then // we can send them down, so that the client can choose // an appropriate certificate to give to us.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:30:50 UTC 2024 - 27.6K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
go func(idx int) { stopfn := globalRebalanceMetrics.log(rebalanceMetricRebalanceBuckets, idx) err := z.rebalanceBuckets(ctx, idx) stopfn(0, err) }(poolIdx) } } // StopRebalance signals the rebalance goroutine running on this node (if any) // to stop, using the context.CancelFunc(s) saved at the time ofStartRebalance. func (z *erasureServerPools) StopRebalance() error { z.rebalMu.Lock()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 03 15:45:54 UTC 2024 - 27.3K bytes - Viewed (0) -
src/runtime/traceback.go
// context value. // // If the traceback function is called from a signal handler on a Unix // system, SigContext will be the signal context argument passed to // the signal handler (a C ucontext_t* cast to uintptr_t). This may be // used to start tracing at the point where the signal occurred. If // the traceback function is not called from a signal handler, // SigContext will be zero. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 16:25:21 UTC 2024 - 55.1K bytes - Viewed (0)