diff options
| author | Steven Rostedt <srostedt@redhat.com> | 2010-03-29 16:36:26 -0400 |
|---|---|---|
| committer | Steven Rostedt <rostedt@goodmis.org> | 2010-03-29 16:36:26 -0400 |
| commit | 3d85518bf58a7052ff18e2c33547ceefac5c1939 (patch) | |
| tree | fa5a27417d13bc0574258d61108c1d85cdcfefa8 | |
| parent | 3bb179570aaa834cd629e2a9e5811a2600c35bc9 (diff) | |
trace-cmd: Have listen clean up children with signals
Clean up the children that are created by a client with signals instead
of leaving them around as zombies until another connection is made.
This is a much cleaner solution.
Signed-off-by: Steven Rostedt <rostedt@goodmis.org>
| -rw-r--r-- | trace-listen.c | 21 |
1 files changed, 14 insertions, 7 deletions
diff --git a/trace-listen.c b/trace-listen.c index 3516258..e12431c 100644 --- a/trace-listen.c +++ b/trace-listen.c | |||
| @@ -372,19 +372,12 @@ static void process_client(const char *node, const char *port, int fd) | |||
| 372 | 372 | ||
| 373 | static int do_fork(int cfd) | 373 | static int do_fork(int cfd) |
| 374 | { | 374 | { |
| 375 | int status; | ||
| 376 | pid_t pid; | 375 | pid_t pid; |
| 377 | int ret; | ||
| 378 | 376 | ||
| 379 | /* in debug mode, we do not fork off children */ | 377 | /* in debug mode, we do not fork off children */ |
| 380 | if (debug) | 378 | if (debug) |
| 381 | return 0; | 379 | return 0; |
| 382 | 380 | ||
| 383 | /* Clean up any children that has started before */ | ||
| 384 | do { | ||
| 385 | ret = waitpid(0, &status, WNOHANG); | ||
| 386 | } while (ret > 0); | ||
| 387 | |||
| 388 | pid = fork(); | 381 | pid = fork(); |
| 389 | if (pid < 0) { | 382 | if (pid < 0) { |
| 390 | warning("failed to create child"); | 383 | warning("failed to create child"); |
| @@ -443,6 +436,17 @@ static void do_connection(int cfd, struct sockaddr_storage *peer_addr, | |||
| 443 | exit(0); | 436 | exit(0); |
| 444 | } | 437 | } |
| 445 | 438 | ||
| 439 | static void clean_up(int sig) | ||
| 440 | { | ||
| 441 | int status; | ||
| 442 | int ret; | ||
| 443 | |||
| 444 | /* Clean up any children that has started before */ | ||
| 445 | do { | ||
| 446 | ret = waitpid(0, &status, WNOHANG); | ||
| 447 | } while (ret > 0); | ||
| 448 | } | ||
| 449 | |||
| 446 | static void do_listen(char *port) | 450 | static void do_listen(char *port) |
| 447 | { | 451 | { |
| 448 | struct addrinfo hints; | 452 | struct addrinfo hints; |
| @@ -451,6 +455,9 @@ static void do_listen(char *port) | |||
| 451 | struct sockaddr_storage peer_addr; | 455 | struct sockaddr_storage peer_addr; |
| 452 | socklen_t peer_addr_len; | 456 | socklen_t peer_addr_len; |
| 453 | 457 | ||
| 458 | if (!debug) | ||
| 459 | signal(SIGCHLD, clean_up); | ||
| 460 | |||
| 454 | memset(&hints, 0, sizeof(hints)); | 461 | memset(&hints, 0, sizeof(hints)); |
| 455 | hints.ai_family = AF_UNSPEC; | 462 | hints.ai_family = AF_UNSPEC; |
| 456 | hints.ai_socktype = SOCK_STREAM; | 463 | hints.ai_socktype = SOCK_STREAM; |
