Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 383 for caller7 (0.05 sec)

  1. impl/maven-core/src/main/java/org/apache/maven/execution/MavenExecutionRequestPopulator.java

         * existing values in the execution request that are controlled by the toolchains. Hence, it is expected that this
         * method is called on a new/empty execution request before the caller mutates it to fit its needs.
         *
         * @param request The execution request to populate, 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.4K bytes
    - Viewed (0)
  2. guava/src/com/google/common/io/ByteSink.java

     *
     * <p>{@code ByteSink} provides two kinds of methods:
     *
     * <ul>
     *   <li><b>Methods that return a stream:</b> These methods should return a <i>new</i>, independent
     *       instance each time they are called. The caller is responsible for ensuring that the
     *       returned stream is closed.
     *   <li><b>Convenience methods:</b> These are implementations of common operations that are
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 28 16:55:09 UTC 2024
    - 5K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/io/CharSink.java

     *
     * <p>{@code CharSink} provides two kinds of methods:
     *
     * <ul>
     *   <li><b>Methods that return a writer:</b> These methods should return a <i>new</i>, independent
     *       instance each time they are called. The caller is responsible for ensuring that the
     *       returned writer is closed.
     *   <li><b>Convenience methods:</b> These are implementations of common operations that are
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java

          ATOMIC_HELPER.compareAndSetSeenExceptions(this, null, seenExceptionsLocal);
          /*
           * If another handleException() caller created the set, we need to use that copy in case yet
           * other callers have added to it.
           *
           * This read is guaranteed to get us the right value because we only set this once (here).
           *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue May 28 20:40:51 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  5. utils/utils.go

    	}
    	return filepath.ToSlash(s) + "/"
    }
    
    // FileWithLineNum return the file name and line number of the current file
    func FileWithLineNum() string {
    	pcs := [13]uintptr{}
    	// the third caller usually from gorm internal
    	len := runtime.Callers(3, pcs[:])
    	frames := runtime.CallersFrames(pcs[:len])
    	for i := 0; i < len; i++ {
    		// second return value is "more", not "ok"
    		frame, _ := frames.Next()
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Aug 22 11:03:42 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/AggregateFutureState.java

          ATOMIC_HELPER.compareAndSetSeenExceptions(this, null, seenExceptionsLocal);
          /*
           * If another handleException() caller created the set, we need to use that copy in case yet
           * other callers have added to it.
           *
           * This read is guaranteed to get us the right value because we only set this once (here).
           *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue May 28 20:40:51 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  7. internal/grid/stream.go

    	"errors"
    )
    
    // A Stream is a two-way stream.
    // All responses *must* be read by the caller.
    // If the call is canceled through the context,
    // the appropriate error will be returned.
    type Stream struct {
    	// responses from the remote server.
    	// Channel will be closed after error or when remote closes.
    	// All responses *must* be read by the caller until either an error is returned or the channel is closed.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  8. internal/cachevalue/cache.go

    // guaranteed to be called only once.
    func (t *Cache[T]) InitOnce(ttl time.Duration, opts Opts, update func(ctx context.Context) (T, error)) {
    	t.Once.Do(func() {
    		t.ttl = ttl
    		t.updateFn = update
    		t.opts = opts
    	})
    }
    
    // GetWithCtx will return a cached value or fetch a new one.
    // passes a caller context, if caller context cancels nothing
    // is cached.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 12:50:46 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/io/ReaderInputStream.java

       * stream. When encoding it is "unflipped" (encoded bytes between 0 and position) and when
       * draining it is flipped (undrained bytes between position and limit).
       */
      private ByteBuffer byteBuffer;
    
      /** Whether we've finished reading the reader. */
      private boolean endOfInput;
      /** Whether we're copying encoded bytes to the caller's buffer. */
      private boolean draining;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  10. guava/src/com/google/common/io/ReaderInputStream.java

       * stream. When encoding it is "unflipped" (encoded bytes between 0 and position) and when
       * draining it is flipped (undrained bytes between position and limit).
       */
      private ByteBuffer byteBuffer;
    
      /** Whether we've finished reading the reader. */
      private boolean endOfInput;
      /** Whether we're copying encoded bytes to the caller's buffer. */
      private boolean draining;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 9.3K bytes
    - Viewed (0)
Back to top