Lines Matching defs:s
172 service_mt_safe(struct rte_service_spec_impl *s)
174 return !!(s->spec.capabilities & RTE_SERVICE_CAP_MT_SAFE);
180 struct rte_service_spec_impl *s;
181 SERVICE_VALID_GET_OR_ERR_RET(id, s, 0);
184 s->internal_flags |= SERVICE_F_STATS_ENABLED;
186 s->internal_flags &= ~(SERVICE_F_STATS_ENABLED);
194 struct rte_service_spec_impl *s;
195 SERVICE_VALID_GET_OR_ERR_RET(id, s, 0);
198 s->internal_flags |= SERVICE_F_START_CHECK;
200 s->internal_flags &= ~(SERVICE_F_START_CHECK);
232 struct rte_service_spec_impl *s;
233 SERVICE_VALID_GET_OR_ERR_RET(id, s, 0);
234 return s->spec.name;
240 struct rte_service_spec_impl *s;
241 SERVICE_VALID_GET_OR_ERR_RET(id, s, -EINVAL);
242 return !!(s->spec.capabilities & capability);
265 struct rte_service_spec_impl *s = &rte_services[free_slot];
266 s->spec = *spec;
267 s->internal_flags |= SERVICE_F_REGISTERED | SERVICE_F_START_CHECK;
282 struct rte_service_spec_impl *s;
283 SERVICE_VALID_GET_OR_ERR_RET(id, s, -EINVAL);
287 s->internal_flags &= ~(SERVICE_F_REGISTERED);
303 struct rte_service_spec_impl *s;
304 SERVICE_VALID_GET_OR_ERR_RET(id, s, -EINVAL);
311 rte_atomic_store_explicit(&s->comp_runstate, RUNSTATE_RUNNING,
314 rte_atomic_store_explicit(&s->comp_runstate, RUNSTATE_STOPPED,
323 struct rte_service_spec_impl *s;
324 SERVICE_VALID_GET_OR_ERR_RET(id, s, -EINVAL);
331 rte_atomic_store_explicit(&s->app_runstate, RUNSTATE_RUNNING,
334 rte_atomic_store_explicit(&s->app_runstate, RUNSTATE_STOPPED,
344 struct rte_service_spec_impl *s;
345 SERVICE_VALID_GET_OR_ERR_RET(id, s, -EINVAL);
351 if (rte_atomic_load_explicit(&s->comp_runstate, rte_memory_order_acquire) ==
353 rte_atomic_load_explicit(&s->app_runstate, rte_memory_order_acquire) ==
355 int check_disabled = !(s->internal_flags &
357 int lcore_mapped = (rte_atomic_load_explicit(&s->num_mapped_cores,
382 service_runner_do_callback(struct rte_service_spec_impl *s,
386 void *userdata = s->spec.callback_userdata;
388 if (service_stats_enabled(s)) {
390 int rc = s->spec.callback(userdata);
410 s->spec.callback(userdata);
416 /* Expects the service 's' is valid. */
419 struct rte_service_spec_impl *s, uint32_t serialize_mt_unsafe)
421 if (!s)
428 if (rte_atomic_load_explicit(&s->comp_runstate, rte_memory_order_acquire) !=
430 rte_atomic_load_explicit(&s->app_runstate, rte_memory_order_acquire) !=
439 if ((service_mt_safe(s) == 0) && (serialize_mt_unsafe == 1)) {
440 if (!rte_spinlock_trylock(&s->execute_lock))
443 service_runner_do_callback(s, cs, i);
444 rte_spinlock_unlock(&s->execute_lock);
446 service_runner_do_callback(s, cs, i);
476 struct rte_service_spec_impl *s;
478 SERVICE_VALID_GET_OR_ERR_RET(id, s, -EINVAL);
483 rte_atomic_fetch_add_explicit(&s->num_mapped_cores, 1, rte_memory_order_relaxed);
487 int ret = service_run(id, cs, all_services, s, serialize_mt_unsafe);
489 rte_atomic_fetch_sub_explicit(&s->num_mapped_cores, 1, rte_memory_order_relaxed);
1038 struct rte_service_spec_impl *s;
1049 s = service_get(id);
1051 fprintf(f, " %s: stats %d\tcalls %"PRIu64"\tcycles %"
1053 s->spec.name, service_stats_enabled(s), service_calls,
1080 struct rte_service_spec_impl *s;
1081 SERVICE_VALID_GET_OR_ERR_RET(id, s, -EINVAL);
1082 fprintf(f, "Service %s Summary\n", s->spec.name);