Search Options

Results per page
Sort
Preferred Languages
Advance

Results 261 - 270 of 487 for shard (0.01 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RoutePlanner.kt

     *     the same connection for an initial exchange and its follow-ups may improve locality.
     *
     *  2. If there is a connection in the pool that can satisfy the request it is used. Note that it is
     *     possible for shared exchanges to make requests to different host names! See
     *     [RealConnection.isEligible] for details.
     *
     *  3. Attempt plans from prior connect attempts for this call. These occur as either follow-ups to
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue May 27 14:58:02 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  2. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java

         */
        public void setBulkBufferSize(final int bulkBufferSize) {
            this.bulkBufferSize = bulkBufferSize;
        }
    
        /**
         * Sets the number of shards for the OpenSearch index.
         *
         * @param numberOfShards The number of shards.
         */
        public void setNumberOfShards(final int numberOfShards) {
            this.numberOfShards = numberOfShards;
        }
    
        /**
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Nov 20 08:40:57 UTC 2025
    - 34.3K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Connection.kt

      fun route(): Route
    
      /**
       * Returns the socket that this connection is using. Returns an
       * [SSL socket][javax.net.ssl.SSLSocket] if this connection is HTTPS. If this is an HTTP/2
       * connection the socket may be shared by multiple concurrent calls.
       */
      fun socket(): Socket
    
      /**
       * Returns the TLS handshake used to establish this connection, or null if the connection is not
       * HTTPS.
       */
      fun handshake(): Handshake?
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  4. src/main/java/jcifs/smb1/smb1/SmbComNTCreateAndX.java

     * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
     */
    
    package jcifs.smb1.smb1;
    
    import jcifs.smb1.util.Hexdump;
    
    class SmbComNTCreateAndX extends AndXServerMessageBlock {
    
        // share access specified in SmbFile
    
        // create disposition
    
        /* Creates a new file or supersedes the existing one
         */
    
        static final int FILE_SUPERSEDE = 0x0;
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  5. src/main/java/jcifs/internal/smb1/com/SmbComOpenAndX.java

        /**
         * Constructs an Open AndX request.
         *
         * @param config the configuration
         * @param fileName the name of the file to open
         * @param access the desired access mode
         * @param shareAccess the share access mode
         * @param flags the open flags
         * @param fileAttributes the file attributes
         * @param andx the next command in the chain
         */
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  6. src/test/java/jcifs/smb1/smb1/SmbRandomAccessFileTest.java

            smbFile.tree = smbTree;
            smbFile.fid = 1;
            smbFile.tree_num = 1;
    
            when(smbFile.isFile()).thenReturn(true);
            when(smbFile.getUncPath()).thenReturn("\\\\server\\share\\file.txt");
            when(smbFile.isOpen()).thenReturn(true);
    
            // Mock the open method to do nothing
            doNothing().when(smbFile).open(anyInt(), anyInt(), anyInt(), anyInt());
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 9.3K bytes
    - Viewed (0)
  7. src/test/java/jcifs/context/CIFSContextWrapperTest.java

            assertNotNull(cifsContextWrapper);
        }
    
        @Test
        void testGetSmbResource() throws CIFSException, MalformedURLException {
            // Test get(String url) method
            String url = "smb://server/share/file.txt";
            SmbResource mockSmbResource = mock(SmbFile.class);
            // Mocking SmbFile constructor is tricky, so we'll just verify the call to the delegate
            // and ensure no exception is thrown for a valid URL.
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 10.7K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java

          new NullPointerTester().testAllPublicInstanceMethods(striped);
        }
      }
    
      public void testSizes() {
        // not bothering testing all variations, since we know they share implementations
        assertThat(Striped.lock(100).size()).isAtLeast(100);
        assertTrue(Striped.lock(256).size() == 256);
        assertThat(Striped.lazyWeakLock(100).size()).isAtLeast(100);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 18:19:59 UTC 2025
    - 8.5K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/StripedTest.java

          new NullPointerTester().testAllPublicInstanceMethods(striped);
        }
      }
    
      public void testSizes() {
        // not bothering testing all variations, since we know they share implementations
        assertThat(Striped.lock(100).size()).isAtLeast(100);
        assertTrue(Striped.lock(256).size() == 256);
        assertThat(Striped.lazyWeakLock(100).size()).isAtLeast(100);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 18:19:59 UTC 2025
    - 8.5K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/collect/Platform.java

       */
      /*
       * The new array contains nulls, even if the old array did not. If we wanted to be accurate, we
       * would declare a return type of `@Nullable T[]`. However, we've decided not to think too hard
       * about arrays for now, as they're a mess. (We previously discussed this in the review of
       * ObjectArrays, which is the main caller of this method.)
       */
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 5.3K bytes
    - Viewed (0)
Back to top