tim@dciem.UUCP (Tim Pointing) (09/03/86)
Below is the source for ofiles. Included are the original source (4.2BSD) and
a locally-modified version (V7). Alas, I do not have the address of the
author (cspencer) to whom all questions and thanks should really be directed.
NOTE: The Makefile is the one for 4.2BSD; V7 users should only have to
change the directory where ofiles is to be installed. The man page is
the one for 4.2BSD, but it should be the same as the V7 one. If you are
running V7 and have added "/etc/fstab" and the routines for accessing it
to your system, add "-DFSTAB" to the CFLAGS line in the Makefile.
------cut--here-------cut--here--------cut--here---------cut--here--------
#! /bin/sh
# This is a shell archive, meaning:
# 1. Remove everything above the #! /bin/sh line.
# 2. Save the resulting text in a file.
# 3. Execute the file with /bin/sh (not csh) to create:
# Makefile
# ofiles.8
# ofiles42.c
# ofilesv7.c
# This archive created: Wed Sep 3 07:32:54 1986
export PATH; PATH=/bin:/usr/bin:$PATH
if test -f 'Makefile'
then
echo shar: "will not over-write existing file 'Makefile'"
else
cat << \SHAR_EOF > 'Makefile'
# $Header: Makefile,v 1.1 85/05/06 19:32:13 cspencer Exp $
# add `-DFSTAB' if you have /etc/fstab and getfstab() and getfsspec()
CFLAGS= -O
INSTALL=/usr/local/bin/install
DESTDIR=/usr/local/bin
all: ofiles
ofiles: ofiles.o
cc ofiles.o ${LIBES} -o ofiles
all.install: ofiles
${INSTALL} ofiles ${DESTDIR} -m 755 -u root -g bin
rmobjects clobber clean:
rm -f ofiles *.o *.out *.log core
SHAR_EOF
fi
if test -f 'ofiles.8'
then
echo shar: "will not over-write existing file 'ofiles.8'"
else
cat << \SHAR_EOF > 'ofiles.8'
.TH OFILES 8 BBN
.UC
.SH NAME
ofiles \- who has a file open
.SH SYNOPSIS
.B /systools/ofiles
[
.B \-p
]
files . . .
.br
.SH DESCRIPTION
.I Ofiles
displays the owner and id of any process accessing a specified device.
The type of access is defined by the
.I type
field which can contain:
.IP
.TP 8
.B p
if
.I device
is a mounted file system and the
proccess has a current directory there.
.br
.TP 8
.B f
if the proccess has a file on
.I device
open.
.br
.TP 8
.B r
if
.I device
contains a mounted file system and the proccess has
it's root directory there.
.LP
In the case of special files,
.I device
can be specified by device or file system. i.e.
.IP
.I ofiles
/dev/disk07
.br
.I ofiles
/usr
.LP
If
.I ofiles
is invoked with the
.B \-p
option, only the process id will be output,
so that the output of
.I ofiles
may be piped to
.I "kill(1)" .
.SH "SEE ALSO"
mount(1) kill(1)
.SH DIAGNOSTICS
\*(OQcannot stat . . .\*(CQ when a file cannot be accessed.
.br
SHAR_EOF
fi
if test -f 'ofiles42.c'
then
echo shar: "will not over-write existing file 'ofiles42.c'"
else
cat << \SHAR_EOF > 'ofiles42.c'
#ifndef lint
static char rcsid[]="$Header: ofiles.c,v 1.1 85/05/03 06:49:19 cspencer Exp $";
#endif lint
#include <sys/param.h>
#include <sys/dir.h>
#define KERNEL
#include <sys/file.h>
#undef KERNEL
#include <sys/inode.h>
#include <sys/user.h>
#include <vax/pte.h>
#include <sys/proc.h>
#include <nlist.h>
#include <sys/stat.h>
#include <pwd.h>
#include <fstab.h>
#include <sys/vmmac.h>
#include <stdio.h>
#define CDIR 01
#define OFILE 02
#define RDIR 04
long eseek();
int nproc; /* number of entries in proc table */
int mem; /* fd for /dev/mem */
int kmem;
int swap; /* fd for /dev/swap */
struct pte *usrpt, *Usrptma;
long procbase;
int pids_only = 0; /* if non-zero, only output process ids */
char *progname;
struct nlist nl[] = {
#define X_PROC 0
{"_proc"},
#define X_NPROC 1
{"_nproc"},
#define X_USRPTMA 2
{"_Usrptmap"},
#define X_USRPT 3
{"_usrpt"},
{0}
};
main(argc, argv)
int argc;
char *argv[];
{
struct inode *i,*getinode();
struct stat s;
struct user *u, *getuser();
struct proc p;
register int filen, flags, procn;
register char *filename, *fsname;
struct fstab *fs, *getfsfile(), *getfsspec();
progname = argv[0];
if(argc == 1) {
fprintf(stderr,"usage: %s [-p] files\n", progname);
exit(1);
}
/* check for -p flag */
if(strcmp(argv[1],"-p") == 0) {
pids_only++;
--argc;
++argv;
}
if((mem = open("/dev/mem", 0)) < 0)
error("can't open /dev/mem. ");
if((kmem = open("/dev/kmem", 0)) < 0)
error("can't open /dev/kmem. ");
if((swap = open("/dev/drum", 0)) < 0)
error("can't open /dev/drum. ");
getsyms();
while(--argc) {
/* assume arg is a filesystem */
if((fs = getfsfile(*++argv)) != NULL) {
fsname = *argv;
filename = fs->fs_spec;
}
/* maybe it's the device name for a filesystem */
else if ((fs = getfsspec(*argv)) != NULL) {
filename = *argv;
fsname = fs->fs_file;
}
/* probably a regular file */
else {
filename = *argv;
fsname = "";
}
if(stat(filename, &s)) {
fprintf(stderr,"can't stat %s. ",filename);
perror("");
continue;
}
if(! pids_only) {
printf("%s\t%s\n", filename,fsname);
printf("%-8.8s\tpid\ttype\tcmd\n", "user");
}
for(procn = 0; procn < nproc; procn++){
procslot(procn, &p);
flags = 0;
if(p.p_stat == 0 || p.p_stat == SZOMB)
continue;
u = getuser(&p);
if ( u == (struct user *)NULL)
continue;
i = getinode(u->u_rdir, "rdir");
if(check(&s,i))
flags |= RDIR;
i = getinode(u->u_cdir, "cdir");
if(check(&s,i))
flags |= CDIR;
for(filen = 0; filen < NOFILE; filen++) {
struct file f;
if(u->u_ofile[filen] == NULL)
continue;
eseek(kmem,(long)u->u_ofile[filen],0,"file");
eread(kmem,(char *)&f, sizeof(f), "file");
if(f.f_count > 0) {
if (f.f_type != DTYPE_INODE)
continue;
i = getinode((char *)f.f_data, "file");
if(check(&s,i))
flags |= OFILE;
}
}
if(flags) gotone(u,&p,flags);
}
if(! pids_only)
printf("\n");
}
}
/*
* print the name of the user owning process "p" and the pid of that process
*/
gotone(u,p,f)
struct user *u;
struct proc *p;
int f;
{
register struct passwd *pw;
struct passwd *getpwuid();
/* only print pids and return */
if(pids_only) {
printf("%d ",p->p_pid);
fflush(stdout);
return;
}
pw = getpwuid(u->u_uid);
if(pw)
printf("%-8.8s\t", pw->pw_name );
else
printf("(%d)\t", u->u_uid);
printf("%d\t", p->p_pid);
if(f & OFILE) putchar('f'); /* proc has a file */
if(f & CDIR) putchar('p'); /* proc's current dir is on device */
if(f & RDIR) putchar('r'); /* proc's root dir is on device */
printf("\t");
printf("%-14.14s", u->u_comm);
printf("\n");
}
/*
* is inode "i" on device "s"? returns TRUE or FALSE
*/
check(s, i)
struct stat *s;
struct inode *i;
{
if ((s->st_mode & S_IFMT) == S_IFBLK && s->st_rdev == i->i_dev)
return 1;
else if((s->st_dev == i->i_dev) && (s->st_ino == i->i_number))
return 1;
else return 0;
}
/*
* getinode - read an inode from from mem at address "addr"
* return pointer to inode struct.
*/
struct inode *getinode(ip,s)
struct inode *ip;
char *s;
{
static struct inode i;
eseek(kmem, (long)ip, 0, "inode");
eread(kmem, (char *)&i, sizeof(i), "inode");
return &i;
}
/*
* get user page for proc "p" from core or swap
* return pointer to user struct
*/
struct user *getuser(p)
struct proc *p;
{
struct pte *ptep, apte;
struct pte mypgtbl[NBPG/sizeof(struct pte)];
int upage;
char *up;
static struct user user;
/* easy way */
if ((p->p_flag & SLOAD) == 0) {
(void) lseek(swap, (long)dtob(p->p_swaddr), 0);
if (read(swap, (char *)&user, sizeof(struct user))==0){
fprintf(stderr, "error: can't get swapped user page\n");
return (struct user *)NULL;
}
} else { /* boo */
ptep = &Usrptma[btokmx(p->p_p0br) + p->p_szpt - 1];
/* get the page table for the user page */
lseek(kmem, (long)ptep, 0);
if (read(kmem, &apte, sizeof(apte)) == 0) {
fprintf(stderr,"error: can't get user page table\n");
return (struct user *)NULL;
}
/* now get this user's page table */
eseek(mem, (long)ctob(apte.pg_pfnum) ,0);
if (read(mem, mypgtbl, sizeof(mypgtbl)) == 0){
fprintf(stderr,"error: can't get mypgtbl.\n");
return (struct user *)NULL;
}
/* now collect various pages of u area */
for(upage = 0,up = (char *)&user; upage < sizeof(struct user)/NBPG; upage++) {
eseek(mem,(long)ctob(mypgtbl[NPTEPG-UPAGES+upage].pg_pfnum), 0);
if (read(mem, up, NBPG) == 0) {
fprintf(stderr, "error: can't get page %d of user area.\n",
upage);
return(NULL);
}
up += NBPG;
}
}
return &user;
}
/*
* read with error checking
*/
eread( fd, p, size, s)
int fd;
char *p;
int size;
char *s;
{
int n;
char buf[100];
if(( n = read(fd, p, size)) != size){
sprintf(buf, "read error for %s. ", s);
error(buf);
}
return n;
}
/*
* seek with error checking
*/
long eseek(fd, off, whence, s)
int fd;
long off;
int whence;
char *s;
{
long lseek();
long ret;
char buf[100];
if(( ret = lseek(fd, off, whence)) != off) {
sprintf(buf, "seek for %s failed, wanted %o, got %o. ",
s, off, ret);
error(buf);
}
return ret;
}
/*
* print mesg "s" followed by system erro msg. exit.
*/
error(s)
char *s;
{
if (s)
fprintf(stderr,s);
perror("");
exit(1);
}
/*
* get some symbols form the kernel
*/
getsyms()
{
register i;
nlist("/vmunix", nl);
for(i = 0; i < (sizeof(nl)/sizeof(nl[0]))-1; i++)
if(nl[i].n_value == 0) {
fprintf(stderr,"%s: can't nlist for %s.\n",
nl[i].n_value);
exit(1);
}
eseek(kmem, (long)nl[X_PROC].n_value, 0);
eread(kmem, &procbase, sizeof(procbase), "procbase 1");
eseek(kmem, (long)nl[X_NPROC].n_value, 0);
eread(kmem, &nproc, sizeof(nproc), "nproc");
Usrptma = (struct pte *)nl[X_USRPTMA].n_value;
usrpt = (struct pte *)nl[X_USRPT].n_value; /* used by <vmmac.h>*/
return;
}
/*
* read proc table entry "n" into buffer "p"
*/
procslot(n, p)
int n;
struct proc *p;
{
eseek(kmem, procbase + (long)(n * sizeof(struct proc)), 0);
eread(kmem, (char *)p, sizeof(struct proc), "proc");
return;
}
SHAR_EOF
fi
if test -f 'ofilesv7.c'
then
echo shar: "will not over-write existing file 'ofilesv7.c'"
else
cat << \SHAR_EOF > 'ofilesv7.c'
#ifndef lint
static char rcsid[]="$Header: ofiles.c,v 1.1 85/05/03 06:49:19 cspencer Exp $";
#endif lint
#include <sys/local.h> /* DCIEM local mod. Delete at other sites */
#include <sys/param.h>
#define KERNEL
#include <sys/file.h>
struct file file[1]; /* to satisfy "extern" reference in <sys/file.h> */
#undef KERNEL
#include <sys/inode.h>
#include <sys/dir.h>
#include <sys/user.h>
#include <sys/proc.h>
#include <a.out.h>
#include <sys/stat.h>
#include <pwd.h>
#ifdef FSTAB
#include <fstab.h>
#endif FSTAB
#include <stdio.h>
#define CDIR 01
#define OFILE 02
#define RDIR 04
long eseek();
int nproc; /* number of entries in proc table */
int swplo; /* lowest block number on swap device */
int mem; /* fd for /dev/mem */
int swap; /* fd for /dev/swap */
long procbase;
int pids_only = 0; /* if non-zero, only output process ids */
char *progname;
struct nlist nl[] = {
#define X_PROC 0
{"_proc"},
#define X_NPROC 1
{"_nproc"},
#define X_SWPLO 2
{"_swplo"},
{""}
};
main(argc, argv)
int argc;
char *argv[];
{
struct inode *i,*getinode();
struct stat s;
struct user *u, *getuser();
struct proc p;
register int filen, flags, procn;
register char *filename, *fsname;
#ifdef FSTAB
struct fstab *fs, *getfsfile(), *getfsspec();
#endif FSTAB
progname = argv[0];
if(argc == 1) {
fprintf(stderr,"usage: %s [-p] files\n", progname);
exit(1);
}
/* check for -p flag */
if(strcmp(argv[1],"-p") == 0) {
pids_only++;
--argc;
++argv;
}
if((mem = open("/dev/mem", 0)) < 0)
error("can't open /dev/mem. ");
if((swap = open("/dev/swap", 0)) < 0)
error("can't open /dev/swap. ");
getsyms();
while(--argc) {
++argv;
#ifdef FSTAB
/* assume arg is a filesystem */
if((fs = getfsfile(*argv)) != NULL) {
fsname = *argv;
filename = fs->fs_spec;
}
/* maybe it's the device name for a filesystem */
else if ((fs = getfsspec(*argv)) != NULL) {
filename = *argv;
fsname = fs->fs_file;
}
/* probably a regular file */
else
#endif FSTAB
{
filename = *argv;
fsname = "";
}
if(stat(filename, &s)) {
fprintf(stderr,"can't stat %s. ",filename);
perror("");
continue;
}
if(! pids_only) {
printf("%s\t%s\n", filename,fsname);
printf("%-8.8s\tpid\ttype\tcmd\n", "user");
}
for(procn = 0; procn < nproc; procn++){
procslot(procn, &p);
flags = 0;
if(p.p_stat == 0 || p.p_stat == SZOMB)
continue;
u = getuser(&p);
if ( u == (struct user *)NULL)
continue;
i = getinode(u->u_rdir, "rdir");
if(check(&s,i))
flags |= RDIR;
i = getinode(u->u_cdir, "cdir");
if(check(&s,i))
flags |= CDIR;
for(filen = 0; filen < NOFILE; filen++) {
struct file f;
if(u->u_ofile[filen] == NULL)
continue;
eseek(mem,(long)u->u_ofile[filen],0,"file");
eread(mem,(char *)&f, sizeof(f), "file");
if(f.f_count > 0) {
#ifdef MASCOT
i = getinode((char *)f.f_typ.f_in.f_inode, "file");
#else
i = getinode((char *)f.f_inode, "file");
#endif MASCOT
if(check(&s,i))
flags |= OFILE;
}
}
if(flags) gotone(u,&p,flags);
}
if(! pids_only)
printf("\n");
}
}
/*
* print the name of the user owning process "p" and the pid of that process
*/
gotone(u,p,f)
struct user *u;
struct proc *p;
int f;
{
register struct passwd *pw;
struct passwd *getpwuid();
/* only print pids and return */
if(pids_only) {
printf("%d ",p->p_pid);
fflush(stdout);
return;
}
pw = getpwuid(u->u_uid);
if(pw)
printf("%-8.8s\t", pw->pw_name );
else
printf("(%d)\t", u->u_uid);
printf("%d\t", p->p_pid);
if(f & OFILE) putchar('f'); /* proc has a file */
else putchar(' ');
if(f & CDIR) putchar('p'); /* proc's current dir is on device */
else putchar(' ');
if(f & RDIR) putchar('r'); /* proc's root dir is on device */
else putchar(' ');
printf("\t");
printf("%-14.14s", u->u_comm);
printf("\n");
}
/*
* is inode "i" on device "s"? returns TRUE or FALSE
*/
check(s, i)
struct stat *s;
struct inode *i;
{
if ((s->st_mode & S_IFMT) == S_IFBLK && s->st_rdev == i->i_dev)
return(1);
if ((s->st_mode & S_IFMT) == S_IFCHR && s->st_rdev == i->i_dev)
return(1);
if((s->st_dev == i->i_dev) && (s->st_ino == i->i_number))
return(1);
return(0);
}
/*
* getinode - read an inode from from mem at address "addr"
* return pointer to inode struct.
*/
struct inode *getinode(ip,s)
struct inode *ip;
char *s;
{
static struct inode i;
eseek(mem, (long)ip, 0, "inode");
eread(mem, (char *)&i, sizeof(i), "inode");
return(&i);
}
/*
* get user structure for proc "p" from core or swap
* return pointer to user struct
*/
struct user *
getuser(p)
struct proc *p;
{
int file;
long addr;
static struct user user;
/* easy way */
if ((p->p_flag & SLOAD) == 0) {
addr = (long)(p->p_addr + swplo) << 9;
file = swap;
}
else {
addr = (long)p->p_addr<<6;
file = mem;
}
lseek(file, addr, 0);
if (read(file, (char *)&user, sizeof(struct user))==0){
fprintf(stderr, "error: can't get swapped user page\n");
return (struct user *)NULL;
}
return(&user);
}
/*
* read with error checking
*/
eread( fd, p, size, s)
int fd;
char *p;
int size;
char *s;
{
int n;
char buf[100];
if(( n = read(fd, p, size)) != size){
sprintf(buf, "read error for %s. ", s);
error(buf);
}
return(n);
}
/*
* seek with error checking
*/
long eseek(fd, off, whence, s)
int fd;
long off;
int whence;
char *s;
{
long lseek();
long ret;
char buf[100];
if(( ret = lseek(fd, off, whence)) != off) {
sprintf(buf, "seek for %s failed, wanted %o, got %o. ",
s, off, ret);
error(buf);
}
return(ret);
}
/*
* print mesg "s" followed by system erro msg. exit.
*/
error(s)
char *s;
{
if (s)
fprintf(stderr,s);
perror("");
exit(1);
}
/*
* get some symbols form the kernel
*/
getsyms()
{
register i;
nlist("/unix", nl);
for(i = 0; i < (sizeof(nl)/sizeof(nl[0]))-1; i++)
if(nl[i].n_value == 0) {
if (i == X_NPROC)
continue;
fprintf(stderr,"%s: can't nlist for %s.\n",
progname, nl[i].n_value);
exit(1);
}
procbase = (unsigned)nl[X_PROC].n_value;
if (nl[X_NPROC].n_value == 0)
nproc = NPROC;
else {
eseek(mem, (long)nl[X_NPROC].n_value, 0, "nproc");
eread(mem, &nproc, sizeof(nproc), "nproc");
}
eseek(mem, (long)nl[X_SWPLO].n_value, 0, "swplo");
eread(mem, &swplo, sizeof(swplo), "swplo");
return;
}
/*
* read proc table entry "n" into buffer "p"
*/
procslot(n, p)
int n;
struct proc *p;
{
eseek(mem, procbase + (long)(n * sizeof(struct proc)), 0, "procslot");
eread(mem, (char *)p, sizeof(struct proc), "proc");
return;
}
SHAR_EOF
fi
exit 0
# End of shell archive
--
Tim Pointing, DCIEM
{decvax|ihnp4|watmath}!utzoo!dciem!tim
or uw-beaver!utcsri!dciem!tim
or seismo!mnetor!lsuc!dciem!tim