- Sort Score
- Num 10 results
- Language All
Results 161 - 170 of 321 for SELECT (0.15 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
src/main/java/org/codelibs/fess/opensearch/user/bsbhv/BsUserBhv.java
return result; } // =================================================================================== // Select // ====== public int selectCount(CBCall<UserCB> cbLambda) { return facadeSelectCount(createCB(cbLambda)); }Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 15 06:53:53 GMT 2025 - 12K bytes - Click Count (0) -
internal/lsync/lrwmutex.go
r := rand.New(rand.NewSource(time.Now().UnixNano())) retryCtx, cancel := context.WithTimeout(ctx, timeout) defer cancel() for { select { case <-retryCtx.Done(): // Caller context canceled or we timedout, // return false anyways for both situations. return false default: if lm.lock(id, source, isWriteLock) { return true
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 4.8K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/opensearch/config/bsbhv/BsFileAuthenticationBhv.java
return result; } // =================================================================================== // Select // ====== public int selectCount(CBCall<FileAuthenticationCB> cbLambda) { return facadeSelectCount(createCB(cbLambda)); }Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 15 06:53:53 GMT 2025 - 10.5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureFallbackAtomicHelperTest.java
* AggregateFutureStateFallbackAtomicHelperTest, as discussed in a comment in * AggregateFutureState. * * Here, we check that we're able to force AbstractFutureState to select SynchronizedHelper, and * below, we actually run the AbstractFutureTest methods under that scenario. */ checkHelperVersion(NO_ATOMIC_REFERENCE_FIELD_UPDATER, "SynchronizedHelper");Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 8.3K bytes - Click Count (0) -
cmd/lock-rest-server.go
lkTimer := time.NewTimer(lockMaintenanceInterval) // Stop the timer upon returning. defer lkTimer.Stop() for { // Verifies every minute for locks held more than 2 minutes. select { case <-ctx.Done(): return case <-lkTimer.C: globalLockServer.expireOldLocks(lockValidityDuration) // Reset the timer for next cycle. lkTimer.Reset(lockMaintenanceInterval) } }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Jan 31 19:54:34 GMT 2025 - 6.3K bytes - Click Count (0) -
cmd/metacache-manager.go
objAPI := newObjectLayerFn() for objAPI == nil { time.Sleep(time.Second) objAPI = newObjectLayerFn() } t := time.NewTicker(time.Minute) defer t.Stop() var exit bool for !exit { select { case <-t.C: case <-GlobalContext.Done(): exit = true } m.mu.RLock() for _, v := range m.buckets { if !exit { v.cleanup() } } m.mu.RUnlock() m.mu.Lock()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Oct 25 00:44:15 GMT 2022 - 5.2K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/opensearch/log/bsbhv/BsSearchLogBhv.java
return result; } // =================================================================================== // Select // ====== public int selectCount(CBCall<SearchLogCB> cbLambda) { return facadeSelectCount(createCB(cbLambda)); }Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 15 06:53:53 GMT 2025 - 10.5K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/opensearch/config/bsbhv/BsFileConfigBhv.java
return result; } // =================================================================================== // Select // ====== public int selectCount(CBCall<FileConfigCB> cbLambda) { return facadeSelectCount(createCB(cbLambda)); }Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 15 06:53:53 GMT 2025 - 10.9K bytes - Click Count (0) -
tests/delete_test.go
Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Mon Jul 21 02:46:58 GMT 2025 - 9.5K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/exception/DefaultExceptionHandler.java
- plugin execution error due to something that is not expected to go wrong (the compiler executable missing) - asking to use a plugin for which you do not have a version defined - tools to easily select versions - goal not found in a plugin (probably could list the ones that are) */ // PluginNotFoundException, PluginResolutionException, PluginDescriptorParsingException, // CycleDetectedInPluginGraphException;
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Sat Apr 05 11:52:05 GMT 2025 - 10.9K bytes - Click Count (0)