summaryrefslogtreecommitdiff
path: root/lib/thread.c
diff options
context:
space:
mode:
authorQuentin Young <qlyoung@nvidia.com>2020-09-28 18:13:27 -0400
committerQuentin Young <qlyoung@nvidia.com>2020-10-23 15:13:51 -0400
commitc7bb4f006b22592d3c57bd7d84d521485c278567 (patch)
treed408a8338e0c47173277f05267f73e02d53ffaab /lib/thread.c
parent552e2a306a3b3335ee60965bbcd61c27eecc576d (diff)
lib, bgpd: convert lttng tracepoints to frrtrace()
- tracepoint() -> frrtrace() - tracelog() -> frrtracelog() - tracepoint_enabled() -> frrtrace_enabled() Also removes copypasta'd #ifdefs for those LTTng macros, those are handled in lib/trace.h Signed-off-by: Quentin Young <qlyoung@nvidia.com>
Diffstat (limited to 'lib/thread.c')
-rw-r--r--lib/thread.c44
1 files changed, 21 insertions, 23 deletions
diff --git a/lib/thread.c b/lib/thread.c
index a15bd541dd..9a5453b185 100644
--- a/lib/thread.c
+++ b/lib/thread.c
@@ -789,11 +789,11 @@ struct thread *funcname_thread_add_read_write(int dir, struct thread_master *m,
struct thread **thread_array;
if (dir == THREAD_READ)
- tracepoint(frr_libfrr, schedule_read, m, funcname, schedfrom,
- fromln, t_ptr, fd, 0, arg, 0);
+ frrtrace(9, frr_libfrr, schedule_read, m, funcname, schedfrom,
+ fromln, t_ptr, fd, 0, arg, 0);
else
- tracepoint(frr_libfrr, schedule_write, m, funcname, schedfrom,
- fromln, t_ptr, fd, 0, arg, 0);
+ frrtrace(9, frr_libfrr, schedule_write, m, funcname, schedfrom,
+ fromln, t_ptr, fd, 0, arg, 0);
assert(fd >= 0 && fd < m->fd_limit);
frr_with_mutex(&m->mtx) {
@@ -869,8 +869,8 @@ funcname_thread_add_timer_timeval(struct thread_master *m,
assert(type == THREAD_TIMER);
assert(time_relative);
- tracepoint(frr_libfrr, schedule_timer, m, funcname, schedfrom, fromln,
- t_ptr, 0, 0, arg, (long)time_relative->tv_sec);
+ frrtrace(9, frr_libfrr, schedule_timer, m, funcname, schedfrom, fromln,
+ t_ptr, 0, 0, arg, (long)time_relative->tv_sec);
frr_with_mutex(&m->mtx) {
if (t_ptr && *t_ptr)
@@ -950,8 +950,8 @@ struct thread *funcname_thread_add_event(struct thread_master *m,
{
struct thread *thread = NULL;
- tracepoint(frr_libfrr, schedule_event, m, funcname, schedfrom, fromln,
- t_ptr, 0, val, arg, 0);
+ frrtrace(9, frr_libfrr, schedule_event, m, funcname, schedfrom, fromln,
+ t_ptr, 0, val, arg, 0);
assert(m != NULL);
@@ -1181,10 +1181,9 @@ void thread_cancel(struct thread *thread)
{
struct thread_master *master = thread->master;
- tracepoint(frr_libfrr, thread_cancel, master, thread->funcname,
- thread->schedfrom, thread->schedfrom_line, NULL,
- thread->u.fd, thread->u.val, thread->arg,
- thread->u.sands.tv_sec);
+ frrtrace(9, frr_libfrr, thread_cancel, master, thread->funcname,
+ thread->schedfrom, thread->schedfrom_line, NULL, thread->u.fd,
+ thread->u.val, thread->arg, thread->u.sands.tv_sec);
assert(master->owner == pthread_self());
@@ -1227,14 +1226,14 @@ void thread_cancel_async(struct thread_master *master, struct thread **thread,
assert(!(thread && eventobj) && (thread || eventobj));
if (thread && *thread)
- tracepoint(frr_libfrr, thread_cancel_async, master,
- (*thread)->funcname, (*thread)->schedfrom,
- (*thread)->schedfrom_line, NULL, (*thread)->u.fd,
- (*thread)->u.val, (*thread)->arg,
- (*thread)->u.sands.tv_sec);
+ frrtrace(9, frr_libfrr, thread_cancel_async, master,
+ (*thread)->funcname, (*thread)->schedfrom,
+ (*thread)->schedfrom_line, NULL, (*thread)->u.fd,
+ (*thread)->u.val, (*thread)->arg,
+ (*thread)->u.sands.tv_sec);
else
- tracepoint(frr_libfrr, thread_cancel_async, master, NULL, NULL,
- 0, NULL, 0, 0, eventobj, 0);
+ frrtrace(9, frr_libfrr, thread_cancel_async, master, NULL, NULL,
+ 0, NULL, 0, 0, eventobj, 0);
assert(master->owner != pthread_self());
@@ -1611,10 +1610,9 @@ void thread_call(struct thread *thread)
GETRUSAGE(&before);
thread->real = before.real;
- tracepoint(frr_libfrr, thread_call, thread->master, thread->funcname,
- thread->schedfrom, thread->schedfrom_line, NULL,
- thread->u.fd, thread->u.val, thread->arg,
- thread->u.sands.tv_sec);
+ frrtrace(9, frr_libfrr, thread_call, thread->master, thread->funcname,
+ thread->schedfrom, thread->schedfrom_line, NULL, thread->u.fd,
+ thread->u.val, thread->arg, thread->u.sands.tv_sec);
pthread_setspecific(thread_current, thread);
(*thread->func)(thread);