Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 28 for sends (0.02 sec)

  1. cmd/peer-rest-server.go

    		}
    		if err != nil {
    			return np, grid.NewRemoteErr(err)
    		}
    	default:
    		return np, grid.NewRemoteErr(errUnsupportedSignal)
    	}
    	return np, nil
    }
    
    // ListenHandler sends http trace messages back to peer rest client
    func (s *peerRESTServer) ListenHandler(ctx context.Context, v *grid.URLValues, out chan<- *grid.Bytes) *grid.RemoteErr {
    	values := v.Values()
    	defer v.Recycle()
    	var prefix string
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 53.4K bytes
    - Viewed (0)
  2. docs/bucket/notifications/README.md

    Bucket events can be published to the following targets:
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 84.2K bytes
    - Viewed (0)
  3. cmd/api-errors.go

    		case *googleapi.Error:
    			apiErr = APIError{
    				Code:           "XGCSInternalError",
    				Description:    e.Message,
    				HTTPStatusCode: e.Code,
    			}
    			// GCS may send multiple errors, just pick the first one
    			// since S3 only sends one Error XML response.
    			if len(e.Errors) >= 1 {
    				apiErr.Code = e.Errors[0].Reason
    			}
    		case *azcore.ResponseError:
    			apiErr = APIError{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 16 07:34:24 UTC 2025
    - 93K bytes
    - Viewed (1)
  4. 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
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 75.5K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool.go

    					perDiskLimit:   opts.Limit,
    					minDisks:       listingQuorum,
    					reportNotFound: false,
    					agreed:         send,
    					partial: func(entries metaCacheEntries, _ []error) {
    						entry, ok := entries.resolve(&resolver)
    						if ok {
    							send(*entry)
    						}
    					},
    					finished: nil,
    				}
    
    				if err := listPathRaw(ctx, lopts); err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
  6. cmd/iam.go

    	// SPECIAL CASE: For service accounts, any valid JSON is allowed as a
    	// policy, regardless of whether the number of statements is 0, this
    	// includes `null`, `{}` and `{"Statement": null}`. In fact, MinIO Console
    	// sends `null` when no policy is set and the intended behavior is that the
    	// service account should inherit parent policy.
    	//
    	// However, for a policy like `{"Statement":[]}`, the intention is to not
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 75.3K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb/SmbSessionImpl.java

        }
    
        <T extends CommonServerMessageBlockResponse> T send(CommonServerMessageBlockRequest request, T response) throws CIFSException {
            return send(request, response, Collections.<RequestParam> emptySet());
        }
    
        <T extends CommonServerMessageBlockResponse> T send(CommonServerMessageBlockRequest request, T response, Set<RequestParam> params)
                throws CIFSException {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 68.9K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb/SmbTransportImpl.java

            throw new DfsReferral(dr);
        }
    
        <T extends CommonServerMessageBlockResponse> T send(final CommonServerMessageBlockRequest request, final T response)
                throws SmbException {
            return send(request, response, Collections.<RequestParam> emptySet());
        }
    
        <T extends CommonServerMessageBlockResponse> T send(final CommonServerMessageBlockRequest request, T response,
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 69.8K bytes
    - Viewed (0)
  9. 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
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Feb 06 14:55:54 UTC 2022
    - 50.8K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt

    import okhttp3.internal.ws.RealWebSocket
    import okio.Sink
    import okio.Source
    import org.codehaus.mojo.animal_sniffer.IgnoreJRERequirement
    
    /**
     * Factory for [calls][Call], which can be used to send HTTP requests and read their responses.
     *
     * ## OkHttpClients Should Be Shared
     *
     * OkHttp performs best when you create a single `OkHttpClient` instance and reuse it for all of
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon May 05 16:01:00 UTC 2025
    - 51.7K bytes
    - Viewed (0)
Back to top