Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 141 for assertHeld (0.16 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

    import java.util.concurrent.locks.Condition
    import java.util.concurrent.locks.ReentrantLock
    import java.util.logging.Logger
    import kotlin.concurrent.withLock
    import okhttp3.internal.addIfAbsent
    import okhttp3.internal.assertHeld
    import okhttp3.internal.concurrent.TaskRunner.Companion.INSTANCE
    import okhttp3.internal.okHttpName
    import okhttp3.internal.threadFactory
    
    /**
     * A set of worker threads that are shared among a set of task queues.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 29 00:33:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

    import java.util.concurrent.atomic.AtomicReferenceFieldUpdater
    import okhttp3.Address
    import okhttp3.ConnectionListener
    import okhttp3.ConnectionPool
    import okhttp3.Route
    import okhttp3.internal.assertHeld
    import okhttp3.internal.closeQuietly
    import okhttp3.internal.concurrent.Task
    import okhttp3.internal.concurrent.TaskQueue
    import okhttp3.internal.concurrent.TaskRunner
    import okhttp3.internal.connection.Locks.withLock
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt

    import okhttp3.Call
    import okhttp3.Callback
    import okhttp3.EventListener
    import okhttp3.Interceptor
    import okhttp3.OkHttpClient
    import okhttp3.Request
    import okhttp3.Response
    import okhttp3.internal.assertHeld
    import okhttp3.internal.assertNotHeld
    import okhttp3.internal.assertThreadDoesntHoldLock
    import okhttp3.internal.cache.CacheInterceptor
    import okhttp3.internal.closeQuietly
    import okhttp3.internal.connection.Locks.withLock
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt

    import okhttp3.Connection
    import okhttp3.ConnectionListener
    import okhttp3.Handshake
    import okhttp3.HttpUrl
    import okhttp3.OkHttpClient
    import okhttp3.Protocol
    import okhttp3.Route
    import okhttp3.internal.assertHeld
    import okhttp3.internal.assertNotHeld
    import okhttp3.internal.closeQuietly
    import okhttp3.internal.concurrent.TaskRunner
    import okhttp3.internal.connection.Locks.withLock
    import okhttp3.internal.http.ExchangeCodec
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/-UtilJvm.kt

     */
    @JvmField
    internal val okHttpName: String =
      OkHttpClient::class.java.name.removePrefix("okhttp3.").removeSuffix("Client")
    
    @Suppress("NOTHING_TO_INLINE")
    internal inline fun ReentrantLock.assertHeld() {
      if (assertionsEnabled && !this.isHeldByCurrentThread) {
        throw AssertionError("Thread ${Thread.currentThread().name} MUST hold lock on $this")
      }
    }
    
    @Suppress("NOTHING_TO_INLINE")
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon May 13 13:42:37 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  6. cni/pkg/util/pluginutil.go

    // Given an unmarshalled CNI config JSON map, return the plugin list asserted as a []interface{}
    func GetPlugins(cniConfigMap map[string]any) (plugins []any, err error) {
    	plugins, ok := cniConfigMap["plugins"].([]any)
    	if !ok {
    		err = fmt.Errorf("error reading plugin list from CNI config")
    		return
    	}
    	return
    }
    
    // Given the raw plugin interface, return the plugin asserted as a map[string]interface{}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb/DosFileFilter.java

         * specified for this filter. The wildcard has no influence on this
         * method as the server should have performed that filtering already. The
         * attributes are asserted here only because server file systems may not
         * support filtering by all attributes (e.g. even though ATTR_DIRECTORY was
         * specified the server may still return objects that are not directories).
         */
        @Override
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 2.1K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb1/smb1/DosFileFilter.java

    /* This returns true if the file's attributes contain any of the attributes
     * specified for this filter. The wildcard has no influence on this
     * method as the server should have performed that filtering already. The
     * attributes are asserted here only because server file systems may not
     * support filtering by all attributes (e.g. even though ATTR_DIRECTORY was
     * specified the server may still return objects that are not directories).
     */
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 1.9K bytes
    - Viewed (0)
  9. licenses/github.com/opencontainers/go-digest/LICENSE

          of any other Contributor, and only if You agree to indemnify,
          defend, and hold each Contributor harmless for any liability
          incurred by, or claims asserted against, such Contributor by reason
          of your accepting any such warranty or additional liability.
    
       END OF TERMS AND CONDITIONS
    
       Copyright 2019, 2020 OCI Contributors
       Copyright 2016 Docker, Inc.
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Dec 16 22:26:43 UTC 2020
    - 10.5K bytes
    - Viewed (0)
  10. licenses/github.com/docker/cli/LICENSE

          of any other Contributor, and only if You agree to indemnify,
          defend, and hold each Contributor harmless for any liability
          incurred by, or claims asserted against, such Contributor by reason
          of your accepting any such warranty or additional liability.
    
       END OF TERMS AND CONDITIONS
    
       Copyright 2013-2017 Docker, Inc.
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jul 30 04:02:55 UTC 2021
    - 10.5K bytes
    - Viewed (0)
Back to top