Search Options

Results per page
Sort
Preferred Languages
Advance

Results 341 - 350 of 777 for callee (0.06 sec)

  1. cmd/post-policy-fan-out.go

    	Checksum *hash.Checksum
    	MD5Hex   string
    }
    
    // fanOutPutObject takes an input source reader and fans out multiple PUT operations
    // based on the incoming fan-out request, a context cancellation by the caller
    // would ensure all fan-out operations are canceled.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  2. compat/maven-resolver-provider/src/main/java/org/apache/maven/repository/internal/RemoteSnapshotMetadataGenerator.java

             * processes one artifact at a time and hence cannot associate the artifacts from the same project to use the
             * same timestamp+buildno for the snapshot versions. Allowing the caller to pass in metadata from a previous
             * deployment allows to re-establish the association between the artifacts of the same project.
             */
            for (Metadata metadata : request.getMetadata()) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  3. guava/src/com/google/common/collect/LinkedListMultimap.java

        @Override
        public void remove() {
          checkForConcurrentModification();
          checkState(current != null, "no calls to next() since the last call to remove()");
          if (current != next) { // after call to next()
            previous = current.previous;
            nextIndex--;
          } else { // after call to previous()
            next = current.next;
          }
          removeNode(current);
          current = null;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 13 14:11:58 UTC 2023
    - 27.5K bytes
    - Viewed (0)
  4. compat/maven-model-builder/src/main/java/org/apache/maven/model/interpolation/ModelInterpolator.java

        /**
         * Interpolates expressions in the specified model. Note that implementations are free to either interpolate the
         * provided model directly or to create a clone of the model and interpolate the clone. Callers should always use
         * the returned model and must not rely on the input model being updated.
         *
         * @param model The model to interpolate, must not be {@code null}.
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  5. okhttp-logging-interceptor/src/test/java/okhttp3/logging/LoggingEventListenerTest.kt

        val request = Request.Builder().url(url).build()
        val call = client.newCall(request)
        val response =
          Response.Builder().request(request).code(200).message("").protocol(Protocol.HTTP_2)
            .build()
        val listener = loggingEventListenerFactory.create(call)
        listener.cacheConditionalHit(call, response)
        listener.cacheHit(call, response)
        listener.cacheMiss(call)
        listener.satisfactionFailure(call, response)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Jan 14 10:20:09 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  6. cni/pkg/install/install.go

    			}
    		}
    	}
    	return nil
    }
    
    // sleepWatchInstall blocks until any file change for the binaries or config are detected.
    // At that point, the func yields so the caller can recheck the validity of the install.
    // If an error occurs or context is canceled, the function will return an error.
    func (in *Installer) sleepWatchInstall(ctx context.Context, installedBinFiles sets.String) error {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Aug 09 21:33:51 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/eventbus/SubscriberTest.java

        } catch (NoSuchMethodException e) {
          throw new AssertionError();
        }
      }
    
      /**
       * Records the provided object in {@link #methodArgument} and sets {@link #methodCalled}. This
       * method is called reflectively by Subscriber during tests, and must remain public.
       *
       * @param arg argument to record.
       */
      @Subscribe
      public void recordingMethod(Object arg) {
        assertFalse(methodCalled);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 4.8K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt

                .write(ByteArray(responseBodySize)),
            )
            .throttleBody(64 * 1024, 125, MILLISECONDS) // 500 Kbps
            .build(),
        )
        val call = client.newCall(Request(server.url("/")))
        val response = call.execute()
        cancelLater(call, 500)
        val responseBody = response.body.byteStream()
        val buffer = ByteArray(1024)
        assertFailsWith<IOException> {
          while (responseBody.read(buffer) != -1) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  9. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingEventListener.kt

        call: Call,
        ioe: IOException,
      ) = logEvent(ResponseFailed(System.nanoTime(), call, ioe))
    
      override fun callEnd(call: Call) = logEvent(CallEnd(System.nanoTime(), call))
    
      override fun callFailed(
        call: Call,
        ioe: IOException,
      ) = logEvent(CallFailed(System.nanoTime(), call, ioe))
    
      override fun canceled(call: Call) = logEvent(Canceled(System.nanoTime(), call))
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 9K bytes
    - Viewed (0)
  10. internal/config/storageclass/storage-class.go

    //
    // -- if input is RRS but RRS is not configured/initialized '-1' parity
    //
    //	for RRS is assumed, the caller is expected to choose the right parity
    //	at that point.
    //
    // -- if input is STANDARD but STANDARD is not configured/initialized '-1' parity
    //
    //	is returned, the caller is expected to choose the right parity
    //	at that point.
    func (sCfg *Config) GetParityForSC(sc string) (parity int) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 12.3K bytes
    - Viewed (0)
Back to top