Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 79 for _observer (0.04 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top