Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 331 - 340 of 507 for send0 (0.07 seconds)

  1. src/main/java/jcifs/internal/smb2/multichannel/ChannelFailover.java

                    alternativeChannel.addPendingOperation(op);
                    // Operation would be resent on alternative channel
                    // For now, skip actual send implementation
                } catch (Exception e) {
                    log.error("Failed to redistribute operation", e);
                    // Notify waiting threads of failure if the operation supports it
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 21 11:13:46 GMT 2025
    - 11.6K bytes
    - Click Count (0)
  2. cmd/signature-v4-parser.go

    	// credElement is fetched first to skip replacing the space in access key.
    	credElement := strings.TrimPrefix(strings.Split(strings.TrimSpace(v4Auth), ",")[0], signV4Algorithm)
    	// Replace all spaced strings, some clients can send spaced
    	// parameters and some won't. So we pro-actively remove any spaces
    	// to make parsing easier.
    	v4Auth = strings.ReplaceAll(v4Auth, " ", "")
    	if v4Auth == "" {
    		return sv, ErrAuthHeaderEmpty
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Oct 10 18:57:35 GMT 2025
    - 9.4K bytes
    - Click Count (0)
  3. internal/grid/msg.go

    	OpConnect Op = iota + 1
    
    	// OpConnectResponse is a response to a connect request.
    	OpConnectResponse
    
    	// OpPing is a ping request.
    	// If a mux id is specified that mux is pinged.
    	// Clients send ping requests.
    	OpPing
    
    	// OpPong is a OpPing response returned by the server.
    	OpPong
    
    	// OpConnectMux will connect a new mux with optional payload.
    	OpConnectMux
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Jul 25 21:07:21 GMT 2024
    - 7.6K bytes
    - Click Count (0)
  4. docs/changelogs/changelog_3x.md

     *  **Web Sockets are now a stable feature of OkHttp.** Since being introduced as a beta feature in
        OkHttp 2.3 our web socket client has matured. Connect to a server's web socket with
        `OkHttpClient.newWebSocket()`, send messages with `send()`, and receive messages with the
        `WebSocketListener`.
    
        The `okhttp-ws` submodule is no longer available and `okhttp-ws` artifacts from previous
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Feb 06 14:55:54 GMT 2022
    - 50.8K bytes
    - Click Count (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt

        assertThat(synStream.outFinished).isFalse()
        val ping = peer.takeFrame()
        assertThat(ping.type).isEqualTo(Http2.TYPE_PING)
      }
    
      /**
       * Test that the client sends a RST_STREAM if doing so won't disrupt the output stream.
       */
      @Test fun clientClosesClientInputStream() {
        // Write the mocking script.
        peer.sendFrame().settings(Settings())
        peer.acceptFrame() // ACK
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 75.5K bytes
    - Click Count (0)
  6. docs/en/docs/tutorial/security/get-current-user.md

    ## Recap { #recap }
    
    You can now get the current user directly in your *path operation function*.
    
    We are already halfway there.
    
    We just need to add a *path operation* for the user/client to actually send the `username` and `password`.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Feb 12 13:19:43 GMT 2026
    - 4K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/util/concurrent/TestThread.java

       */
      public void assertPriorCallReturns(boolean expected, @Nullable String methodName)
          throws Exception {
        assertEquals(expected, getResponse(methodName).getResult());
      }
    
      /**
       * Sends the given method call to this thread.
       *
       * @throws TimeoutException if this thread does not accept the request within a reasonable amount
       *     of time
       */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 11.5K bytes
    - Click Count (0)
  8. src/main/java/jcifs/smb1/smb1/AndXServerMessageBlock.java

             * response will not read a batched command and therefore
             * the 'received' member of the response object will not
             * be set to true indicating the send and sendTransaction
             * methods that the next part should be sent. This is a
             * very indirect and simple batching control mechanism.
             */
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 10.9K bytes
    - Click Count (0)
  9. src/main/java/jcifs/http/NtlmHttpURLConnection.java

                while (attempt < MAX_REDIRECTS) {
                    this.connection.setRequestProperty(this.authProperty, this.authMethod + ' ' + Base64.toBase64String(type1.toByteArray()));
                    this.connection.connect(); // send type 1
                    response = parseResponseCode();
                    if (response != HTTP_UNAUTHORIZED && response != HTTP_PROXY_AUTH) {
                        return;
                    }
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 25.6K bytes
    - Click Count (0)
  10. docs/pt/docs/deployment/docker.md

    Em contraste com a "**imagem de contêiner**" que contém os conteúdos estáticos armazenados, um "**contêiner**" normalmente se refere à instância rodando, a coisa que está sendo **executada**.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:20:43 GMT 2026
    - 30.9K bytes
    - Click Count (0)
Back to Top