/dports/graphics/qgis/qgis-3.22.3/tests/src/python/ |
H A D | test_qgstaskmanager.py | 80 QgsApplication.taskManager().addTask(task) 90 QgsApplication.taskManager().addTask(bad_task) 110 QgsApplication.taskManager().addTask(task) 121 QgsApplication.taskManager().addTask(bad_task) 137 QgsApplication.taskManager().addTask(task) 163 QgsApplication.taskManager().addTask(task) 184 QgsApplication.taskManager().addTask(task) 206 QgsApplication.taskManager().addTask(task) 229 QgsApplication.taskManager().addTask(task) 253 QgsApplication.taskManager().addTask(task) [all …]
|
/dports/graphics/qgis-ltr/qgis-3.16.16/tests/src/python/ |
H A D | test_qgstaskmanager.py | 80 QgsApplication.taskManager().addTask(task) 90 QgsApplication.taskManager().addTask(bad_task) 110 QgsApplication.taskManager().addTask(task) 121 QgsApplication.taskManager().addTask(bad_task) 137 QgsApplication.taskManager().addTask(task) 163 QgsApplication.taskManager().addTask(task) 184 QgsApplication.taskManager().addTask(task) 206 QgsApplication.taskManager().addTask(task) 229 QgsApplication.taskManager().addTask(task) 253 QgsApplication.taskManager().addTask(task) [all …]
|
/dports/www/ilias6/ILIAS-6.14/Services/Mail/test/ |
H A D | ilMailTaskProcessorTest.php | 48 $taskManager = $this->getMockBuilder(BasicTaskManager::class) 53 $taskManager 76 $taskManager, 117 $taskManager = $this->getMockBuilder(BasicTaskManager::class) 122 $taskManager 146 $taskManager, 195 $taskManager = $this->getMockBuilder(BasicTaskManager::class) 200 $taskManager 224 $taskManager, 291 $taskManager [all …]
|
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/procedure/flush/ |
H A D | FlushTableSubprocedure.java | 44 private final FlushTableSubprocedurePool taskManager; field in FlushTableSubprocedure 49 FlushTableSubprocedurePool taskManager) { in FlushTableSubprocedure() argument 53 this.taskManager = taskManager; in FlushTableSubprocedure() 86 if (taskManager.hasTasks()) { in flushRegions() 94 taskManager.submitTask(new RegionFlushTask(region)); in flushRegions() 101 taskManager.waitForOutstandingTasks(); in flushRegions() 129 taskManager.cancelTasks(); in cleanup()
|
/dports/www/ilias6/ILIAS-6.14/Services/Mail/classes/BackgroundTask/ |
H A D | class.ilMassMailTaskProcessor.php | 17 private $taskManager; variable in ilMassMailTaskProcessor 45 * @param TaskManager $taskManager 54 TaskManager $taskManager = null, argument 67 if (null === $taskManager) { 68 $taskManager = $dic->backgroundTasks()->taskManager(); 70 $this->taskManager = $taskManager; 164 $this->taskManager->run($bucket);
|
/dports/x11/simdock/trunk/src/ |
H A D | tasks.cc | 47 …if (!taskManager::getProcessName(wnck_application_get_pid (app), &processName[0],sizeof (processNa… in Init() 106 taskManager::getProcessName (unsigned int pid, char *target_name, int size_targetname) in getProcessName() 124 static void tasks_window_closed (WnckScreen *screen, WnckWindow *window,taskManager* tm ) in tasks_window_closed() 162 static void tasks_window_opened (WnckScreen *screen, WnckWindow *window,taskManager* tm ) in tasks_window_opened() 232 taskManager::taskManager(ImagesArray * ImagesList,simSettings* settings) in taskManager() function in taskManager 238 void taskManager::register_signals() in register_signals() 252 void taskManager::addNewImage(WnckWindow *window, const taskInfo& ti) in addNewImage() 285 taskManager::fillList () in fillList() 338 taskManager::getFromName (const char *name, int nameLength) in getFromName() 365 void taskManager::raise (WnckWindow* win) in raise() [all …]
|
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/snapshot/ |
H A D | FlushSnapshotSubprocedure.java | 52 private final SnapshotSubprocedurePool taskManager; field in FlushSnapshotSubprocedure 58 SnapshotSubprocedurePool taskManager) { in FlushSnapshotSubprocedure() argument 66 this.taskManager = taskManager; in FlushSnapshotSubprocedure() 124 if (taskManager.hasTasks()) { in flushSnapshot() 133 taskManager.submitTask(new RegionSnapshotTask(region)); in flushSnapshot() 140 taskManager.waitForOutstandingTasks(); in flushSnapshot() 172 taskManager.cancelTasks(); in cleanup()
|
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/procedure/ |
H A D | SimpleRSProcedureManager.java | 100 SimpleSubprocedurePool taskManager = in buildSubprocedure() local 102 return new SimpleSubprocedure(rss, member, errorDispatcher, taskManager, name); in buildSubprocedure() 201 private final SimpleSubprocedurePool taskManager; field in SimpleRSProcedureManager.SimpleSubprocedure 204 ForeignExceptionDispatcher errorListener, SimpleSubprocedurePool taskManager, String name) { in SimpleSubprocedure() argument 208 this.taskManager = taskManager; in SimpleSubprocedure() 232 taskManager.submitTask(new RSSimpleTask()); in execute() 236 taskManager.waitForOutstandingTasks(); in execute() 260 taskManager.abort("Aborting simple subprocedure tasks due to error", e); in cleanup()
|
/dports/x11/plasma5-plasma-workspace/plasma-workspace-5.23.5/applets/kicker/plugin/ |
H A D | containmentinterface.cpp | 70 const Plasma::Applet *taskManager = nullptr; in mayAddLauncher() local 74 taskManager = applet; in mayAddLauncher() 80 if (taskManager) { in mayAddLauncher() 81 …QQuickItem *gObj = qobject_cast<QQuickItem *>(taskManager->property("_plasma_graphicObject").value… in mayAddLauncher() 168 const Plasma::Applet *taskManager = nullptr; in addLauncher() local 172 taskManager = applet; in addLauncher() 178 if (taskManager) { in addLauncher() 179 …QQuickItem *gObj = qobject_cast<QQuickItem *>(taskManager->property("_plasma_graphicObject").value… in addLauncher()
|
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/agent/ |
H A D | task.go | 16 type taskManager struct { struct 29 …(ctx context.Context, task *api.Task, ctlr exec.Controller, reporter StatusReporter) *taskManager { 30 t := &taskManager{ 43 func (tm *taskManager) Update(ctx context.Context, task *api.Task) error { argument 55 func (tm *taskManager) Close() error { argument 65 func (tm *taskManager) Logs(ctx context.Context, options api.LogSubscriptionOptions, publisher exec… argument 77 func (tm *taskManager) run(ctx context.Context) { argument
|
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/vendor/github.com/docker/swarmkit/agent/ |
H A D | task.go | 16 type taskManager struct { struct 29 …(ctx context.Context, task *api.Task, ctlr exec.Controller, reporter StatusReporter) *taskManager { 30 t := &taskManager{ 43 func (tm *taskManager) Update(ctx context.Context, task *api.Task) error { argument 55 func (tm *taskManager) Close() error { argument 65 func (tm *taskManager) Logs(ctx context.Context, options api.LogSubscriptionOptions, publisher exec… argument 77 func (tm *taskManager) run(ctx context.Context) { argument
|
/dports/sysutils/docker/docker-ce-18.09.5/components/engine/vendor/github.com/docker/swarmkit/agent/ |
H A D | task.go | 16 type taskManager struct { struct 29 …(ctx context.Context, task *api.Task, ctlr exec.Controller, reporter StatusReporter) *taskManager { 30 t := &taskManager{ 43 func (tm *taskManager) Update(ctx context.Context, task *api.Task) error { argument 55 func (tm *taskManager) Close() error { argument 65 func (tm *taskManager) Logs(ctx context.Context, options api.LogSubscriptionOptions, publisher exec… argument 77 func (tm *taskManager) run(ctx context.Context) { argument
|
/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/agent/ |
H A D | task.go | 16 type taskManager struct { struct 29 …(ctx context.Context, task *api.Task, ctlr exec.Controller, reporter StatusReporter) *taskManager { 30 t := &taskManager{ 43 func (tm *taskManager) Update(ctx context.Context, task *api.Task) error { argument 55 func (tm *taskManager) Close() error { argument 65 func (tm *taskManager) Logs(ctx context.Context, options api.LogSubscriptionOptions, publisher exec… argument 77 func (tm *taskManager) run(ctx context.Context) { argument
|
/dports/databases/timescaledb-backup/timescaledb-backup-0.1.1/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/agent/ |
H A D | task.go | 16 type taskManager struct { struct 29 …(ctx context.Context, task *api.Task, ctlr exec.Controller, reporter StatusReporter) *taskManager { 30 t := &taskManager{ 43 func (tm *taskManager) Update(ctx context.Context, task *api.Task) error { argument 55 func (tm *taskManager) Close() error { argument 65 func (tm *taskManager) Logs(ctx context.Context, options api.LogSubscriptionOptions, publisher exec… argument 77 func (tm *taskManager) run(ctx context.Context) { argument
|
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/agent/ |
H A D | task.go | 16 type taskManager struct { struct 29 …(ctx context.Context, task *api.Task, ctlr exec.Controller, reporter StatusReporter) *taskManager { 30 t := &taskManager{ 43 func (tm *taskManager) Update(ctx context.Context, task *api.Task) error { argument 55 func (tm *taskManager) Close() error { argument 65 func (tm *taskManager) Logs(ctx context.Context, options api.LogSubscriptionOptions, publisher exec… argument 77 func (tm *taskManager) run(ctx context.Context) { argument
|
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/agent/ |
H A D | task.go | 16 type taskManager struct { struct 29 …(ctx context.Context, task *api.Task, ctlr exec.Controller, reporter StatusReporter) *taskManager { 30 t := &taskManager{ 43 func (tm *taskManager) Update(ctx context.Context, task *api.Task) error { argument 55 func (tm *taskManager) Close() error { argument 65 func (tm *taskManager) Logs(ctx context.Context, options api.LogSubscriptionOptions, publisher exec… argument 77 func (tm *taskManager) run(ctx context.Context) { argument
|
/dports/security/vault/vault-1.8.2/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/agent/ |
H A D | task.go | 16 type taskManager struct { struct 29 …(ctx context.Context, task *api.Task, ctlr exec.Controller, reporter StatusReporter) *taskManager { 30 t := &taskManager{ 43 func (tm *taskManager) Update(ctx context.Context, task *api.Task) error { argument 55 func (tm *taskManager) Close() error { argument 65 func (tm *taskManager) Logs(ctx context.Context, options api.LogSubscriptionOptions, publisher exec… argument 77 func (tm *taskManager) run(ctx context.Context) { argument
|
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/agent/ |
H A D | task.go | 16 type taskManager struct { struct 29 …(ctx context.Context, task *api.Task, ctlr exec.Controller, reporter StatusReporter) *taskManager { 30 t := &taskManager{ 43 func (tm *taskManager) Update(ctx context.Context, task *api.Task) error { argument 55 func (tm *taskManager) Close() error { argument 65 func (tm *taskManager) Logs(ctx context.Context, options api.LogSubscriptionOptions, publisher exec… argument 77 func (tm *taskManager) run(ctx context.Context) { argument
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/agent/ |
H A D | task.go | 16 type taskManager struct { struct 29 …(ctx context.Context, task *api.Task, ctlr exec.Controller, reporter StatusReporter) *taskManager { 30 t := &taskManager{ 43 func (tm *taskManager) Update(ctx context.Context, task *api.Task) error { argument 55 func (tm *taskManager) Close() error { argument 65 func (tm *taskManager) Logs(ctx context.Context, options api.LogSubscriptionOptions, publisher exec… argument 77 func (tm *taskManager) run(ctx context.Context) { argument
|
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/docker/moby-20.10.2/vendor/github.com/docker/swarmkit/agent/ |
H A D | task.go | 16 type taskManager struct { struct 29 …(ctx context.Context, task *api.Task, ctlr exec.Controller, reporter StatusReporter) *taskManager { 30 t := &taskManager{ 43 func (tm *taskManager) Update(ctx context.Context, task *api.Task) error { argument 55 func (tm *taskManager) Close() error { argument 65 func (tm *taskManager) Logs(ctx context.Context, options api.LogSubscriptionOptions, publisher exec… argument 77 func (tm *taskManager) run(ctx context.Context) { argument
|
/dports/sysutils/helm/helm-3.5.2/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/agent/ |
H A D | task.go | 16 type taskManager struct { struct 29 …(ctx context.Context, task *api.Task, ctlr exec.Controller, reporter StatusReporter) *taskManager { 30 t := &taskManager{ 43 func (tm *taskManager) Update(ctx context.Context, task *api.Task) error { argument 55 func (tm *taskManager) Close() error { argument 65 func (tm *taskManager) Logs(ctx context.Context, options api.LogSubscriptionOptions, publisher exec… argument 77 func (tm *taskManager) run(ctx context.Context) { argument
|
/dports/net-mgmt/zabbix5-proxy/zabbix-5.0.19/src/go/cmd/zabbix_agent2/ |
H A D | config.go | 31 func updateHostname(taskManager scheduler.Scheduler, options *agent.AgentOptions) error { 44 …options.Hostname, err = taskManager.PerformTask(hostnameItem, time.Second*time.Duration(options.Ti… 71 func configUpdateItemParameters(taskManager scheduler.Scheduler, options *agent.AgentOptions) error… 74 if err = updateHostname(taskManager, options); err != nil {
|
/dports/net-mgmt/zabbix5-agent/zabbix-5.0.19/src/go/cmd/zabbix_agent2/ |
H A D | config.go | 31 func updateHostname(taskManager scheduler.Scheduler, options *agent.AgentOptions) error { 44 …options.Hostname, err = taskManager.PerformTask(hostnameItem, time.Second*time.Duration(options.Ti… 71 func configUpdateItemParameters(taskManager scheduler.Scheduler, options *agent.AgentOptions) error… 74 if err = updateHostname(taskManager, options); err != nil {
|
/dports/net-mgmt/zabbix5-java/zabbix-5.0.19/src/go/cmd/zabbix_agent2/ |
H A D | config.go | 31 func updateHostname(taskManager scheduler.Scheduler, options *agent.AgentOptions) error { 44 …options.Hostname, err = taskManager.PerformTask(hostnameItem, time.Second*time.Duration(options.Ti… 71 func configUpdateItemParameters(taskManager scheduler.Scheduler, options *agent.AgentOptions) error… 74 if err = updateHostname(taskManager, options); err != nil {
|
/dports/net-mgmt/zabbix5-server/zabbix-5.0.19/src/go/cmd/zabbix_agent2/ |
H A D | config.go | 31 func updateHostname(taskManager scheduler.Scheduler, options *agent.AgentOptions) error { 44 …options.Hostname, err = taskManager.PerformTask(hostnameItem, time.Second*time.Duration(options.Ti… 71 func configUpdateItemParameters(taskManager scheduler.Scheduler, options *agent.AgentOptions) error… 74 if err = updateHostname(taskManager, options); err != nil {
|