Search Options

Results per page
Sort
Preferred Languages
Advance

Results 351 - 360 of 438 for readlink (0.09 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt

          if (this.errorCode == null) {
            this.errorCode = errorCode
            condition.signalAll()
          }
        }
      }
    
      /**
       * Returns true if read timeouts should be enforced while reading response headers or body bytes.
       * We always do timeouts in the HTTP server role. For clients, we only do timeouts after the
       * request is transmitted. This is only interesting for duplex calls where the request and
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  2. android/guava-testlib/src/com/google/common/testing/NullPointerTester.java

            }
          }
          return map.values();
        }
    
        private ImmutableList<Method> getVisibleMethods(Class<?> cls) {
          // Don't use cls.getPackage() because it does nasty things like reading
          // a file.
          String visiblePackage = Reflection.getPackageName(cls);
          ImmutableList.Builder<Method> builder = ImmutableList.builder();
          for (Class<?> type : TypeToken.of(cls).getTypes().rawTypes()) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 22.6K bytes
    - Viewed (0)
  3. docs/debugging/xl-meta/main.go

    		// block -> data
    		combineSharedBlocks := make(map[int][]byte)
    		combineFilledBlocks := make(map[int][]byte)
    	nextFile:
    		for key, file := range files[partIdx] {
    			fmt.Println("Reading base version", file[0], "part", part)
    			var combined []byte
    			var missingAll int
    			var lastValidAll int
    
    			attempt := 0
    			for block := 0; ; block++ {
    				combineFilled := combineFilledBlocks[block]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 05 11:57:44 UTC 2024
    - 40.3K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

     *       Future} is "completed" even if it is cancelled while its underlying work continues on a
     *       thread, an RPC, etc. The {@code Future} is also "completed" if it fails "early" -- for
     *       example, if the deadline expires on a {@code Future} returned from {@link
     *       Futures#withTimeout} while the {@code Future} it wraps continues its underlying work. So
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  5. internal/dsync/drwmutex.go

    		// quorum + 1 when tolerance is exactly half of the
    		// total locker clients.
    		if quorum == tolerance {
    			quorum++
    		}
    	}
    
    	log("lockBlocking %s/%s for %#v: lockType readLock(%t), additional opts: %#v, quorum: %d, tolerance: %d, lockClients: %d\n", id, source, dm.Names, isReadLock, opts, quorum, tolerance, len(restClnts))
    
    	tolerance = len(restClnts) - quorum
    	attempt := uint(0)
    
    	for {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 15:49:49 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  6. cmd/test-utils_test.go

    	}
    
    	// httptest Recorder to capture all the response by the http handler.
    	rec := httptest.NewRecorder()
    	// reading the body to preserve it so that it can be used again for second attempt of sending unsigned HTTP request.
    	// If the body is read in the handler the same request cannot be made use of.
    	buf, err := io.ReadAll(anonReq.Body)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/collect/Multimaps.java

          stream.writeObject(factory);
          stream.writeObject(backingMap());
        }
    
        @GwtIncompatible // java.io.ObjectInputStream
        @J2ktIncompatible
        @SuppressWarnings("unchecked") // reading data stored by writeObject
        private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
          stream.defaultReadObject();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 16 21:21:17 UTC 2024
    - 86.3K bytes
    - Viewed (0)
  8. cmd/data-usage-cache_gen.go

    							return
    						}
    					case "nv":
    						za0002.NumVersions, err = dc.ReadInt()
    						if err != nil {
    							err = msgp.WrapError(err, "Tiers", za0001, "NumVersions")
    							return
    						}
    					case "no":
    						za0002.NumObjects, err = dc.ReadInt()
    						if err != nil {
    							err = msgp.WrapError(err, "Tiers", za0001, "NumObjects")
    							return
    						}
    					default:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 75K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/Range.java

     *       property <i>P</i>. See, for example, the definition of {@link #intersection intersection}.
     *   <li>A {@code Range} is serializable if it has no bounds, or if each bound is serializable.
     * </ul>
     *
     * <h3>Further reading</h3>
     *
     * <p>See the Guava User Guide article on <a
     * href="https://github.com/google/guava/wiki/RangesExplained">{@code Range}</a>.
     *
     * @author Kevin Bourrillion
     * @author Gregory Kick
     * @since 10.0
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 16 17:21:56 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/hash/Hashing.java

      }
    
      /**
       * Used to randomize {@link #goodFastHash} instances, so that programs which persist anything
       * dependent on the hash codes they produce will fail sooner.
       */
      @SuppressWarnings("GoodTime") // reading system time without TimeSource
      static final int GOOD_FAST_HASH_SEED = (int) System.currentTimeMillis();
    
      /**
       * Returns a hash function implementing the <a
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jul 19 16:02:36 UTC 2024
    - 29.3K bytes
    - Viewed (0)
Back to top