- Sort Score
- Result 10 results
- Languages All
Results 251 - 260 of 366 for checkIsE (0.07 sec)
-
android/guava-tests/test/com/google/common/graph/AbstractStandardUndirectedNetworkTest.java
- assertThrows(
- IllegalArgumentException.class, () -> networkAsMutableNetwork.addEdge(N1, N1, E11));
- assertThat(e).hasMessageThat().contains(ERROR_SELF_LOOP);
- }
- /**
- * This test checks an implementation dependent feature. It tests that the method {@code addEdge}
- * will silently add the missing nodes to the graph, then add the edge connecting them. We are not
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Jul 02 18:21:29 UTC 2024 - 18.6K bytes - Viewed (0) -
cmd/metrics.go
- closer.Close()
- }
- })
- }
- // NoAuthMiddleware no auth middle ware.
- func NoAuthMiddleware(h http.Handler) http.Handler {
- return h
- }
- // AuthMiddleware checks if the bearer token is valid and authorized.
- func AuthMiddleware(h http.Handler) http.Handler {
- return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 16.6K bytes - Viewed (0) -
src/archive/tar/reader.go
- nb = 0
- }
- if nb < 0 {
- return ErrHeader
- }
- tr.pad = blockPadding(nb)
- tr.curr = ®FileReader{r: tr.r, nb: nb}
- return nil
- }
- // handleSparseFile checks if the current file is a sparse format of any type
- // and sets the curr reader appropriately.
- func (tr *Reader) handleSparseFile(hdr *Header, rawHdr *block) error {
- var spd sparseDatas
- var err error
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Fri Mar 08 01:59:14 UTC 2024 - 26.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/graph/TraverserTest.java
- public void forGraph_breadthFirst_emptyGraph() {
- assertThrows(
- IllegalArgumentException.class,
- () -> Traverser.forGraph(createDirectedGraph()).breadthFirst('a'));
- }
- /**
- * Checks that the elements of the iterable are calculated on the fly. Concretely, that means that
- * {@link SuccessorsFunction#successors(Object)} can only be called for a subset of all nodes.
- */
- @Test
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 47.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/graph/TraverserTest.java
- public void forGraph_breadthFirst_emptyGraph() {
- assertThrows(
- IllegalArgumentException.class,
- () -> Traverser.forGraph(createDirectedGraph()).breadthFirst('a'));
- }
- /**
- * Checks that the elements of the iterable are calculated on the fly. Concretely, that means that
- * {@link SuccessorsFunction#successors(Object)} can only be called for a subset of all nodes.
- */
- @Test
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 47.5K bytes - Viewed (0) -
internal/bucket/object/lock/lock_test.go
- actualStatus := parseLegalHoldStatus(tt.value)
- if actualStatus != tt.expectedStatus {
- t.Errorf("Expected legal hold status %s, got %s", tt.expectedStatus, actualStatus)
- }
- }
- }
- // TestUnmarshalDefaultRetention checks if default retention
- // marshaling and unmarshalling work as expected
- func TestUnmarshalDefaultRetention(t *testing.T) {
- days := uint64(4)
- years := uint64(1)
- zerodays := uint64(0)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Jun 29 01:20:27 UTC 2024 - 17.1K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
- hostIptables.DeleteHostRules()
- if err := hostIptables.CreateHostRulesForHealthChecks(&HostProbeSNATIP, &HostProbeSNATIPV6); err != nil {
- return nil, fmt.Errorf("error initializing the host rules for health checks: %w", err)
- }
- podNetns := NewPodNetnsProcFinder(os.DirFS(filepath.Join(pconstants.HostMountsPath, "proc")))
- netServer := newNetServer(ztunnelServer, podNsMap, podIptables, podNetns)
- // Set some defaults
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Sep 25 20:54:34 UTC 2024 - 13.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractService.java
- "Timed out waiting for "
- + this
- + " to reach a terminal state. "
- + "Current state: "
- + state());
- }
- }
- /** Checks that the current state is equal to the expected state. */
- @GuardedBy("monitor")
- private void checkCurrentState(State expected) {
- State actual = state();
- if (actual != expected) {
- if (actual == FAILED) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 20.4K bytes - Viewed (0) -
internal/grid/muxclient.go
- if !m.doPing(respHandler) {
- return
- }
- goto sendResp
- }
- case <-pingTimer:
- if !m.doPing(respHandler) {
- return
- }
- }
- }
- }
- // doPing checks last ping time and sends another ping.
- func (m *muxClient) doPing(respHandler chan<- Response) (ok bool) {
- m.respMu.Lock()
- if m.closed {
- m.respMu.Unlock()
- // Already closed. This is not an error state;
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.9K bytes - Viewed (0) -
android/guava/src/com/google/common/base/Verify.java
- * autoboxing and varargs array creation may happen as well, even when the verification succeeds and
- * the message ends up unneeded. Performance-sensitive verification checks should continue to use
- * usual form:
- *
- * <pre>{@code
- * Bill bill = remoteService.getLastUnpaidBill();
- * if (bill.status() != Status.UNPAID) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon May 17 14:07:47 UTC 2021 - 18.5K bytes - Viewed (0)