Search Options

Results per page
Sort
Preferred Languages
Advance

Results 531 - 540 of 777 for callee (0.09 sec)

  1. internal/grid/manager.go

    			}
    			w.WriteHeader(http.StatusUpgradeRequired)
    			return
    		}
    		m.IncomingConn(ctx, conn)
    	}
    }
    
    // IncomingConn will handle an incoming connection.
    // This should be called with the incoming connection after accept.
    // Auth is handled internally, as well as disconnecting any connections from the same host.
    func (m *Manager) IncomingConn(ctx context.Context, conn net.Conn) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  2. docs/bucket/versioning/README.md

    To permanently delete an object you need to specify the version you want to delete, only the user with appropriate permissions can permanently delete a version.  As shown below DELETE request called with a specific version id permanently deletes an object from a bucket. Delete marker is not added for DELETE requests with version id.
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 04 21:43:52 UTC 2023
    - 11.9K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/hash/BloomFilter.java

       *     been added to the filter. Note that {@code put(t)} always returns the <i>opposite</i>
       *     result to what {@code mightContain(t)} would have returned at the time it is called.
       * @since 12.0 (present in 11.0 with {@code void} return type})
       */
      @CanIgnoreReturnValue
      public boolean put(@ParametricNullness T object) {
        return strategy.put(object, funnel, numHashFunctions, bits);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 23 16:45:30 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  4. internal/logger/target/kafka/kafka.go

    		if errors.Is(ctx.Err(), context.DeadlineExceeded) {
    			return ctx.Err()
    		}
    		return nil
    	default:
    		// log channel is full, do not wait and return
    		// an error immediately to the caller
    		atomic.AddInt64(&h.totalMessages, 1)
    		atomic.AddInt64(&h.failedMessages, 1)
    		return errors.New("log buffer full")
    	}
    	return nil
    }
    
    // SendFromStore - reads the log from store and sends it to kafka.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  5. cmd/xl-storage.go

    			// that for fresh PutObject() call dstDataPath can never exist.
    			// if its an overwrite then the caller deletes the DataDir
    			// in a separate RPC call.
    			s.moveToTrash(dstDataPath, true, false)
    
    			// If we are healing we should purge any legacyDataPath content,
    			// that was previously preserved during PutObject() call
    			// on a versioned bucket.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

        return capacityWithoutIt >= addressState.policy.minimumConcurrentCalls
      }
    
      /**
       * Prunes any leaked calls and then returns the number of remaining live calls on [connection].
       * Calls are leaked if the connection is tracking them but the application code has abandoned
       * them. Leak detection is imprecise and relies on garbage collection.
       */
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/base/MoreObjects.java

        }
    
        /**
         * Adds a name/value pair to the formatted output in {@code name=value} format. If {@code value}
         * is {@code null}, the string {@code "null"} is used, unless {@link #omitNullValues()} is
         * called, in which case this name/value pair will not be added.
         */
        @CanIgnoreReturnValue
        public ToStringHelper add(String name, @CheckForNull Object value) {
          return addHolder(name, value);
        }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 10 15:41:27 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  8. src/main/java/jcifs/netbios/NbtAddress.java

            if ( type.isAssignableFrom(this.getClass()) ) {
                return (T) this;
            }
            return null;
        }
    
    
        /**
         * Guess next called name to try for session establishment. These
         * methods are used by the smb package.
         * 
         * @return guessed name
         */
        @Override
        public String firstCalledName () {
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 15.2K bytes
    - Viewed (0)
  9. cmd/admin-handlers_test.go

    		t.Fatal("Failed to initialize a single node Erasure backend for admin handler tests.", err)
    	}
    	defer adminTestBed.TearDown()
    
    	// Initialize admin peers to make admin RPC calls. Note: In a
    	// single node setup, this degenerates to a simple function
    	// call under the hood.
    	globalMinioAddr = "127.0.0.1:9000"
    
    	var wg sync.WaitGroup
    
    	// Setting up a go routine to simulate ServerRouter's
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  10. docs/tls/README.md

    ```
    
    A response similar to this one should be displayed:
    
    ```
    Generating a 3072 bit RSA private key...
    ```
    
    #### 3.3.3 Generate a public certificate
    
    Create a file called `cert.cnf` with the content below. This file contains all of the information necessary to generate a certificate using `certtool.exe`:
    
    ```
    # X.509 Certificate options
    #
    # DN options
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 8.4K bytes
    - Viewed (0)
Back to top