- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 219 for isSynchronized (0.24 sec)
-
okhttp-dnsoverhttps/src/main/kotlin/okhttp3/dnsoverhttps/DnsOverHttps.kt
results: MutableList<InetAddress>, failures: MutableList<Exception>, ) { try { val addresses = readResponse(hostname, response) synchronized(results) { results.addAll(addresses) } } catch (e: Exception) { synchronized(failures) { failures.add(e) } } } @Throws(UnknownHostException::class) private fun throwBestFailure(
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat May 10 11:15:14 UTC 2025 - 8.6K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/rdma/RdmaTransport.java
} /** * Establishes RDMA connection to the remote server. * * @throws IOException if connection fails */ public void connectRdma() throws IOException { synchronized (connectionLock) { if (rdmaConnection != null && rdmaConnection.isConnected()) { return; } try { rdmaConnection =
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 05:11:12 UTC 2025 - 8.9K bytes - Viewed (0) -
src/main/java/jcifs/context/SingletonContext.java
* * @param props the properties to use for initialization * @throws CIFSException if the singleton context is already initialized or there is an error during initialization */ public static synchronized final void init(final Properties props) throws CIFSException { if (INSTANCE != null) { throw new CIFSException("Singleton context is already initialized"); }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 4.3K bytes - Viewed (0) -
src/main/java/jcifs/smb/PreauthIntegrityService.java
return hashAlgorithm; } public byte[] getCurrentHash() { synchronized (hashLock) { return currentHash.clone(); } } public void updateHash(byte[] newHash) { synchronized (hashLock) { if (newHash != null && newHash.length == currentHash.length) {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 12.1K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/NtlmAuthenticator.java
* @param a the authenticator to set as default */ public synchronized static void setDefault(final NtlmAuthenticator a) { if (auth != null) { return; } auth = a; } /** * Gets the URL that is requesting authentication.
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 3.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ExecutionList.java
// Lock while we check state. We must maintain the lock while adding the new pair so that // another thread can't run the list out from under us. We only add to the list if we have not // yet started execution. synchronized (this) { if (!executed) { runnables = new RunnableExecutorPair(runnable, executor, runnables); return; } }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 6.9K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbFileHandleImpl.java
} /** * {@inheritDoc} * * @see jcifs.SmbFileHandle#close(long) */ @Override public synchronized void close(final long lastWriteTime) throws CIFSException { closeInternal(lastWriteTime, true); } /** * @param lastWriteTime * @throws SmbException */
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 9.4K bytes - Viewed (1) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingHostnameVerifier.kt
package okhttp3 import javax.net.ssl.HostnameVerifier import javax.net.ssl.SSLSession class RecordingHostnameVerifier : HostnameVerifier { @JvmField val calls: MutableList<String> = mutableListOf() @Synchronized override fun verify( hostname: String, session: SSLSession, ): Boolean { calls.add("verify $hostname") return true }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 980 bytes - Viewed (0) -
okhttp/src/androidMain/kotlin/okhttp3/internal/platform/android/DeferredSocketAdapter.kt
getDelegate(sslSocket)?.configureTlsExtensions(sslSocket, hostname, protocols) } override fun getSelectedProtocol(sslSocket: SSLSocket): String? = getDelegate(sslSocket)?.getSelectedProtocol(sslSocket) @Synchronized private fun getDelegate(sslSocket: SSLSocket): SocketAdapter? { if (this.delegate == null && socketAdapterFactory.matchesSocket(sslSocket)) { this.delegate = socketAdapterFactory.create(sslSocket) }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 2.1K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/features/FeatureUtil.java
*/ public static TesterRequirements getTesterRequirements(Class<?> testerClass) throws ConflictingRequirementsException { synchronized (classTesterRequirementsCache) { TesterRequirements requirements = classTesterRequirementsCache.get(testerClass); if (requirements == null) { requirements = buildTesterRequirements(testerClass);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 14:50:24 UTC 2024 - 12.4K bytes - Viewed (0)