Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 83 for Farries (0.14 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/http/ExchangeCodec.kt

       * That may happen later by the connection pool thread.
       */
      fun cancel()
    
      /**
       * Carries an exchange. This is usually a connection, but it could also be a connect plan for
       * CONNECT tunnels. Note that CONNECT tunnels are significantly less capable than connections.
       */
      interface Carrier {
        val route: Route
    
        fun trackFailure(
          call: RealCall,
          e: IOException?,
        )
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3K bytes
    - Viewed (0)
  2. okhttp/src/test/resources/okhttp3/internal/publicsuffix/public_suffix_list.dat

    // Rad Web Hosting: https://radwebhosting.com
    // Submitted by Scott Claeys <******@****.***>
    cloudsite.builders
    
    // Redgate Software: https://red-gate.com
    // Submitted by Andrew Farries <andrew.farries@red-gate.com>
    instances.spawn.cc
    
    // Redstar Consultants : https://www.redstarconsultants.com/
    // Submitted by Jons Slemmer <******@****.***>
    instantcloud.cn
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Dec 20 23:27:07 UTC 2023
    - 240.3K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/http2/FlowControlListener.kt

       * [WindowCounter] generally carries the client view of total and acked bytes.
       */
      fun receivingStreamWindowChanged(
        streamId: Int,
        windowCounter: WindowCounter,
        bufferSize: Long,
      )
    
      /**
       * Notification that the receiving connection flow control window has changed.
       * [WindowCounter] generally carries the client view of total and acked bytes.
       */
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt

      private var refusedStreamCount = 0
    
      /**
       * The maximum number of concurrent streams that can be carried by this connection. If
       * `allocations.size() < allocationLimit` then new streams can be created on this connection.
       */
      internal var allocationLimit = 1
        private set
    
      /** Current calls carried by this connection. */
      val calls = mutableListOf<Reference<RealCall>>()
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        }
        final CyclicBarrier barrier =
            new CyclicBarrier(
                6 // for the setter threads
                    + 50 // for the listeners
                    + 50 // for the blocking get threads,
                    + 1); // for the main thread
        final ExecutorService executor = Executors.newFixedThreadPool(barrier.getParties());
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 47.1K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

          barrier.await(1, SECONDS);
          executor.execute(barrierTask);
          // timeout means the second task wasn't even tried
          barrier.await(1, SECONDS);
        } finally {
          service.shutdown();
        }
      }
    
      public void testRejectedExecutionThrownWithMultipleCalls() throws Exception {
        final CountDownLatch latch = new CountDownLatch(1);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java

                    }
                  });
          final CyclicBarrier barrier = new CyclicBarrier(numThreads + 1);
          Runnable wrapper =
              new Runnable() {
                @Override
                public void run() {
                  awaitUnchecked(barrier);
                  task.run();
                  awaitUnchecked(barrier);
                }
              };
          for (int j = 0; j < 10; j++) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 15:41:36 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

     */
    class Http1ExchangeCodec(
      /** The client that configures this stream. May be null for HTTPS proxy tunnels. */
      private val client: OkHttpClient?,
      override val carrier: ExchangeCodec.Carrier,
      private val source: BufferedSource,
      private val sink: BufferedSink,
    ) : ExchangeCodec {
      private var state = STATE_IDLE
      private val headersReader = HeadersReader(source)
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  9. cmd/format-erasure.go

    type formatErasureV1 struct {
    	formatMetaV1
    	Erasure struct {
    		Version string `json:"version"` // Version of 'xl' format.
    		Disk    string `json:"drive"`   // Disk field carries assigned disk uuid.
    		// JBOD field carries the input disk order generated the first
    		// time when fresh disks were supplied.
    		JBOD []string `json:"jbod"`
    	} `json:"xl"` // Erasure field holds xl format.
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

          barrier.await(1, SECONDS);
          executor.execute(barrierTask);
          // timeout means the second task wasn't even tried
          barrier.await(1, SECONDS);
        } finally {
          service.shutdown();
        }
      }
    
      public void testRejectedExecutionThrownWithMultipleCalls() throws Exception {
        final CountDownLatch latch = new CountDownLatch(1);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 11.4K bytes
    - Viewed (0)
Back to top