Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 103 for Farries (0.05 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. docs/bucket/versioning/DESIGN.md

    This file is the source of truth for each `version` at rest. `xl.meta` is a msgpack file serialized from a
    well defined data structure. To understand `xl.meta` here are the few things to start with
    
    `xl.meta` carries first 8 bytes an XL header which describes the current format and the format version,
    allowing the unmarshaller's to automatically use the right data structures to parse the subsequent content in the stream.
    
    ### v1.0
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jul 17 15:43:14 UTC 2022
    - 5.8K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top