Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 28 for 500ms (0.02 sec)

  1. okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt

        client.processNextFrame()
    
        // After 500ms the client automatically pings and the server pongs back.
        taskFaker.advanceUntil(ns(500L))
        server.processNextFrame() // Ping.
        client.processNextFrame() // Pong.
    
        // After 1000ms the client will attempt a ping 2, but we don't process it. That'll cause the
        // client to fail at 1500ms when it's time to send ping 3 because pong 2 hasn't been received.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 01:59:58 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  2. cmd/batch-expire_test.go

        token: Bearer xxxxx # optional authentication token for the notification endpoint
      
      retry:
        attempts: 10 # number of retries for the job before giving up
        delay: 500ms # least amount of delay between each retry
    `
    	var job BatchJobRequest
    	err := yaml.Unmarshal([]byte(expireYaml), &job)
    	if err != nil {
    		t.Fatal("Failed to parse batch-job-expire yaml", err)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 01 12:53:30 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  3. cmd/batch-replicate_test.go

    #      token: "Bearer xxxxx" # optional authentication token for the notification endpoint
    #
    #    retry:
    #      attempts: 10 # number of retries for the job before giving up
    #      delay: "500ms" # least amount of delay between each retry
    
    `
    	var job BatchJobRequest
    	err := yaml.Unmarshal([]byte(replicateYaml), &job)
    	if err != nil {
    		t.Fatal("Failed to parse batch-job-replicate yaml", err)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 01 12:53:30 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  4. mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt

        }
        server.url("/b").toUrl().openConnection().getInputStream() // Should succeed.
      }
    
      /**
       * Throttle the request body by sleeping 500ms after every 3 bytes. With a 6-byte request, this
       * should yield one sleep for a total delay of 500ms.
       */
      @Test
      fun throttleRequest() {
        assumeNotWindows()
        server.enqueue(
          MockResponse()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  5. mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt

        assertThat(inputStream!!.read()).isEqualTo('B'.code)
      }
    
      /**
       * Throttle the request body by sleeping 500ms after every 3 bytes. With a 6-byte request, this
       * should yield one sleep for a total delay of 500ms.
       */
      @Test
      fun throttleRequest() {
        assumeNotWindows()
        server.enqueue(
          MockResponse.Builder()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 23.5K bytes
    - Viewed (0)
  6. docs/batch-jobs/README.md

    	  token: "Bearer xxxxx" # optional authentication token for the notification endpoint
    
    	retry:
    	  attempts: 10 # number of retries for the job before giving up
    	  delay: "500ms" # least amount of delay between each retry
    ```
    
    You can create and run multiple 'replication' jobs at a time there are no predefined limits set.
    
    ## Batch Jobs Terminology
    
    ### Job
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 06 06:00:43 UTC 2022
    - 4.8K bytes
    - Viewed (0)
  7. cmd/batch-rotate.go

    //     token: "Bearer xxxxx" # optional authentication token for the notification endpoint
    
    //   retry:
    //     attempts: 10 # number of retries for the job before giving up
    //     delay: "500ms" # least amount of delay between each retry
    
    //go:generate msgp -file $GOFILE -unexported
    
    // BatchKeyRotationType defines key rotation type
    type BatchKeyRotationType string
    
    const (
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt

        val openAtNanos = System.nanoTime()
        newWebSocket()
        clientListener.assertOpen()
        clientListener.assertFailure(
          SocketTimeoutException::class.java,
          "sent ping but didn't receive pong within 500ms (after 0 successful ping/pongs)",
        )
        latch.countDown()
        val elapsedUntilFailure = System.nanoTime() - openAtNanos
        assertThat(TimeUnit.NANOSECONDS.toMillis(elapsedUntilFailure).toDouble())
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 35.2K bytes
    - Viewed (0)
  9. cmd/batch-expire.go

    //     token: Bearer xxxxx # optional authentication token for the notification endpoint
    //
    //   retry:
    //     attempts: 10 # number of retries for the job before giving up
    //     delay: 500ms # least amount of delay between each retry
    
    //go:generate msgp -file $GOFILE
    
    // BatchJobExpirePurge type accepts non-negative versions to be retained
    type BatchJobExpirePurge struct {
    	line, col      int
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  10. src/main/resources/fess_config.properties

    crawler.ignore.robots.tags=false
    crawler.ignore.content.exception=true
    crawler.failure.url.status.codes=404
    crawler.system.monitor.interval=60
    crawler.hotthread.ignore_idle_threads=true
    crawler.hotthread.interval=500ms
    crawler.hotthread.snapshots=10
    crawler.hotthread.threads=3
    crawler.hotthread.timeout=30s
    crawler.hotthread.type=cpu
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Tue Oct 01 14:13:38 UTC 2024
    - 30.9K bytes
    - Viewed (0)
Back to top