- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for isStopped (0.18 sec)
-
src/main/java/org/codelibs/core/timer/TimeoutTask.java
* 止まっているかどうか返します。 * * @return 止まっているかどうか */ public boolean isStopped() { return status == STOPPED; } /** * タイマーをとめます。 */ public void stop() { if (status != ACTIVE) { throw new ClIllegalStateException(String.valueOf(status)); } status = STOPPED; } /** * タイマーを再開始します。 */
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 2.7K bytes - Viewed (0) -
src/main/java/org/codelibs/core/timer/TimeoutManager.java
final TimeoutTask task = e.getElement(); if (task.isCanceled()) { e.remove(); } else if (!task.isStopped() && task.isExpired()) { expiredTask.add(task); if (!task.isPermanent()) { e.remove(); } } } return expiredTask;
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 8K bytes - Viewed (0) -
cmd/license-update.go
// reason, the lock will be released and another node will acquire it and // take over because of this loop. for { licenceUpdaterLoop(ctx, objAPI) // license update stopped for some reason. // sleep for some time and try again. duration := time.Duration(r.Float64() * float64(time.Hour)) if duration < time.Second { // Make sure to sleep at least a second to avoid high CPU ticks.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 3.3K bytes - Viewed (0) -
buildscripts/heal-manual.go
fmt.Println("Healstatus on items ===") for _, item := range status.Items { if err = enc.Encode(&item); err != nil { log.Fatalln(err) } } break } if status.Summary == "stopped" { fmt.Println("Healstatus on items ===") fmt.Println("Heal failed with", status.FailureDetail) break } for _, item := range status.Items { if err = enc.Encode(&item); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 27 09:47:58 GMT 2024 - 2.3K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
switch { case errors.Is(rebalErr, context.Canceled): status = rebalStopped traceMsg = fmt.Sprintf("stopped at %s", now) case rebalErr == nil: status = rebalCompleted traceMsg = fmt.Sprintf("completed at %s", now) default: status = rebalFailed traceMsg = fmt.Sprintf("stopped at %s with err: %v", now, rebalErr) } z.rebalMu.Lock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K bytes - Viewed (0) -
cmd/admin-heal-ops.go
type healStatusSummary string // healStatusSummary constants const ( healNotStartedStatus healStatusSummary = "not started" healRunningStatus = "running" healStoppedStatus = "stopped" healFinishedStatus = "finished" ) const ( // a heal sequence with this many un-consumed heal result // items blocks until heal-status consumption resumes or is // aborted due to timeout.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
cni/pkg/nodeagent/net.go
func (s *NetServer) DelPodFromMesh(ctx context.Context, pod *corev1.Pod) error { log := log.WithLabels("ns", pod.Namespace, "name", pod.Name) log.Debug("Pod is now stopped... cleaning up.") if err := removePodFromHostNSIpset(pod, &s.hostsideProbeIPSet); err != nil { log.Errorf("failed to remove pod %s from host ipset, error was: %v", pod.Name, err) return err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
cmd/prepare-storage.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 11.1K bytes - Viewed (0) -
src/builtin/builtin.go
// invocation of F then behaves like a call to panic, terminating G's // execution and running any deferred functions. This continues until all // functions in the executing goroutine have stopped, in reverse order. At // that point, the program is terminated with a non-zero exit code. This // termination sequence is called panicking and can be controlled by the // built-in function recover. //
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Apr 11 20:22:45 GMT 2024 - 12.7K bytes - Viewed (0) -
common-protos/k8s.io/api/batch/v1/generated.proto
// may be continuously active before the system tries to terminate it; value // must be positive integer. If a Job is suspended (at creation or through an // update), this timer will effectively be stopped and reset when the Job is // resumed again. // +optional optional int64 activeDeadlineSeconds = 3; // Specifies the policy of handling failed pods. In particular, it allows to
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 21.1K bytes - Viewed (0)