Home
last modified time | relevance | path

Searched refs:workqueue (Results 1 – 25 of 1457) sorted by relevance

12345678910>>...59

/dports/sysutils/liburcu/userspace-rcu-0.13.0/src/
H A Dworkqueue.c175 workqueue->initialize_worker_fct(workqueue, workqueue->priv); in workqueue_thread()
199 workqueue->worker_before_pause_fct(workqueue, workqueue->priv); in workqueue_thread()
207 workqueue->worker_after_resume_fct(workqueue, workqueue->priv); in workqueue_thread()
212 &cbs_tmp_tail, &workqueue->cbs_head, &workqueue->cbs_tail); in workqueue_thread()
217 workqueue->grace_period_fct(workqueue, workqueue->priv); in workqueue_thread()
233 workqueue->worker_before_wait_fct(workqueue, workqueue->priv); in workqueue_thread()
252 workqueue->worker_after_wake_up_fct(workqueue, workqueue->priv); in workqueue_thread()
262 workqueue->finalize_worker_fct(workqueue, workqueue->priv); in workqueue_thread()
279 workqueue = malloc(sizeof(*workqueue)); in urcu_workqueue_create()
282 memset(workqueue, '\0', sizeof(*workqueue)); in urcu_workqueue_create()
[all …]
H A Dworkqueue.h64 void (*grace_period_fct)(struct urcu_workqueue *workqueue, void *priv),
65 void (*initialize_worker_fct)(struct urcu_workqueue *workqueue, void *priv),
66 void (*finalize_worker_fct)(struct urcu_workqueue *workqueue, void *priv),
67 void (*worker_before_wait_fct)(struct urcu_workqueue *workqueue, void *priv),
71 void urcu_workqueue_destroy(struct urcu_workqueue *workqueue);
77 void urcu_workqueue_queue_work(struct urcu_workqueue *workqueue,
84 void urcu_workqueue_queue_completion(struct urcu_workqueue *workqueue,
88 void urcu_workqueue_flush_queued_work(struct urcu_workqueue *workqueue);
96 void urcu_workqueue_pause_worker(struct urcu_workqueue *workqueue);
97 void urcu_workqueue_resume_worker(struct urcu_workqueue *workqueue);
[all …]
/dports/sysutils/istio/istio-1.6.7/vendor/sigs.k8s.io/controller-runtime/pkg/source/
H A Dsource_test.go66 q := workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "test")
107 q := workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "test")
157 q := workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "test")
216 q := workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "test")
235 workqueue.RateLimitingInterface, ...predicate.Predicate) error {
245 workqueue.RateLimitingInterface, ...predicate.Predicate) error {
289 q := workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "test")
329 q := workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "test")
383 q := workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "test")
391 q := workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "test")
[all …]
H A Dsource_integration_test.go43 var q workqueue.RateLimitingInterface
58 q = workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "test")
264 q := workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "test")
278 UpdateFunc: func(event.UpdateEvent, workqueue.RateLimitingInterface) {
282 DeleteFunc: func(event.DeleteEvent, workqueue.RateLimitingInterface) {
286 GenericFunc: func(event.GenericEvent, workqueue.RateLimitingInterface) {
307 q := workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "test")
327 DeleteFunc: func(event.DeleteEvent, workqueue.RateLimitingInterface) {
347 q := workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "test")
350 CreateFunc: func(event.CreateEvent, workqueue.RateLimitingInterface) {
[all …]
/dports/sysutils/istio/istio-1.6.7/vendor/sigs.k8s.io/controller-runtime/pkg/handler/
H A Deventhandler.go44 Create(event.CreateEvent, workqueue.RateLimitingInterface)
47 Update(event.UpdateEvent, workqueue.RateLimitingInterface)
50 Delete(event.DeleteEvent, workqueue.RateLimitingInterface)
54 Generic(event.GenericEvent, workqueue.RateLimitingInterface)
63 CreateFunc func(event.CreateEvent, workqueue.RateLimitingInterface)
67 UpdateFunc func(event.UpdateEvent, workqueue.RateLimitingInterface)
71 DeleteFunc func(event.DeleteEvent, workqueue.RateLimitingInterface)
75 GenericFunc func(event.GenericEvent, workqueue.RateLimitingInterface)
79 func (h Funcs) Create(e event.CreateEvent, q workqueue.RateLimitingInterface) {
86 func (h Funcs) Delete(e event.DeleteEvent, q workqueue.RateLimitingInterface) {
[all …]
/dports/sysutils/istio/istio-1.6.7/vendor/sigs.k8s.io/service-apis/vendor/sigs.k8s.io/controller-runtime/pkg/handler/
H A Deventhandler.go44 Create(event.CreateEvent, workqueue.RateLimitingInterface)
47 Update(event.UpdateEvent, workqueue.RateLimitingInterface)
50 Delete(event.DeleteEvent, workqueue.RateLimitingInterface)
54 Generic(event.GenericEvent, workqueue.RateLimitingInterface)
63 CreateFunc func(event.CreateEvent, workqueue.RateLimitingInterface)
67 UpdateFunc func(event.UpdateEvent, workqueue.RateLimitingInterface)
71 DeleteFunc func(event.DeleteEvent, workqueue.RateLimitingInterface)
75 GenericFunc func(event.GenericEvent, workqueue.RateLimitingInterface)
79 func (h Funcs) Create(e event.CreateEvent, q workqueue.RateLimitingInterface) {
86 func (h Funcs) Delete(e event.DeleteEvent, q workqueue.RateLimitingInterface) {
[all …]
/dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/prometheus/prometheus/discovery/kubernetes/
H A Dclient_metrics.go130 workqueue.SetProvider(f)
141 func (f *clientGoWorkqueueMetricsProvider) NewDepthMetric(name string) workqueue.GaugeMetric {
144 func (f *clientGoWorkqueueMetricsProvider) NewAddsMetric(name string) workqueue.CounterMetric {
147 func (f *clientGoWorkqueueMetricsProvider) NewLatencyMetric(name string) workqueue.HistogramMetric {
150 func (f *clientGoWorkqueueMetricsProvider) NewWorkDurationMetric(name string) workqueue.HistogramMe…
159 func (clientGoWorkqueueMetricsProvider) NewRetriesMetric(name string) workqueue.CounterMetric {
163 func (clientGoWorkqueueMetricsProvider) NewDeprecatedDepthMetric(name string) workqueue.GaugeMetric…
166 func (clientGoWorkqueueMetricsProvider) NewDeprecatedAddsMetric(name string) workqueue.CounterMetri…
169 func (clientGoWorkqueueMetricsProvider) NewDeprecatedLatencyMetric(name string) workqueue.SummaryMe…
172 func (f *clientGoWorkqueueMetricsProvider) NewDeprecatedWorkDurationMetric(name string) workqueue.S…
[all …]
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/memcache/include/
H A Dworkqueue.h41 struct workqueue { struct
79 int workqueue_init(struct workqueue *q, int size, int nconsumers); argument
82 int workqueue_add (struct workqueue *q, void *item);
85 void * workqueue_consumer_wait(struct workqueue *q);
88 int workqueue_consumer_poll(struct workqueue *q);
92 void workqueue_destroy(struct workqueue *q);
95 void workqueue_abort(struct workqueue *q);
98 int workqueue_is_aborted(struct workqueue *q);
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/storage/ndb/memcache/include/
H A Dworkqueue.h43 struct workqueue { struct
81 int workqueue_init(struct workqueue *q, int size, int nconsumers); argument
84 int workqueue_add (struct workqueue *q, void *item);
87 void * workqueue_consumer_wait(struct workqueue *q);
90 int workqueue_consumer_poll(struct workqueue *q);
94 void workqueue_destroy(struct workqueue *q);
97 void workqueue_abort(struct workqueue *q);
100 int workqueue_is_aborted(struct workqueue *q);
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/ndb/memcache/include/
H A Dworkqueue.h43 struct workqueue { struct
81 int workqueue_init(struct workqueue *q, int size, int nconsumers); argument
84 int workqueue_add (struct workqueue *q, void *item);
87 void * workqueue_consumer_wait(struct workqueue *q);
90 int workqueue_consumer_poll(struct workqueue *q);
94 void workqueue_destroy(struct workqueue *q);
97 void workqueue_abort(struct workqueue *q);
100 int workqueue_is_aborted(struct workqueue *q);
/dports/databases/percona57-client/percona-server-5.7.36-39/storage/ndb/memcache/include/
H A Dworkqueue.h43 struct workqueue { struct
81 int workqueue_init(struct workqueue *q, int size, int nconsumers); argument
84 int workqueue_add (struct workqueue *q, void *item);
87 void * workqueue_consumer_wait(struct workqueue *q);
90 int workqueue_consumer_poll(struct workqueue *q);
94 void workqueue_destroy(struct workqueue *q);
97 void workqueue_abort(struct workqueue *q);
100 int workqueue_is_aborted(struct workqueue *q);
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/storage/ndb/memcache/include/
H A Dworkqueue.h43 struct workqueue { struct
81 int workqueue_init(struct workqueue *q, int size, int nconsumers); argument
84 int workqueue_add (struct workqueue *q, void *item);
87 void * workqueue_consumer_wait(struct workqueue *q);
90 int workqueue_consumer_poll(struct workqueue *q);
94 void workqueue_destroy(struct workqueue *q);
97 void workqueue_abort(struct workqueue *q);
100 int workqueue_is_aborted(struct workqueue *q);
/dports/databases/percona57-server/percona-server-5.7.36-39/storage/ndb/memcache/include/
H A Dworkqueue.h43 struct workqueue { struct
81 int workqueue_init(struct workqueue *q, int size, int nconsumers); argument
84 int workqueue_add (struct workqueue *q, void *item);
87 void * workqueue_consumer_wait(struct workqueue *q);
90 int workqueue_consumer_poll(struct workqueue *q);
94 void workqueue_destroy(struct workqueue *q);
97 void workqueue_abort(struct workqueue *q);
100 int workqueue_is_aborted(struct workqueue *q);
/dports/benchmarks/fio/fio-3.29/
H A Dworkqueue.h25 struct workqueue *wq;
55 struct workqueue { struct
71 int workqueue_init(struct thread_data *td, struct workqueue *wq, struct workqueue_ops *ops, unsigne… argument
72 void workqueue_exit(struct workqueue *wq);
74 void workqueue_enqueue(struct workqueue *wq, struct workqueue_work *work);
75 void workqueue_flush(struct workqueue *wq);
79 struct workqueue *wq = sw->wq; in workqueue_pre_sleep_check()
89 struct workqueue *wq = sw->wq; in workqueue_pre_sleep()
97 struct workqueue *wq = sw->wq; in workqueue_init_worker()
108 struct workqueue *wq = sw->wq; in workqueue_exit_worker()
/dports/security/gnupg/gnupg-2.3.3/dirmngr/
H A Dworkqueue.c51 static wqitem_t workqueue; variable
64 saved_workqueue = workqueue; in workqueue_dump_queue()
65 workqueue = NULL; in workqueue_dump_queue()
79 if (!(item=workqueue)) in workqueue_dump_queue()
80 workqueue = saved_workqueue; in workqueue_dump_queue()
106 if (!(wi=workqueue)) in workqueue_add_task()
107 workqueue = item; in workqueue_add_task()
153 for (item = workqueue; item; prev = item, item = item->next) in workqueue_run_global_tasks()
162 workqueue = item->next; in workqueue_run_global_tasks()
188 for (item = workqueue; item; prev = item, item = item->next) in workqueue_run_post_session_tasks()
[all …]
/dports/databases/prometheus-postgresql-adapter/prometheus-postgresql-adapter-0.6.0/vendor/github.com/prometheus/prometheus/discovery/kubernetes/
H A Dclient_metrics.go234 workqueue.SetProvider(f)
243 func (f *clientGoWorkqueueMetricsProvider) NewDepthMetric(name string) workqueue.GaugeMetric {
246 func (f *clientGoWorkqueueMetricsProvider) NewAddsMetric(name string) workqueue.CounterMetric {
249 func (f *clientGoWorkqueueMetricsProvider) NewLatencyMetric(name string) workqueue.HistogramMetric {
256 func (f *clientGoWorkqueueMetricsProvider) NewWorkDurationMetric(name string) workqueue.HistogramMe…
269 func (clientGoWorkqueueMetricsProvider) NewRetriesMetric(name string) workqueue.CounterMetric {
273 func (clientGoWorkqueueMetricsProvider) NewDeprecatedDepthMetric(name string) workqueue.GaugeMetric…
276 func (clientGoWorkqueueMetricsProvider) NewDeprecatedAddsMetric(name string) workqueue.CounterMetri…
279 func (clientGoWorkqueueMetricsProvider) NewDeprecatedLatencyMetric(name string) workqueue.SummaryMe…
282 func (f *clientGoWorkqueueMetricsProvider) NewDeprecatedWorkDurationMetric(name string) workqueue.S…
[all …]
/dports/security/aws-iam-authenticator/aws-iam-authenticator-0.5.2/vendor/k8s.io/component-base/component-base-0.16.8/metrics/prometheus/workqueue/
H A Dmetrics.go17 package workqueue package
103 workqueue.SetProvider(prometheusMetricsProvider{})
106 func (prometheusMetricsProvider) NewDepthMetric(name string) workqueue.GaugeMetric {
110 func (prometheusMetricsProvider) NewAddsMetric(name string) workqueue.CounterMetric {
114 func (prometheusMetricsProvider) NewLatencyMetric(name string) workqueue.HistogramMetric {
118 func (prometheusMetricsProvider) NewWorkDurationMetric(name string) workqueue.HistogramMetric {
122 func (prometheusMetricsProvider) NewUnfinishedWorkSecondsMetric(name string) workqueue.SettableGaug…
126 func (prometheusMetricsProvider) NewLongestRunningProcessorSecondsMetric(name string) workqueue.Set…
130 func (prometheusMetricsProvider) NewRetriesMetric(name string) workqueue.CounterMetric {
/dports/sysutils/helm/helm-3.5.2/vendor/k8s.io/component-base/metrics/prometheus/workqueue/
H A Dmetrics.go17 package workqueue package
101 workqueue.SetProvider(prometheusMetricsProvider{})
104 func (prometheusMetricsProvider) NewDepthMetric(name string) workqueue.GaugeMetric {
108 func (prometheusMetricsProvider) NewAddsMetric(name string) workqueue.CounterMetric {
112 func (prometheusMetricsProvider) NewLatencyMetric(name string) workqueue.HistogramMetric {
116 func (prometheusMetricsProvider) NewWorkDurationMetric(name string) workqueue.HistogramMetric {
120 func (prometheusMetricsProvider) NewUnfinishedWorkSecondsMetric(name string) workqueue.SettableGaug…
124 func (prometheusMetricsProvider) NewLongestRunningProcessorSecondsMetric(name string) workqueue.Set…
128 func (prometheusMetricsProvider) NewRetriesMetric(name string) workqueue.CounterMetric {
/dports/sysutils/kubectl/kubernetes-1.22.2/staging/src/k8s.io/component-base/metrics/prometheus/workqueue/
H A Dmetrics.go17 package workqueue package
101 workqueue.SetProvider(prometheusMetricsProvider{})
104 func (prometheusMetricsProvider) NewDepthMetric(name string) workqueue.GaugeMetric {
108 func (prometheusMetricsProvider) NewAddsMetric(name string) workqueue.CounterMetric {
112 func (prometheusMetricsProvider) NewLatencyMetric(name string) workqueue.HistogramMetric {
116 func (prometheusMetricsProvider) NewWorkDurationMetric(name string) workqueue.HistogramMetric {
120 func (prometheusMetricsProvider) NewUnfinishedWorkSecondsMetric(name string) workqueue.SettableGaug…
124 func (prometheusMetricsProvider) NewLongestRunningProcessorSecondsMetric(name string) workqueue.Set…
128 func (prometheusMetricsProvider) NewRetriesMetric(name string) workqueue.CounterMetric {
/dports/security/aws-iam-authenticator/aws-iam-authenticator-0.5.2/pkg/mapper/crd/controller/
H A Dcontroller.go68 workqueue workqueue.RateLimitingInterface member
94 …workqueue: workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "…
125 defer c.workqueue.ShutDown()
154 obj, shutdown := c.workqueue.Get()
161 defer c.workqueue.Done(obj)
165 c.workqueue.Forget(obj)
171 c.workqueue.AddRateLimited(key)
175 c.workqueue.Forget(obj)
232 c.workqueue.Add(key)
/dports/devel/binutils/binutils-2.37/gold/
H A Dgold.cc134 this->layout_, workqueue, this->mapfile_); in run()
165 this->symtab_, this->layout_, workqueue, in run()
196 workqueue->set_thread_count(thread_count); in queue_initial_tasks()
269 workqueue->queue(tasks[i]); in queue_initial_tasks()
443 Workqueue* workqueue, in queue_middle_gc_tasks() argument
488 Workqueue* workqueue, in queue_middle_tasks() argument
603 workqueue->set_thread_count(thread_count); in queue_middle_tasks()
800 Workqueue* workqueue, in queue_final_tasks() argument
810 workqueue->set_thread_count(thread_count); in queue_final_tasks()
875 workqueue->queue(t); in queue_final_tasks()
[all …]
/dports/lang/gnatdroid-binutils-x86/binutils-2.27/gold/
H A Dgold.cc134 this->layout_, workqueue, this->mapfile_); in run()
165 this->symtab_, this->layout_, workqueue, in run()
196 workqueue->set_thread_count(thread_count); in queue_initial_tasks()
269 workqueue->queue(tasks[i]); in queue_initial_tasks()
443 Workqueue* workqueue, in queue_middle_gc_tasks() argument
488 Workqueue* workqueue, in queue_middle_tasks() argument
603 workqueue->set_thread_count(thread_count); in queue_middle_tasks()
794 Workqueue* workqueue, in queue_final_tasks() argument
804 workqueue->set_thread_count(thread_count); in queue_final_tasks()
869 workqueue->queue(t); in queue_final_tasks()
[all …]
/dports/devel/arm-elf-binutils/binutils-2.37/gold/
H A Dgold.cc134 this->layout_, workqueue, this->mapfile_); in run()
165 this->symtab_, this->layout_, workqueue, in run()
196 workqueue->set_thread_count(thread_count); in queue_initial_tasks()
269 workqueue->queue(tasks[i]); in queue_initial_tasks()
443 Workqueue* workqueue, in queue_middle_gc_tasks() argument
488 Workqueue* workqueue, in queue_middle_tasks() argument
603 workqueue->set_thread_count(thread_count); in queue_middle_tasks()
800 Workqueue* workqueue, in queue_final_tasks() argument
810 workqueue->set_thread_count(thread_count); in queue_final_tasks()
875 workqueue->queue(t); in queue_final_tasks()
[all …]
/dports/devel/gnulibiberty/binutils-2.37/gold/
H A Dgold.cc134 this->layout_, workqueue, this->mapfile_); in run()
165 this->symtab_, this->layout_, workqueue, in run()
196 workqueue->set_thread_count(thread_count); in queue_initial_tasks()
269 workqueue->queue(tasks[i]); in queue_initial_tasks()
443 Workqueue* workqueue, in queue_middle_gc_tasks() argument
488 Workqueue* workqueue, in queue_middle_tasks() argument
603 workqueue->set_thread_count(thread_count); in queue_middle_tasks()
800 Workqueue* workqueue, in queue_final_tasks() argument
810 workqueue->set_thread_count(thread_count); in queue_final_tasks()
875 workqueue->queue(t); in queue_final_tasks()
[all …]
/dports/lang/gnatdroid-binutils/binutils-2.27/gold/
H A Dgold.cc134 this->layout_, workqueue, this->mapfile_); in run()
165 this->symtab_, this->layout_, workqueue, in run()
196 workqueue->set_thread_count(thread_count); in queue_initial_tasks()
269 workqueue->queue(tasks[i]); in queue_initial_tasks()
443 Workqueue* workqueue, in queue_middle_gc_tasks() argument
488 Workqueue* workqueue, in queue_middle_tasks() argument
603 workqueue->set_thread_count(thread_count); in queue_middle_tasks()
794 Workqueue* workqueue, in queue_final_tasks() argument
804 workqueue->set_thread_count(thread_count); in queue_final_tasks()
869 workqueue->queue(t); in queue_final_tasks()
[all …]

12345678910>>...59