- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 79 for _observer (0.04 sec)
-
guava/src/com/google/common/util/concurrent/AbstractFutureState.java
// * Future completion can be observed if the waitersField field contains a TOMBSTONE // Timed Get // There are a few design constraints to consider // * We want to be responsive to small timeouts, unpark() has non trivial latency overheads (I // have observed 12 micros on 64-bit linux systems to wake up a parked thread). So if the
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 34.8K bytes - Viewed (0) -
src/test/java/jcifs/smb/NetServerFileEntryAdapterIteratorTest.java
setupParentForUrlCreation(); StubFileEntry bad = new StubFileEntry(badName, SmbConstants.TYPE_SERVER); StubFileEntry good = new StubFileEntry("OKSERVER", SmbConstants.TYPE_SERVER); when(delegate.hasNext()).thenReturn(true, true, false); when(delegate.next()).thenReturn(bad, good);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 7.9K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Interceptor.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3 import java.io.IOException import java.util.concurrent.TimeUnit /** * Observes, modifies, and potentially short-circuits requests going out and the corresponding * responses coming back in. Typically interceptors add, remove, or transform headers on the request * or response. *
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 3.5K bytes - Viewed (0) -
okhttp/src/androidMain/kotlin/okhttp3/internal/platform/android/AndroidSocketAdapter.kt
} } } companion object { val playProviderFactory: DeferredSocketAdapter.Factory = factory("com.google.android.gms.org.conscrypt") /** * Builds a SocketAdapter from an observed implementation class, by grabbing the Class * reference to perform reflection on at runtime. * * @param actualSSLSocketClass the runtime class of Conscrypt class socket. */
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 4.6K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/Trans2QueryPathInformationResponse.java
return 0; } @Override int readParametersWireFormat(final byte[] buffer, final int bufferIndex, final int len) { // observed two zero bytes here with at least win98 return 2; } @Override int readDataWireFormat(final byte[] buffer, final int bufferIndex, final int len) { return switch (informationLevel) {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 07:14:38 UTC 2025 - 5.6K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/DiskLruCache.kt
* * Every [edit] call must be matched by a call to [Editor.commit] or [Editor.abort]. Committing is * atomic: a read observes the full set of values as they were before or after the commit, but never * a mix of values. * * Clients call [get] to read a snapshot of an entry. The read will observe the value at the time * that [get] was called. Updates and removals after the call do not impact ongoing reads. *
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 34.7K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/com/SmbComTreeConnectAndXResponse.java
this.service = new String(buffer, bufferIndex, len, "ASCII"); } catch (final UnsupportedEncodingException uee) { return 0; } bufferIndex += len + 1; // win98 observed not returning nativeFileSystem // Problems here with iSeries returning ASCII even though useUnicode = true // Fortunately we don't really need nativeFileSystem for anything.
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 5.1K bytes - Viewed (0) -
docs/features/https.md
* **Security** of the connection. This includes verification of the remote webserver with certificates and the privacy of data exchanged with strong ciphers.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Dec 24 00:16:30 UTC 2022 - 10.5K bytes - Viewed (0) -
src/test/java/jcifs/smb/SecurityBlobTest.java
assertTrue(right.equals(left), "Equality should be symmetric for identical content"); } // Demonstrates observed equals() asymmetry when this is shorter than argument @Test @DisplayName("equals: this shorter but same prefix -> true (observed behavior)") void equals_thisShorterSamePrefix_true_dueToImplementation() { // Arrange: left shorter than right but with identical prefix
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 9.4K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/platform/Jdk9Platform.kt
} @SuppressSignatureCheck override fun getSelectedProtocol(sslSocket: SSLSocket): String? = try { // SSLSocket.getApplicationProtocol returns "" if application protocols values will not // be used. Observed if you didn't specify SSLParameters.setApplicationProtocols when (val protocol = sslSocket.applicationProtocol) { null, "" -> null else -> protocol }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu May 29 16:52:38 UTC 2025 - 3.5K bytes - Viewed (0)