Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 180 for wlocked (0.06 sec)

  1. src/main/java/org/codelibs/fess/app/web/admin/badword/EditForm.java

     * This form extends CreateForm to include fields necessary for updating existing bad word entries,
     * including tracking information for optimistic locking and audit trails.
     * Bad words are terms that should be filtered or blocked in search results.
     *
     */
    public class EditForm extends CreateForm {
    
        /**
         * Creates a new EditForm instance.
         */
        public EditForm() {
            super();
        }
    
        /**
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 2.2K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        ReentrantLock lockD = otherFactory.newReentrantLock("LockD");
    
        // lockA -> lockD
        lockA.lock();
        lockD.lock();
        lockA.unlock();
        lockD.unlock();
    
        // lockD -> lockA should fail even though lockD is from a different factory.
        lockD.lock();
        PotentialDeadlockException expected =
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  3. internal/ringbuffer/ring_buffer.go

    func (r *RingBuffer) WithCancel(ctx context.Context) *RingBuffer {
    	go func() {
    		<-ctx.Done()
    		r.CloseWithError(ctx.Err())
    	}()
    	return r
    }
    
    func (r *RingBuffer) setErr(err error, locked bool) error {
    	if !locked {
    		r.mu.Lock()
    		defer r.mu.Unlock()
    	}
    	if r.err != nil && r.err != io.EOF {
    		return r.err
    	}
    
    	switch err {
    	// Internal errors are transient
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 13.3K bytes
    - Viewed (0)
  4. src/main/java/jcifs/dcerpc/msrpc/samr.idl

    		ACB_SVRTRUST               = 0x00000100, /* 1 = Server trust account */
    		ACB_PWNOEXP                = 0x00000200, /* 1 = User password does not expire */
    		ACB_AUTOLOCK               = 0x00000400, /* 1 = Account auto locked */
    		ACB_ENC_TXT_PWD_ALLOWED    = 0x00000800, /* 1 = Encryped text password is allowed */
    		ACB_SMARTCARD_REQUIRED     = 0x00001000, /* 1 = Smart Card required */
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 3.1K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

                }
                throw new RejectedExecutionException();
              }
            };
        SequentialExecutor executor = new SequentialExecutor(delegate);
        ExecutorService blocked = newCachedThreadPool();
        Future<?> first =
            blocked.submit(
                new Runnable() {
                  @Override
                  public void run() {
                    executor.execute(Runnables.doNothing());
                  }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  6. cmd/callhome.go

    	// Make sure only 1 callhome is running on the cluster.
    	locker := objAPI.NewNSLock(minioMetaBucket, "callhome/runCallhome.lock")
    	lkctx, err := locker.GetLock(ctx, callhomeLeaderLockTimeout)
    	if err != nil {
    		// lock timedout means some other node is the leader,
    		// cycle back return 'true'
    		return true
    	}
    
    	ctx = lkctx.Context()
    	defer locker.Unlock(lkctx)
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

                }
                throw new RejectedExecutionException();
              }
            };
        SequentialExecutor executor = new SequentialExecutor(delegate);
        ExecutorService blocked = newCachedThreadPool();
        Future<?> first =
            blocked.submit(
                new Runnable() {
                  @Override
                  public void run() {
                    executor.execute(Runnables.doNothing());
                  }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  8. src/test/java/jcifs/smb/SessionSetupHandlerTest.java

        }
    
        @Mock
        SessionSetupHandler mocked;
    
        @Test
        @DisplayName("Interactions: Mockito mock has no interactions by default")
        void testMockitoNoInteractions() {
            // Intent: ensure we can mock the interface and verify no unexpected calls
            // Act & Assert
            assertNotNull(mocked);
            verifyNoInteractions(mocked);
        }
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  9. src/test/java/jcifs/dcerpc/ndr/NdrHyperTest.java

        void testEncode() throws NdrException {
            // Test the encode method
            long testValue = 987654321098765L;
            NdrHyper ndrHyper = new NdrHyper(testValue);
    
            // Call the encode method with the mocked NdrBuffer
            ndrHyper.encode(mockNdrBuffer);
    
            // Verify that enc_ndr_hyper was called exactly once with the correct value
            verify(mockNdrBuffer, times(1)).enc_ndr_hyper(testValue);
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 2.2K bytes
    - Viewed (0)
  10. cmd/shared-lock.go

    })
    
    type sharedLock struct {
    	lockContext chan LockContext
    }
    
    func (ld sharedLock) backgroundRoutine(ctx context.Context, objAPI ObjectLayer, lockName string) {
    	for {
    		locker := objAPI.NewNSLock(minioMetaBucket, lockName)
    		lkctx, err := locker.GetLock(ctx, sharedLockTimeout)
    		if err != nil {
    			continue
    		}
    
    	keepLock:
    		for {
    			select {
    			case <-ctx.Done():
    				return
    			case <-lkctx.Context().Done():
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Feb 13 09:26:38 UTC 2023
    - 2.3K bytes
    - Viewed (0)
Back to top