mirror of
https://github.com/troglobit/finit.git
synced 2026-11-06 15:51:03 +00:00
Fix #438: refactor initctl ps/top to handle loooooong command lines
Signed-off-by: Joachim Wiberg <troglobit@gmail.com>
This commit is contained in:
2 files changed
+40
-25
No files matched your search
+39
-24
@@ -58,34 +58,47 @@ int cgroup_avail(void)
|
|||||||
return fismnt(FINIT_CGPATH);
|
return fismnt(FINIT_CGPATH);
|
||||||
}
|
}
|
||||||
|
|
||||||
char *pid_cmdline(int pid, char *buf, size_t len)
|
static size_t flen(FILE *fp)
|
||||||
{
|
{
|
||||||
size_t i, sz;
|
size_t total = 0, sz;
|
||||||
char *ptr;
|
char buf[512];
|
||||||
|
|
||||||
|
while ((sz = fread(buf, 1, sizeof(buf), fp)) > 0)
|
||||||
|
total += sz;
|
||||||
|
rewind(fp);
|
||||||
|
|
||||||
|
return total;
|
||||||
|
}
|
||||||
|
|
||||||
|
char *pid_cmdline(int pid)
|
||||||
|
{
|
||||||
|
size_t i, len;
|
||||||
|
char *buf;
|
||||||
FILE *fp;
|
FILE *fp;
|
||||||
|
|
||||||
fp = fopenf("r", "/proc/%d/cmdline", pid);
|
fp = fopenf("r", "/proc/%d/cmdline", pid);
|
||||||
if (!fp) {
|
if (!fp)
|
||||||
buf[0] = 0;
|
return strdup(""); /* regular process */
|
||||||
return buf;
|
|
||||||
}
|
|
||||||
|
|
||||||
sz = fread(buf, sizeof(buf[0]), len - 1, fp);
|
len = flen(fp);
|
||||||
fclose(fp);
|
if (len == 0) {
|
||||||
if (!sz)
|
fail:
|
||||||
|
fclose(fp);
|
||||||
return NULL; /* kernel thread */
|
return NULL; /* kernel thread */
|
||||||
|
|
||||||
buf[sz] = 0;
|
|
||||||
|
|
||||||
ptr = strchr(buf, 0);
|
|
||||||
if (ptr && ptr != buf) {
|
|
||||||
ptr++;
|
|
||||||
sz -= ptr - buf;
|
|
||||||
memmove(buf, ptr, sz + 1);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
for (i = 0; i < sz; i++) {
|
buf = calloc(len + 1, 1);
|
||||||
if (buf[i] == 0)
|
if (!buf)
|
||||||
|
goto fail;
|
||||||
|
|
||||||
|
if (fread(buf, 1, len, fp) < len) {
|
||||||
|
free(buf);
|
||||||
|
goto fail;
|
||||||
|
}
|
||||||
|
|
||||||
|
/* replace all NUL chars with space */
|
||||||
|
for (i = 0; i < len; i++) {
|
||||||
|
if (buf[i] == '\0')
|
||||||
buf[i] = ' ';
|
buf[i] = ' ';
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -423,7 +436,7 @@ int cgroup_tree(char *path, char *pfx, int mode, int pos)
|
|||||||
|
|
||||||
i = 0;
|
i = 0;
|
||||||
while (fgets(buf, sizeof(buf), fp)) {
|
while (fgets(buf, sizeof(buf), fp)) {
|
||||||
char comm[80] = { 0 };
|
char *cmdline;
|
||||||
pid_t pid;
|
pid_t pid;
|
||||||
|
|
||||||
pid = atoi(chomp(buf));
|
pid = atoi(chomp(buf));
|
||||||
@@ -431,8 +444,8 @@ int cgroup_tree(char *path, char *pfx, int mode, int pos)
|
|||||||
continue;
|
continue;
|
||||||
|
|
||||||
/* skip kernel threads for now (no cmdline) */
|
/* skip kernel threads for now (no cmdline) */
|
||||||
pid_comm(pid, comm, sizeof(comm));
|
cmdline = pid_cmdline(pid);
|
||||||
if (pid_cmdline(pid, buf, sizeof(buf))) {
|
if (cmdline) {
|
||||||
char proc[ttcols];
|
char proc[ttcols];
|
||||||
|
|
||||||
switch (mode) {
|
switch (mode) {
|
||||||
@@ -450,7 +463,7 @@ int cgroup_tree(char *path, char *pfx, int mode, int pos)
|
|||||||
strlcat(row, pfx, rplen);
|
strlcat(row, pfx, rplen);
|
||||||
strlcat(row, ++i == num ? END : FORK, rlen);
|
strlcat(row, ++i == num ? END : FORK, rlen);
|
||||||
|
|
||||||
snprintf(proc, sizeof(proc), " %d %s %s", pid, comm, buf);
|
snprintf(proc, sizeof(proc), " %d %s", pid, cmdline);
|
||||||
|
|
||||||
if (plain) {
|
if (plain) {
|
||||||
strlcat(row, proc, rplen);
|
strlcat(row, proc, rplen);
|
||||||
@@ -468,6 +481,8 @@ int cgroup_tree(char *path, char *pfx, int mode, int pos)
|
|||||||
}
|
}
|
||||||
|
|
||||||
puts(row);
|
puts(row);
|
||||||
|
|
||||||
|
free(cmdline);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (mode == 1) {
|
if (mode == 1) {
|
||||||
|
|||||||
+1
-1
@@ -54,7 +54,7 @@ struct cg {
|
|||||||
|
|
||||||
int cgroup_avail(void);
|
int cgroup_avail(void);
|
||||||
|
|
||||||
char *pid_cmdline (int pid, char *buf, size_t len);
|
char *pid_cmdline (int pid);
|
||||||
char *pid_comm (int pid, char *buf, size_t len);
|
char *pid_comm (int pid, char *buf, size_t len);
|
||||||
char *pid_cgroup (int pid, char *buf, size_t len);
|
char *pid_cgroup (int pid, char *buf, size_t len);
|
||||||
|
|
||||||
|
|||||||
Reference in new issue
Block a user