- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 385 for Stopping (0.24 sec)
-
guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
protected void doStart() { // Never starts! } @Override protected void doCancelStart() { assertThat(state()).isEqualTo(Service.State.STOPPING); notifyStopped(); } @Override protected void doStop() { throw new AssertionError(); // Should not be called. } };
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Oct 02 17:20:27 UTC 2023 - 23.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/mux_test.go
} // This is how we force the watchers to close down independently of the // eventbroadcaster, see real usage pattern in startRecordingEvents() go func() { <-stopCh t.Log("Stopping Watchers") m.stopWatching(int64(i)) }() } event := Event{Type: Added, Object: &myType{"foo", "hello world"}} err := m.Action(event.Type, event.Object) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 16 15:26:25 UTC 2022 - 8K bytes - Viewed (0) -
docs/docker/README.md
```sh docker ps -a ``` `-a` flag makes sure you get all the containers (Created, Running, Exited). Then identify the `Container ID` from the output. ### Starting and Stopping Containers To start a stopped container, you can use the [`docker start`](https://docs.docker.com/engine/reference/commandline/start/) command. ```sh docker start <container_id> ```
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Sep 29 04:28:45 UTC 2022 - 8.2K bytes - Viewed (2) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller.go
// waiting to be processed at that itme, they will be dropped. func (c *controller[T]) Run(ctx context.Context) error { klog.Infof("starting %s", c.options.Name) defer klog.Infof("stopping %s", c.options.Name) c.queue = workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: c.options.Name}, )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
protected void doStart() { // Never starts! } @Override protected void doCancelStart() { assertThat(state()).isEqualTo(Service.State.STOPPING); notifyStopped(); } @Override protected void doStop() { throw new AssertionError(); // Should not be called. } };
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Oct 02 17:20:27 UTC 2023 - 23.2K bytes - Viewed (0) -
tensorflow/cc/tools/freeze_saved_model.cc
auto parent = name_to_node_map.find(node->input(0)); if (parent == name_to_node_map.end()) break; node = parent->second; if (node->op() != "Identity") { VLOG(2) << "Stopping at non-identity node " << node->op(); break; } } if (node->op() == "VarHandleOp") { return node->name(); } return absl::NotFoundError("No VarHandleOp ancestor found"); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu May 11 08:05:36 UTC 2023 - 11.9K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/tasks/TaskCreationBuildOperationIntegrationTest.groovy
} } private void stopBeforeTaskGraphCalculation() { buildFile << """ gradle.projectsEvaluated { throw new RuntimeException("stopping before task graph calculation") } """ } private void register(String name) { buildFile << """ tasks.register("$name") """ }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 20 11:16:24 UTC 2024 - 12.6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/cmd/server/testing/testserver.go
// should that become a staging repo. ctx, cancel := context.WithCancelCause(context.Background()) var errCh chan error tearDown := func() { // Cancel is stopping apiextensions apiserver and its // delegates, which itself is cleaning up after itself, // including shutting down its storage layer. cancel(errors.New("tearing down"))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 9K bytes - Viewed (1) -
test/typeparam/slices.go
if tot <= cap(s) { s = s[:tot] } else { news := make([]T, tot, tot+tot/2) _Copy(news, s) s = news } _Copy(s[lens:tot], t) return s } // _Copy copies values from t to s, stopping when either slice is full, // returning the number of values copied. This is like the predeclared // copy function; it's an example of how to write it using generics. func _Copy[T any](s, t []T) int { i := 0
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 01 19:45:34 UTC 2022 - 7.8K bytes - Viewed (0) -
cmd/utils_test.go
} if objectName != testCase.object { t.Errorf("failed expected bucket name \"%s\", got \"%s\"", testCase.object, objectName) } }) } } // Add tests for starting and stopping different profilers. func TestStartProfiler(t *testing.T) { _, err := startProfiler("") if err == nil { t.Fatal("Expected a non nil error, but nil error returned for invalid profiler.") } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Feb 23 21:28:14 UTC 2024 - 10.2K bytes - Viewed (0)