Search Options

Results per page
Sort
Preferred Languages
Advance

Results 381 - 390 of 558 for unread (0.07 sec)

  1. guava/src/com/google/common/collect/MapMakerInternalMap.java

         * look at table entries if it is 0.
         *
         * - All (synchronized) write operations should write to the "count" field after structurally
         * changing any bin. The operations must not take any action that could even momentarily
         * cause a concurrent read operation to see inconsistent data. This is made easier by the
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 90.8K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/CallKotlinTest.kt

        assertThat(server.takeRequest().sequenceNumber).isEqualTo(0)
    
        // Give the socket a chance to become stale.
        connection!!.idleAtNs -= IDLE_CONNECTION_HEALTHY_NS
        Thread.sleep(250)
    
        val requestB =
          Request(
            url = server.url("/"),
            body = "b".toRequestBody("text/plain".toMediaType()),
          )
        val responseB = client.newCall(requestB).execute()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  3. compat/maven-embedder/src/main/java/org/apache/maven/cli/MavenCli.java

        }
    
        PlexusContainer container(CliRequest cliRequest) throws Exception {
            if (cliRequest.classWorld == null) {
                cliRequest.classWorld =
                        new ClassWorld("plexus.core", Thread.currentThread().getContextClassLoader());
            }
    
            ClassRealm coreRealm = cliRequest.classWorld.getClassRealm("plexus.core");
            if (coreRealm == null) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 76.8K bytes
    - Viewed (0)
  4. compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/descriptor/MojoDescriptor.java

            return executeGoal;
        }
    
        /**
         * @return True if the <code>Mojo</code> is thread-safe and can be run safely in parallel
         * @since 3.0-beta-2
         */
        public boolean isThreadSafe() {
            return threadSafe;
        }
    
        /**
         * @param threadSafe indicates that the mojo is thread-safe and can be run safely in parallel
         * @since 3.0-beta-2
         */
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 21.7K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/cache/CacheBuilder.java

       * higher value than you need can waste space and time, and a significantly lower value can lead
       * to thread contention. But overestimates and underestimates within an order of magnitude do not
       * usually have much noticeable impact. A value of one permits only one thread to modify the cache
       * at a time, but since read operations and cache loading computations can proceed concurrently,
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 52K bytes
    - Viewed (0)
  6. src/main/java/jcifs/SmbResource.java

         * read. Because any file, directory, or other resource can be read if it
         * exists, this method simply calls the <code>exists</code> method.
         *
         * @return <code>true</code> if the file is read-only
         * @throws CIFSException
         */
        boolean canRead () throws CIFSException;
    
    
        /**
         * Turn off the read-only attribute of this file. This is shorthand for
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Dec 20 14:09:34 UTC 2020
    - 26K bytes
    - Viewed (1)
  7. internal/ringbuffer/ring_buffer_test.go

    		t.Errorf("Read error: got %T, want testError1", err)
    	}
    	if _, err := rb.TryRead([]byte{0}); err != (testError1{}) {
    		t.Errorf("Read error: got %T, want testError1", err)
    	}
    	rb.CloseWithError(testError2{})
    	if _, err := rb.Read(nil); err != (testError1{}) {
    		t.Errorf("Read error: got %T, want testError1", err)
    	}
    	if _, err := rb.Read([]byte{0}); err != (testError1{}) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb/SmbCopyUtil.java

                            }
                            w.checkException();
    
                            if ( read <= 0 ) {
                                break;
                            }
    
                            w.write(b[ i ], read, fos);
                        }
    
                        i = i == 1 ? 0 : 1;
                        off += read;
                    }
    
                    if ( log.isDebugEnabled() ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Tue Jul 07 10:52:42 UTC 2020
    - 17.1K bytes
    - Viewed (0)
  9. docs/distributed/README.md

    - **Each object is written to a single EC set, and therefore is spread over no more than 16 drives.**
    - **All the nodes running distributed MinIO setup are recommended to be homogeneous, i.e. same operating system, same number of drives and same network interconnects.**
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  10. guava/src/com/google/common/collect/ImmutableSortedSet.java

       * comparable.
       *
       * <p>This method is safe to use even when {@code elements} is a synchronized or concurrent
       * collection that is currently being modified by another thread.
       *
       * @throws ClassCastException if the elements are not mutually comparable
       * @throws NullPointerException if any of {@code elements} is null
       * @since 7.0 (source-compatible since 2.0)
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 39.1K bytes
    - Viewed (0)
Back to top