Search Options

Results per page
Sort
Preferred Languages
Advance

Results 191 - 200 of 1,849 for receive (1.41 sec)

  1. fastapi/applications.py

                self.add_route(self.redoc_url, redoc_html, include_in_schema=False)
    
        async def __call__(self, scope: Scope, receive: Receive, send: Send) -> None:
            if self.root_path:
                scope["root_path"] = self.root_path
            await super().__call__(scope, receive, send)
    
        def add_api_route(
            self,
            path: str,
            endpoint: Callable[..., Any],
            *,
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Dec 17 21:25:59 UTC 2025
    - 176.3K bytes
    - Viewed (0)
  2. cmd/erasure-healing.go

    			// written to for remaining parts, so we nil it out.
    			for i, disk := range outDatedDisks {
    				if disk == OfflineDisk {
    					continue
    				}
    
    				// A non-nil stale disk which did not receive
    				// a healed part checksum had a write error.
    				if writers[i] == nil {
    					outDatedDisks[i] = nil
    					disksToHealCount--
    					continue
    				}
    
    				// A non-nil stale disk which got error on Close()
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 34.7K bytes
    - Viewed (0)
  3. api/maven-api-core/src/main/java/org/apache/maven/api/Session.java

         */
        @Nonnull
        Session withRemoteRepositories(@Nonnull List<RemoteRepository> repositories);
    
        /**
         * Register the given listener which will receive all events.
         *
         * @param listener the listener to register
         * @throws NullPointerException if {@code listener} is null
         */
        void registerListener(@Nonnull Listener listener);
    
        /**
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Thu Jul 03 14:18:26 UTC 2025
    - 36.5K bytes
    - Viewed (0)
  4. cmd/server-main.go

    //   - The returned List needs to be deduplicated as well.
    func getServerListenAddrs() []string {
    	// Use a string set to avoid duplication
    	addrs := set.NewStringSet()
    	// Listen on local interface to receive requests from Console
    	for _, ip := range localLoopbacks.ToSlice() {
    		addrs.Add(net.JoinHostPort(ip, globalMinioPort))
    	}
    	host, _ := mustSplitHostPort(globalMinioAddr)
    	if host != "" {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:18:36 UTC 2025
    - 35.9K bytes
    - Viewed (4)
  5. guava/src/com/google/common/net/InetAddresses.java

     * </dl>
     *
     * <p>A few notes about IPv6 "IPv4 mapped" addresses and their observed use in Java.
     *
     * <p>"IPv4 mapped" addresses were originally a representation of IPv4 addresses for use on an IPv6
     * socket that could receive both IPv4 and IPv6 connections (by disabling the {@code IPV6_V6ONLY}
     * socket option on an IPv6 socket). Yes, it's confusing. Nevertheless, these "mapped" addresses
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 47.4K bytes
    - Viewed (0)
  6. CHANGELOG.md

        receiving stream to process it.
    
        This change may increase OkHttp's memory use for applications that make many concurrent HTTP
        calls and that can receive data faster than they can process it. Previously, OkHttp limited
        HTTP/2 to 16 MiB of unacknowledged data per connection. With this fix there is a limit of 16 MiB
        of unacknowledged data per stream and no per-connection limit.
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 05 16:02:59 UTC 2025
    - 36.2K bytes
    - Viewed (2)
  7. cmd/encryption-v1.go

    	mac := hmac.New(sha256.New, d.objectEncryptionKey) // derive part encryption key from part ID and object key
    	mac.Write(partIDbin[:])
    	partEncryptionKey := mac.Sum(nil)
    
    	// Limit the reader, so the decryptor doesn't receive bytes
    	// from the next part (different DARE stream)
    	encLenToRead := d.parts[d.partIndex].Size - d.partEncRelOffset
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 38K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb/SmbTransportImpl.java

                     */
    
                    do {
                        doSend0(req);
                    } while (req.hasMoreElements() && req.nextElement() != null);
    
                    /*
                     * Receive multiple fragments
                     */
                    synchronized (resp) {
                        while (!resp.isReceived() || resp.hasMoreElements()) {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 69.8K bytes
    - Viewed (0)
  9. cmd/bucket-replication.go

    	ReplicationTimestamp = "replication-timestamp"
    	// ReplicaStatus - this header is present if a replica was received by this cluster for this object version
    	ReplicaStatus = "replica-status"
    	// ReplicaTimestamp - the last time a replica was received by this cluster for this object version
    	ReplicaTimestamp = "replica-timestamp"
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 118.2K bytes
    - Viewed (0)
  10. CHANGELOG/CHANGELOG-1.2.md

    headers are now properly handled as per the HTTP spec.  As a consequence, if
    you had a client that was sending an invalid Content-Type or Accept header to
    the API, in 1.2 you will either receive a 415 or 406 error.
    The only client
    this is known to affect is curl when you use -d with JSON but don't set a
    content type, helpfully sends "application/x-www-urlencoded", which is not
    correct.
    Registered: Fri Dec 26 09:05:12 UTC 2025
    - Last Modified: Fri Dec 04 06:36:19 UTC 2020
    - 41.4K bytes
    - Viewed (0)
Back to top