- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 502 for timerC (0.41 sec)
-
internal/http/server.go
_ = pprof.Lookup("goroutine").WriteTo(tmp, 1) tmp.Close() return errors.New("timed out. some connections are still active. goroutines written to " + tmp.Name()) } return errors.New("timed out. some connections are still active") case <-timer.C: if atomic.LoadInt32(&srv.requestCount) <= 0 { return nil } timer.Reset(nextPollInterval()) } } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Feb 09 21:25:16 UTC 2024 - 7.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/timer/MonitorTarget.java
* governing permissions and limitations under the License. */ package org.codelibs.fess.timer; import java.io.IOException; import java.io.PrintWriter; import java.util.Arrays; import java.util.function.Supplier; import org.apache.commons.io.output.ByteArrayOutputStream; import org.apache.commons.text.StringEscapeUtils; import org.codelibs.core.timer.TimeoutTarget; import org.codelibs.fess.Constants;
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 3K bytes - Viewed (0) -
src/runtime/race/testdata/sync_test.go
c := make(chan bool) var f func() f = func() { i-- if i >= 0 { time.AfterFunc(0, f) } else { c <- true } } time.AfterFunc(0, f) <-c } func TestNoRaceAfterFunc2(t *testing.T) { var x int _ = x timer := time.AfterFunc(10, func() { x = 1 }) defer timer.Stop() } func TestNoRaceAfterFunc3(t *testing.T) { c := make(chan bool, 1)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 10 15:05:17 UTC 2020 - 3K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/daemon/TestableDaemon.groovy
} protected void waitForState(State state) { def timer = Time.startCountdownTimer(STATE_CHANGE_TIMEOUT) def lastRegistryState = registryProbe.currentState def lastLogState = logFileProbe.currentState while (!timer.hasExpired() && (lastRegistryState != state || lastLogState != state)) { Thread.sleep(200)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 15:22:16 UTC 2024 - 3.4K bytes - Viewed (0) -
tensorflow/compiler/mlir/tf2xla/api/v2/legalize_tf.cc
std::vector<std::vector<xla::Shape>>* per_core_arg_shapes, xla::CompileOnlyClient* client) { CompilationTimer timer; auto record_time = llvm::make_scope_exit([&timer] { phase2_bridge_compilation_time->GetCell(kFullBridge) ->Add(timer.ElapsedCyclesInMilliseconds()); }); auto compilation_result = std::make_unique<XlaCompilationResult>(); DumpComputationInput(computation);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed May 29 00:40:46 UTC 2024 - 6.8K bytes - Viewed (0) -
src/runtime/trace.go
type traceAdvancerState struct { timer *wakeableSleep done chan struct{} } // start starts a new traceAdvancer. func (s *traceAdvancerState) start() { // Start a goroutine to periodically advance the trace generation. s.done = make(chan struct{}) s.timer = newWakeableSleep() go func() { for traceEnabled() { // Set a timer to wake us up s.timer.sleep(int64(debug.traceadvanceperiod))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:17:41 UTC 2024 - 37.1K bytes - Viewed (0) -
platforms/core-execution/workers/src/main/java/org/gradle/workers/internal/WorkerDaemonStarter.java
import org.gradle.api.logging.LoggingManager; import org.gradle.internal.UncheckedException; import org.gradle.internal.classloader.VisitableURLClassLoader; import org.gradle.internal.time.Time; import org.gradle.internal.time.Timer; import org.gradle.process.internal.JavaExecHandleBuilder; import org.gradle.process.internal.worker.MultiRequestClient; import org.gradle.process.internal.worker.MultiRequestWorkerProcessBuilder;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 19 14:39:33 UTC 2024 - 4.5K bytes - Viewed (0) -
src/internal/trace/testdata/generators/go122-go-create-without-running-g.go
// // GoCreate events can happen on bare Ps in a variety of situations and // and earlier version of the parser assumed this wasn't possible. At // the time of writing, one such example is goroutines created by expiring // timers. package main import ( "internal/trace" "internal/trace/event/go122" testgen "internal/trace/internal/testgen/go122" ) func main() { testgen.Main(gen) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:15:28 UTC 2024 - 996 bytes - Viewed (0) -
src/context/x_test.go
} } } func testDeadline(c Context, name string, t *testing.T) { t.Helper() d := quiescent(t) timer := time.NewTimer(d) defer timer.Stop() select { case <-timer.C: t.Fatalf("%s: context not timed out after %v", name, d) case <-c.Done(): } if e := c.Err(); e != DeadlineExceeded { t.Errorf("%s: c.Err() == %v; want %v", name, e, DeadlineExceeded) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 26.3K bytes - Viewed (0) -
src/net/testdata/igmp
Idx Device : Count Querier Group Users Timer Reporter 1 lo : 1 V3 010000E0 1 0:00000000 0 2 eth0 : 2 V2 FB0000E0 1 0:00000000 1 010000E0 1 0:00000000 0 3 eth1 : 1 V3 010000E0 1 0:00000000 0 4 eth2 : 1 V3 010000E0 1 0:00000000 0 5 eth0.100 : 2 V3 FB0000E0 1 0:00000000 0 010000E0 1 0:00000000 0
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 08 04:08:51 UTC 2014 - 775 bytes - Viewed (0)