- Sort Score
- Num 10 results
- Language All
Results 301 - 310 of 547 for shard (0.03 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)