- Sort Score
- Num 10 results
- Language All
Results 251 - 260 of 420 for Select1 (0.07 seconds)
-
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/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) -
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) -
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/BsBadWordBhv.java
return result; } // =================================================================================== // Select // ====== public int selectCount(CBCall<BadWordCB> cbLambda) { return facadeSelectCount(createCB(cbLambda)); }Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 15 06:53:53 GMT 2025 - 9.5K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/opensearch/config/bsbhv/BsBoostDocumentRuleBhv.java
return result; } // =================================================================================== // Select // ====== public int selectCount(CBCall<BoostDocumentRuleCB> 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.1K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/opensearch/config/bsbhv/BsDuplicateHostBhv.java
return result; } // =================================================================================== // Select // ====== public int selectCount(CBCall<DuplicateHostCB> cbLambda) { return facadeSelectCount(createCB(cbLambda)); }Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 15 06:53:53 GMT 2025 - 9.9K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/opensearch/config/bsbhv/BsJobLogBhv.java
return result; } // =================================================================================== // Select // ====== public int selectCount(CBCall<JobLogCB> cbLambda) { return facadeSelectCount(createCB(cbLambda)); }Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 15 06:53:53 GMT 2025 - 9.6K bytes - Click Count (0) -
cmd/metacache.go
func (m metacache) keepAlive(ctx context.Context, rpc *peerRESTClient) { // we intentionally operate on a copy of m, so we can update without locks. t := time.NewTicker(metacacheMaxClientWait / 10) defer t.Stop() for { select { case <-ctx.Done(): // Request is done, stop updating. return case <-t.C: m.lastHandout = time.Now() if m2, err := rpc.UpdateMetacacheListing(ctx, m); err == nil {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Jul 12 16:23:16 GMT 2024 - 6K bytes - Click Count (0) -
docs/debugging/reorder-disks/main.go
flag.Parse() localDisks, err := filterLocalDisks(node, args) if err != nil { log.Fatal(err) } if len(localDisks) == 0 { log.Fatal("Fix --local-node-name or/and --args to select local disks.") } format, err := getFormatJSON(localDisks[0].path) if err != nil { log.Fatal(err) } setSize := len(format.XL.Sets[0]) expectedDisksName := make(map[string]string)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri May 24 23:05:23 GMT 2024 - 5.4K bytes - Click Count (0)