Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 1,884 for just (0.06 sec)

  1. istioctl/pkg/util/configdump/route.go

    			}
    		}
    	}
    	if lastUpdated.After(time.Unix(0, 0)) { // if a timestamp was obtained from a drc
    		return &lastUpdated, nil
    	}
    	return nil, nil
    }
    
    // GetDynamicRouteDump retrieves a route dump with just dynamic active routes in it
    func (w *Wrapper) GetDynamicRouteDump(stripVersions bool) (*admin.RoutesConfigDump, error) {
    	routeDump, err := w.GetRouteConfigDump()
    	if err != nil {
    		return nil, err
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Nov 03 08:41:32 UTC 2022
    - 3.2K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/connection/RoutePlanner.kt

       * non-null, it should be reported to the user should all further attempts fail.
       *
       * The two values are independent: results can contain both (recoverable error), neither
       * (success), just an exception (permanent failure), or just a plan (non-exceptional retry).
       */
      data class ConnectResult(
        val plan: Plan,
        val nextPlan: Plan? = null,
        val throwable: Throwable? = null,
      ) {
        val isSuccess: Boolean
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Dec 20 23:27:07 UTC 2023
    - 4.2K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java

        }
    
        @Override
        public void run() {
          while (true) {
            try {
              Thread.sleep(everyMillis);
            } catch (InterruptedException e) {
              // ok. just stop sleeping.
            }
            if (shouldStop) {
              break;
            }
            interruptee.interrupt();
          }
        }
    
        void stopInterrupting() {
          shouldStop = true;
        }
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 4.4K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/informers.go

    		// Existing pods will be handled by the dataplane using `GetAmbientPods`,
    		// and the initial enqueueNamespace, and new pods will be handled by the CNI.
    
    	case controllers.EventUpdate:
    		// For update, we just need to handle opt outs
    		newPod := event.New.(*corev1.Pod)
    		oldPod := event.Old.(*corev1.Pod)
    		ns := s.namespaces.Get(newPod.Namespace, "")
    		if ns == nil {
    			return fmt.Errorf("failed to find namespace %v", ns)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  5. docs/en/docs/how-to/custom-request-and-route.md

    For example, if you want to read or manipulate the request body before it is processed by your application.
    
    /// danger
    
    This is an "advanced" feature.
    
    If you are just starting with **FastAPI** you might want to skip this section.
    
    ///
    
    ## Use cases
    
    Some use cases include:
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 27 22:39:38 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/io/MultiInputStreamTest.java

        // https://github.com/google/guava/issues/2996
        // no data, just testing that there's no StackOverflowException
        assertEquals(-1, tenMillionEmptySources().read());
      }
    
      public void testReadArray_noStackOverflow() throws IOException {
        // https://github.com/google/guava/issues/2996
        // no data, just testing that there's no StackOverflowException
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 4.6K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/Uninterruptibles.java

        try {
          long remainingNanos = unit.toNanos(timeout);
          long end = System.nanoTime() + remainingNanos;
    
          while (true) {
            try {
              // CountDownLatch treats negative timeouts just like zero.
              return latch.await(remainingNanos, NANOSECONDS);
            } catch (InterruptedException e) {
              interrupted = true;
              remainingNanos = end - System.nanoTime();
            }
          }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 19.1K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/EventListener.kt

       */
      open fun proxySelectEnd(
        call: Call,
        url: HttpUrl,
        proxies: List<@JvmSuppressWildcards Proxy>,
      ) {
      }
    
      /**
       * Invoked just prior to a DNS lookup. See [Dns.lookup].
       *
       * This can be invoked more than 1 time for a single [Call]. For example, if the response to the
       * [Call.request] is a redirect to a different host.
       *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 15.2K bytes
    - Viewed (0)
  9. guava-testlib/src/com/google/common/testing/FreshValueGenerator.java

        return freshness.get();
      }
    
      @SuppressWarnings("removal") // b/321209431 -- maybe just use valueOf here?
      @Generates
      Integer generateInteger() {
        return new Integer(generateInt());
      }
    
      @Generates
      long generateLong() {
        return generateInt();
      }
    
      @SuppressWarnings("removal") // b/321209431 -- maybe just use valueOf here?
      @Generates
      Long generateLongObject() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:22:54 UTC 2024
    - 28.7K bytes
    - Viewed (0)
  10. docs/en/docs/tutorial/handling-errors.md

    ```Python hl_lines="2-5  15  21"
    {!../../docs_src/handling_errors/tutorial006.py!}
    ```
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 9.1K bytes
    - Viewed (0)
Back to top