Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 175 for rocks (0.03 sec)

  1. src/test/java/jcifs/http/NetworkExplorerTest.java

        }
    
        /**
         * Test servlet initialization with default parameters
         */
        @Test
        void testInit_DefaultConfig() throws ServletException {
            // Reset mocks for this test
            reset(servletConfig, servletContext);
    
            lenient().when(servletConfig.getServletContext()).thenReturn(servletContext);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 04:51:33 UTC 2025
    - 21.2K bytes
    - Viewed (0)
  2. docs/contribute/concurrency.md

    ### Locks
    
    We have 3 different things that we synchronize on.
    
    #### Http2Connection
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 7K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java

     * object). So it is important to not call {@link #dispatch} while holding any locks. This is why
     * {@link #enqueue} and {@link #dispatch} are 2 different methods. It is expected that the decision
     * to run a particular event is made during the state change, but the decision to actually invoke
     * the listeners can be delayed slightly so that locks can be dropped. Also, because {@link
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

    import com.google.common.annotations.VisibleForTesting;
    import com.google.j2objc.annotations.ReflectionSupport;
    import java.util.concurrent.atomic.AtomicReference;
    import java.util.concurrent.locks.AbstractOwnableSynchronizer;
    import java.util.concurrent.locks.LockSupport;
    import org.jspecify.annotations.Nullable;
    
    @GwtCompatible
    @ReflectionSupport(value = ReflectionSupport.Level.FULL)
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 10K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RouteSelector.kt

        inetSocketAddresses = mutableInetSocketAddresses
    
        val socketHost: String
        val socketPort: Int
        if (proxy.type() == Proxy.Type.DIRECT || proxy.type() == Proxy.Type.SOCKS) {
          socketHost = address.url.host
          socketPort = address.url.port
        } else {
          val proxyAddress = proxy.address()
          require(proxyAddress is InetSocketAddress) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 7.3K bytes
    - Viewed (1)
  6. android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

    import com.google.common.util.concurrent.CycleDetectingLockFactory.PotentialDeadlockException;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReentrantLock;
    import java.util.concurrent.locks.ReentrantReadWriteLock;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Unittests for {@link CycleDetectingLockFactory}.
     *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

    import com.google.common.util.concurrent.CycleDetectingLockFactory.PotentialDeadlockException;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReentrantLock;
    import java.util.concurrent.locks.ReentrantReadWriteLock;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Unittests for {@link CycleDetectingLockFactory}.
     *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  8. cmd/metrics-v3-system-process.go

    	processVirtualMemoryMaxBytes    = "virtual_memory_max_bytes"
    )
    
    var (
    	processLocksReadTotalMD           = NewGaugeMD(processLocksReadTotal, "Number of current READ locks on this peer")
    	processLocksWriteTotalMD          = NewGaugeMD(processLocksWriteTotal, "Number of current WRITE locks on this peer")
    	processCPUTotalSecondsMD          = NewCounterMD(processCPUTotalSeconds, "Total user and system CPU time spent in seconds")
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Jun 20 17:55:03 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  9. docs/site-replication/gen-oidc-sts-cred.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package main
    
    // This programs mocks user interaction against Dex IDP and generates STS
    // credentials. It is for MinIO testing purposes only.
    //
    // Run like:
    //
    // $ MINIO_ENDPOINT=http://localhost:9000 go run gen-oidc-sts-cred.go
    
    import (
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 29 01:27:09 UTC 2022
    - 2.3K bytes
    - Viewed (0)
  10. .teamcity/src/main/kotlin/promotion/BasePromotionBuildType.kt

                // we only allow 1 promotion job running at the same time to avoid website xml conflicts
                feature {
                    type = "JetBrains.SharedResources"
                    param("locks-param", "WebsiteReleasesXml writeLock")
                }
            }
        }
    Registered: Wed Sep 10 11:36:15 UTC 2025
    - Last Modified: Thu Mar 20 06:13:56 UTC 2025
    - 2.2K bytes
    - Viewed (0)
Back to top