1 diff -u -r ../util-linux-2.28/sys-utils/ipcutils.c ./sys-utils/ipcutils.c
2 --- ../util-linux-2.28/sys-utils/ipcutils.c 2016-04-04 04:29:50.698566374 -0400
3 +++ ./sys-utils/ipcutils.c 2016-06-23 06:20:15.952794444 -0400
5 # define SHMMIN 1 /* min shared segment size in bytes */
9 int ipc_msg_get_limits(struct ipc_limits *lim)
11 - if (path_exist(_PATH_PROC_IPC_MSGMNI) &&
12 - path_exist(_PATH_PROC_IPC_MSGMNB) &&
13 - path_exist(_PATH_PROC_IPC_MSGMAX)) {
15 - lim->msgmni = path_read_s32(_PATH_PROC_IPC_MSGMNI);
16 - lim->msgmnb = path_read_s32(_PATH_PROC_IPC_MSGMNB);
17 - lim->msgmax = path_read_s32(_PATH_PROC_IPC_MSGMAX);
19 - struct msginfo msginfo;
21 - if (msgctl(0, IPC_INFO, (struct msqid_ds *) &msginfo) < 0)
23 - lim->msgmni = msginfo.msgmni;
24 - lim->msgmnb = msginfo.msgmnb;
25 - lim->msgmax = msginfo.msgmax;
32 int ipc_sem_get_limits(struct ipc_limits *lim)
37 - lim->semvmx = SEMVMX;
39 - f = path_fopen("r", 0, _PATH_PROC_IPC_SEM);
41 - rc = fscanf(f, "%d\t%d\t%d\t%d",
42 - &lim->semmsl, &lim->semmns, &lim->semopm, &lim->semmni);
48 - struct seminfo seminfo = { .semmni = 0 };
49 - union semun arg = { .array = (ushort *) &seminfo };
51 - if (semctl(0, 0, IPC_INFO, arg) < 0)
53 - lim->semmni = seminfo.semmni;
54 - lim->semmsl = seminfo.semmsl;
55 - lim->semmns = seminfo.semmns;
56 - lim->semopm = seminfo.semopm;
63 int ipc_shm_get_limits(struct ipc_limits *lim)
65 - lim->shmmin = SHMMIN;
67 - if (path_exist(_PATH_PROC_IPC_SHMALL) &&
68 - path_exist(_PATH_PROC_IPC_SHMMAX) &&
69 - path_exist(_PATH_PROC_IPC_SHMMNI)) {
71 - lim->shmall = path_read_u64(_PATH_PROC_IPC_SHMALL);
72 - lim->shmmax = path_read_u64(_PATH_PROC_IPC_SHMMAX);
73 - lim->shmmni = path_read_u64(_PATH_PROC_IPC_SHMMNI);
76 - struct shminfo *shminfo;
77 - struct shmid_ds shmbuf;
79 - if (shmctl(0, IPC_INFO, &shmbuf) < 0)
81 - shminfo = (struct shminfo *) &shmbuf;
82 - lim->shmmni = shminfo->shmmni;
83 - lim->shmall = shminfo->shmall;
84 - lim->shmmax = shminfo->shmmax;
91 int ipc_shm_get_info(int id, struct shm_data **shmds)
97 - struct shmid_ds dummy;
99 - p = *shmds = xcalloc(1, sizeof(struct shm_data));
102 - f = path_fopen("r", 0, _PATH_PROC_SYSV_SHM);
106 - while (fgetc(f) != '\n'); /* skip header */
108 - while (fgets(buf, sizeof(buf), f) != NULL) {
109 - /* scan for the first 14-16 columns (e.g. Linux 2.6.32 has 14) */
110 - p->shm_rss = 0xdead;
111 - p->shm_swp = 0xdead;
113 - "%d %d %o %"SCNu64 " %u %u "
114 - "%"SCNu64 " %u %u %u %u %"SCNi64 " %"SCNi64 " %"SCNi64
115 - " %"SCNu64 " %"SCNu64 "\n",
132 - continue; /* ivalid line, skipped */
136 - if (id == p->shm_perm.id) {
143 - p->next = xcalloc(1, sizeof(struct shm_data));
154 - /* Fallback; /proc or /sys file(s) missing. */
156 - maxid = shmctl(0, SHM_INFO, &dummy);
158 - for (int j = 0; j <= maxid; j++) {
160 - struct shmid_ds shmseg;
161 - struct ipc_perm *ipcp = &shmseg.shm_perm;
163 - shmid = shmctl(j, SHM_STAT, &shmseg);
164 - if (shmid < 0 || (id > -1 && shmid != id)) {
169 - p->shm_perm.key = ipcp->KEY;
170 - p->shm_perm.id = shmid;
171 - p->shm_perm.mode = ipcp->mode;
172 - p->shm_segsz = shmseg.shm_segsz;
173 - p->shm_cprid = shmseg.shm_cpid;
174 - p->shm_lprid = shmseg.shm_lpid;
175 - p->shm_nattch = shmseg.shm_nattch;
176 - p->shm_perm.uid = ipcp->uid;
177 - p->shm_perm.gid = ipcp->gid;
178 - p->shm_perm.cuid = ipcp->cuid;
179 - p->shm_perm.cgid = ipcp->cuid;
180 - p->shm_atim = shmseg.shm_atime;
181 - p->shm_dtim = shmseg.shm_dtime;
182 - p->shm_ctim = shmseg.shm_ctime;
183 - p->shm_rss = 0xdead;
184 - p->shm_swp = 0xdead;
187 - p->next = xcalloc(1, sizeof(struct shm_data));
200 void ipc_shm_free_info(struct shm_data *shmds)
203 - struct shm_data *next = shmds->next;
210 static void get_sem_elements(struct sem_data *p)
214 - if (!p || !p->sem_nsems || p->sem_perm.id < 0)
217 - p->elements = xcalloc(p->sem_nsems, sizeof(struct sem_elem));
219 - for (i = 0; i < p->sem_nsems; i++) {
220 - struct sem_elem *e = &p->elements[i];
221 - union semun arg = { .val = 0 };
223 - e->semval = semctl(p->sem_perm.id, i, GETVAL, arg);
225 - err(EXIT_FAILURE, _("%s failed"), "semctl(GETVAL)");
227 - e->ncount = semctl(p->sem_perm.id, i, GETNCNT, arg);
229 - err(EXIT_FAILURE, _("%s failed"), "semctl(GETNCNT)");
231 - e->zcount = semctl(p->sem_perm.id, i, GETZCNT, arg);
233 - err(EXIT_FAILURE, _("%s failed"), "semctl(GETZCNT)");
235 - e->pid = semctl(p->sem_perm.id, i, GETPID, arg);
237 - err(EXIT_FAILURE, _("%s failed"), "semctl(GETPID)");
242 int ipc_sem_get_info(int id, struct sem_data **semds)
246 - struct sem_data *p;
247 - struct seminfo dummy;
250 - p = *semds = xcalloc(1, sizeof(struct sem_data));
253 - f = path_fopen("r", 0, _PATH_PROC_SYSV_SEM);
257 - while (fgetc(f) != '\n') ; /* skip header */
259 - while (feof(f) == 0) {
261 - "%d %d %o %" SCNu64 " %u %u %u %u %"
262 - SCNi64 " %" SCNi64 "\n",
272 - &p->sem_ctime) != 10)
277 - if (id == p->sem_perm.id) {
278 - get_sem_elements(p);
285 - p->next = xcalloc(1, sizeof(struct sem_data));
296 - /* Fallback; /proc or /sys file(s) missing. */
298 - arg.array = (ushort *) (void *)&dummy;
299 - maxid = semctl(0, 0, SEM_INFO, arg);
301 - for (int j = 0; j <= maxid; j++) {
303 - struct semid_ds semseg;
304 - struct ipc_perm *ipcp = &semseg.sem_perm;
305 - arg.buf = (struct semid_ds *)&semseg;
307 - semid = semctl(j, 0, SEM_STAT, arg);
308 - if (semid < 0 || (id > -1 && semid != id)) {
313 - p->sem_perm.key = ipcp->KEY;
314 - p->sem_perm.id = semid;
315 - p->sem_perm.mode = ipcp->mode;
316 - p->sem_nsems = semseg.sem_nsems;
317 - p->sem_perm.uid = ipcp->uid;
318 - p->sem_perm.gid = ipcp->gid;
319 - p->sem_perm.cuid = ipcp->cuid;
320 - p->sem_perm.cgid = ipcp->cuid;
321 - p->sem_otime = semseg.sem_otime;
322 - p->sem_ctime = semseg.sem_ctime;
325 - p->next = xcalloc(1, sizeof(struct sem_data));
330 - get_sem_elements(p);
341 void ipc_sem_free_info(struct sem_data *semds)
344 - struct sem_data *next = semds->next;
345 - free(semds->elements);
352 int ipc_msg_get_info(int id, struct msg_data **msgds)
356 - struct msg_data *p;
357 - struct msqid_ds dummy;
358 - struct msqid_ds msgseg;
360 - p = *msgds = xcalloc(1, sizeof(struct msg_data));
363 - f = path_fopen("r", 0, _PATH_PROC_SYSV_MSG);
367 - while (fgetc(f) != '\n') ; /* skip header */
369 - while (feof(f) == 0) {
371 - "%d %d %o %" SCNu64 " %" SCNu64
372 - " %u %u %u %u %u %u %" SCNi64 " %" SCNi64 " %" SCNi64 "\n",
386 - &p->q_ctime) != 14)
391 - if (id == p->msg_perm.id) {
392 - if (msgctl(id, IPC_STAT, &msgseg) != -1)
393 - p->q_qbytes = msgseg.msg_qbytes;
400 - p->next = xcalloc(1, sizeof(struct msg_data));
411 - /* Fallback; /proc or /sys file(s) missing. */
413 - maxid = msgctl(0, MSG_INFO, &dummy);
415 - for (int j = 0; j <= maxid; j++) {
417 - struct ipc_perm *ipcp = &msgseg.msg_perm;
419 - msgid = msgctl(j, MSG_STAT, &msgseg);
420 - if (msgid < 0 || (id > -1 && msgid != id)) {
425 - p->msg_perm.key = ipcp->KEY;
426 - p->msg_perm.id = msgid;
427 - p->msg_perm.mode = ipcp->mode;
428 - p->q_cbytes = msgseg.msg_cbytes;
429 - p->q_qnum = msgseg.msg_qnum;
430 - p->q_lspid = msgseg.msg_lspid;
431 - p->q_lrpid = msgseg.msg_lrpid;
432 - p->msg_perm.uid = ipcp->uid;
433 - p->msg_perm.gid = ipcp->gid;
434 - p->msg_perm.cuid = ipcp->cuid;
435 - p->msg_perm.cgid = ipcp->cgid;
436 - p->q_stime = msgseg.msg_stime;
437 - p->q_rtime = msgseg.msg_rtime;
438 - p->q_ctime = msgseg.msg_ctime;
439 - p->q_qbytes = msgseg.msg_qbytes;
442 - p->next = xcalloc(1, sizeof(struct msg_data));
455 void ipc_msg_free_info(struct msg_data *msgds)
458 - struct msg_data *next = msgds->next;
465 void ipc_print_perms(FILE *f, struct ipc_stat *is)
470 - fprintf(f, "%-10d %-10o", is->id, is->mode & 0777);
472 - if ((pw = getpwuid(is->cuid)))
473 - fprintf(f, " %-10s", pw->pw_name);
475 - fprintf(f, " %-10u", is->cuid);
477 - if ((gr = getgrgid(is->cgid)))
478 - fprintf(f, " %-10s", gr->gr_name);
480 - fprintf(f, " %-10u", is->cgid);
482 - if ((pw = getpwuid(is->uid)))
483 - fprintf(f, " %-10s", pw->pw_name);
485 - fprintf(f, " %-10u", is->uid);
487 - if ((gr = getgrgid(is->gid)))
488 - fprintf(f, " %-10s\n", gr->gr_name);
490 - fprintf(f, " %-10u\n", is->gid);
494 void ipc_print_size(int unit, char *msg, uint64_t size, const char *end,
501 - else if (msg[strlen(msg) - 1] == '=')
503 - else if (unit == IPC_UNIT_BYTES)
504 - printf(_("%s (bytes) = "), msg);
505 - else if (unit == IPC_UNIT_KB)
506 - printf(_("%s (kbytes) = "), msg);
508 - printf("%s = ", msg);
511 - case IPC_UNIT_DEFAULT:
512 - case IPC_UNIT_BYTES:
513 - sprintf(format, "%%%dju", width);
514 - printf(format, size);
517 - sprintf(format, "%%%dju", width);
518 - printf(format, size / 1024);
520 - case IPC_UNIT_HUMAN:
521 - sprintf(format, "%%%ds", width);
522 - printf(format, size_to_human_string(SIZE_SUFFIX_1LETTER, size));
525 - /* impossible occurred */