Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 461 - 470 of 1,372 for carl (0.25 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. guava-tests/test/com/google/common/reflect/SubtypeTester.java

        /** Suppresses the assertion on {@link TypeToken#getSupertype}. */
        boolean suppressGetSupertype() default false;
      }
    
      private @Nullable Method method = null;
    
      /** Call this in a {@link TestSubtype} public method asserting subtype relationship. */
      final <T> T isSubtype(T sub) {
        Type returnType = method.getGenericReturnType();
        Type paramType = getOnlyParameterType();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 16:11:48 GMT 2026
    - 6.1K bytes
    - Click Count (0)
  2. tensorflow/c/eager/c_api_experimental.h

    //
    // This call may not block for execution of ops enqueued concurrently with this
    // call.
    TF_CAPI_EXPORT extern void TFE_ExecutorWaitForAllPendingNodes(
        TFE_Executor*, TF_Status* status);
    
    // When an error happens, any pending operations are discarded, and newly issued
    // ops return an error. This call clears the error state and re-enables
    // execution of newly issued ops.
    //
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Wed Feb 21 22:37:46 GMT 2024
    - 39.5K bytes
    - Click Count (1)
  3. internal/rest/client.go

    		return nil, errors.New(resp.Status)
    	}
    	if !c.NoMetrics {
    		resp.Body = &respBodyMonitor{ReadCloser: resp.Body, expectTimeouts: expectTimeouts}
    	}
    	return resp.Body, nil
    }
    
    // Call - make a REST call with context.
    func (c *Client) Call(ctx context.Context, rpcMethod string, values url.Values, body io.Reader, length int64) (reply io.ReadCloser, err error) {
    	return c.CallWithHTTPMethod(ctx, http.MethodPost, rpcMethod, values, body, length)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 14.7K bytes
    - Click Count (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketReader.kt

       * Process the next protocol frame.
       *
       *  * If it is a control frame this will result in a single call to [FrameCallback].
       *  * If it is a message frame this will result in a single call to [FrameCallback.onReadMessage].
       *    If the message spans multiple frames, each interleaved control frame will result in a
       *    corresponding call to [FrameCallback].
       */
      @Throws(IOException::class)
      fun processNextFrame() {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 10K bytes
    - Click Count (0)
  5. okcurl/src/main/kotlin/okhttp3/curl/logging/MessageFormatter.kt

     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package okhttp3.curl.logging
    
    import java.util.logging.LogRecord
    import java.util.logging.SimpleFormatter
    
    object MessageFormatter : SimpleFormatter() {
      override fun format(record: LogRecord): String = String.format("%s%n", record.message)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 845 bytes
    - Click Count (0)
  6. .ci/templates.t/periodic-trigger-lgc.yml

          - timed: "{cron}"
        builders:
          - shell: |
              #!/usr/bin/env bash
              set -o pipefail
              echo "Retrieving last good commit for job '{lgc-job}'"
              echo branch_specifier=$(curl -s "${JENKINS_URL}job/{lgc-job}/lastSuccessfulBuild/api/json" | jq -r -e '.actions | map(select(._class == "hudson.plugins.git.util.BuildData")) | .[] | .lastBuiltRevision.SHA1' || echo "refs/heads/%BRANCH%") > trigger.properties
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Thu May 06 21:46:09 GMT 2021
    - 1K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/util/concurrent/ListenableFutureTask.java

     * FutureTask}, {@code ListenableFutureTask} does not provide an overrideable {@link
     * FutureTask#done() done()} method. For similar functionality, call {@link #addListener}.
     *
     * <p>Few users should use this class. It is intended primarily for those who are implementing an
     * {@code ExecutorService}. Most users should call {@link ListeningExecutorService#submit(Callable)
     * ListeningExecutorService.submit} on a service obtained from {@link
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Feb 10 11:51:21 GMT 2026
    - 4.2K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/base/Stopwatch.java

        this.ticker = checkNotNull(ticker, "ticker");
      }
    
      /**
       * Returns {@code true} if {@link #start()} has been called on this stopwatch, and {@link #stop()}
       * has not been called since the last call to {@code start()}.
       */
      public boolean isRunning() {
        return isRunning;
      }
    
      /**
       * Starts the stopwatch.
       *
       * @return this {@code Stopwatch} instance
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Oct 08 18:55:33 GMT 2025
    - 9.5K bytes
    - Click Count (0)
  9. okhttp/src/jvmTest/kotlin/okhttp3/SessionReuseTest.kt

            .connectionSpecs(listOf(spec))
            .eventListenerFactory(
              clientTestRule.wrap(
                object : EventListener() {
                  override fun connectionAcquired(
                    call: Call,
                    connection: Connection,
                  ) {
                    val sslSocket = connection.socket() as SSLSocket
    
                    sessionIds.add(
                      sslSocket.session.id
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sat Nov 01 12:18:11 GMT 2025
    - 5.9K bytes
    - Click Count (1)
  10. android/guava-tests/test/com/google/common/base/StringsTest.java

      }
    
      public void testPadStart_negativeMinLength() {
        assertThat(Strings.padStart("x", -1, '-')).isSameInstanceAs("x");
      }
    
      @SuppressWarnings("nullness") // test of a bogus call
      public void testPadStart_null() {
        assertThrows(NullPointerException.class, () -> Strings.padStart(null, 5, '0'));
      }
    
      public void testPadEnd_noPadding() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 15:59:55 GMT 2026
    - 11.4K bytes
    - Click Count (0)
Back to Top