Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 59 for timeEnd (0.12 sec)

  1. cmd/admin-handlers.go

    	if err != nil {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(toAPIErrorCode(ctx, err)), r.URL)
    		return
    	}
    	ctx = lkctx.Context()
    	defer nsLock.Unlock(lkctx)
    	timeEnd := time.Now()
    
    	atomic.SwapInt64(&globalLastClientPerfExtraTime, timeEnd.Sub(timeStart).Nanoseconds())
    
    	ctx, cancel := context.WithTimeout(ctx, madmin.MaxClientPerfTimeout)
    	defer cancel()
    	totalRx := int64(0)
    	connectTime := time.Now()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/AutobahnTester.kt

              response: Response?,
            ) {
              t.printStackTrace(System.out)
              latch.countDown()
            }
          },
        )
    
        check(latch.await(30, TimeUnit.SECONDS)) { "Timed out waiting for test $number to finish." }
        val endNanos = System.nanoTime()
        val tookMs = TimeUnit.NANOSECONDS.toMillis(endNanos - startNanos.get())
        println("Took ${tookMs}ms")
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  3. docs/en/docs/js/custom.js

                            useLines.push({
                                type: "input",
                                value: value
                            });
                        } else if (line.startsWith("// ")) {
                            saveBuffer();
                            const value = "💬 " + line.replace("// ", "").trimEnd();
                            useLines.push({
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  4. android/guava-testlib/src/com/google/common/testing/GcFinalization.java

      }
    
      /**
       * Waits until the given future {@linkplain Future#isDone is done}, invoking the garbage collector
       * as necessary to try to ensure that this will happen.
       *
       * @throws RuntimeException if timed out or interrupted while waiting
       */
      @SuppressWarnings("removal") // b/260137033
      public static void awaitDone(Future<?> future) {
        if (future.isDone()) {
          return;
        }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  5. guava-testlib/src/com/google/common/testing/GcFinalization.java

      }
    
      /**
       * Waits until the given future {@linkplain Future#isDone is done}, invoking the garbage collector
       * as necessary to try to ensure that this will happen.
       *
       * @throws RuntimeException if timed out or interrupted while waiting
       */
      @SuppressWarnings("removal") // b/260137033
      public static void awaitDone(Future<?> future) {
        if (future.isDone()) {
          return;
        }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  6. cni/pkg/install/cniconfig_test.go

    				result, err := getCNIConfigFilepath(ctx1, c.specifiedConfName, tempDir, c.chainedCNIPlugin)
    				if err != nil {
    					assert.Equal(t, result, "")
    					if err == context.DeadlineExceeded {
    						t.Fatalf("timed out waiting for expected %s", expectedFilepath)
    					}
    					t.Fatal(err)
    				}
    				if result != expectedFilepath {
    					t.Fatalf("expected %s, got %s", expectedFilepath, result)
    				}
    				// Successful test case
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 18:38:14 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/AbstractService.java

          // timed out. e.g. if we weren't event able to grab the lock within the timeout we would never
          // even check the guard. I don't think we care too much about this use case but it could lead
          // to a confusing error message.
          throw new TimeoutException("Timed out waiting for " + this + " to reach the RUNNING state.");
        }
      }
    
      @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.7K bytes
    - Viewed (0)
  8. cni/pkg/install/install_test.go

    				assert.Equal(t, isReady.Load(), true)
    			case err := <-errChan:
    				if err == nil {
    					t.Fatal("invalid configuration detected")
    				}
    				t.Fatal(err)
    			case <-time.After(5 * time.Second):
    				t.Fatal("timed out waiting for isReady to be set to true")
    			}
    
    			// Change SA token
    			if len(c.saNewFilename) > 0 {
    				t.Log("Expecting detect changes to the SA token")
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/MoreExecutors.java

          ListeningExecutorService executorService,
          Collection<? extends Callable<T>> tasks,
          boolean timed,
          Duration timeout)
          throws InterruptedException, ExecutionException, TimeoutException {
        return invokeAnyImpl(
            executorService, tasks, timed, toNanosSaturated(timeout), TimeUnit.NANOSECONDS);
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 44.1K bytes
    - Viewed (0)
  10. build-logic/binary-compatibility/src/main/kotlin/gradlebuild/binarycompatibility/sources/KotlinSourceQueries.kt

        if (ktTypeAsText.contains(" -> ")) {
            // This is a function of some sort
            return name.startsWith("kotlin.jvm.functions.Function")
        }
    
        val ktTypeRawName = ktTypeAsText
            .trimEnd('?') // nullability is not part of JVM types
            .substringBefore('<') // generics are not part of parameter types in JVM method signatures
    
        val thisTypeAsKt = primitiveTypeStrings[name] ?: name
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Thu Jul 04 08:05:22 UTC 2024
    - 11.2K bytes
    - Viewed (0)
Back to top