Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 141 - 150 of 263 for dispatch (0.05 seconds)

  1. android/guava/src/com/google/common/graph/GraphConstants.java

              + "adjacentNode(node) if you already have a node, or nodeU()/nodeV() if you don't.";
      static final String EDGE_ALREADY_EXISTS = "Edge %s already exists in the graph.";
      static final String ENDPOINTS_MISMATCH =
          "Mismatch: endpoints' ordering is not compatible with directionality of the graph";
    
      /** Singleton edge value for {@link Graph} implementations backed by {@link ValueGraph}s. */
      enum Presence {
        EDGE_EXISTS
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Jan 18 02:54:30 GMT 2025
    - 3.1K bytes
    - Click Count (0)
  2. scripts/tests/test_translation_fixer/test_complex_doc/data/en_doc.md

    The following code block uses quadruple backticks.
    
    ````python
    # Hello world function
    def hello_world():
        print("Hello, world!")  # Print greeting
    ````
    
    ### Backticks number mismatch is fixable { #backticks-number-mismatch-is-fixable }
    
    The following code block has triple backticks in the original document, but quadruple backticks in the translated document.
    It will be fixed by the fixer tool (will convert to triple backticks).
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Tue Feb 17 08:08:04 GMT 2026
    - 7.6K bytes
    - Click Count (0)
  3. okhttp-dnsoverhttps/src/test/java/okhttp3/dnsoverhttps/TestDohMain.kt

            http2Only = true,
            workingOnly = true,
            getOnly = true,
          )
        runBatch(dnsProviders, names)
      } finally {
        bootstrapClient.connectionPool.evictAll()
        bootstrapClient.dispatcher.executorService.shutdownNow()
        bootstrapClient.cache?.close()
      }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 3.2K bytes
    - Click Count (0)
  4. internal/crypto/header_test.go

    )
    
    func TestIsRequested(t *testing.T) {
    	for i, test := range kmsIsRequestedTests {
    		_, got := IsRequested(test.Header)
    		if Requested(test.Header) != got {
    			// Test if result matches.
    			t.Errorf("Requested mismatch, want %v, got %v", Requested(test.Header), got)
    		}
    		got = got && S3KMS.IsRequested(test.Header)
    		if got != test.Expected {
    			t.Errorf("SSE-KMS: Test %d: Wanted %v but got %v", i, test.Expected, got)
    		}
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Jul 13 14:52:15 GMT 2022
    - 21.4K bytes
    - Click Count (0)
  5. src/test/java/jcifs/EncodableTest.java

            // Assert: copied region equals the source slice.
            for (int i = 0; i < len; i++) {
                assertEquals(src[off + i], dst[dstIndex + i], "Byte mismatch at " + i);
            }
    
            // Assert: bytes before and after region remain unchanged.
            for (int i = 0; i < dstIndex; i++) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/TestTls13Request.kt

        .build()
    
    private fun testClient(
      urls: List<String>,
      client: OkHttpClient,
    ) {
      try {
        for (url in urls) {
          sendRequest(client, url)
        }
      } finally {
        client.dispatcher.executorService.shutdownNow()
        client.connectionPool.evictAll()
      }
    }
    
    private fun buildClient(vararg specs: ConnectionSpec): OkHttpClient =
      OkHttpClient
        .Builder()
        .connectionSpecs(listOf(*specs))
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu May 22 14:39:30 GMT 2025
    - 3.6K bytes
    - Click Count (0)
  7. src/test/java/jcifs/smb/SSPContextTest.java

                }
                byte[] expected = calculateMIC(data);
                if (mic.length != expected.length || mic[0] != expected[0]) {
                    throw new CIFSException("MIC mismatch");
                }
            }
    
            @Override
            public boolean isMICAvailable() {
                // Available if context is established and integrity is supported
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 15.2K bytes
    - Click Count (0)
  8. internal/grid/muxserver.go

    func (m *muxServer) checkSeq(seq uint32) (ok bool) {
    	if seq != m.RecvSeq {
    		if debugPrint {
    			fmt.Printf("expected sequence %d, got %d\n", m.RecvSeq, seq)
    		}
    		m.disconnect(fmt.Sprintf("receive sequence number mismatch. want %d, got %d", m.RecvSeq, seq), false)
    		return false
    	}
    	m.RecvSeq++
    	return true
    }
    
    func (m *muxServer) message(msg message) {
    	if debugPrint {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 9.7K bytes
    - Click Count (0)
  9. tests/chainable_api_test.go

    	if len(tx.Statement.Joins) == 0 {
    		t.Fatalf("Joins expected")
    	}
    	if tx.Statement.Joins[0].Name != "JOIN accounts ON accounts.user_id = users.id" {
    		t.Fatalf("Join name mismatch: %v", tx.Statement.Joins[0].Name)
    	}
    
    	// Preload
    	tx = tx.Preload("Orders", "state != ?", "cancelled")
    	args, ok := tx.Statement.Preloads["Orders"]
    	if !ok || len(args) != 2 {
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sat Jan 31 08:39:40 GMT 2026
    - 3.9K bytes
    - Click Count (0)
  10. docs/changelogs/changelog_2x.md

     *  New: `Headers.toMultimap()`.
     *  New: `RequestBody.create(MediaType, ByteString)`.
     *  New: `ConnectionSpec.isCompatible(SSLSocket)`.
     *  New: `Dispatcher.getQueuedCallCount()` and
        `Dispatcher.getRunningCallCount()`. These can be useful in diagnostics.
     *  Fix: OkHttp no longer shares timeouts between pooled connections. This was
        causing some applications to crash when connections were reused.
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Feb 06 02:19:09 GMT 2022
    - 26.6K bytes
    - Click Count (0)
Back to Top