- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 143 for Widmer (0.22 sec)
-
internal/dsync/dsync_test.go
defer cancel() dm.Unlock(ctx) unlockReturned <- struct{}{} }() timer := time.NewTimer(2 * testDrwMutexUnlockCallTimeout) defer timer.Stop() select { case <-unlockReturned: t.Fatal("Unlock timed out, which should not happen") case <-timer.C: } } // Borrowed from mutex_test.go func HammerMutex(m *DRWMutex, loops int, cdone chan bool) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 11K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exec/ThumbnailGenerator.java
import org.codelibs.core.misc.DynamicProperties; import org.codelibs.core.timer.TimeoutManager; import org.codelibs.core.timer.TimeoutTask; import org.codelibs.fess.Constants; import org.codelibs.fess.crawler.client.FesenClient; import org.codelibs.fess.es.client.SearchEngineClient; import org.codelibs.fess.exception.ContainerNotAvailableException; import org.codelibs.fess.timer.SystemMonitorTarget; import org.codelibs.fess.util.ComponentUtil;
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 8.2K bytes - Viewed (0) -
cmd/erasure-sets.go
wg.Wait() // Reset for the next interval timer.Reset(globalAPIConfig.getDeleteCleanupInterval()) } } } func (s *erasureSets) cleanupStaleUploads(ctx context.Context) { timer := time.NewTimer(globalAPIConfig.getStaleUploadsCleanupInterval()) defer timer.Stop() for { select { case <-ctx.Done(): return case <-timer.C: var wg sync.WaitGroup for _, set := range s.sets {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 37.5K bytes - Viewed (5) -
guava-tests/test/com/google/common/collect/QueuesTest.java
producer.beganProducing.await(); // make sure we time out Stopwatch timer = Stopwatch.createStarted(); int drained = drain(q, newArrayList(), 2, 10, MILLISECONDS, interruptibly); assertThat(drained).isAtMost(1); assertThat(timer.elapsed(MILLISECONDS)).isAtLeast(10L);
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 12K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exec/SuggestCreator.java
import org.codelibs.core.timer.TimeoutManager; import org.codelibs.core.timer.TimeoutTask; import org.codelibs.fess.Constants; import org.codelibs.fess.crawler.client.FesenClient; import org.codelibs.fess.es.client.SearchEngineClient; import org.codelibs.fess.exception.ContainerNotAvailableException; import org.codelibs.fess.helper.SuggestHelper; import org.codelibs.fess.timer.SystemMonitorTarget;
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 10K bytes - Viewed (0) -
docs/de/docs/deployment/concepts.md
## Beim Hochfahren ausführen
Plain Text - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Sat Mar 30 20:16:25 GMT 2024 - 20.6K bytes - Viewed (0) -
cmd/mrf.go
// let recently failed networks to reconnect // making MRF wait for 1s before retrying, // i.e 4 reconnect attempts. time.Sleep(time.Second) } // wait on timer per heal wait := healSleeper.Timer(context.Background()) scan := madmin.HealNormalScan if u.scanMode != 0 { scan = u.scanMode } if u.object == "" { healBucket(u.bucket, scan) } else {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 3.2K bytes - Viewed (0) -
docs/de/docs/how-to/separate-openapi-schemas.md
<img src="/img/tutorial/separate-openapi-schemas/image02.png"> </div> Das bedeutet, dass es **immer einen Wert** hat, der Wert kann jedoch manchmal `None` sein (oder `null` in JSON). Das bedeutet, dass Clients, die Ihre API verwenden, nicht prüfen müssen, ob der Wert vorhanden ist oder nicht. Sie können davon ausgehen, dass das Feld immer vorhanden ist. In einigen Fällen hat es jedoch nur den Defaultwert `None`.
Plain Text - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Sat Mar 30 18:18:03 GMT 2024 - 7.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/ExecJob.java
import org.apache.commons.io.FileUtils; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.lang.StringUtil; import org.codelibs.core.timer.TimeoutManager; import org.codelibs.core.timer.TimeoutTask; import org.codelibs.fess.Constants; import org.codelibs.fess.es.config.exentity.ScheduledJob; import org.codelibs.fess.util.ComponentUtil;
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 7.2K bytes - Viewed (0) -
internal/kms/kes.go
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Apr 16 15:43:39 GMT 2024 - 14.9K bytes - Viewed (0)