summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorJohn Kacur <jkacur@redhat.com>2015-10-08 16:49:03 +0200
committerJohn Kacur <jkacur@redhat.com>2015-10-08 16:49:03 +0200
commita43126d192b81996bbada485112936985919b430 (patch)
treea24475591703e6a3e39ebb17d58f5f91e90a893b
parentb921fb3d1f13e18459c414032a003502883e1a56 (diff)
downloadrt-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.c50
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 */