- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 180 for wlocked (0.06 sec)
-
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) -
android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 16.2K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)