Home
last modified time | relevance | path

Searched refs:Schedulers (Results 1 – 25 of 725) sorted by relevance

12345678910>>...29

/dports/sysutils/epazote/epazote-2.1.2/vendor/github.com/epazote/scheduler/
H A Dscheduler.go12 Schedulers map[string]scheduler
25 Schedulers: make(map[string]scheduler),
43 if sk, ok := s.Schedulers[name]; ok {
48 s.Schedulers[name] = scheduler
67 sk, ok := s.Schedulers[name]
82 for k, v := range s.Schedulers {
/dports/www/mattermost-server/mattermost-server-6.0.2/jobs/
H A Dschedulers.go15 type Schedulers struct { struct
43 schedulers := &Schedulers{
112 func (schedulers *Schedulers) Start() { argument
186 func (schedulers *Schedulers) Stop() { argument
195 func (schedulers *Schedulers) setNextRunTime(cfg *model.Config, idx int, now time.Time, pendingJobs… argument
219 func (schedulers *Schedulers) scheduleJob(cfg *model.Config, scheduler model.Scheduler) (*model.Job… argument
233 func (schedulers *Schedulers) handleConfigChange(_, newConfig *model.Config) { argument
241 func (schedulers *Schedulers) handleClusterLeaderChange(isLeader bool) { argument
/dports/net-im/signald/signald-65cf5e8a1cf2b81fd1f5c3936e0164d53c5a9b29/src/main/java/io/finn/signald/
H A DSignalWebSocketHealthMonitor.java20 import io.reactivex.rxjava3.schedulers.Schedulers;
57 .subscribeOn(Schedulers.computation()) in monitor()
58 .observeOn(Schedulers.computation()) in monitor()
64 .subscribeOn(Schedulers.computation()) in monitor()
65 .observeOn(Schedulers.computation()) in monitor()
/dports/net-im/signal-cli/signal-cli-0.9.0/lib/src/main/java/org/asamk/signal/manager/
H A DSignalWebSocketHealthMonitor.java15 import io.reactivex.rxjava3.schedulers.Schedulers;
51 .subscribeOn(Schedulers.computation()) in monitor()
52 .observeOn(Schedulers.computation()) in monitor()
58 .subscribeOn(Schedulers.computation()) in monitor()
59 .observeOn(Schedulers.computation()) in monitor()
/dports/lang/erlang-runtime24/otp-OTP-24.1.7/erts/emulator/test/
H A Dstatistics_SUITE.erl334 Schedulers = erlang:system_info(schedulers_online),
339 Schedulers + DirtyCPUSchedulers + DirtyIOSchedulers;
341 Schedulers + DirtyCPUSchedulers
354 Schedulers,
389 HalfHogs = [StartHog() || _ <- lists:seq(1, (Schedulers-1) div 2)],
397 if Schedulers =:= 1, HalfLoad > 80 -> ok; %% Ok only one scheduler online and one hog
406 LastHogs = [StartHog() || _ <- lists:seq(1, (Schedulers+1) div 2),
407 Schedulers =/= 1],
453 Schedulers = erlang:system_info(schedulers),
463 lists:sublist(SortedStats, Schedulers+1, DirtyCPUSchedulersOnline),
[all …]
H A Dunique_SUITE.erl265 Schedulers = schedulers(),
266 io:format("Schedulers=~p~n", [Schedulers]),
271 SchedBits = calc_sched_bits(Schedulers, 0),
273 MaxInt = ((((1 bsl 64) - 1) bsl SchedBits) bor Schedulers) + MinSmall,
278 schedulers = Schedulers,
/dports/lang/erlang-runtime23/otp-OTP-23.3.4.10/erts/emulator/test/
H A Dstatistics_SUITE.erl334 Schedulers = erlang:system_info(schedulers_online),
339 Schedulers + DirtyCPUSchedulers + DirtyIOSchedulers;
341 Schedulers + DirtyCPUSchedulers
354 Schedulers,
389 HalfHogs = [StartHog() || _ <- lists:seq(1, (Schedulers-1) div 2)],
397 if Schedulers =:= 1, HalfLoad > 80 -> ok; %% Ok only one scheduler online and one hog
406 LastHogs = [StartHog() || _ <- lists:seq(1, (Schedulers+1) div 2),
407 Schedulers =/= 1],
453 Schedulers = erlang:system_info(schedulers),
463 lists:sublist(SortedStats, Schedulers+1, DirtyCPUSchedulersOnline),
[all …]
H A Dunique_SUITE.erl265 Schedulers = schedulers(),
266 io:format("Schedulers=~p~n", [Schedulers]),
271 SchedBits = calc_sched_bits(Schedulers, 0),
273 MaxInt = ((((1 bsl 64) - 1) bsl SchedBits) bor Schedulers) + MinSmall,
278 schedulers = Schedulers,
/dports/lang/erlang-wx/otp-OTP-24.1.7/erts/emulator/test/
H A Dstatistics_SUITE.erl334 Schedulers = erlang:system_info(schedulers_online),
339 Schedulers + DirtyCPUSchedulers + DirtyIOSchedulers;
341 Schedulers + DirtyCPUSchedulers
354 Schedulers,
389 HalfHogs = [StartHog() || _ <- lists:seq(1, (Schedulers-1) div 2)],
397 if Schedulers =:= 1, HalfLoad > 80 -> ok; %% Ok only one scheduler online and one hog
406 LastHogs = [StartHog() || _ <- lists:seq(1, (Schedulers+1) div 2),
407 Schedulers =/= 1],
453 Schedulers = erlang:system_info(schedulers),
463 lists:sublist(SortedStats, Schedulers+1, DirtyCPUSchedulersOnline),
[all …]
H A Dunique_SUITE.erl265 Schedulers = schedulers(),
266 io:format("Schedulers=~p~n", [Schedulers]),
271 SchedBits = calc_sched_bits(Schedulers, 0),
273 MaxInt = ((((1 bsl 64) - 1) bsl SchedBits) bor Schedulers) + MinSmall,
278 schedulers = Schedulers,
/dports/lang/erlang/otp-OTP-24.1.7/erts/emulator/test/
H A Dstatistics_SUITE.erl334 Schedulers = erlang:system_info(schedulers_online),
339 Schedulers + DirtyCPUSchedulers + DirtyIOSchedulers;
341 Schedulers + DirtyCPUSchedulers
354 Schedulers,
389 HalfHogs = [StartHog() || _ <- lists:seq(1, (Schedulers-1) div 2)],
397 if Schedulers =:= 1, HalfLoad > 80 -> ok; %% Ok only one scheduler online and one hog
406 LastHogs = [StartHog() || _ <- lists:seq(1, (Schedulers+1) div 2),
407 Schedulers =/= 1],
453 Schedulers = erlang:system_info(schedulers),
463 lists:sublist(SortedStats, Schedulers+1, DirtyCPUSchedulersOnline),
[all …]
H A Dunique_SUITE.erl265 Schedulers = schedulers(),
266 io:format("Schedulers=~p~n", [Schedulers]),
271 SchedBits = calc_sched_bits(Schedulers, 0),
273 MaxInt = ((((1 bsl 64) - 1) bsl SchedBits) bor Schedulers) + MinSmall,
278 schedulers = Schedulers,
/dports/lang/erlang-java/otp-OTP-24.1.7/erts/emulator/test/
H A Dstatistics_SUITE.erl334 Schedulers = erlang:system_info(schedulers_online),
339 Schedulers + DirtyCPUSchedulers + DirtyIOSchedulers;
341 Schedulers + DirtyCPUSchedulers
354 Schedulers,
389 HalfHogs = [StartHog() || _ <- lists:seq(1, (Schedulers-1) div 2)],
397 if Schedulers =:= 1, HalfLoad > 80 -> ok; %% Ok only one scheduler online and one hog
406 LastHogs = [StartHog() || _ <- lists:seq(1, (Schedulers+1) div 2),
407 Schedulers =/= 1],
453 Schedulers = erlang:system_info(schedulers),
463 lists:sublist(SortedStats, Schedulers+1, DirtyCPUSchedulersOnline),
[all …]
H A Dunique_SUITE.erl265 Schedulers = schedulers(),
266 io:format("Schedulers=~p~n", [Schedulers]),
271 SchedBits = calc_sched_bits(Schedulers, 0),
273 MaxInt = ((((1 bsl 64) - 1) bsl SchedBits) bor Schedulers) + MinSmall,
278 schedulers = Schedulers,
/dports/multimedia/musikcube/musikcube-0.96.7/src/musikdroid/app/src/main/java/io/casey/musikcube/remote/service/gapless/db/
H A DGaplessDb.kt7 import io.reactivex.schedulers.Schedulers
19 .subscribeOn(Schedulers.io()) in dao()
/dports/multimedia/musikcube/musikcube-0.96.7/src/musikdroid/app/src/main/java/io/casey/musikcube/remote/service/playback/impl/streaming/db/
H A DOfflineDb.kt14 import io.reactivex.schedulers.Schedulers in <lambda>()
65 .subscribeOn(Schedulers.io()) in <lambda>()
115 .subscribeOn(Schedulers.io()) in <lambda>()
/dports/lang/erlang-runtime22/otp-OTP-22.3.4.24/erts/emulator/test/
H A Dunique_SUITE.erl265 Schedulers = schedulers(),
266 io:format("Schedulers=~p~n", [Schedulers]),
271 SchedBits = calc_sched_bits(Schedulers, 0),
273 MaxInt = ((((1 bsl 64) - 1) bsl SchedBits) bor Schedulers) + MinSmall,
278 schedulers = Schedulers,
H A Dstatistics_SUITE.erl334 Schedulers = erlang:system_info(schedulers_online),
339 Schedulers + DirtyCPUSchedulers + DirtyIOSchedulers;
341 Schedulers + DirtyCPUSchedulers
374 HalfHogs = [StartHog() || _ <- lists:seq(1, (Schedulers-1) div 2)],
380 if Schedulers < 2, HalfLoad > 80 -> ok; %% Ok only one scheduler online and one hog
387 LastHogs = [StartHog() || _ <- lists:seq(1, Schedulers div 2)],
/dports/lang/erlang-runtime21/otp-OTP-21.3.8.24/erts/emulator/test/
H A Dunique_SUITE.erl265 Schedulers = schedulers(),
266 io:format("Schedulers=~p~n", [Schedulers]),
271 SchedBits = calc_sched_bits(Schedulers, 0),
273 MaxInt = ((((1 bsl 64) - 1) bsl SchedBits) bor Schedulers) + MinSmall,
278 schedulers = Schedulers,
H A Dstatistics_SUITE.erl325 Schedulers = erlang:system_info(schedulers_online),
330 Schedulers + DirtyCPUSchedulers + DirtyIOSchedulers;
332 Schedulers + DirtyCPUSchedulers
365 HalfHogs = [StartHog() || _ <- lists:seq(1, (Schedulers-1) div 2)],
371 if Schedulers < 2, HalfLoad > 80 -> ok; %% Ok only one scheduler online and one hog
378 LastHogs = [StartHog() || _ <- lists:seq(1, Schedulers div 2)],
/dports/devel/py-buildbot/buildbot-3.4.1/docs/developer/
H A Dschedulers.rst1 .. _Writing-Schedulers:
3 Writing Schedulers
8 Schedulers are free to decide when to request builds, and to define the parameters of the builds.
38 Schedulers are Twisted services, so they can implement ``startService`` and ``stopService``.
82 Schedulers must up-call the parent class's ``activate`` and ``deactivate`` methods!
/dports/multimedia/musikcube/musikcube-0.96.7/src/musikdroid/app/src/main/java/io/casey/musikcube/remote/service/websocket/model/impl/remote/
H A DRemoteMetadataProxy.kt12 import io.reactivex.schedulers.Schedulers in <lambda>()
50 .observeOn(Schedulers.computation()) in <lambda>()
63 .observeOn(Schedulers.computation()) in <lambda>()
79 .observeOn(Schedulers.computation()) in <lambda>()
94 .observeOn(Schedulers.computation()) in <lambda>()
110 .observeOn(Schedulers.computation()) in <lambda>()
163 .observeOn(Schedulers.computation()) in <lambda>()
194 .observeOn(Schedulers.computation()) in <lambda>()
236 .observeOn(Schedulers.computation()) in <lambda>()
248 .observeOn(Schedulers.computation()) in <lambda>()
[all …]
/dports/lang/mono/mono-5.10.1.57/external/rx/component/
H A DDetails.md6 streams using Schedulers . Simply put, Rx = Observables + LINQ +
7 Schedulers.
/dports/lang/mono/mono-5.10.1.57/external/rx/xpkg/
H A DDetails.md6 streams using Schedulers . Simply put, Rx = Observables + LINQ +
7 Schedulers.
/dports/multimedia/musikcube/musikcube-0.96.7/src/musikdroid/app/src/main/java/io/casey/musikcube/remote/ui/shared/util/
H A DUpdateCheck.kt8 import io.reactivex.schedulers.Schedulers in <lambda>()
85 .subscribeOn(Schedulers.io()) in run()

12345678910>>...29