Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 521 - 530 of 813 for mock (0.03 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. guava/src/com/google/common/base/Suppliers.java

          in.defaultReadObject();
          lock = new Object();
        }
    
        @GwtIncompatible @J2ktIncompatible private static final long serialVersionUID = 0;
      }
    
      private static final class NonSerializableMemoizingSupplier<T extends @Nullable Object>
          implements Supplier<T> {
        private final Object lock = new Object();
    
        private volatile @Nullable Supplier<T> delegate;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 31 21:24:28 GMT 2026
    - 16.1K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/hash/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.
       *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 15 22:17:15 GMT 2025
    - 11.4K bytes
    - Click Count (0)
  3. internal/dsync/locked_rand.go

    func (r *lockedRandSource) Int63() (n int64) {
    	r.lk.Lock()
    	n = r.src.Int63()
    	r.lk.Unlock()
    	return n
    }
    
    // Seed uses the provided seed value to initialize the generator to a
    // deterministic state.
    func (r *lockedRandSource) Seed(seed int64) {
    	r.lk.Lock()
    	r.src.Seed(seed)
    	r.lk.Unlock()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 1.3K bytes
    - Click Count (0)
  4. internal/cachevalue/cache.go

    				defer t.updating.Unlock()
    				t.update(context.Background())
    			}()
    		}
    		return *v, nil
    	}
    
    	// Get lock. Either we get it or we wait for it.
    	t.updating.Lock()
    	defer t.updating.Unlock()
    
    	if time.Since(time.UnixMilli(t.lastUpdateMs.Load())) < ttl {
    		// There is a new value, release lock and return it.
    		if v = t.val.Load(); v != nil {
    			return *v, nil
    		}
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 24 12:50:46 GMT 2024
    - 4.4K bytes
    - Click Count (0)
  5. cmd/iam-store.go

    type IAMStorageAPI interface {
    	// The role of the read-write lock is to prevent go routines from
    	// concurrently reading and writing the IAM storage. The (r)lock()
    	// functions return the iamCache. The cache can be safely written to
    	// only when returned by `lock()`.
    	lock() *iamCache
    	unlock()
    	rlock() *iamCache
    	runlock()
    	getUsersSysType() UsersSysType
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 87.1K bytes
    - Click Count (0)
  6. src/main/webapp/WEB-INF/view/profile/index.jsp

    						</c:set>
    						<la:password property="oldPassword" class="form-control"
    									 placeholder="${ph_old_password}" />
    						<div class="input-group-append">
    							<span class="input-group-text"><i class="fa fa-lock fa-fw" aria-hidden="true"></i></span>
    						</div>
    					</div>
    					<div class="input-group mb-3">
    						<c:set var="ph_new_password">
    							<la:message key="labels.profile.placeholder_new_password" />
    						</c:set>
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Nov 13 05:54:52 GMT 2025
    - 3.6K bytes
    - Click Count (0)
  7. src/main/java/jcifs/internal/smb1/com/LockingAndXRange.java

            this.largeFile = largeFile;
        }
    
        /**
         * Returns the process ID associated with this lock range.
         *
         * @return the process ID
         */
        public int getPid() {
            return this.pid;
        }
    
        /**
         * Returns the starting byte offset of the lock range.
         *
         * @return the starting byte offset
         */
        public long getByteOffset() {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 4.1K bytes
    - Click Count (0)
  8. src/main/java/jcifs/smb1/smb1/TransTransactNamedPipeResponse.java

            if (pipe.pipeIn != null) {
                final TransactNamedPipeInputStream in = (TransactNamedPipeInputStream) pipe.pipeIn;
                synchronized (in.lock) {
                    in.receive(buffer, bufferIndex, len);
                    in.lock.notify();
                }
            }
            return len;
        }
    
        @Override
        public String toString() {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 2.2K bytes
    - Click Count (0)
  9. docs/bucket/replication/sio-error.sh

    ./mc alias set myminio2 http://localhost:9101 minioadmin minioadmin
    
    ./mc ready myminio1
    ./mc ready myminio2
    sleep 1
    
    ./mc mb myminio1/testbucket/ --with-lock
    ./mc mb myminio2/testbucket/ --with-lock
    
    ./mc encrypt set sse-s3 my-minio-key myminio1/testbucket/
    ./mc encrypt set sse-s3 my-minio-key myminio2/testbucket/
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sat May 18 18:19:01 GMT 2024
    - 1.7K bytes
    - Click Count (0)
  10. cmd/tier.go

    }
    
    func (t *tierMetrics) logSuccess(tier string) {
    	t.Lock()
    	defer t.Unlock()
    
    	stat := t.requestsCount[tier]
    	stat.success++
    	t.requestsCount[tier] = stat
    }
    
    func (t *tierMetrics) logFailure(tier string) {
    	t.Lock()
    	defer t.Unlock()
    
    	stat := t.requestsCount[tier]
    	stat.failure++
    	t.requestsCount[tier] = stat
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (0)
Back to Top