- Sort Score
- Result 10 results
- Languages All
Results 311 - 320 of 373 for attempt (0.04 sec)
-
guava/src/com/google/common/util/concurrent/AbstractService.java
listeners.addListener(listener, executor); } @Override public String toString() { return getClass().getSimpleName() + " [" + state() + "]"; } /** * Attempts to execute all the listeners in {@link #listeners} while not holding the {@link * #monitor}. */ private void dispatchListenerEvents() { if (!monitor.isOccupiedByCurrentThread()) { listeners.dispatch();
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Feb 19 21:24:11 UTC 2025 - 20.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java
/** * Sets the maximum retry attempts for configuration synchronization status checks. * * @param maxConfigSyncStatusRetry the maximum retry attempts */ public void setMaxConfigSyncStatusRetry(final int maxConfigSyncStatusRetry) { this.maxConfigSyncStatusRetry = maxConfigSyncStatusRetry; } /** * Sets the maximum retry attempts for search engine status checks. *
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sun Aug 31 08:19:00 UTC 2025 - 121.9K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
} fun idleConnectionCount(): Int = connections.count { it.withLock { it.calls.isEmpty() } } fun connectionCount(): Int = connections.size /** * Attempts to acquire a recycled connection to [address] for [connectionUser]. Returns the connection if it * was acquired, or null if no connection was acquired. The acquired connection will also be
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Jun 03 17:10:08 UTC 2025 - 16.1K bytes - Viewed (0) -
src/archive/tar/format.go
func (b *block) toUSTAR() *headerUSTAR { return (*headerUSTAR)(b) } func (b *block) toSparse() sparseArray { return sparseArray(b[:]) } // getFormat checks that the block is a valid tar header based on the checksum. // It then attempts to guess the specific format based on magic values. // If the checksum fails, then FormatUnknown is returned. func (b *block) getFormat() Format { // Verify checksum. var p parser
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Fri Oct 13 18:36:46 UTC 2023 - 11.3K bytes - Viewed (0) -
cmd/bucket-replication-utils.go
ReplicationStatus replication.StatusType PrevReplicationStatus replication.StatusType VersionPurgeStatus VersionPurgeStatusType ResyncTimestamp string ReplicationResynced bool // true only if resync attempted for this target endpoint string secure bool Err error // replication error if any } // Empty returns true for a target if arn is empty
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 26K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt
*/ public fun settings(settings: Settings): Builder = apply { this.settings_.clear() this.settings_.merge(settings) } /** * Attempts to perform a web socket upgrade on the connection. * This will overwrite any previously set status, body, or streamHandler. */ public fun webSocketUpgrade(listener: WebSocketListener): Builder = apply {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 17.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/sso/spnego/SpnegoAuthenticator.java
return authenticator; } catch (final Exception e) { throw new SsoLoginException("Failed to initialize SPNEGO.", e); } } /** * Attempts to obtain login credentials using SPNEGO authentication. * * This method processes the HTTP request to extract and validate SPNEGO * authentication tokens. It handles the SPNEGO handshake process and
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 17.2K bytes - Viewed (3) -
src/main/java/jcifs/smb/SmbTransportPoolImpl.java
} ex = e; } } if (ex != null) { throw ex; } throw new TransportException("All connection attempts failed"); } /** * Checks if the specified transport is contained in the connection pool * @param trans the transport to check for * @return whether (non-exclusive) connection is in the pool
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 33.4K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt
connectionPool.scheduleCloser() } } } override fun handshake(): Handshake? = handshake /** Track a bad route in the route database. Other routes will be attempted first. */ internal fun connectFailed( client: OkHttpClient, failedRoute: Route, failure: IOException, ) { // Tell the proxy selector when we fail to connect on a fresh connection.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 14.9K bytes - Viewed (0) -
guava/src/com/google/common/collect/ImmutableTable.java
* {@link Builder} and call {@link Builder#orderRowsBy}, {@link Builder#orderColumnsBy}, and * {@link Builder#putAll} * * <p>Despite the method name, this method attempts to avoid actually copying the data when it is * safe to do so. The exact circumstances under which a copy will or will not be performed are * undocumented and subject to change. */
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 17.3K bytes - Viewed (0)