Skip to content

Commit 6f5e1d2

Browse files
authored
Merge pull request #555 from kolyshkin/log-fixups
Logging fixups and cleanups
2 parents 503645f + 869f9d2 commit 6f5e1d2

File tree

6 files changed

+18
-30
lines changed

6 files changed

+18
-30
lines changed

src/cmsg.c

Lines changed: 3 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -36,20 +36,15 @@
3636
#define ECOMM EINVAL
3737
#endif
3838

39-
#define error(s) \
40-
do { \
41-
fprintf(stderr, "conmon: %s %s\n", s, strerror(errno)); \
42-
errno = ECOMM; \
43-
goto err; /* return value */ \
44-
} while (0)
45-
4639
#define errorf(fmt, ...) \
4740
do { \
48-
fprintf(stderr, "conmon: " fmt ": %s\n", ##__VA_ARGS__, strerror(errno)); \
41+
fprintf(stderr, "conmon: " fmt "\n", ##__VA_ARGS__); \
4942
errno = ECOMM; \
5043
goto err; /* return value */ \
5144
} while (0)
5245

46+
#define error(s) errorf("%s", s)
47+
5348
/*
5449
* Sends a file descriptor along the sockfd provided. Returns the return
5550
* value of sendmsg(2). Any synchronisation and preparation of state

src/ctr_logging.c

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -328,7 +328,7 @@ static int write_journald(int pipe, char *buf, ssize_t buflen)
328328

329329
int err = sd_journal_sendv(bufv.iov, bufv.iovcnt);
330330
if (err < 0) {
331-
pwarn(strerror(-err));
331+
nwarnf("sd_journal_sendv: %s", strerror(-err));
332332
return err;
333333
}
334334

@@ -638,5 +638,5 @@ void sync_logs(void)
638638
/* Sync the logs to disk */
639639
if (k8s_log_fd > 0)
640640
if (fsync(k8s_log_fd) < 0)
641-
pwarn("Failed to sync log file before exit");
641+
nwarnf("Failed to sync log file before exit: %m");
642642
}

src/ctr_stdio.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -140,7 +140,7 @@ static bool read_stdio(int fd, stdpipe_t pipe, gboolean *eof)
140140
*eof = true;
141141
return false;
142142
}
143-
nwarnf("stdio_input read failed %s", strerror(errno));
143+
nwarnf("stdio_input read failed: %m");
144144
return false;
145145
} else {
146146
// Always null terminate the buffer, just in case.

src/ctrl.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -231,7 +231,7 @@ static void resize_winsz(int height, int width)
231231

232232
int ret = ioctl(mainfd_stdout, TIOCSWINSZ, &ws);
233233
if (ret == -1)
234-
pwarn("Failed to set process pty terminal size");
234+
nwarnf("Failed to set process pty terminal size: %m");
235235
}
236236

237237

src/oom.c

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -15,18 +15,18 @@ static void write_oom_adjust(int oom_score, int *old_value)
1515
char fmt_oom_score[16];
1616
int oom_score_fd = open("/proc/self/oom_score_adj", O_RDWR | O_CLOEXEC);
1717
if (oom_score_fd < 0) {
18-
ndebugf("failed to open /proc/self/oom_score_adj: %s\n", strerror(errno));
18+
ndebugf("failed to open /proc/self/oom_score_adj: %m");
1919
return;
2020
}
2121
if (old_value) {
2222
if (read(oom_score_fd, fmt_oom_score, sizeof(fmt_oom_score)) < 0) {
23-
ndebugf("failed to read from /proc/self/oom_score_adj: %s\n", strerror(errno));
23+
ndebugf("failed to read from /proc/self/oom_score_adj: %m");
2424
}
2525
*old_value = atoi(fmt_oom_score);
2626
}
2727
sprintf(fmt_oom_score, "%d", oom_score);
2828
if (write(oom_score_fd, fmt_oom_score, strlen(fmt_oom_score)) < 0) {
29-
ndebugf("failed to write to /proc/self/oom_score_adj: %s\n", strerror(errno));
29+
ndebugf("failed to write to /proc/self/oom_score_adj: %m");
3030
}
3131
close(oom_score_fd);
3232
#else

src/utils.h

Lines changed: 8 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -37,43 +37,36 @@ extern gboolean use_syslog;
3737

3838
#define _pexit(s) \
3939
do { \
40-
fprintf(stderr, "[conmon:e]: %s %s\n", s, strerror(errno)); \
40+
fprintf(stderr, "[conmon:e]: %s %m\n", s); \
4141
if (use_syslog) \
42-
syslog(LOG_ERR, "conmon %.20s <error>: %s %s\n", log_cid, s, strerror(errno)); \
42+
syslog(LOG_ERR, "conmon %.20s <error>: %s %m\n", log_cid, s); \
4343
_exit(EXIT_FAILURE); \
4444
} while (0)
4545

4646
#define _pexitf(fmt, ...) \
4747
do { \
48-
fprintf(stderr, "[conmon:e]: " fmt " %s\n", ##__VA_ARGS__, strerror(errno)); \
48+
fprintf(stderr, "[conmon:e]: " fmt " %m\n", ##__VA_ARGS__); \
4949
if (use_syslog) \
50-
syslog(LOG_ERR, "conmon %.20s <error>: " fmt ": %s\n", log_cid, ##__VA_ARGS__, strerror(errno)); \
50+
syslog(LOG_ERR, "conmon %.20s <error>: " fmt ": %m\n", log_cid, ##__VA_ARGS__); \
5151
_exit(EXIT_FAILURE); \
5252
} while (0)
5353

5454
#define pexit(s) \
5555
do { \
56-
fprintf(stderr, "[conmon:e]: %s %s\n", s, strerror(errno)); \
56+
fprintf(stderr, "[conmon:e]: %s %m\n", s); \
5757
if (use_syslog) \
58-
syslog(LOG_ERR, "conmon %.20s <error>: %s %s\n", log_cid, s, strerror(errno)); \
58+
syslog(LOG_ERR, "conmon %.20s <error>: %s %m\n", log_cid, s); \
5959
exit(EXIT_FAILURE); \
6060
} while (0)
6161

6262
#define pexitf(fmt, ...) \
6363
do { \
64-
fprintf(stderr, "[conmon:e]: " fmt " %s\n", ##__VA_ARGS__, strerror(errno)); \
64+
fprintf(stderr, "[conmon:e]: " fmt " %m\n", ##__VA_ARGS__); \
6565
if (use_syslog) \
66-
syslog(LOG_ERR, "conmon %.20s <error>: " fmt ": %s\n", log_cid, ##__VA_ARGS__, strerror(errno)); \
66+
syslog(LOG_ERR, "conmon %.20s <error>: " fmt ": %m\n", log_cid, ##__VA_ARGS__); \
6767
exit(EXIT_FAILURE); \
6868
} while (0)
6969

70-
#define pwarn(s) \
71-
do { \
72-
fprintf(stderr, "[conmon:w]: %s %s\n", s, strerror(errno)); \
73-
if (use_syslog) \
74-
syslog(LOG_INFO, "conmon %.20s <pwarn>: %s %s\n", log_cid, s, strerror(errno)); \
75-
} while (0)
76-
7770
#define nexit(s) \
7871
do { \
7972
fprintf(stderr, "[conmon:e] %s\n", s); \

0 commit comments

Comments
 (0)