Search Options

Results per page
Sort
Preferred Languages
Advance

Results 381 - 390 of 540 for blocks (0.05 sec)

  1. okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt

        this.connectionType = mode.second
    
        if (connectionType == H2) {
          platform.assumeHttp2Support()
        }
    
        // Sockets on some platforms can have large buffers that mean writes do not block when
        // required. These socket factories explicitly set the buffer sizes on sockets created.
        server = MockWebServer()
        server.serverSocketFactory =
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

              timeoutFuture.timer = null; // Don't include already elapsed delay in delegate.toString()
              String message = "Timed out";
              // This try-finally block ensures that we complete the timeout future, even if attempting
              // to produce the message throws (probably StackOverflowError from delegate.toString())
              try {
                if (timer != null) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/collect/Tables.java

       * ...
       * Map<C, V> row = table.row(rowKey);  // Needn't be in synchronized block
       * ...
       * synchronized (table) {  // Synchronizing on table, not row!
       *   Iterator<Entry<C, V>> i = row.entrySet().iterator(); // Must be in synchronized block
       *   while (i.hasNext()) {
       *     foo(i.next());
       *   }
       * }
       * }</pre>
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 16 21:21:17 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  4. guava/src/com/google/common/hash/Murmur3_32HashFunction.java

      }
    
      private static int mixH1(int h1, int k1) {
        h1 ^= k1;
        h1 = Integer.rotateLeft(h1, 13);
        h1 = h1 * 5 + 0xe6546b64;
        return h1;
      }
    
      // Finalization mix - force all bits of a hash block to avalanche
      private static HashCode fmix(int h1, int length) {
        h1 ^= length;
        h1 ^= h1 >>> 16;
        h1 *= 0x85ebca6b;
        h1 ^= h1 >>> 13;
        h1 *= 0xc2b2ae35;
        h1 ^= h1 >>> 16;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Aug 02 13:50:22 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  5. guava/src/com/google/common/io/CharStreams.java

          total += read;
          Java8Compatibility.clear(buf);
        }
        return total;
      }
    
      /**
       * Discards {@code n} characters of data from the reader. This method will block until the full
       * amount has been skipped. Does not close the reader.
       *
       * @param reader the reader to read from
       * @param n the number of characters to skip
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed May 17 14:35:11 UTC 2023
    - 10.9K bytes
    - Viewed (0)
  6. impl/maven-core/lifecycle-executor.txt

    - plugin in any default values
    - check to see if anything is missing
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  7. src/main/webapp/WEB-INF/orig/view/searchResults.jsp

    						<span class="favorited"><i class="fas fa-star"></i></span>
    					</c:if>
    				</div>
    			</li>
    		</c:forEach>
    	</ol>
    	<aside class="col-md-4 d-none d-md-block">
    		<%-- Side Content --%>
    		<c:if test="${facetResponse != null}">
    			<c:forEach var="fieldData" items="${facetResponse.fieldList}">
    				<c:if
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Jun 09 04:29:42 UTC 2022
    - 9K bytes
    - Viewed (0)
  8. internal/lock/lock_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package lock
    
    import (
    	"os"
    	"testing"
    	"time"
    )
    
    // Test lock fails.
    func TestLockFail(t *testing.T) {
    	f, err := os.CreateTemp("", "lock")
    	if err != nil {
    		t.Fatal(err)
    	}
    	f.Close()
    	defer func() {
    		err = os.Remove(f.Name())
    		if err != nil {
    			t.Fatal(err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.6K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt

          }
    
        @JvmName("-addInterceptor") // Prefix with '-' to prevent ambiguous overloads from Java.
        inline fun addInterceptor(crossinline block: (chain: Interceptor.Chain) -> Response) =
          addInterceptor(Interceptor { chain -> block(chain) })
    
        /**
         * Returns a modifiable list of interceptors that observe a single network request and response.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 06 04:21:33 UTC 2024
    - 52K bytes
    - Viewed (0)
  10. compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/DefaultUpdateCheckManager.java

                    return;
                }
    
                FileChannel channel = null;
                FileLock lock = null;
                try {
                    Properties props = new Properties();
    
                    channel = new RandomAccessFile(touchfile, "rw").getChannel();
                    lock = channel.lock();
    
                    if (touchfile.canRead()) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 12.1K bytes
    - Viewed (0)
Back to top