/dports/sysutils/epazote/epazote-2.1.2/vendor/github.com/epazote/scheduler/ |
H A D | scheduler.go | 12 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 D | schedulers.go | 15 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 D | SignalWebSocketHealthMonitor.java | 20 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 D | SignalWebSocketHealthMonitor.java | 15 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 D | statistics_SUITE.erl | 334 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 D | unique_SUITE.erl | 265 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 D | statistics_SUITE.erl | 334 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 D | unique_SUITE.erl | 265 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 D | statistics_SUITE.erl | 334 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 D | unique_SUITE.erl | 265 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 D | statistics_SUITE.erl | 334 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 D | unique_SUITE.erl | 265 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 D | statistics_SUITE.erl | 334 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 D | unique_SUITE.erl | 265 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 D | GaplessDb.kt | 7 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 D | OfflineDb.kt | 14 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 D | unique_SUITE.erl | 265 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 D | statistics_SUITE.erl | 334 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 D | unique_SUITE.erl | 265 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 D | statistics_SUITE.erl | 325 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 D | schedulers.rst | 1 .. _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 D | RemoteMetadataProxy.kt | 12 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 D | Details.md | 6 streams using Schedulers . Simply put, Rx = Observables + LINQ + 7 Schedulers.
|
/dports/lang/mono/mono-5.10.1.57/external/rx/xpkg/ |
H A D | Details.md | 6 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 D | UpdateCheck.kt | 8 import io.reactivex.schedulers.Schedulers in <lambda>() 85 .subscribeOn(Schedulers.io()) in run()
|