Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 602 for Flock (2.48 sec)

  1. guava-testlib/src/com/google/common/testing/TearDownStack.java

    @GwtCompatible
    @NullMarked
    public class TearDownStack implements TearDownAccepter {
      private static final Logger logger = Logger.getLogger(TearDownStack.class.getName());
    
      @VisibleForTesting final Object lock = new Object();
    
      @GuardedBy("lock")
      final Deque<TearDown> stack = new ArrayDeque<>();
    
      private final boolean suppressThrows;
    
      public TearDownStack() {
        this.suppressThrows = false;
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 2.5K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/core/exception/IllegalBlockSizeRuntimeException.java

     */
    package org.codelibs.core.exception;
    
    import javax.crypto.IllegalBlockSizeException;
    
    /**
     * Signals that this exception has been thrown when a block cipher is supplied with input data whose length is not a multiple of the cipher's block size, or that has been padded to the wrong length.
     * @author shinsuke
     */
    public class IllegalBlockSizeRuntimeException extends ClRuntimeException {
    
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Sat Jul 05 00:11:05 UTC 2025
    - 1.4K bytes
    - Viewed (0)
  3. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingEventListener.kt

      /** The timestamp of the last taken event, used to measure elapsed time between events. */
      private var lastTimestampNs: Long? = null
    
      /** Confirm that the thread does not hold a lock on `lock` during the callback. */
      fun forbidLock(lock: Any) {
        forbiddenLocks.add(lock)
      }
    
      /**
       * Removes recorded events up to (and including) an event is found whose class equals [eventClass]
       * and returns it.
       */
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue May 27 14:58:02 UTC 2025
    - 9.5K bytes
    - Viewed (0)
  4. cmd/callhome.go

    		return
    	}
    
    	go func() {
    		r := rand.New(rand.NewSource(time.Now().UnixNano()))
    		// Leader node (that successfully acquires the lock inside runCallhome)
    		// will keep performing the callhome. If the leader goes down for some reason,
    		// the lock will be released and another node will acquire it and take over
    		// because of this loop.
    		for {
    			if !globalCallhomeConfig.Enabled() {
    				return
    			}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/MediaTypeJvmTest.kt

          assertEquals("jpeg", mediaType.subtype)
        }
      }
    
      private fun <T> withLocale(
        locale: Locale,
        block: () -> T,
      ): T {
        val previous = Locale.getDefault()
        try {
          Locale.setDefault(locale)
          return block()
        } finally {
          Locale.setDefault(previous)
        }
      }
    
      @Test fun testIllegalCharsetName() {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 3K bytes
    - Viewed (0)
  6. tests/transaction_test.go

    		t.Fatalf("Transaction return error will equal the block returns error")
    	}
    
    	if err := DB.First(&User{}, "name = ?", "transaction-block").Error; err == nil {
    		t.Fatalf("Should not find record after rollback")
    	}
    
    	// commit
    	DB.Transaction(func(tx *gorm.DB) error {
    		user := *GetUser("transaction-block-2", Config{})
    		if err := tx.Save(&user).Error; err != nil {
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Sun May 25 07:40:40 UTC 2025
    - 13.3K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/http/ne.css

    a {
        display: block;
        float: left;
        width: 300px;
        height: 50px;
        padding: 2px;
        font-family: Verdana, sans-serif;
        font-size: 10pt;
        color: #000000;
        text-decoration: none
    }
    a.plain {
        display: inline;
        float: none;
        width: auto;
        height: auto
    }
    a.sort {
        display: block;
        float: left;
        width: 100px;
        height: 15px;
        font-family: Verdana, sans-serif;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 1.2K bytes
    - Viewed (0)
  8. src/main/java/jcifs/internal/smb2/lock/Smb2LockResponse.java

     * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
     */
    package jcifs.internal.smb2.lock;
    
    import jcifs.Configuration;
    import jcifs.internal.SMBProtocolDecodingException;
    import jcifs.internal.smb2.ServerMessageBlock2Response;
    import jcifs.internal.util.SMBUtil;
    
    /**
     * SMB2 Lock response message. This response acknowledges the successful
     * acquisition or release of byte-range locks.
     *
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 2.1K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/cache/Striped64.java

       * needed.
       *
       * A single spinlock ("busy") is used for initializing and
       * resizing the table, as well as populating slots with new Cells.
       * There is no need for a blocking lock; when the lock is not
       * available, threads try other slots (or the base).  During these
       * retries, there is increased contention and reduced locality,
       * which is still better than alternatives.
       *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jan 15 22:17:15 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Interceptor.kt

         * val interceptor = Interceptor { chain: Interceptor.Chain ->
         *     chain.proceed(chain.request())
         * }
         * ```
         */
        inline operator fun invoke(crossinline block: (chain: Chain) -> Response): Interceptor = Interceptor { block(it) }
      }
    
      interface Chain {
        fun request(): Request
    
        @Throws(IOException::class)
        fun proceed(request: Request): 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)
Back to top