@@ -362,7 +362,7 @@ test_ctrl_thread(void)
/* Create one control thread */
t = &ctrl_thread_context;
t->state = Thread_INIT;
- if (rte_ctrl_thread_create((pthread_t *)&t->id, "test_ctrl_threads",
+ if (rte_ctrl_thread_create((pthread_t *)&t->id, "dpdk-test-ctrlt",
NULL, ctrl_thread_loop, t) != 0)
return -1;
@@ -239,7 +239,7 @@ test_thread_control_create_join(void)
rte_thread_t thread_main_id;
thread_id_ready = 0;
- RTE_TEST_ASSERT(rte_thread_create_control(&thread_id, "test_control_threads",
+ RTE_TEST_ASSERT(rte_thread_create_control(&thread_id, "dpdk-test-thcc",
NULL, thread_main, &thread_main_id) == 0,
"Failed to create thread.");
@@ -127,7 +127,7 @@ skeldma_start(struct rte_dma_dev *dev)
rte_mb();
- snprintf(name, sizeof(name), "dma_skel_%d", dev->data->dev_id);
+ snprintf(name, sizeof(name), "dpdk-dma-skel%d", dev->data->dev_id);
ret = rte_thread_create_control(&hw->thread, name, NULL,
cpucopy_thread, dev);
if (ret) {
@@ -200,7 +200,7 @@ static inline void os_schedule_work(struct dlb2_hw *hw)
dlb2_dev = container_of(hw, struct dlb2_dev, hw);
ret = rte_ctrl_thread_create(&complete_queue_map_unmap_thread,
- "dlb_queue_unmap_waiter",
+ "dpdk-dlb-qunmap",
NULL,
dlb2_complete_queue_map_unmap,
dlb2_dev);
@@ -600,11 +600,11 @@ eth_ark_dev_start(struct rte_eth_dev *dev)
if (!ark->isvf && ark->start_pg && !ark->pg_running) {
pthread_t thread;
- /* Delay packet generatpr start allow the hardware to be ready
+ /* Delay packet generator start allow the hardware to be ready
* This is only used for sanity checking with internal generator
*/
char tname[32];
- snprintf(tname, sizeof(tname), "ark-delay-pg-%d",
+ snprintf(tname, sizeof(tname), "dpdk-ark-pg%d",
dev->data->port_id);
if (rte_ctrl_thread_create(&thread, tname, NULL,
@@ -135,7 +135,7 @@ iavf_dev_event_handler_init(void)
TAILQ_INIT(&handler->pending);
pthread_mutex_init(&handler->lock, NULL);
- if (rte_thread_create_control(&handler->tid, "iavf-event-thread",
+ if (rte_thread_create_control(&handler->tid, "dpdk-iavf-event",
NULL, iavf_dev_event_handle, NULL)) {
__atomic_fetch_sub(&handler->ndev, 1, __ATOMIC_RELAXED);
return -1;
@@ -181,7 +181,7 @@ start_vsi_reset_thread(struct ice_dcf_hw *dcf_hw, bool vfr, uint16_t vf_id)
param->vfr = vfr;
param->vf_id = vf_id;
- snprintf(name, sizeof(name), "ice-reset-%u", vf_id);
+ snprintf(name, sizeof(name), "dpdk-ice-rst%u", vf_id);
ret = rte_thread_create_control(&thread, name, NULL,
ice_dcf_vsi_update_service_handler, param);
if (ret != 0) {
@@ -2593,7 +2593,7 @@ ipn3ke_rpst_scan_check(void)
if (ipn3ke_rpst_scan_num == 1) {
ret = rte_ctrl_thread_create(&ipn3ke_rpst_scan_thread,
- "ipn3ke scanner",
+ "dpdk-ipn3ke-scn",
NULL,
ipn3ke_rpst_scan_handle_request, NULL);
if (ret) {
@@ -4329,7 +4329,7 @@ ixgbe_dev_link_update_share(struct rte_eth_dev *dev,
*/
intr->flags |= IXGBE_FLAG_NEED_LINK_CONFIG;
if (rte_thread_create_control(&ad->link_thread_tid,
- "ixgbe-link-handler",
+ "dpdk-ixgbe-link",
NULL,
ixgbe_dev_setup_link_thread_handler,
dev) < 0) {
@@ -163,7 +163,7 @@ eth_kni_dev_start(struct rte_eth_dev *dev)
internals->stop_thread = 0;
ret = rte_ctrl_thread_create(&internals->thread,
- "kni_handle_req", NULL,
+ "dpdk-kni-req", NULL,
kni_handle_request, internals);
if (ret) {
PMD_LOG(ERR,
@@ -439,8 +439,7 @@ mlx5_hws_cnt_pool_init(struct mlx5_dev_ctx_shared *sh,
int
mlx5_hws_cnt_service_thread_create(struct mlx5_dev_ctx_shared *sh)
{
-#define CNT_THREAD_NAME_MAX 256
- char name[CNT_THREAD_NAME_MAX];
+ char name[RTE_MAX_THREAD_NAME_LEN];
rte_cpuset_t cpuset;
int ret;
uint32_t service_core = sh->cnt_svc->service_core;
@@ -453,8 +452,7 @@ mlx5_hws_cnt_service_thread_create(struct mlx5_dev_ctx_shared *sh)
DRV_LOG(ERR, "Failed to create HW steering's counter service thread.");
return -ENOSYS;
}
- snprintf(name, CNT_THREAD_NAME_MAX - 1, "%s/svc@%d",
- sh->ibdev_name, service_core);
+ snprintf(name, RTE_MAX_THREAD_NAME_LEN, "dpdk-mlx5-%d", service_core);
rte_thread_set_name((rte_thread_t){(uintptr_t)sh->cnt_svc->service_thread},
name);
CPU_SET(service_core, &cpuset);
@@ -711,7 +711,7 @@ sfc_mae_counter_thread_spawn(struct sfc_adapter *sa,
counter_registry->polling.thread.run = true;
rc = rte_ctrl_thread_create(&sa->mae.counter_registry.polling.thread.id,
- "mae_counter_thread", NULL,
+ "dpdk-sfc-maecnt", NULL,
sfc_mae_counter_thread, sa);
return rc;
@@ -551,7 +551,7 @@ ifpga_monitor_start_func(struct ifpga_rawdev *dev)
if (!__atomic_fetch_add(&ifpga_monitor_refcnt, 1, __ATOMIC_RELAXED)) {
ret = rte_ctrl_thread_create(&ifpga_monitor_start_thread,
- "ifpga-monitor", NULL,
+ "dpdk-ifpga-mon", NULL,
ifpga_rawdev_gsd_handle, NULL);
if (ret != 0) {
ifpga_monitor_start_thread = 0;
@@ -570,7 +570,7 @@ setup_notify_relay(struct ifcvf_internal *internal)
char name[THREAD_NAME_LEN];
int ret;
- snprintf(name, sizeof(name), "ifc-notify-%d", internal->vid);
+ snprintf(name, sizeof(name), "dpdk-ifc-noti%d", internal->vid);
ret = rte_ctrl_thread_create(&internal->tid, name, NULL, notify_relay,
(void *)internal);
if (ret != 0) {
@@ -681,7 +681,7 @@ setup_intr_relay(struct ifcvf_internal *internal)
char name[THREAD_NAME_LEN];
int ret;
- snprintf(name, sizeof(name), "ifc-intr-%d", internal->vid);
+ snprintf(name, sizeof(name), "dpdk-ifc-int%d", internal->vid);
ret = rte_ctrl_thread_create(&internal->intr_tid, name, NULL,
intr_relay, (void *)internal);
if (ret) {
@@ -1019,7 +1019,7 @@ setup_vring_relay(struct ifcvf_internal *internal)
char name[THREAD_NAME_LEN];
int ret;
- snprintf(name, sizeof(name), "ifc-vring-%d", internal->vid);
+ snprintf(name, sizeof(name), "dpdk-ifc-ring%d", internal->vid);
ret = rte_ctrl_thread_create(&internal->tid, name, NULL, vring_relay,
(void *)internal);
if (ret != 0) {
@@ -312,7 +312,7 @@ mlx5_vdpa_c_thread_create(int cpu_core)
"vdpa multi-threads %d.", thrd_idx);
goto c_thread_err;
}
- snprintf(name, sizeof(name), "vDPA-mthread-%d", thrd_idx);
+ snprintf(name, sizeof(name), "dpdk-vmlx5-c%d", thrd_idx);
ret = pthread_setname_np(
conf_thread_mng.cthrd[thrd_idx].tid, name);
if (ret)
@@ -546,7 +546,7 @@ mlx5_vdpa_cqe_event_setup(struct mlx5_vdpa_priv *priv)
DRV_LOG(ERR, "Failed to set thread affinity.");
goto out;
}
- snprintf(name, sizeof(name), "vDPA-mlx5-%d", priv->vid);
+ snprintf(name, sizeof(name), "dpdk-vmlx5-%d", priv->vid);
rte_thread_set_name((rte_thread_t){(uintptr_t)priv->timer_tid}, name);
out:
if (attrp != NULL)
@@ -1986,11 +1986,11 @@ main(int argc, char *argv[])
/* Enable stats if the user option is set. */
if (enable_stats) {
- ret = rte_ctrl_thread_create(&tid, "print-stats", NULL,
+ ret = rte_ctrl_thread_create(&tid, "dpdk-vhost-stat", NULL,
print_stats, NULL);
if (ret < 0)
rte_exit(EXIT_FAILURE,
- "Cannot create print-stats thread\n");
+ "Cannot create dpdk-vhost-stat thread\n");
}
/* Launch all data cores. */
@@ -686,7 +686,7 @@ new_device(int vid)
/* start polling vring */
worker_thread_status = WORKER_STATE_START;
fprintf(stdout, "New Device %s, Device ID %d\n", path, vid);
- if (rte_ctrl_thread_create(&tid, "vhostblk-ctrlr", NULL,
+ if (rte_ctrl_thread_create(&tid, "dpdk-vhost-blk", NULL,
&ctrlr_worker, ctrlr) != 0) {
fprintf(stderr, "Worker Thread Started Failed\n");
return -1;
@@ -635,7 +635,7 @@ rte_mp_channel_init(void)
return -1;
}
- if (rte_ctrl_thread_create(&mp_handle_tid, "rte_mp_handle",
+ if (rte_ctrl_thread_create(&mp_handle_tid, "dpdk-mp-msg",
NULL, mp_handle, NULL) < 0) {
RTE_LOG(ERR, EAL, "failed to create mp thread: %s\n",
strerror(errno));
@@ -843,7 +843,7 @@ rte_eal_init(int argc, char **argv)
/* Set thread_name for aid in debugging. */
snprintf(thread_name, sizeof(thread_name),
- "rte-worker-%d", i);
+ "dpdk-worker%d", i);
rte_thread_set_name(lcore_config[i].thread_id, thread_name);
ret = rte_thread_set_affinity_by_id(lcore_config[i].thread_id,
@@ -637,7 +637,7 @@ rte_eal_intr_init(void)
}
/* create the host thread to wait/handle the interrupt */
- ret = rte_ctrl_thread_create(&intr_thread, "eal-intr-thread", NULL,
+ ret = rte_ctrl_thread_create(&intr_thread, "dpdk-intr", NULL,
eal_intr_thread_main, NULL);
if (ret != 0) {
rte_errno = -ret;
@@ -1272,7 +1272,7 @@ rte_eal_init(int argc, char **argv)
/* Set thread_name for aid in debugging. */
snprintf(thread_name, sizeof(thread_name),
- "rte-worker-%d", i);
+ "dpdk-worker%d", i);
rte_thread_set_name(lcore_config[i].thread_id, thread_name);
ret = rte_thread_set_affinity_by_id(lcore_config[i].thread_id,
@@ -1188,7 +1188,7 @@ rte_eal_intr_init(void)
}
/* create the host thread to wait/handle the interrupt */
- ret = rte_ctrl_thread_create(&intr_thread, "eal-intr-thread", NULL,
+ ret = rte_ctrl_thread_create(&intr_thread, "dpdk-intr", NULL,
eal_intr_thread_main, NULL);
if (ret != 0) {
rte_errno = -ret;
@@ -176,7 +176,7 @@ rte_eal_hpet_init(int make_default)
/* create a thread that will increment a global variable for
* msb (hpet is 32 bits by default under linux) */
- ret = rte_ctrl_thread_create(&msb_inc_thread_id, "hpet-msb-inc", NULL,
+ ret = rte_ctrl_thread_create(&msb_inc_thread_id, "dpdk-hpet-msb", NULL,
hpet_msb_inc, NULL);
if (ret != 0) {
RTE_LOG(ERR, EAL, "ERROR: Cannot create HPET timer thread!\n");
@@ -468,7 +468,7 @@ rte_eal_init(int argc, char **argv)
/* Set thread name for aid in debugging. */
snprintf(thread_name, sizeof(thread_name),
- "rte-worker-%d", i);
+ "dpdk-worker%d", i);
rte_thread_set_name(lcore_config[i].thread_id, thread_name);
ret = rte_thread_set_affinity_by_id(lcore_config[i].thread_id,
@@ -98,7 +98,7 @@ rte_eal_intr_init(void)
return -1;
}
- ret = rte_thread_create_control(&intr_thread, "eal-intr-thread", NULL,
+ ret = rte_thread_create_control(&intr_thread, "dpdk-intr", NULL,
eal_intr_thread_main, NULL);
if (ret != 0) {
rte_errno = -ret;
@@ -1620,7 +1620,7 @@ rxa_create_intr_thread(struct event_eth_rx_adapter *rx_adapter)
rte_spinlock_init(&rx_adapter->intr_ring_lock);
snprintf(thread_name, RTE_MAX_THREAD_NAME_LEN,
- "rx-intr-thread-%d", rx_adapter->id);
+ "dpdk-evt-rx%d", rx_adapter->id);
err = rte_ctrl_thread_create(&rx_adapter->rx_intr_thread, thread_name,
NULL, rxa_intr_thread, rx_adapter);
@@ -563,7 +563,7 @@ telemetry_legacy_init(void)
return -1;
}
pthread_setaffinity_np(t_old, sizeof(*thread_cpuset), thread_cpuset);
- set_thread_name(t_old, "telemetry-v1");
+ set_thread_name(t_old, "dpdk-telemet-v1");
TMTY_LOG(DEBUG, "Legacy telemetry socket initialized ok\n");
pthread_detach(t_old);
return 0;
@@ -617,7 +617,7 @@ telemetry_v2_init(void)
return -1;
}
pthread_setaffinity_np(t_new, sizeof(*thread_cpuset), thread_cpuset);
- set_thread_name(t_new, "telemetry-v2");
+ set_thread_name(t_new, "dpdk-telemet-v2");
pthread_detach(t_new);
atexit(unlink_sockets);
@@ -513,7 +513,7 @@ vhost_user_reconnect_init(void)
}
TAILQ_INIT(&reconn_list.head);
- ret = rte_ctrl_thread_create(&reconn_tid, "vhost_reconn", NULL,
+ ret = rte_ctrl_thread_create(&reconn_tid, "dpdk-vhost-reco", NULL,
vhost_user_client_reconnect, NULL);
if (ret != 0) {
VHOST_LOG_CONFIG("thread", ERR, "failed to create reconnect thread\n");
@@ -1239,7 +1239,7 @@ rte_vhost_driver_start(const char *path)
}
int ret = rte_ctrl_thread_create(&fdset_tid,
- "vhost-events", NULL, fdset_event_dispatch,
+ "dpdk-vhost-evt", NULL, fdset_event_dispatch,
&vhost_user.fdset);
if (ret != 0) {
VHOST_LOG_CONFIG(path, ERR, "failed to create fdset handling thread\n");
@@ -455,7 +455,7 @@ vduse_device_create(const char *path)
return -1;
}
- ret = rte_ctrl_thread_create(&fdset_tid, "vduse-events", NULL,
+ ret = rte_ctrl_thread_create(&fdset_tid, "dpdk-vduse-evt", NULL,
fdset_event_dispatch, &vduse.fdset);
if (ret != 0) {
VHOST_LOG_CONFIG(path, ERR, "failed to create vduse fdset handling thread\n");