- set_sched_policy_and_prio(SCHED_FIFO, 99);
-
-#define SEND() \
- do { \
- ret = send_frame(pfd[0].fd); \
- if (ret != sizeof(struct can_frame)) { \
- if (ret == -1 && errno == ENOBUFS && opt.period_us == 0 && !opt.oneattime) { \
- /* Ignore this error - pfifo_fast qeuue is full */ \
- } else \
- error(1, errno, "send_frame (line %d)", __LINE__); \
- } \
- else { \
- count++; \
- msg_in_progress++; \
- } \
- } while (0)
-
- if (opt.oneattime) {
+ set_sched_policy_and_prio(SCHED_FIFO, 40);
+
+#define SEND() send_and_check(pfd[0].fd)
+
+ if (opt.oneattime)