375 lines
9.2 KiB
C
375 lines
9.2 KiB
C
/*
|
|
* Simplified implementation of SYSV ipcs.
|
|
*
|
|
* $Id: ipcs.c,v 1.1 1993/11/14 16:17:58 cgd Exp $
|
|
*/
|
|
|
|
#include <nlist.h>
|
|
#include <stdio.h>
|
|
#include <stdlib.h>
|
|
#include <unistd.h>
|
|
#include <paths.h>
|
|
|
|
#include <sys/types.h>
|
|
#include <sys/param.h>
|
|
#include <sys/proc.h>
|
|
#define KERNEL
|
|
#include <sys/ipc.h>
|
|
#include <sys/sem.h>
|
|
#include <sys/shm.h>
|
|
#include <sys/msg.h>
|
|
|
|
static kmem_fd;
|
|
|
|
getsymbol(struct nlist * symbols, char *symname, void *dptr, int len)
|
|
{
|
|
int i, rlen;
|
|
|
|
for (i = 0; symbols[i].n_name != NULL; i += 1) {
|
|
if (strcmp(symbols[i].n_name, symname) == 0) {
|
|
break;
|
|
}
|
|
}
|
|
|
|
if (symbols[i].n_name == NULL) {
|
|
fprintf(stderr,
|
|
"ipcs(getsymbol): symbol %s not in local symbols list\n",
|
|
symname);
|
|
exit(1);
|
|
}
|
|
|
|
if (symbols[i].n_value == NULL) {
|
|
fprintf(stderr, "ipcs(getsymbol): symbol %s not in %s\n",
|
|
symname, _PATH_UNIX);
|
|
return (0);
|
|
}
|
|
|
|
if (kmem_fd == 0) {
|
|
kmem_fd = open("/dev/kmem", 0);
|
|
if (kmem_fd < 0) {
|
|
perror("ipcs(getsymbol(open /dev/kmem))");
|
|
exit(1);
|
|
}
|
|
}
|
|
|
|
lseek(kmem_fd, symbols[i].n_value, SEEK_SET);
|
|
if ((rlen = read(kmem_fd, dptr, len)) != len) {
|
|
fprintf(stderr,
|
|
"ipcs(getsymbol): can't fetch symbol %s from /dev/kmem\n",
|
|
symname);
|
|
exit(1);
|
|
}
|
|
return (1);
|
|
}
|
|
|
|
void
|
|
getlocation(void *addr, void *dptr, int len)
|
|
{
|
|
int i, rlen;
|
|
|
|
if (kmem_fd == 0) {
|
|
kmem_fd = open("/dev/kmem", 0);
|
|
if (kmem_fd < 0) {
|
|
perror("ipcs(getlocation(open /dev/kmem))");
|
|
exit(1);
|
|
}
|
|
}
|
|
|
|
lseek(kmem_fd, (long) addr, SEEK_SET);
|
|
if ((rlen = read(kmem_fd, dptr, len)) != len) {
|
|
fprintf(stderr,"ipcs(getlocation): can't fetch location %08x from /dev/kmem\n",
|
|
addr);
|
|
exit(1);
|
|
}
|
|
}
|
|
|
|
char *
|
|
fmt_perm(ushort mode)
|
|
{
|
|
static char buffer[100];
|
|
|
|
buffer[0] = '-';
|
|
buffer[1] = '-';
|
|
buffer[2] = ((mode & 0400) ? 'r' : '-');
|
|
buffer[3] = ((mode & 0200) ? 'w' : '-');
|
|
buffer[4] = ((mode & 0100) ? 'a' : '-');
|
|
buffer[5] = ((mode & 0040) ? 'r' : '-');
|
|
buffer[6] = ((mode & 0020) ? 'w' : '-');
|
|
buffer[7] = ((mode & 0010) ? 'a' : '-');
|
|
buffer[8] = ((mode & 0004) ? 'r' : '-');
|
|
buffer[9] = ((mode & 0002) ? 'w' : '-');
|
|
buffer[10] = ((mode & 0001) ? 'a' : '-');
|
|
buffer[11] = '\0';
|
|
return (&buffer[0]);
|
|
}
|
|
|
|
void
|
|
cvt_time(time_t t, char *buf)
|
|
{
|
|
struct tm tms;
|
|
static char *months[] = {"Jan", "Feb", "Mar", "Apr", "May", "Jun",
|
|
"Jul", "Aug", "Sep", "Oct", "Nov", "Dec"};
|
|
|
|
if (t == 0) {
|
|
strcpy(buf, "<not set>");
|
|
}
|
|
else {
|
|
tms = *localtime(&t);
|
|
if (t > time(0) - 6 * 30 * 24 * 3600) { /* less than about 6
|
|
months ago? */
|
|
sprintf(buf, "%s %2d %2d:%2d",
|
|
months[tms.tm_mon], tms.tm_mday, tms.tm_hour,
|
|
tms.tm_min);
|
|
}
|
|
else {
|
|
sprintf(buf, "%s %2d %5d",
|
|
months[tms.tm_mon], tms.tm_mday,
|
|
tms.tm_year + 1900);
|
|
}
|
|
}
|
|
}
|
|
|
|
main()
|
|
{
|
|
static struct nlist symbols[] = {
|
|
{"_sema"},
|
|
{"_seminfo"},
|
|
{"_semu"},
|
|
{"_msginfo"},
|
|
{"_msqids"},
|
|
{NULL}
|
|
};
|
|
int i;
|
|
int show_sem_values = 1;
|
|
int show_undo_values = 1;
|
|
|
|
switch (nlist(_PATH_UNIX, &symbols[0])) {
|
|
case 0:
|
|
break;
|
|
case -1:
|
|
fprintf(stderr, "ipcs: can't open %s - bye!\n", _PATH_UNIX);
|
|
exit(1);
|
|
default:
|
|
fprintf(stderr, "ipcs: nlist failed\n");
|
|
for (i = 0; symbols[i].n_name != NULL; i += 1) {
|
|
if (symbols[i].n_value == 0) {
|
|
fprintf(stderr, "\tsymbol %s not found\n",
|
|
symbols[i].n_name);
|
|
}
|
|
}
|
|
break;
|
|
}
|
|
|
|
#ifdef notdef
|
|
for ( i = 0; symbols[i].n_name != NULL; i += 1 ) {
|
|
fprintf(stderr,"\t%s : %08x\n",symbols[i].n_name,
|
|
symbols[i].n_value);
|
|
}
|
|
#endif
|
|
|
|
if (getsymbol(symbols, "_seminfo", &seminfo, sizeof(seminfo))) {
|
|
struct semid_ds *xsema;
|
|
|
|
printf("seminfo:\n");
|
|
printf("\tsemmap: %6d\t(# of entries in semaphore map)\n",
|
|
seminfo.semmap);
|
|
printf("\tsemmni: %6d\t(# of semaphore identifiers)\n",
|
|
seminfo.semmni);
|
|
printf("\tsemmns: %6d\t(# of semaphores in system)\n",
|
|
seminfo.semmns);
|
|
printf("\tsemmnu: %6d\t(# of undo structures in system)\n",
|
|
seminfo.semmnu);
|
|
printf("\tsemmsl: %6d\t(max # of semaphores per id)\n",
|
|
seminfo.semmsl);
|
|
printf("\tsemopm: %6d\t(max # of operations per semop call)\n",
|
|
seminfo.semopm);
|
|
printf("\tsemume: %6d\t(max # of undo entries per process)\n",
|
|
seminfo.semume);
|
|
printf("\tsemusz: %6d\t(size in bytes of undo structure)\n",
|
|
seminfo.semusz);
|
|
printf("\tsemvmx: %6d\t(semaphore maximum value)\n",
|
|
seminfo.semvmx);
|
|
printf("\tsemaem: %6d\t(adjust on exit max value)\n",
|
|
seminfo.semaem);
|
|
|
|
/*
|
|
* Lock out other users of the semaphore facility
|
|
*/
|
|
|
|
if (semconfig(SEM_CONFIG_FREEZE) != 0) {
|
|
perror("semconfig");
|
|
fprintf(stderr,
|
|
"Can't lock semaphore facility - winging it...\n");
|
|
}
|
|
|
|
getsymbol(symbols, "_sema", &sema, sizeof(sema));
|
|
xsema = malloc(sizeof(struct semid_ds) * seminfo.semmni);
|
|
getlocation(sema, xsema, sizeof(struct semid_ds) *
|
|
seminfo.semmni);
|
|
|
|
for (i = 0; i < seminfo.semmni; i += 1) {
|
|
if ((xsema[i].sem_perm.mode & SEM_ALLOC) != 0) {
|
|
char ctime_buf[100], otime_buf[100];
|
|
struct semid_ds *semaptr = &xsema[i];
|
|
|
|
cvt_time(semaptr->sem_ctime, ctime_buf);
|
|
cvt_time(semaptr->sem_otime, otime_buf);
|
|
|
|
printf("\nsema id: %d key: 0x%08x:\n",
|
|
IXSEQ_TO_IPCID(i, semaptr->sem_perm),
|
|
semaptr->sem_perm.key);
|
|
|
|
printf(" cuid: %6d cgid: %6d ctime: %s\n",
|
|
semaptr->sem_perm.cuid,
|
|
semaptr->sem_perm.cgid, ctime_buf);
|
|
|
|
printf(" uid: %6d gid: %6d otime: %s\n",
|
|
semaptr->sem_perm.uid,
|
|
semaptr->sem_perm.gid, otime_buf);
|
|
|
|
printf(" nsems: %6d perm: %s\n",
|
|
semaptr->sem_nsems,
|
|
fmt_perm(semaptr->sem_perm.mode));
|
|
|
|
if (show_sem_values) {
|
|
int j, value;
|
|
union semun junk;
|
|
|
|
for (j = 0; j < semaptr->sem_nsems;
|
|
j += 1) {
|
|
if ((value = semctl(IXSEQ_TO_IPCID(i, semaptr->sem_perm), j, GETVAL, junk)) < 0) {
|
|
printf("can't get semaphore values\n");
|
|
break;
|
|
}
|
|
if (j % 5 == 0) {
|
|
if (j == 0) {
|
|
printf(" values: {");
|
|
}
|
|
else {
|
|
printf("\n");
|
|
printf(" ");
|
|
}
|
|
}
|
|
printf(" %d", value);
|
|
if (j == semaptr->sem_nsems - 1) {
|
|
printf(" }\n");
|
|
}
|
|
else {
|
|
printf(", ");
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
if (show_undo_values) {
|
|
int j;
|
|
int *ksemu, *semu;
|
|
int semu_size;
|
|
int got_one_undo = 0;
|
|
|
|
semu = 0;
|
|
semu_size = (int) SEMU(seminfo.semmnu);
|
|
semu = (int *) malloc(semu_size);
|
|
getsymbol(symbols, "_semu", &ksemu, sizeof(ksemu));
|
|
getlocation(ksemu, semu, semu_size);
|
|
|
|
printf("\nsem undos:\n");
|
|
for (j = 0; j < seminfo.semmnu; j += 1) {
|
|
struct sem_undo *suptr;
|
|
int k;
|
|
|
|
suptr = SEMU(j);
|
|
if (suptr->un_proc != NULL) {
|
|
struct proc proc;
|
|
|
|
getlocation(suptr->un_proc, &proc,
|
|
sizeof(proc));
|
|
got_one_undo = 1;
|
|
printf(" pid %d: semid semnum adjval\n",
|
|
proc.p_pid);
|
|
for (k = 0; k < suptr->un_cnt; k += 1) {
|
|
printf(" %10d %5d %6d\n",
|
|
IXSEQ_TO_IPCID(suptr->un_ent[k].un_id, xsema[suptr->un_ent[k].un_id].sem_perm),
|
|
suptr->un_ent[k].un_num,
|
|
suptr->un_ent[k].un_adjval);
|
|
}
|
|
}
|
|
}
|
|
if (!got_one_undo) {
|
|
printf(" none allocated\n");
|
|
}
|
|
}
|
|
|
|
(void) semconfig(SEM_CONFIG_THAW);
|
|
|
|
}
|
|
else {
|
|
fprintf(stderr, "SVID semaphores facility not configured in the system\n");
|
|
}
|
|
|
|
if (getsymbol(symbols, "_msginfo", &msginfo, sizeof(msginfo))) {
|
|
struct msqid_ds *xmsqids;
|
|
|
|
printf("\nmsginfo:\n");
|
|
printf("\tmsgmax: %6d\t(max characters in a message)\n",
|
|
msginfo.msgmax);
|
|
printf("\tmsgmni: %6d\t(# of message queues)\n",
|
|
msginfo.msgmni);
|
|
printf("\tmsgmnb: %6d\t(max characters in a message queue)\n",
|
|
msginfo.msgmnb);
|
|
printf("\tmsgtql: %6d\t(max # of messages in system)\n",
|
|
msginfo.msgtql);
|
|
printf("\tmsgssz: %6d\t(size of a message segment)\n",
|
|
msginfo.msgssz);
|
|
printf("\tmsgseg: %6d\t(# of message segments in system)\n",
|
|
msginfo.msgseg);
|
|
|
|
getsymbol(symbols, "_msqids", &msqids, sizeof(msqids));
|
|
xmsqids = malloc(sizeof(struct msqid_ds) * msginfo.msgmni);
|
|
getlocation(msqids, xmsqids, sizeof(struct msqid_ds) *
|
|
msginfo.msgmni);
|
|
|
|
for (i = 0; i < msginfo.msgmni; i += 1) {
|
|
if (xmsqids[i].msg_qbytes != 0) {
|
|
char stime_buf[100], rtime_buf[100],
|
|
ctime_buf[100];
|
|
struct msqid_ds *msqptr = &xmsqids[i];
|
|
|
|
cvt_time(msqptr->msg_stime, stime_buf);
|
|
cvt_time(msqptr->msg_rtime, rtime_buf);
|
|
cvt_time(msqptr->msg_ctime, ctime_buf);
|
|
|
|
printf("\nmsgq id: %d key: 0x%08x\n",
|
|
IXSEQ_TO_IPCID(i, msqptr->msg_perm),
|
|
msqptr->msg_perm.key);
|
|
|
|
printf(" cuid: %6d cgid: %6d ctime: %s\n",
|
|
msqptr->msg_perm.cuid,
|
|
msqptr->msg_perm.cgid, ctime_buf);
|
|
|
|
printf(" uid: %6d gid: %6d\n",
|
|
msqptr->msg_perm.uid,
|
|
msqptr->msg_perm.gid);
|
|
|
|
printf(" lspid: %6d stime: %s\n",
|
|
msqptr->msg_lspid, stime_buf);
|
|
|
|
printf(" lrpid: %6d qnum: %6d rtime: %s\n",
|
|
msqptr->msg_lrpid, msqptr->msg_qnum,
|
|
rtime_buf);
|
|
|
|
printf(" cbytes:%6d qbytes:%6d perm: %s\n",
|
|
msqptr->msg_cbytes, msqptr->msg_qbytes,
|
|
fmt_perm(msqptr->msg_perm.mode));
|
|
}
|
|
}
|
|
}
|
|
else {
|
|
fprintf(stderr,
|
|
"SVID messages facility not configured in the system\n");
|
|
}
|
|
|
|
exit(0);
|
|
}
|