diff options
author | John Kacur <jkacur@redhat.com> | 2015-10-08 16:49:03 +0200 |
---|---|---|
committer | John Kacur <jkacur@redhat.com> | 2015-10-08 16:49:03 +0200 |
commit | a43126d192b81996bbada485112936985919b430 (patch) | |
tree | a24475591703e6a3e39ebb17d58f5f91e90a893b | |
parent | b921fb3d1f13e18459c414032a003502883e1a56 (diff) | |
download | rt-tests-a43126d192b81996bbada485112936985919b430.tar.gz |
cyclictest: Clean-ups in timerthread before working on it
- Clean this function up a bit before modifying it
- Don't use assignment in if statements
- Put spaces before open braces and parentheses
- Break lines up where possible that go over 80 chars
Signed-off-by: John Kacur <jkacur@redhat.com>
-rw-r--r-- | src/cyclictest/cyclictest.c | 50 |
1 files changed, 29 insertions, 21 deletions
diff --git a/src/cyclictest/cyclictest.c b/src/cyclictest/cyclictest.c index b1f99ab..00168e2 100644 --- a/src/cyclictest/cyclictest.c +++ b/src/cyclictest/cyclictest.c @@ -785,8 +785,9 @@ static void *timerthread(void *param) CPU_ZERO(&mask); CPU_SET(par->cpu, &mask); thread = pthread_self(); - if(pthread_setaffinity_np(thread, sizeof(mask), &mask) == -1) - warn("Could not set CPU affinity to CPU #%d\n", par->cpu); + if (pthread_setaffinity_np(thread, sizeof(mask), &mask) == -1) + warn("Could not set CPU affinity to CPU #%d\n", + par->cpu); } interval.tv_sec = par->interval / USEC_PER_SEC; @@ -809,11 +810,12 @@ static void *timerthread(void *param) memset(&schedp, 0, sizeof(schedp)); schedp.sched_priority = par->prio; if (setscheduler(0, par->policy, &schedp)) - fatal("timerthread%d: failed to set priority to %d\n", par->cpu, par->prio); + fatal("timerthread%d: failed to set priority to %d\n", + par->cpu, par->prio); /* Get current time */ #ifndef NO_PTHREAD_BARRIER - if(aligned || secaligned){ + if (aligned || secaligned) { pthread_barrier_wait(&globalt_barr); if (par->tnum == 0) { clock_gettime(par->clock, &globalt); @@ -829,15 +831,14 @@ static void *timerthread(void *param) } pthread_barrier_wait(&align_barr); now = globalt; - if(offset) { + if (offset) { if (aligned) now.tv_nsec += offset * par->tnum; else now.tv_nsec += offset; tsnorm(&now); } - } - else + } else #endif clock_gettime(par->clock, &now); @@ -854,9 +855,8 @@ static void *timerthread(void *param) if (par->mode == MODE_CYCLIC) { if (par->timermode == TIMER_ABSTIME) tspec.it_value = next; - else { + else tspec.it_value = interval; - } timer_settime(timer, par->timermode, &tspec, NULL); } @@ -864,7 +864,7 @@ static void *timerthread(void *param) itimer.it_interval.tv_sec = interval.tv_sec; itimer.it_interval.tv_usec = interval.tv_nsec / 1000; itimer.it_value = itimer.it_interval; - setitimer (ITIMER_REAL, &itimer, NULL); + setitimer(ITIMER_REAL, &itimer, NULL); } stat->threadstarted++; @@ -884,18 +884,23 @@ static void *timerthread(void *param) case MODE_CLOCK_NANOSLEEP: if (par->timermode == TIMER_ABSTIME) { - if ((ret = clock_nanosleep(par->clock, TIMER_ABSTIME, &next, NULL))) { + ret = clock_nanosleep(par->clock, TIMER_ABSTIME, + &next, NULL); + if (ret != 0) { if (ret != EINTR) warn("clock_nanosleep failed. errno: %d\n", errno); goto out; } } else { - if ((ret = clock_gettime(par->clock, &now))) { + ret = clock_gettime(par->clock, &now); + if (ret != 0) { if (ret != EINTR) warn("clock_gettime() failed: %s", strerror(errno)); goto out; } - if ((ret = clock_nanosleep(par->clock, TIMER_RELTIME, &interval, NULL))) { + ret = clock_nanosleep(par->clock, + TIMER_RELTIME, &interval, NULL); + if (ret != 0) { if (ret != EINTR) warn("clock_nanosleep() failed. errno: %d\n", errno); goto out; @@ -907,14 +912,16 @@ static void *timerthread(void *param) break; case MODE_SYS_NANOSLEEP: - if ((ret = clock_gettime(par->clock, &now))) { + ret = clock_gettime(par->clock, &now); + if (ret != 0) { if (ret != EINTR) warn("clock_gettime() failed: errno %d\n", errno); goto out; } if (nanosleep(&interval, NULL)) { if (errno != EINTR) - warn("nanosleep failed. errno: %d\n", errno); + warn("nanosleep failed. errno: %d\n", + errno); goto out; } next.tv_sec = now.tv_sec + interval.tv_sec; @@ -922,10 +929,11 @@ static void *timerthread(void *param) tsnorm(&next); break; } - - if ((ret = clock_gettime(par->clock, &now))) { + ret = clock_gettime(par->clock, &now); + if (ret != 0) { if (ret != EINTR) - warn("clock_getttime() failed. errno: %d\n", errno); + warn("clock_getttime() failed. errno: %d\n", + errno); goto out; } @@ -968,9 +976,9 @@ static void *timerthread(void *param) stat->hist_overflow++; if (stat->num_outliers < histogram) stat->outliers[stat->num_outliers++] = stat->cycles; - } - else + } else { stat->hist_array[diff]++; + } } stat->cycles++; @@ -1003,7 +1011,7 @@ out: itimer.it_value.tv_usec = 0; itimer.it_interval.tv_sec = 0; itimer.it_interval.tv_usec = 0; - setitimer (ITIMER_REAL, &itimer, NULL); + setitimer(ITIMER_REAL, &itimer, NULL); } /* switch to normal */ |