#include <stdio.h>
#include <stdint.h>
#include <sys/queue.h>
#include <rte_config.h>
#include <rte_lcore.h>

Macros
#define	RTE_SERVICE_CAP_MT_SAFE (1 << 0)

#define	RTE_SERVICE_ATTR_CYCLES 0

#define	RTE_SERVICE_ATTR_CALL_COUNT 1

#define	RTE_SERVICE_LCORE_ATTR_LOOPS 0

Functions
uint32_t	rte_service_get_count (void)

int32_t	rte_service_get_by_name (const char name, uint32_t service_id)

const char *	rte_service_get_name (uint32_t id)

int32_t	rte_service_probe_capability (uint32_t id, uint32_t capability)

int32_t	rte_service_map_lcore_set (uint32_t service_id, uint32_t lcore, uint32_t enable)

int32_t	rte_service_map_lcore_get (uint32_t service_id, uint32_t lcore)

int32_t	rte_service_runstate_set (uint32_t id, uint32_t runstate)

int32_t	rte_service_runstate_get (uint32_t id)

int32_t __rte_experimental	rte_service_may_be_active (uint32_t id)

int32_t	rte_service_set_runstate_mapped_check (uint32_t id, int32_t enable)

int32_t	rte_service_run_iter_on_app_lcore (uint32_t id, uint32_t serialize_multithread_unsafe)

int32_t	rte_service_lcore_start (uint32_t lcore_id)

int32_t	rte_service_lcore_stop (uint32_t lcore_id)

int32_t	rte_service_lcore_add (uint32_t lcore)

int32_t	rte_service_lcore_del (uint32_t lcore)

int32_t	rte_service_lcore_count (void)

int32_t	rte_service_lcore_reset_all (void)

int32_t	rte_service_set_stats_enable (uint32_t id, int32_t enable)

int32_t	rte_service_lcore_list (uint32_t array[], uint32_t n)

int32_t	rte_service_lcore_count_services (uint32_t lcore)

int32_t	rte_service_dump (FILE *f, uint32_t id)

int32_t	rte_service_attr_get (uint32_t id, uint32_t attr_id, uint64_t *attr_value)

int32_t	rte_service_attr_reset_all (uint32_t id)

int32_t __rte_experimental	rte_service_lcore_attr_get (uint32_t lcore, uint32_t attr_id, uint64_t *attr_value)

int32_t __rte_experimental	rte_service_lcore_attr_reset_all (uint32_t lcore)

Detailed Description

Service functions

The service functionality provided by this header allows a DPDK component to indicate that it requires a function call in order for it to perform its processing.

An example usage of this functionality would be a component that registers a service to perform a particular packet processing duty: for example the eventdev software PMD. At startup the application requests all services that have been registered, and the cores in the service-coremask run the required services. The EAL removes these number of cores from the available runtime cores, and dedicates them to performing service-core workloads. The application has access to the remaining lcores as normal.

Definition in file rte_service.h.

Macro Definition Documentation

◆ RTE_SERVICE_CAP_MT_SAFE

#define RTE_SERVICE_CAP_MT_SAFE (1 << 0)

When set, the service is capable of having multiple threads run it at the same time.

Definition at line 47 of file rte_service.h.

◆ RTE_SERVICE_ATTR_CYCLES

#define RTE_SERVICE_ATTR_CYCLES 0

Returns the number of cycles that this service has consumed

Definition at line 361 of file rte_service.h.

◆ RTE_SERVICE_ATTR_CALL_COUNT

#define RTE_SERVICE_ATTR_CALL_COUNT 1

Returns the count of invocations of this service function

Definition at line 366 of file rte_service.h.

◆ RTE_SERVICE_LCORE_ATTR_LOOPS

#define RTE_SERVICE_LCORE_ATTR_LOOPS 0

Returns the number of times the service runner has looped.

Definition at line 389 of file rte_service.h.

Function Documentation

◆ rte_service_get_count()

uint32_t rte_service_get_count ( void )

Return the number of services registered.

The number of services registered can be passed to rte_service_get_by_id, enabling the application to retrieve the specification of each service.

Returns: The number of services registered.

◆ rte_service_get_by_name()

int32_t rte_service_get_by_name	(	const char *	name,
		uint32_t *	service_id
	)

Return the id of a service by name.

This function provides the id of the service using the service name as lookup key. The service id is to be passed to other functions in the rte_service_* API.

Example usage:

uint32_t service_id;
int32_t ret = rte_service_get_by_name("service_X", &service_id);
if (ret) {
        // handle error
}

Parameters

	name	The name of the service to retrieve
[out]	service_id	A pointer to a uint32_t, to be filled in with the id.

Return values

0	Success. The service id is provided in service_id.
-EINVAL	Null service_id pointer provided
-ENODEV	No such service registered

◆ rte_service_get_name()

const char* rte_service_get_name ( uint32_t id )

Return the name of the service.

Returns: A pointer to the name of the service. The returned pointer remains in ownership of the service, and the application must not free it.

◆ rte_service_probe_capability()

int32_t rte_service_probe_capability	(	uint32_t	id,
		uint32_t	capability
	)

Check if a service has a specific capability.

This function returns if service has implements capability. See RTE_SERVICE_CAP_* defines for a list of valid capabilities.

Return values

1	Capability supported by this service instance
0	Capability not supported by this service instance

◆ rte_service_map_lcore_set()

int32_t rte_service_map_lcore_set	(	uint32_t	service_id,
		uint32_t	lcore,
		uint32_t	enable
	)

Map or unmap a lcore to a service.

Each core can be added or removed from running a specific service. This function enables or disables lcore to run service_id.

If multiple cores are enabled on a service, an atomic is used to ensure that only one cores runs the service at a time. The exception to this is when a service indicates that it is multi-thread safe by setting the capability called RTE_SERVICE_CAP_MT_SAFE. With the multi-thread safe capability set, the service function can be run on multiple threads at the same time.

Parameters

service_id	the service to apply the lcore to
lcore	The lcore that will be mapped to service
enable	Zero to unmap or disable the core, non-zero to enable

Return values

0	lcore map updated successfully
-EINVAL	An invalid service or lcore was provided.

Examples: examples/service_cores/main.c.

◆ rte_service_map_lcore_get()

int32_t rte_service_map_lcore_get	(	uint32_t	service_id,
		uint32_t	lcore
	)

Retrieve the mapping of an lcore to a service.

Parameters

service_id	the service to apply the lcore to
lcore	The lcore that will be mapped to service

Return values

1	lcore is mapped to service
0	lcore is not mapped to service
-EINVAL	An invalid service or lcore was provided.

◆ rte_service_runstate_set()

int32_t rte_service_runstate_set	(	uint32_t	id,
		uint32_t	runstate
	)

Set the runstate of the service.

Each service is either running or stopped. Setting a non-zero runstate enables the service to run, while setting runstate zero disables it.

Parameters

id	The id of the service
runstate	The run state to apply to the service

Return values

0	The service was successfully started
-EINVAL	Invalid service id

Examples: examples/eventdev_pipeline/pipeline_worker_generic.c, examples/eventdev_pipeline/pipeline_worker_tx.c, and examples/service_cores/main.c.

◆ rte_service_runstate_get()

int32_t rte_service_runstate_get ( uint32_t id )

Get the runstate for the service with id. See rte_service_runstate_set for details of runstates. A service can call this function to ensure that the application has indicated that it will receive CPU cycles. Either a service-core is mapped (default case), or the application has explicitly disabled the check that a service-cores is mapped to the service and takes responsibility to run the service manually using the available function rte_service_run_iter_on_app_lcore to do so.

Return values

1	Service is running
0	Service is stopped
-EINVAL	Invalid service id

◆ rte_service_may_be_active()

int32_t __rte_experimental rte_service_may_be_active ( uint32_t id )

Warning: EXPERIMENTAL: this API may change, or be removed, without prior notice

This function returns whether the service may be currently executing on at least one lcore, or definitely is not. This function can be used to determine if, after setting the service runstate to stopped, the service is still executing a service lcore.

Care must be taken if calling this function when the service runstate is running, since the result of this function may be incorrect by the time the function returns due to service cores running in parallel.

Return values

1	Service may be running on one or more lcores
0	Service is not running on any lcore
-EINVAL	Invalid service id

◆ rte_service_set_runstate_mapped_check()

int32_t rte_service_set_runstate_mapped_check	(	uint32_t	id,
		int32_t	enable
	)

Enable or disable the check for a service-core being mapped to the service. An application can disable the check when takes the responsibility to run a service itself using rte_service_run_iter_on_app_lcore.

Parameters

id	The id of the service to set the check on
enable	When zero, the check is disabled. Non-zero enables the check.

Return values

0	Success
-EINVAL	Invalid service ID

Examples: examples/eventdev_pipeline/pipeline_worker_generic.c, and examples/eventdev_pipeline/pipeline_worker_tx.c.

◆ rte_service_run_iter_on_app_lcore()

int32_t rte_service_run_iter_on_app_lcore	(	uint32_t	id,
		uint32_t	serialize_multithread_unsafe
	)

This function runs a service callback from a non-service lcore.

This function is designed to enable gradual porting to service cores, and to enable unit tests to verify a service behaves as expected.

When called, this function ensures that the service identified by id is safe to run on this lcore. Multi-thread safe services are invoked even if other cores are simultaneously running them as they are multi-thread safe.

Multi-thread unsafe services are handled depending on the variable serialize_multithread_unsafe:

When set, the function will check if a service is already being invoked on another lcore, refusing to run it and returning -EBUSY.
When zero, the application takes responsibility to ensure that the service indicated by id is not going to be invoked by another lcore. This setting avoids atomic operations, so is likely to be more performant.

Parameters

id	The ID of the service to run
serialize_multithread_unsafe	This parameter indicates to the service cores library if it is required to use atomics to serialize access to mult-thread unsafe services. As there is an overhead in using atomics, applications can choose to enable or disable this feature

Note that any thread calling this function MUST be a DPDK EAL thread, as the rte_lcore_id function is used to access internal data structures.

Return values

0	Service was run on the calling thread successfully
-EBUSY	Another lcore is executing the service, and it is not a multi-thread safe service, so the service was not run on this lcore
-ENOEXEC	Service is not in a run-able state
-EINVAL	Invalid service id

Examples: examples/eventdev_pipeline/pipeline_worker_tx.c.

◆ rte_service_lcore_start()

int32_t rte_service_lcore_start ( uint32_t lcore_id )

Start a service core.

Starting a core makes the core begin polling. Any services assigned to it will be run as fast as possible. The application must ensure that the lcore is in a launchable state: e.g. call rte_eal_lcore_wait on the lcore_id before calling this function.

Return values

0	Success
-EINVAL	Failed to start core. The lcore_id passed in is not currently assigned to be a service core.

Examples: examples/service_cores/main.c.

◆ rte_service_lcore_stop()

int32_t rte_service_lcore_stop ( uint32_t lcore_id )

Stop a service core.

Stopping a core makes the core become idle, but remains assigned as a service core.

Return values

0	Success
-EINVAL	Invalid lcore_id provided
-EALREADY	Already stopped core
-EBUSY	Failed to stop core, as it would cause a service to not be run, as this is the only core currently running the service. The application must stop the service first, and then stop the lcore.

Examples: examples/service_cores/main.c.

◆ rte_service_lcore_add()

int32_t rte_service_lcore_add ( uint32_t lcore )

Adds lcore to the list of service cores.

This functions can be used at runtime in order to modify the service core mask.

Return values

0	Success
-EBUSY	lcore is busy, and not available for service core duty
-EALREADY	lcore is already added to the service core list
-EINVAL	Invalid lcore provided

Examples: examples/service_cores/main.c.

◆ rte_service_lcore_del()

int32_t rte_service_lcore_del ( uint32_t lcore )

Removes lcore from the list of service cores.

This can fail if the core is not stopped, see rte_service_core_stop.

Return values

0	Success
-EBUSY	Lcore is not stopped, stop service core before removing.
-EINVAL	failed to add lcore to service core mask.

Examples: examples/service_cores/main.c.

◆ rte_service_lcore_count()

int32_t rte_service_lcore_count ( void )

Retrieve the number of service cores currently available.

This function returns the integer count of service cores available. The service core count can be used in mapping logic when creating mappings from service cores to services.

See rte_service_lcore_list for details on retrieving the lcore_id of each service core.

Returns: The number of service cores currently configured.

◆ rte_service_lcore_reset_all()

int32_t rte_service_lcore_reset_all ( void )

Resets all service core mappings. This does not remove the service cores from duty, just unmaps all services / cores, and stops() the service cores. The runstate of services is not modified.

Return values

0 Success

◆ rte_service_set_stats_enable()

int32_t rte_service_set_stats_enable	(	uint32_t	id,
		int32_t	enable
	)

Enable or disable statistics collection for service.

This function enables per core, per-service cycle count collection.

Parameters

id	The service to enable statistics gathering on.
enable	Zero to disable statistics, non-zero to enable.

Return values

0	Success
-EINVAL	Invalid service pointer passed

Examples: examples/service_cores/main.c.

◆ rte_service_lcore_list()

int32_t rte_service_lcore_list	(	uint32_t	array[],
		uint32_t	n
	)

Retrieve the list of currently enabled service cores.

This function fills in an application supplied array, with each element indicating the lcore_id of a service core.

Adding and removing service cores can be performed using rte_service_lcore_add and rte_service_lcore_del.

Parameters

[out]	array	An array of at least rte_service_lcore_count items. If statically allocating the buffer, use RTE_MAX_LCORE.
[out]	n	The size of array.

Return values

>=0	Number of service cores that have been populated in the array
-ENOMEM	The provided array is not large enough to fill in the service core list. No items have been populated, call this function with a size of at least rte_service_core_count items.

◆ rte_service_lcore_count_services()

int32_t rte_service_lcore_count_services ( uint32_t lcore )

Get the number of services running on the supplied lcore.

Parameters

lcore Id of the service core.

Return values

>=0	Number of services registered to this core.
-EINVAL	Invalid lcore provided
-ENOTSUP	The provided lcore is not a service core.

◆ rte_service_dump()

int32_t rte_service_dump	(	FILE *	f,
		uint32_t	id
	)

Dumps any information available about the service. When id is UINT32_MAX, this function dumps info for all services.

Return values

0	Statistics have been successfully dumped
-EINVAL	Invalid service id provided

Examples: examples/service_cores/main.c.

◆ rte_service_attr_get()

int32_t rte_service_attr_get	(	uint32_t	id,
		uint32_t	attr_id,
		uint64_t *	attr_value
	)

Get an attribute from a service.

Return values

0	Success, the attribute value has been written to attr_value. -EINVAL Invalid id, attr_id or attr_value was NULL.

◆ rte_service_attr_reset_all()

int32_t rte_service_attr_reset_all ( uint32_t id )

Reset all attribute values of a service.

Parameters

id	The service to reset all statistics of

Return values

0	Successfully reset attributes -EINVAL Invalid service id provided

◆ rte_service_lcore_attr_get()

int32_t __rte_experimental rte_service_lcore_attr_get	(	uint32_t	lcore,
		uint32_t	attr_id,
		uint64_t *	attr_value
	)

Warning: EXPERIMENTAL: this API may change without prior notice

Get an attribute from a service core.

Parameters

	lcore	Id of the service core.
	attr_id	Id of the attribute to be retrieved.
[out]	attr_value	Pointer to storage in which to write retrieved value.

Return values

0	Success, the attribute value has been written to attr_value. -EINVAL Invalid lcore, attr_id or attr_value was NULL. -ENOTSUP lcore is not a service core.

◆ rte_service_lcore_attr_reset_all()

int32_t __rte_experimental rte_service_lcore_attr_reset_all ( uint32_t lcore )

Warning: EXPERIMENTAL: this API may change without prior notice

Reset all attribute values of a service core.

Parameters

lcore The service core to reset all the statistics of

Return values

0	Successfully reset attributes -EINVAL Invalid service id provided -ENOTSUP lcore is not a service core.

Macros

Functions

Detailed Description

Macro Definition Documentation

◆ RTE_SERVICE_CAP_MT_SAFE

◆ RTE_SERVICE_ATTR_CYCLES

◆ RTE_SERVICE_ATTR_CALL_COUNT

◆ RTE_SERVICE_LCORE_ATTR_LOOPS

Function Documentation

◆ rte_service_get_count()

◆ rte_service_get_by_name()

◆ rte_service_get_name()

◆ rte_service_probe_capability()

◆ rte_service_map_lcore_set()

◆ rte_service_map_lcore_get()

◆ rte_service_runstate_set()

◆ rte_service_runstate_get()

◆ rte_service_may_be_active()

◆ rte_service_set_runstate_mapped_check()

◆ rte_service_run_iter_on_app_lcore()

◆ rte_service_lcore_start()

◆ rte_service_lcore_stop()

◆ rte_service_lcore_add()

◆ rte_service_lcore_del()

◆ rte_service_lcore_count()

◆ rte_service_lcore_reset_all()

◆ rte_service_set_stats_enable()

◆ rte_service_lcore_list()

◆ rte_service_lcore_count_services()

◆ rte_service_dump()

◆ rte_service_attr_get()

◆ rte_service_attr_reset_all()

◆ rte_service_lcore_attr_get()

◆ rte_service_lcore_attr_reset_all()