Home
last modified time | relevance | path

Searched refs:create_worker (Results 1 – 25 of 165) sorted by relevance

1234567

/dports/devel/py-buildbot-worker/buildbot-worker-3.4.1/buildbot_worker/test/unit/
H A Dtest_scripts_create_worker.py25 from buildbot_worker.scripts import create_worker
58 create_worker._makeBaseDir("dummy", False)
74 create_worker._makeBaseDir("dummy", True)
89 create_worker._makeBaseDir("dummy", False)
104 create_worker._makeBaseDir("dummy", True)
124 create_worker._makeBaseDir("dummy", False)
414 create_worker._makeInfoFiles("bdir", quiet)
465 create_worker._makeInfoFiles("bdir", False)
514 self.patch(create_worker,
519 self.patch(create_worker,
[all …]
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/spec/lib/gitlab/sidekiq_config/
H A Dworker_spec.rb6 def create_worker(queue:, **attributes) method
74 namespaced_worker = create_worker(queue: 'namespace:queue')
75 plain_worker = create_worker(queue: 'a_queue')
83 create_worker(queue: 'namespace:a'),
84 create_worker(queue: 'namespace:b'),
85 create_worker(queue: 'other_namespace:a'),
86 create_worker(queue: 'other_namespace:b'),
87 create_worker(queue: 'a'),
88 create_worker(queue: 'b')
119 worker_a = create_worker(queue: 'a', **attributes_a)
[all …]
H A Dworker_router_spec.rb10 def create_worker(name, namespace = nil) method
18 create_worker('PagesWorker') | 'pages'
19 create_worker('PipelineNotificationWorker') | 'pipeline_notification'
20 create_worker('PostReceive') | 'post_receive'
21 create_worker('PostReceive', :git) | 'git:post_receive'
22 create_worker('PipelineHooksWorker', :pipeline_hooks) | 'pipeline_hooks:pipeline_hooks'
23 create_worker('Gitlab::JiraImport::AdvanceStageWorker') | 'jira_import_advance_stage'
24 …create_worker('Gitlab::PhabricatorImport::ImportTasksWorker', :importer) | 'importer:phabricator_i…
/dports/net/elixir-kafka_ex/kafka_ex-0.10.0/test/integration/
H A Dconsumer_group_test.exs38 KafkaEx.create_worker(
80 KafkaEx.create_worker(
100 KafkaEx.create_worker(
125 KafkaEx.create_worker(
146 KafkaEx.create_worker(
171 KafkaEx.create_worker(
260 KafkaEx.create_worker(worker_name)
309 KafkaEx.create_worker(
387 KafkaEx.create_worker(
433 KafkaEx.create_worker(
[all …]
H A Dintegration_test.exs14 # create_worker
16 {:ok, pid} = KafkaEx.create_worker(:bar, uris: uris())
22 KafkaEx.create_worker(
30 test "create_worker allows custom metadata_update_interval" do
32 KafkaEx.create_worker(
44 {:ok, pid} = KafkaEx.create_worker(:d, uris: uris())
54 KafkaEx.create_worker(
511 KafkaEx.create_worker(:stream, uris: uris())
549 KafkaEx.create_worker(:stream, uris: uris())
591 KafkaEx.create_worker(:stream, uris: uris())
[all …]
H A Dserver0_p_9_p_0_test.exs15 KafkaEx.create_worker(
40 KafkaEx.create_worker(
81 KafkaEx.create_worker(
112 KafkaEx.create_worker(
/dports/devel/py-grab/grab-0.6.41/grab/spider/
H A Dparser_service.py19 self.workers_pool.append(self.create_worker(self.worker_callback))
20 self.supervisor = self.create_worker(self.supervisor_callback)
28 new_worker = self.create_worker(self.worker_callback)
/dports/science/py-chainer/chainer-7.8.0/chainer/training/extensions/
H A Dsnapshot_writers.py142 self._worker = self.create_worker(filename, outdir, target,
147 def create_worker(self, filename, outdir, target, **kwds): member in StandardWriter
184 def create_worker(self, filename, outdir, target, **kwds): member in ThreadWriter
209 def create_worker(self, filename, outdir, target, **kwds): member in ProcessWriter
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/tools/
H A DNdbImportImpl.hpp339 virtual Worker* create_worker(uint n) = 0;
436 virtual Worker* create_worker(uint n);
480 virtual Worker* create_worker(uint n);
517 virtual Worker* create_worker(uint n);
660 virtual Worker* create_worker(uint n);
721 virtual Worker* create_worker(uint n);
777 virtual Worker* create_worker(uint n);
/dports/multimedia/v4l_compat/linux-5.13-rc2/tools/perf/bench/
H A Dsched-messaging.c137 static pthread_t create_worker(void *ctx, void *(*func)(void *)) in create_worker() function
221 pth[i] = create_worker(ctx, (void *)receiver); in group()
234 pth[num_fds+i] = create_worker(snd_ctx, (void *)sender); in group()
/dports/multimedia/libv4l/linux-5.13-rc2/tools/perf/bench/
H A Dsched-messaging.c137 static pthread_t create_worker(void *ctx, void *(*func)(void *)) in create_worker() function
221 pth[i] = create_worker(ctx, (void *)receiver); in group()
234 pth[num_fds+i] = create_worker(snd_ctx, (void *)sender); in group()
/dports/multimedia/v4l-utils/linux-5.13-rc2/tools/perf/bench/
H A Dsched-messaging.c137 static pthread_t create_worker(void *ctx, void *(*func)(void *)) in create_worker() function
221 pth[i] = create_worker(ctx, (void *)receiver); in group()
234 pth[num_fds+i] = create_worker(snd_ctx, (void *)sender); in group()
/dports/misc/py-cinder/cinder-12.0.10/cinder/tests/unit/objects/
H A Dtest_cleanable.py100 res = backup.create_worker()
114 res = backup.create_worker()
125 res = backup.create_worker()
138 res = backup.create_worker()
163 self.assertTrue(backup.create_worker())
/dports/www/py-spyne/spyne-2.13.16/spyne/server/
H A Dzeromq.py139 worker, job = self.create_worker(i, be_url)
146 def create_worker(self, i, be_url): member in ZeroMQThreadPoolServer
/dports/security/gpgme-qt5/gpgme-1.15.1/lang/qt/src/
H A Dqgpgmewkspublishjob.cpp109 static QGpgMEWKSPublishJob::result_type create_worker(const char *fpr, const QString &mail) in create_worker() function
186 run(std::bind(&create_worker, fpr, mailbox)); in startCreate()
/dports/security/gpgme/gpgme-1.15.1/lang/qt/src/
H A Dqgpgmewkspublishjob.cpp109 static QGpgMEWKSPublishJob::result_type create_worker(const char *fpr, const QString &mail) in create_worker() function
186 run(std::bind(&create_worker, fpr, mailbox)); in startCreate()
/dports/security/gpgme-cpp/gpgme-1.15.1/lang/qt/src/
H A Dqgpgmewkspublishjob.cpp109 static QGpgMEWKSPublishJob::result_type create_worker(const char *fpr, const QString &mail) in create_worker() function
186 run(std::bind(&create_worker, fpr, mailbox)); in startCreate()
/dports/security/py-gpgme/gpgme-1.15.1/lang/qt/src/
H A Dqgpgmewkspublishjob.cpp109 static QGpgMEWKSPublishJob::result_type create_worker(const char *fpr, const QString &mail) in create_worker() function
186 run(std::bind(&create_worker, fpr, mailbox)); in startCreate()
/dports/net/elixir-kafka_ex/kafka_ex-0.10.0/lib/
H A Dkafka_ex.ex48 create_worker creates KafkaEx workers
63 iex> KafkaEx.create_worker(:pr) # where :pr is the name of the worker created
65 iex> KafkaEx.create_worker(:pr, uris: [{"localhost", 9092}])
67 iex> KafkaEx.create_worker(:pr, [uris: [{"localhost", 9092}], consumer_group: "foo"])
69 iex> KafkaEx.create_worker(:pr, consumer_group: nil)
73 @spec create_worker(atom, KafkaEx.worker_init()) ::
75 def create_worker(name, worker_init \\ []) do function
86 Stop a worker created with create_worker/2
159 iex> KafkaEx.create_worker(:mt)
546 Note this happens automatically when using `KafkaEx.create_worker`.
[all …]
/dports/security/medusa/medusa-2.2/src/
H A Dmedusa-thread-pool.c77 create_worker(thr_pool_t *pool) in create_worker() function
114 create_worker(pool) == 0) { in worker_cleanup()
363 create_worker(pool) == 0) in thr_pool_queue()
/dports/deskutils/calibre/calibre-src-5.34.0/src/calibre/utils/ipc/
H A Dsimple_worker.py124 def create_worker(env, priority='normal', cwd=None, func='main'): function
172 conn, w = create_worker(env, priority, cwd)
264 conn, w = create_worker(env=env, priority=priority, cwd=cwd, func='offload')
/dports/databases/percona56-client/percona-server-5.6.51-91.0/sql/
H A Dthreadpool_unix.cc187 static int create_worker(thread_group_t *thread_group);
835 create_worker(thread_group); in listener()
872 static int create_worker(thread_group_t *thread_group) in create_worker() function
968 DBUG_RETURN(create_worker(thread_group)); in wake_or_create_thread()
979 DBUG_RETURN(create_worker(thread_group)); in wake_or_create_thread()
1512 ret= create_worker(new_group); in change_group()
/dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/sql/
H A Dthreadpool_unix.cc187 static int create_worker(thread_group_t *thread_group);
835 create_worker(thread_group); in listener()
872 static int create_worker(thread_group_t *thread_group) in create_worker() function
968 DBUG_RETURN(create_worker(thread_group)); in wake_or_create_thread()
979 DBUG_RETURN(create_worker(thread_group)); in wake_or_create_thread()
1512 ret= create_worker(new_group); in change_group()
/dports/databases/percona57-server/percona-server-5.7.36-39/sql/
H A Dthreadpool_unix.cc185 static int create_worker(thread_group_t *thread_group);
833 create_worker(thread_group); in listener()
870 static int create_worker(thread_group_t *thread_group) in create_worker() function
966 DBUG_RETURN(create_worker(thread_group)); in wake_or_create_thread()
977 DBUG_RETURN(create_worker(thread_group)); in wake_or_create_thread()
1528 ret= create_worker(new_group); in change_group()
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/sql/
H A Dthreadpool_unix.cc185 static int create_worker(thread_group_t *thread_group);
833 create_worker(thread_group); in listener()
870 static int create_worker(thread_group_t *thread_group) in create_worker() function
966 DBUG_RETURN(create_worker(thread_group)); in wake_or_create_thread()
977 DBUG_RETURN(create_worker(thread_group)); in wake_or_create_thread()
1528 ret= create_worker(new_group); in change_group()

1234567