Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 301 - 310 of 547 for shard (0.03 seconds)

  1. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

     * #runOneIteration} takes longer than its schedule defines, then subsequent executions may start
     * late. Also, all life cycle methods are executed with a lock held, so subclasses can safely modify
     * shared state without additional synchronization necessary for visibility to later executions of
     * the life cycle methods.
     *
     * <h3>Usage Example</h3>
     *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Aug 09 01:14:59 GMT 2025
    - 27.8K bytes
    - Click Count (0)
  2. src/test/java/jcifs/smb/SmbTransportPoolImplTest.java

            assertTrue(ex.getMessage().contains("Connection failed"));
        }
    
        @Test
        @DisplayName("Should perform logon to IPC$ share")
        void testLogon() throws Exception {
            // Given: Mock transport, session and tree
            SmbTransportPoolImpl poolSpy = spy(pool);
            when(ctx.getTransportPool()).thenReturn(poolSpy);
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 19.2K bytes
    - Click Count (0)
  3. 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;
        }
    
        /**
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Thu Nov 20 08:40:57 GMT 2025
    - 34.3K bytes
    - Click Count (0)
  4. compat/maven-compat/src/main/java/org/apache/maven/artifact/repository/metadata/AbstractRepositoryMetadata.java

    import org.apache.maven.artifact.repository.ArtifactRepositoryPolicy;
    import org.apache.maven.metadata.v4.MetadataStaxReader;
    import org.apache.maven.metadata.v4.MetadataStaxWriter;
    
    /**
     * Shared methods of the repository metadata handling.
     *
     */
    @Deprecated
    public abstract class AbstractRepositoryMetadata implements RepositoryMetadata {
        private static final String LS = System.lineSeparator();
    
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 7.2K bytes
    - Click Count (0)
  5. docs/metrics/prometheus/list.md

    | `minio_node_mem_free_max`      | Free memory on the node (max).            |
    | `minio_node_mem_shared`        | Shared memory on the node.                |
    | `minio_node_mem_shared_avg`    | Shared memory on the node (avg).          |
    | `minio_node_mem_shared_max`    | Shared memory on the node (max).          |
    | `minio_node_mem_total`         | Total memory on the node.                 |
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 43.4K bytes
    - Click Count (0)
  6. ci/official/utilities/code_check_full.bats

      license_query "deps($LICENSES_TARGET)" > $BATS_TEST_TMPDIR/actual_licenses
    
      # Column 1 is left only, Column 2 is right only, Column 3 is shared lines
      # Select lines unique to actual_licenses, i.e. extra licenses.
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Fri Dec 19 18:47:57 GMT 2025
    - 13.5K bytes
    - Click Count (0)
  7. 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?
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 4.3K bytes
    - Click Count (0)
  8. 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;
    
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  9. compat/maven-resolver-provider/src/test/java/org/apache/maven/repository/internal/RepositorySystemTest.java

        }
    
        @Test
        void testNewSyncContext() throws Exception {
            // SyncContext newSyncContext( RepositorySystemSession session, boolean shared );
        }
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Wed Sep 17 10:01:14 GMT 2025
    - 9.5K bytes
    - Click Count (0)
  10. 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
         */
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 7.3K bytes
    - Click Count (0)
Back to Top