- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for Rockarts (0.18 sec)
-
cmd/local-locker_test.go
t.Fatal("failed:", err, ok) } } } // Expire 50% toUnLock := make([]dsync.LockArgs, 0, locks*readers) for k, v := range l.lockMap { for _, lock := range v { if rng.Intn(2) == 0 { toUnLock = append(toUnLock, dsync.LockArgs{Resources: []string{k}, UID: lock.UID}) } } } start := time.Now() for _, lock := range toUnLock {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 05 04:57:35 GMT 2023 - 11.8K bytes - Viewed (0) -
cmd/local-locker.go
delete(l.lockUID, mapID) idx++ continue } reply = true l.removeEntry(resource, dsync.LockArgs{UID: args.UID}, &lris) idx++ } } } func (l *localLocker) Refresh(ctx context.Context, args dsync.LockArgs) (refreshed bool, err error) { select { case <-ctx.Done(): return false, ctx.Err() default: l.mutex.Lock() defer l.mutex.Unlock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 19 22:54:46 GMT 2024 - 10.6K bytes - Viewed (0) -
internal/dsync/drwmutex.go
}() } func forceUnlock(ctx context.Context, ds *Dsync, id string) { ctx, cancel := context.WithTimeout(ctx, ds.Timeouts.ForceUnlockCall) defer cancel() restClnts, _ := ds.GetLockers() args := LockArgs{ UID: id, } var wg sync.WaitGroup for index, c := range restClnts { wg.Add(1) // Send refresh request to all nodes go func(index int, c NetLocker) { defer wg.Done()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
okhttp/src/main/resources/okhttp3/internal/publicsuffix/PublicSuffixDatabase.gz
riopreto.br rip rishiri.hokkaido.jp rishirifuji.hokkaido.jp risor.no rissa.no risør.no ritto.shiga.jp rivne.ua rj.gov.br rj.leg.br rl.no rm.it rn.gov.br rn.it rn.leg.br ro ro.eu.org ro.gov.br ro.im ro.it ro.leg.br roan.no rocher rochester.museum rockart.museum rocks rocky.page rodeo rodoy.no rogers rokunohe.aomori.jp rollag.no roma.it roma.museum rome.it romsa.no romskog.no room roros.no rost.no rotorcraft.aero router.management rovigo.it rovno.ua royal-commission.uk royken.no royrvik.no rr.gov.br...
Others - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 40.4K bytes - Viewed (0)