Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 278 for segondas (0.07 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

        assertThrows(TimeoutException.class, () -> manager.awaitHealthy(1, MILLISECONDS));
        manager.awaitHealthy(5, SECONDS); // no exception thrown
    
        manager.stopAsync();
        assertThrows(TimeoutException.class, () -> manager.awaitStopped(1, MILLISECONDS));
        manager.awaitStopped(5, SECONDS); // no exception thrown
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 25.5K bytes
    - Viewed (0)
  2. okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceRecorder.kt

      private fun drainCancelQueue(eventSource: EventSource) {
        if (cancel) {
          cancel = false
          eventSource.cancel()
        }
      }
    
      private fun nextEvent(): Any {
        return events.poll(10, TimeUnit.SECONDS)
          ?: throw AssertionError("Timed out waiting for event.")
      }
    
      fun assertExhausted() {
        assertThat(events).isEmpty()
      }
    
      fun assertEvent(
        id: String?,
        type: String?,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  3. docs/sts/assume-role.go

    			if err != nil {
    				log.Fatalf("Error reading session policy file: %v", err)
    			}
    			policy = string(bs)
    		}
    		stsOpts.Policy = policy
    	}
    	if expiryDuration != 0 {
    		stsOpts.DurationSeconds = int(expiryDuration.Seconds())
    	}
    	li, err := cr.NewSTSAssumeRole(stsEndpoint, stsOpts)
    	if err != nil {
    		log.Fatalf("Error initializing STS Identity: %v", err)
    	}
    
    	stsEndpointURL, err := url.Parse(stsEndpoint)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Aug 17 01:24:54 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  4. cmd/update-notifier_test.go

    		{0, "another_update_url", ""},
    		{time.Hour, "", ""},
    		{0 * time.Second, "my_download_url", "now"},
    		{1 * time.Second, "my_download_url", "1 second before the latest release"},
    		{37 * time.Second, "my_download_url", "37 seconds before the latest release"},
    		{60 * time.Second, "my_download_url", "1 minute before the latest release"},
    		{61 * time.Second, "my_download_url", "1 minute before the latest release"},
    
    		// Testcase index 10
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 31 15:36:19 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  5. common-protos/k8s.io/apimachinery/pkg/apis/meta/v1/generated.proto

    // +protobuf.as=Timestamp
    // +protobuf.options.(gogoproto.goproto_stringer)=false
    message MicroTime {
      // Represents seconds of UTC time since Unix epoch
      // 1970-01-01T00:00:00Z. Must be from 0001-01-01T00:00:00Z to
      // 9999-12-31T23:59:59Z inclusive.
      optional int64 seconds = 1;
    
      // Non-negative fractions of a second at nanosecond resolution. Negative
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 53.3K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/base/FinalizableReferenceQueueClassLoaderUnloadingTest.java

    import static com.google.common.base.StandardSystemProperty.JAVA_SPECIFICATION_VERSION;
    import static com.google.common.base.StandardSystemProperty.PATH_SEPARATOR;
    import static java.util.concurrent.TimeUnit.SECONDS;
    
    import com.google.common.collect.ImmutableList;
    import com.google.common.testing.GcFinalization;
    import java.io.Closeable;
    import java.io.File;
    import java.lang.ref.WeakReference;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/internal/http/HttpDateTest.kt

        assertThat("Thu, 01 Jan 1970 00:00:00 GMT JUNK".toHttpDateOrNull()!!.time).isEqualTo(0L)
        // Missing timezones treated as bad.
        assertThat("Thu, 01 Jan 1970 00:00:00".toHttpDateOrNull()).isNull()
        // Missing seconds treated as bad.
        assertThat("Thu, 01 Jan 1970 00:00 GMT".toHttpDateOrNull()).isNull()
        // Extra spaces treated as bad.
        assertThat("Thu,  01 Jan 1970 00:00 GMT".toHttpDateOrNull()).isNull()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  8. mockwebserver/README.md

        .setBody("{}");
    ```
    
    MockResponse can be used to simulate a slow network. This is useful for
    testing timeouts and interactive testing.
    
    ```java
    response.throttleBody(1024, 1, TimeUnit.SECONDS);
    ```
    
    
    #### RecordedRequest
    
    Verify requests by their method, path, HTTP version, body, and headers.
    
    ```java
    RecordedRequest request = server.takeRequest();
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Dec 17 15:34:10 UTC 2023
    - 5K bytes
    - Viewed (0)
  9. internal/bucket/bandwidth/monitor_test.go

    	test1Want2[BucketOptions{Name: "bucket", ReplicationARN: "arn"}] = Details{
    		LimitInBytesPerSecond:            1024 * 1024,
    		CurrentBandwidthInBytesPerSecond: (1024 * 1024) / start.Add(2*time.Second).Sub(start.Add(1*time.Second)).Seconds(),
    	}
    
    	test2Want := make(map[BucketOptions]Details)
    	test2Want[BucketOptions{Name: "bucket", ReplicationARN: "arn"}] = Details{LimitInBytesPerSecond: 1024 * 1024, CurrentBandwidthInBytesPerSecond: float64(oneMiB)}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 06 03:21:59 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  10. cmd/perf-tests.go

    	if delta < 0 {
    		rx = 0
    		errStr = "network disconnection issues detected"
    	}
    
    	globalNetPerfRX.Reset()
    	return madmin.NetperfNodeResult{Endpoint: "", TX: r.n / uint64(duration.Seconds()), RX: uint64(rx / delta.Seconds()), Error: errStr}
    }
    
    func siteNetperf(ctx context.Context, duration time.Duration) madmin.SiteNetPerfNodeResult {
    	r := &netperfReader{eof: make(chan struct{})}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.8K bytes
    - Viewed (0)
Back to top