| 271 | } |
| 272 | |
| 273 | int |
| 274 | rte_thread_get_priority(rte_thread_t thread_id, |
| 275 | enum rte_thread_priority *priority) |
| 276 | { |
| 277 | struct sched_param param; |
| 278 | int policy; |
| 279 | int ret; |
| 280 | |
| 281 | ret = pthread_getschedparam((pthread_t)thread_id.opaque_id, &policy, |
| 282 | ¶m); |
| 283 | if (ret != 0) { |
| 284 | RTE_LOG(DEBUG, EAL, "pthread_getschedparam failed\n"); |
| 285 | goto cleanup; |
| 286 | } |
| 287 | |
| 288 | return thread_map_os_priority_to_eal_priority(policy, |
| 289 | param.sched_priority, priority); |
| 290 | |
| 291 | cleanup: |
| 292 | return ret; |
| 293 | } |
| 294 | |
| 295 | int |
| 296 | rte_thread_set_priority(rte_thread_t thread_id, |