Home
last modified time | relevance | path

Searched refs:taskManager (Results 1 – 25 of 271) sorted by relevance

1234567891011

/dports/graphics/qgis/qgis-3.22.3/tests/src/python/
H A Dtest_qgstaskmanager.py80 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 Dtest_qgstaskmanager.py80 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 DilMailTaskProcessorTest.php48 $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 DFlushTableSubprocedure.java44 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 Dclass.ilMassMailTaskProcessor.php17 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 Dtasks.cc47 …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 DFlushSnapshotSubprocedure.java52 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 DSimpleRSProcedureManager.java100 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 Dcontainmentinterface.cpp70 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 Dtask.go16 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 Dtask.go16 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 Dtask.go16 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 Dtask.go16 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 Dtask.go16 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 Dtask.go16 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 Dtask.go16 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 Dtask.go16 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 Dtask.go16 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 Dtask.go16 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 Dtask.go16 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 Dtask.go16 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 Dconfig.go31 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 Dconfig.go31 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 Dconfig.go31 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 Dconfig.go31 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 {

1234567891011