/*
* Copyright 2000, International Business Machines Corporation and others.
* All Rights Reserved.
- *
+ *
* This software has been released under the terms of the IBM Public
* License. For details, see the LICENSE file in the top-level source
* directory or online at http://www.openafs.org/dl/license10.html
#include <afsconfig.h>
#include <afs/param.h>
-RCSID("$Header$");
+#include <roken.h>
-#include <fcntl.h>
-#include <stdarg.h>
#ifdef AFS_AIX32_ENV
#include <sys/audit.h>
+#else
+#define AUDIT_OK 0
+#define AUDIT_FAIL 1
+#define AUDIT_FAIL_AUTH 2
+#define AUDIT_FAIL_ACCESS 3
+#define AUDIT_FAIL_PRIV 4
#endif /* AFS_AIX32_ENV */
-#include <errno.h>
+#include <afs/opr.h>
#include "afs/afsint.h"
+#include "afs/butc.h"
#include <rx/rx.h>
#include <rx/rxkad.h>
#include "audit.h"
+#include "audit-api.h"
#include "lock.h"
-#ifdef AFS_AIX32_ENV
-#include <sys/audit.h>
-#endif
+
#include <afs/afsutil.h>
-char *bufferPtr;
-int bufferLen;
-int osi_audit_all = (-1); /* Not determined yet */
-int osi_echo_trail = (-1);
+extern struct osi_audit_ops audit_file_ops;
+#ifdef HAVE_SYS_IPC_H
+extern struct osi_audit_ops audit_sysvmq_ops;
+#endif
-#ifdef AFS_AIX_ENV /** all these functions are only defined for AIX */
+static struct {
+ void *rock;
+ int (*islocal)(void *rock, char *name, char *inst, char *cell);
+} audit_user_check = { NULL, NULL };
-#ifndef AFS_OSF_ENV
-/*
- * These variadic functions work under AIX, and not all systems (osf1)
- */
-/* ************************************************************************** */
-/* AIX requires a buffer filled with values to record with each audit event.
- * aixmakebuf creates that buffer from the variable list of values we are given.
- * ************************************************************************** */
-static aixmakebuf (audEvent, vaList)
- char *audEvent;
- char *vaList;
-{
- int code;
- int vaEntry;
- int vaInt;
- afs_int32 vaLong;
- char *vaStr;
- char *vaLst;
- char hname[20];
- struct AFSFid *vaFid;
-
- vaEntry = va_arg(vaList, int);
- while ( vaEntry != AUD_END )
- {
- switch (vaEntry)
- {
- case AUD_STR : /* String */
- vaStr = (char *) va_arg(vaList, int);
- if ( vaStr )
- {
- strcpy (bufferPtr, vaStr);
- bufferPtr += strlen(vaStr) + 1;
- }
- else
- {
- strcpy (bufferPtr, "");
- bufferPtr++;
- }
- break;
- case AUD_INT : /* Integer */
- vaInt = va_arg(vaList, int);
- *(int *)bufferPtr = vaInt;
- bufferPtr += sizeof(vaInt);
- break;
- case AUD_DATE : /* Date */
- case AUD_HOST : /* Host ID */
- case AUD_LONG : /* long */
- vaLong = va_arg(vaList, afs_int32);
- *(afs_int32 *)bufferPtr = vaLong;
- bufferPtr += sizeof(vaLong);
- break;
- case AUD_LST : /* Ptr to another list */
- vaLst = (char *) va_arg(vaList, int);
- aixmakebuf(audEvent, vaLst);
- break;
- case AUD_FID : /* AFSFid - contains 3 entries */
- vaFid = (struct AFSFid *) va_arg(vaList, int);
- if (vaFid) {
- memcpy(bufferPtr, vaFid, sizeof(struct AFSFid));
- }
- else {
- memset(bufferPtr, 0, sizeof(struct AFSFid));
- }
- bufferPtr += sizeof(struct AFSFid);
- break;
+static struct {
+ const char *name;
+ const struct osi_audit_ops *ops;
+} audit_interfaces[] = {
- /* Whole array of fids-- don't know how to handle variable length audit
- * data with AIX audit package, so for now we just store the first fid.
- * Better one than none. */
- case AUD_FIDS :
- {
- struct AFSCBFids *Fids;
-
- Fids = (struct AFSCBFids *) va_arg(vaList, int);
- if (Fids && Fids->AFSCBFids_len) {
- *((u_int *)bufferPtr) = Fids->AFSCBFids_len;
- bufferPtr += sizeof(u_int);
- memcpy(bufferPtr, Fids->AFSCBFids_val, sizeof(struct AFSFid));
- }
- else {
- struct AFSFid dummy;
- *((u_int *)bufferPtr) = 0;
- bufferPtr += sizeof(u_int);
- memset(bufferPtr, 0, sizeof(struct AFSFid));
- }
- bufferPtr += sizeof(struct AFSFid);
- break;
- }
- default:
-#ifdef AFS_AIX32_ENV
- code = auditlog("AFS_Aud_EINVAL", (-1), audEvent, (strlen(audEvent)+1));
+ { "file", &audit_file_ops },
+#ifdef HAVE_SYS_IPC_H
+ { "sysvmq", &audit_sysvmq_ops },
#endif
- return;
- break;
- } /* end switch */
+};
- vaEntry = va_arg(vaList, int);
- } /* end while */
-}
+#define N_INTERFACES (sizeof(audit_interfaces) / sizeof(audit_interfaces[0]))
+
+/* default to `file' audit interface */
+static const struct osi_audit_ops *audit_ops = &audit_file_ops;
+
+static int osi_audit_all = (-1); /* Not determined yet */
+static int osi_echo_trail = (-1);
-static printbuf (audEvent, errCode, vaList)
- char *audEvent;
- afs_int32 errCode;
- char *vaList;
+static int auditout_open = 0;
+
+static int osi_audit_check(void);
+
+#ifdef AFS_AIX32_ENV
+static char *bufferPtr;
+static int bufferLen;
+
+static void
+audmakebuf(char *audEvent, va_list vaList)
{
- int vaEntry;
- int vaInt;
- afs_int32 vaLong;
- char *vaStr;
- char *vaLst;
- char hname[20];
- struct AFSFid *vaFid;
- struct AFSCBFids *vaFids;
-
- if ( osi_echo_trail < 0 ) osi_audit_check();
- if ( ! osi_echo_trail ) return;
-
- if ( strcmp(audEvent,"VALST") != 0 )
- printf ("%s %d ", audEvent, errCode);
-
- vaEntry = va_arg(vaList, int);
- while ( vaEntry != AUD_END )
- {
- switch (vaEntry)
- {
- case AUD_STR : /* String */
- vaStr = (char *) va_arg(vaList, int);
- if ( vaStr ) printf("%s ", vaStr);
- else printf("<null>", vaStr);
- break;
- case AUD_INT : /* Integer */
- vaInt = va_arg(vaList, int);
- printf("%d ", vaInt);
- break;
- case AUD_DATE : /* Date */
- case AUD_HOST : /* Host ID */
- vaLong = va_arg(vaList, afs_int32);
- printf("%u ", vaLong);
- break;
- case AUD_LONG : /* afs_int32 */
- vaLong = va_arg(vaList, afs_int32);
- printf("%d ", vaLong);
- break;
- case AUD_LST : /* Ptr to another list */
- vaLst = (char *) va_arg(vaList, int);
- printbuf("VALST", 0, vaLst);
- break;
- case AUD_FID : /* AFSFid - contains 3 entries */
- vaFid = (struct AFSFid *) va_arg(vaList, int);
- if (vaFid) printf ("%u:%u:%u ", vaFid->Volume, vaFid->Vnode, vaFid->Unique);
- else printf ("%u:%u:%u ", 0, 0, 0);
- break;
- case AUD_FIDS : /* array of Fids */
- vaFids = (struct AFSCBFids *) va_arg(vaList, int);
- vaFid = NULL;
-
- if (vaFids)
- vaFid = vaFids->AFSCBFids_val;
- if (vaFid)
- printf ("%u %u:%u:%u ", vaFids->AFSCBFids_len, vaFid->Volume,
- vaFid->Vnode, vaFid->Unique);
- else printf ("0 0:0:0 ");
- break;
- default:
- printf ("--badval-- ");
- break;
- } /* end switch */
- vaEntry = va_arg(vaList, int);
- } /* end while */
+ int code;
+ int vaEntry;
+ int vaInt;
+ afs_int32 vaLong;
+ char *vaStr;
+ struct AFSFid *vaFid;
+
+ vaEntry = va_arg(vaList, int);
+ while (vaEntry != AUD_END) {
+ switch (vaEntry) {
+ case AUD_STR: /* String */
+ case AUD_NAME: /* Name */
+ case AUD_ACL: /* ACL */
+ vaStr = (char *)va_arg(vaList, char *);
+ if (vaStr) {
+ strcpy(bufferPtr, vaStr);
+ bufferPtr += strlen(vaStr) + 1;
+ } else {
+ strcpy(bufferPtr, "");
+ bufferPtr++;
+ }
+ break;
+ case AUD_INT: /* Integer */
+ case AUD_ID: /* ViceId */
+ vaInt = va_arg(vaList, int);
+ *(int *)bufferPtr = vaInt;
+ bufferPtr += sizeof(vaInt);
+ break;
+ case AUD_DATE: /* Date */
+ case AUD_HOST: /* Host ID */
+ case AUD_LONG: /* long */
+ vaLong = va_arg(vaList, afs_int32);
+ *(afs_int32 *) bufferPtr = vaLong;
+ bufferPtr += sizeof(vaLong);
+ break;
+ case AUD_FID: /* AFSFid - contains 3 entries */
+ vaFid = (struct AFSFid *)va_arg(vaList, struct AFSFid *);
+ if (vaFid) {
+ memcpy(bufferPtr, vaFid, sizeof(struct AFSFid));
+ } else {
+ memset(bufferPtr, 0, sizeof(struct AFSFid));
+ }
+ bufferPtr += sizeof(struct AFSFid);
+ break;
+
+ /* Whole array of fids-- don't know how to handle variable length audit
+ * data with AIX audit package, so for now we just store the first fid.
+ * Better one than none. */
+ case AUD_FIDS:
+ {
+ struct AFSCBFids *Fids;
+
+ Fids = (struct AFSCBFids *)va_arg(vaList, struct AFSCBFids *);
+ if (Fids && Fids->AFSCBFids_len) {
+ *((u_int *) bufferPtr) = Fids->AFSCBFids_len;
+ bufferPtr += sizeof(u_int);
+ memcpy(bufferPtr, Fids->AFSCBFids_val,
+ sizeof(struct AFSFid));
+ } else {
+ *((u_int *) bufferPtr) = 0;
+ bufferPtr += sizeof(u_int);
+ memset(bufferPtr, 0, sizeof(struct AFSFid));
+ }
+ bufferPtr += sizeof(struct AFSFid);
+ break;
+ }
+ /* butc tape label */
+ case AUD_TLBL:
+ {
+ struct tc_tapeLabel *label;
+
+ label = (struct tc_tapeLabel *)va_arg(vaList,
+ struct tc_tapeLabel *);
+ if (label)
+ memcpy(bufferPtr, label, sizeof(*label));
+ else
+ memset(bufferPtr, 0, sizeof(*label));
+ bufferPtr += sizeof(label);
+ break;
+ }
+ /* butc dump interface */
+ case AUD_TDI:
+ {
+ struct tc_dumpInterface *di;
+
+ di = (struct tc_dumpInterface *)
+ va_arg(vaList, struct tc_dumpInterface *);
+ if (di)
+ memcpy(bufferPtr, di, sizeof(*di));
+ else
+ memset(bufferPtr, 0, sizeof(*di));
+ bufferPtr += sizeof(*di);
+ break;
+ }
+ /*
+ * butc dump array
+ * An array of dump descriptions, but the AIX audit package assumes fixed
+ * length, so we can only do the first one for now.
+ */
+ case AUD_TDA:
+ {
+ struct tc_dumpArray *da;
+
+ da = (struct tc_dumpArray *)
+ va_arg(vaList, struct tc_dumpArray *);
+ if (da && da->tc_dumpArray_len) {
+ memcpy(bufferPtr, &da->tc_dumpArray_len, sizeof(u_int));
+ bufferPtr += sizeof(u_int);
+ memcpy(bufferPtr, da->tc_dumpArray_val,
+ sizeof(da->tc_dumpArray_val[0]));
+ } else {
+ memset(bufferPtr, 0, sizeof(u_int));
+ bufferPtr += sizeof(u_int);
+ memset(bufferPtr, 0, sizeof(da->tc_dumpArray_val[0]));
+ }
+ bufferPtr += sizeof(da->tc_dumpArray_val[0]);
+ break;
+ }
+ /*
+ * butc restore array
+ * An array of restore descriptions, but the AIX audit package assumes
+ * fixed length, so we can only do the first one for now.
+ */
+ case AUD_TRA:
+ {
+ struct tc_restoreArray *ra;
+
+ ra = (struct tc_restoreArray *)
+ va_arg(vaList, struct tc_restoreArray *);
+ if (ra && ra->tc_restoreArray_len) {
+ memcpy(bufferPtr, &ra->tc_restoreArray_len, sizeof(u_int));
+ bufferPtr += sizeof(u_int);
+ memcpy(bufferPtr, ra->tc_restoreArray_val,
+ sizeof(ra->tc_restoreArray_val[0]));
+ } else {
+ memset(bufferPtr, 0, sizeof(u_int));
+ bufferPtr += sizeof(u_int);
+ memset(bufferPtr, 0, sizeof(ra->tc_restoreArray_val[0]));
+ }
+ bufferPtr += sizeof(ra->tc_restoreArray_val[0]);
+ break;
+ }
+ /* butc tape controller status */
+ {
+ struct tciStatusS *status;
+
+ status = (struct tciStatusS *)va_arg(vaList,
+ struct tciStatusS *);
+ if (status)
+ memcpy(bufferPtr, status, sizeof(*status));
+ else
+ memset(bufferPtr, 0, sizeof(*status));
+ bufferPtr += sizeof(*status);
+ break;
+ }
+ default:
+#ifdef AFS_AIX32_ENV
+ code =
+ auditlog("AFS_Aud_EINVAL", (-1), audEvent,
+ (strlen(audEvent) + 1));
+#endif
+ return;
+ break;
+ } /* end switch */
- if ( strcmp(audEvent,"VALST") != 0 )
- printf ("\n");
+ vaEntry = va_arg(vaList, int);
+ } /* end while */
}
-#else
-static aixmakebuf (audEvent, vaList)
- char *audEvent;
- va_list vaList;
+#endif
+
+static void
+printbuf(int rec, char *audEvent, char *afsName, afs_int32 hostId,
+ afs_int32 errCode, va_list vaList)
{
- return;
+ int vaEntry;
+ int vaInt;
+ afs_int32 vaLong;
+ char *vaStr;
+ struct AFSFid *vaFid;
+ struct AFSCBFids *vaFids;
+ struct tc_tapeLabel *vaLabel;
+ struct tc_dumpInterface *vaDI;
+ struct tc_dumpArray *vaDA;
+ struct tc_restoreArray *vaRA;
+ struct tciStatusS *vaTCstatus;
+ int num = LogThreadNum();
+ struct in_addr hostAddr;
+ time_t currenttime;
+ char tbuffer[26];
+ struct tm tm;
+
+ /* Don't print the timestamp or thread id if we recursed */
+ if (rec == 0) {
+ currenttime = time(0);
+ if (strftime(tbuffer, sizeof(tbuffer), "%a %b %d %H:%M:%S %Y ",
+ localtime_r(¤ttime, &tm)) !=0)
+ audit_ops->append_msg(tbuffer);
+
+ if (num > -1)
+ audit_ops->append_msg("[%d] ", num);
+ }
+
+ audit_ops->append_msg("EVENT %s CODE %d ", audEvent, errCode);
+
+ if (afsName) {
+ hostAddr.s_addr = hostId;
+ audit_ops->append_msg("NAME %s HOST %s ", afsName, inet_ntoa(hostAddr));
+ }
+
+ vaEntry = va_arg(vaList, int);
+ while (vaEntry != AUD_END) {
+ switch (vaEntry) {
+ case AUD_STR: /* String */
+ vaStr = (char *)va_arg(vaList, char *);
+ if (vaStr)
+ audit_ops->append_msg("STR %s ", vaStr);
+ else
+ audit_ops->append_msg("STR <null>");
+ break;
+ case AUD_NAME: /* Name */
+ vaStr = (char *)va_arg(vaList, char *);
+ if (vaStr)
+ audit_ops->append_msg("NAME %s ", vaStr);
+ else
+ audit_ops->append_msg("NAME <null>");
+ break;
+ case AUD_ACL: /* ACL */
+ vaStr = (char *)va_arg(vaList, char *);
+ if (vaStr)
+ audit_ops->append_msg("ACL %s ", vaStr);
+ else
+ audit_ops->append_msg("ACL <null>");
+ break;
+ case AUD_INT: /* Integer */
+ vaInt = va_arg(vaList, int);
+ audit_ops->append_msg("INT %d ", vaInt);
+ break;
+ case AUD_ID: /* ViceId */
+ vaInt = va_arg(vaList, int);
+ audit_ops->append_msg("ID %d ", vaInt);
+ break;
+ case AUD_DATE: /* Date */
+ vaLong = va_arg(vaList, afs_int32);
+ audit_ops->append_msg("DATE %u ", vaLong);
+ break;
+ case AUD_HOST: /* Host ID */
+ vaLong = va_arg(vaList, afs_int32);
+ hostAddr.s_addr = vaLong;
+ audit_ops->append_msg("HOST %s ", inet_ntoa(hostAddr));
+ break;
+ case AUD_LONG: /* afs_int32 */
+ vaLong = va_arg(vaList, afs_int32);
+ audit_ops->append_msg("LONG %d ", vaLong);
+ break;
+ case AUD_FID: /* AFSFid - contains 3 entries */
+ vaFid = va_arg(vaList, struct AFSFid *);
+ if (vaFid)
+ audit_ops->append_msg("FID %u:%u:%u ", vaFid->Volume, vaFid->Vnode,
+ vaFid->Unique);
+ else
+ audit_ops->append_msg("FID %u:%u:%u ", 0, 0, 0);
+ break;
+ case AUD_FIDS: /* array of Fids */
+ vaFids = va_arg(vaList, struct AFSCBFids *);
+
+ if (vaFids) {
+ unsigned int i;
+
+ vaFid = vaFids->AFSCBFids_val;
+
+ if (vaFid) {
+ audit_ops->append_msg("FIDS %u ", vaFids->AFSCBFids_len);
+ for ( i = 1; i <= vaFids->AFSCBFids_len; i++, vaFid++ )
+ audit_ops->append_msg("FID %u:%u:%u ", vaFid->Volume,
+ vaFid->Vnode, vaFid->Unique);
+ } else
+ audit_ops->append_msg("FIDS 0 FID 0:0:0 ");
+
+ }
+ break;
+ case AUD_TLBL: /* butc tape label */
+ vaLabel = va_arg(vaList, struct tc_tapeLabel *);
+
+ if (vaLabel) {
+ audit_ops->append_msg("TAPELABEL %d:%.*s:%.*s:%u ",
+ vaLabel->size,
+ TC_MAXTAPELEN, vaLabel->afsname,
+ TC_MAXTAPELEN, vaLabel->pname,
+ vaLabel->tapeId);
+ } else {
+ audit_ops->append_msg("TAPELABEL <null>");
+ }
+ break;
+ case AUD_TDI:
+ vaDI = va_arg(vaList, struct tc_dumpInterface *);
+
+ if (vaDI) {
+ audit_ops->append_msg(
+ "TCDUMPINTERFACE %.*s:%.*s:%.*s:%d:%d:%d:$d:%.*s:%.*s:%d:%d:%d:%d:%d ",
+ TC_MAXDUMPPATH, vaDI->dumpPath, TC_MAXNAMELEN, vaDI->volumeSetName,
+ TC_MAXNAMELEN, vaDI->dumpName, vaDI->parentDumpId, vaDI->dumpLevel,
+ vaDI->doAppend,
+ vaDI->tapeSet.id, TC_MAXHOSTLEN, vaDI->tapeSet.tapeServer,
+ TC_MAXFORMATLEN, vaDI->tapeSet.format, vaDI->tapeSet.maxTapes,
+ vaDI->tapeSet.a, vaDI->tapeSet.b, vaDI->tapeSet.expDate,
+ vaDI->tapeSet.expType);
+ } else {
+ audit_ops->append_msg("TCDUMPINTERFACE <null>");
+ }
+ break;
+ case AUD_TDA:
+ vaDA = va_arg(vaList, struct tc_dumpArray *);
+
+ if (vaDA) {
+ u_int i;
+ struct tc_dumpDesc *desc;
+ struct in_addr hostAddr;
+
+ desc = vaDA->tc_dumpArray_val;
+ if (desc) {
+ audit_ops->append_msg("DUMPS %d ", vaDA->tc_dumpArray_len);
+ for (i = 0; i < vaDA->tc_dumpArray_len; i++, desc++) {
+ hostAddr.s_addr = desc->hostAddr;
+ audit_ops->append_msg("DUMP %d:%d:%.*s:$d:%d:%d:%s ",
+ desc->vid, desc->vtype, TC_MAXNAMELEN, desc->name,
+ desc->partition, desc->date, desc->cloneDate,
+ inet_ntoa(hostAddr));
+ }
+ } else {
+ audit_ops->append_msg("DUMPS 0 DUMP 0:0::0:0:0:0.0.0.0");
+ }
+ }
+ break;
+ case AUD_TRA:
+ vaRA = va_arg(vaList, struct tc_restoreArray *);
+
+ if (vaRA) {
+ u_int i;
+ struct tc_restoreDesc *desc;
+ struct in_addr hostAddr;
+
+ desc = vaRA->tc_restoreArray_val;
+ if (desc) {
+ audit_ops->append_msg("RESTORES %d ",
+ vaRA->tc_restoreArray_len);
+ for(i = 0; i < vaRA->tc_restoreArray_len; i++, desc++) {
+ hostAddr.s_addr = desc->hostAddr;
+ audit_ops->append_msg(
+ "RESTORE %d:%.*s:%d:%d:%d:%d:%d:%d:%d:%s:%.*s:%.*s ",
+ desc->flags, TC_MAXTAPELEN, desc->tapeName,
+ desc->dbDumpId, desc->initialDumpId,
+ desc->position, desc->origVid, desc->vid,
+ desc->partition, desc->dumpLevel,
+ inet_ntoa(hostAddr), TC_MAXNAMELEN,
+ desc->oldName, TC_MAXNAMELEN, desc->newName);
+ }
+ } else {
+ audit_ops->append_msg(
+ "RESTORES 0 RESTORE 0::0:0:0:0:0:0:0:0.0.0.0::: ");
+ }
+ }
+ break;
+ case AUD_TSTT:
+ vaTCstatus = va_arg(vaList, struct tciStatusS *);
+
+ if (vaTCstatus)
+ audit_ops->append_msg("TCSTATUS %.*s:%d:%d:%d:%d:%.*s:%d:%d ",
+ TC_MAXNAMELEN, vaTCstatus->taskName,
+ vaTCstatus->taskId, vaTCstatus->flags,
+ vaTCstatus->dbDumpId, vaTCstatus->nKBytes,
+ TC_MAXNAMELEN, vaTCstatus->volumeName,
+ vaTCstatus->volsFailed,
+ vaTCstatus->lastPolled);
+ else
+ audit_ops->append_msg("TCSTATUS <null>");
+ break;
+ default:
+ audit_ops->append_msg("--badval-- ");
+ break;
+ } /* end switch */
+ vaEntry = va_arg(vaList, int);
+ } /* end while */
+
+ audit_ops->send_msg();
}
-static printbuf (audEvent, errCode, vaList)
- char *audEvent;
- long errCode;
- va_list vaList;
+#ifdef AFS_PTHREAD_ENV
+static pthread_mutex_t audit_lock;
+static volatile afs_int32 audit_lock_initialized = 0;
+static pthread_once_t audit_lock_once = PTHREAD_ONCE_INIT;
+
+static void
+osi_audit_init_lock(void)
{
- return;
+ MUTEX_INIT(&audit_lock, "audit", MUTEX_DEFAULT, 0);
+ audit_lock_initialized = 1;
}
-
#endif
+void
+osi_audit_init(void)
+{
+#ifdef AFS_PTHREAD_ENV
+ if (!audit_lock_initialized) {
+ pthread_once(&audit_lock_once, osi_audit_init_lock);
+ }
+#endif /* AFS_PTHREAD_ENV */
+}
/* ************************************************************************** */
/* The routine that acually does the audit call.
* ************************************************************************** */
-int osi_audit (char *audEvent, /* Event name (15 chars or less) */
- afs_int32 errCode, /* The error code */
- ...)
+static int
+osi_audit_internal(char *audEvent, /* Event name (15 chars or less) */
+ afs_int32 errCode, /* The error code */
+ char *afsName,
+ afs_int32 hostId,
+ va_list vaList)
{
#ifdef AFS_AIX32_ENV
- afs_int32 code;
- afs_int32 err;
- int result;
+ afs_int32 code;
+ afs_int32 err;
+ static char BUFFER[32768];
+ int result;
+#endif
- va_list vaList;
- static struct Lock audbuflock = {0,0,0,0,
#ifdef AFS_PTHREAD_ENV
- PTHREAD_MUTEX_INITIALIZER,
- PTHREAD_COND_INITIALIZER,
- PTHREAD_COND_INITIALIZER
+ /* i'm pretty sure all the server apps now call osi_audit_init(),
+ * but to be extra careful we'll leave this assert in here for a
+ * while to make sure */
+ opr_Assert(audit_lock_initialized);
#endif /* AFS_PTHREAD_ENV */
- };
- static char BUFFER[32768];
-
- if ( osi_audit_all < 0 ) osi_audit_check();
- if ( ! osi_audit_all ) return;
-
- switch (errCode)
- {
- case 0 :
- result = AUDIT_OK;
- break;
- case KANOAUTH : /* kautils.h */
- case RXKADNOAUTH : /* rxkad.h */
- result = AUDIT_FAIL_AUTH;
- break;
- case EPERM : /* errno.h */
- case EACCES : /* errno.h */
- case PRPERM : /* pterror.h */
- result = AUDIT_FAIL_ACCESS;
- break;
- case VL_PERM : /* vlserver.h */
- case BUDB_NOTPERMITTED : /* budb_errs.h */
-/* case KRB_RD_AP_UNAUTHOR : */
- case BZACCESS : /* bnode.h */
- case VOLSERBAD_ACCESS : /* volser.h */
- result = AUDIT_FAIL_PRIV;
- break;
+
+ if ((osi_audit_all < 0) || (osi_echo_trail < 0))
+ osi_audit_check();
+ if (!osi_audit_all && !auditout_open)
+ return 0;
+
+#ifdef AFS_AIX32_ENV
+ switch (errCode) {
+ case 0:
+ result = AUDIT_OK;
+ break;
+ case KANOAUTH: /* kautils.h */
+ case RXKADNOAUTH: /* rxkad.h */
+ result = AUDIT_FAIL_AUTH;
+ break;
+ case EPERM: /* errno.h */
+ case EACCES: /* errno.h */
+ case PRPERM: /* pterror.h */
+ result = AUDIT_FAIL_ACCESS;
+ break;
+ case VL_PERM: /* vlserver.h */
+ case BUDB_NOTPERMITTED: /* budb_errs.h */
+ case BZACCESS: /* bnode.h */
+ case VOLSERBAD_ACCESS: /* volser.h */
+ result = AUDIT_FAIL_PRIV;
+ break;
default:
- result = AUDIT_FAIL;
- break;
- }
-
- ObtainWriteLock(&audbuflock);
- bufferPtr = BUFFER;
-
- /* Put the error code into the buffer list */
- *(int *)bufferPtr = errCode;
- bufferPtr += sizeof(errCode);
-
- va_start(vaList, errCode);
- aixmakebuf(audEvent, vaList);
-
- va_start(vaList, errCode);
- printbuf(audEvent, errCode, vaList);
-
- bufferLen = (int)((afs_int32)bufferPtr - (afs_int32)&BUFFER[0]);
- code = auditlog (audEvent, result, BUFFER, bufferLen);
-#ifdef notdef
- if (code)
- {
- err = errno;
- code = auditlog ("AFS_Aud_Fail", result, &err, sizeof(err));
- if (code)
- printf("Error while writing audit entry: %d.\n", errno);
- }
-#endif /* notdef */
- ReleaseWriteLock(&audbuflock);
+ result = AUDIT_FAIL;
+ break;
+ }
+#endif
+
+ MUTEX_ENTER(&audit_lock);
+#ifdef AFS_AIX32_ENV
+ bufferPtr = BUFFER;
+
+ /* Put the error code into the buffer list */
+ *(int *)bufferPtr = errCode;
+ bufferPtr += sizeof(errCode);
+
+ audmakebuf(audEvent, vaList);
+#endif
+
+#ifdef AFS_AIX32_ENV
+ bufferLen = (int)((afs_int32) bufferPtr - (afs_int32) & BUFFER[0]);
+ code = auditlog(audEvent, result, BUFFER, bufferLen);
+#else
+ if (auditout_open) {
+ printbuf(0, audEvent, afsName, hostId, errCode, vaList);
+ }
#endif
+ MUTEX_EXIT(&audit_lock);
+
+ return 0;
+}
+int
+osi_audit(char *audEvent, /* Event name (15 chars or less) */
+ afs_int32 errCode, /* The error code */
+ ...)
+{
+ va_list vaList;
+
+ if ((osi_audit_all < 0) || (osi_echo_trail < 0))
+ osi_audit_check();
+ if (!osi_audit_all && !auditout_open)
+ return 0;
+
+ va_start(vaList, errCode);
+ osi_audit_internal(audEvent, errCode, NULL, 0, vaList);
+ va_end(vaList);
+
+ return 0;
}
/* ************************************************************************** */
-/* Given a RPC call structure, this routine extracts the name and host id from the
+/* Given a RPC call structure, this routine extracts the name and host id from the
* call and includes it within the audit information.
* ************************************************************************** */
-int osi_auditU (struct rx_call *call,
- char *audEvent,
- int errCode,
- ...)
+int
+osi_auditU(struct rx_call *call, char *audEvent, int errCode, ...)
{
- struct rx_connection *conn;
- struct rx_peer *peer;
- afs_int32 secClass;
- afs_int32 code;
- char afsName[MAXKTCNAMELEN];
- afs_int32 hostId;
- va_list vaList;
-
-
- if ( osi_audit_all < 0 ) osi_audit_check();
- if ( !osi_audit_all ) return;
-
- strcpy (afsName, "--Unknown--");
- hostId = 0;
-
- if ( call )
- {
- conn = rx_ConnectionOf(call); /* call -> conn) */
- if (conn)
- {
- secClass = rx_SecurityClassOf(conn); /* conn -> securityIndex */
- if (secClass == 0) /* unauthenticated */
- {
- osi_audit ("AFS_Aud_Unauth", (-1), AUD_STR, audEvent, AUD_END);
- strcpy (afsName, "--UnAuth--");
- }
- else if (secClass == 2) /* authenticated */
- {
- code = rxkad_GetServerInfo(conn, NULL, NULL, afsName,
- NULL, NULL, NULL);
- if (code)
- {
- osi_audit ("AFS_Aud_NoAFSId", (-1), AUD_STR, audEvent, AUD_END);
- strcpy (afsName, "--NoName--");
+ struct rx_connection *conn;
+ struct rx_peer *peer;
+ afs_int32 secClass;
+ afs_int32 code;
+ char afsName[MAXKTCNAMELEN + MAXKTCNAMELEN + MAXKTCREALMLEN + 3];
+ afs_int32 hostId;
+ va_list vaList;
+
+ if (osi_audit_all < 0)
+ osi_audit_check();
+ if (!osi_audit_all && !auditout_open)
+ return 0;
+
+ strcpy(afsName, "--Unknown--");
+ hostId = 0;
+
+ if (call) {
+ conn = rx_ConnectionOf(call); /* call -> conn) */
+ if (conn) {
+ secClass = rx_SecurityClassOf(conn); /* conn -> securityIndex */
+ if (secClass == RX_SECIDX_NULL) { /* unauthenticated */
+ osi_audit("AFS_Aud_Unauth", (-1), AUD_STR, audEvent, AUD_END);
+ strcpy(afsName, "--UnAuth--");
+ } else if (secClass == RX_SECIDX_KAD || secClass == RX_SECIDX_KAE) {
+ /* authenticated with rxkad */
+ char tcell[MAXKTCREALMLEN];
+ char name[MAXKTCNAMELEN];
+ char inst[MAXKTCNAMELEN];
+
+ code =
+ rxkad_GetServerInfo(conn, NULL, NULL, name, inst, tcell,
+ NULL);
+ if (code) {
+ osi_audit("AFS_Aud_NoAFSId", (-1), AUD_STR, audEvent, AUD_END);
+ strcpy(afsName, "--NoName--");
+ } else {
+ afs_int32 islocal = 0;
+ if (audit_user_check.islocal) {
+ islocal =
+ audit_user_check.islocal(audit_user_check.rock,
+ name, inst, tcell);
+ }
+ strlcpy(afsName, name, sizeof(afsName));
+ if (inst[0]) {
+ strlcat(afsName, ".", sizeof(afsName));
+ strlcat(afsName, inst, sizeof(afsName));
+ }
+ if (tcell[0] && !islocal) {
+ strlcat(afsName, "@", sizeof(afsName));
+ strlcat(afsName, tcell, sizeof(afsName));
+ }
+ }
+ } else { /* Unauthenticated and/or unknown */
+ osi_audit("AFS_Aud_UnknSec", (-1), AUD_STR, audEvent, AUD_END);
+ strcpy(afsName, "--Unknown--");
+ }
+ peer = rx_PeerOf(conn); /* conn -> peer */
+ if (peer)
+ hostId = rx_HostOf(peer); /* peer -> host */
+ else
+ osi_audit("AFS_Aud_NoHost", (-1), AUD_STR, audEvent, AUD_END);
+ } else { /* null conn */
+ osi_audit("AFS_Aud_NoConn", (-1), AUD_STR, audEvent, AUD_END);
}
- }
- else /* Unauthenticated & unknown */
- {
- osi_audit ("AFS_Aud_UnknSec", (-1), AUD_STR, audEvent, AUD_END);
- }
-
- peer = rx_PeerOf(conn); /* conn -> peer */
- if ( peer )
- hostId = rx_HostOf(peer); /* peer -> host */
- else
- osi_audit ("AFS_Aud_NoHost", (-1), AUD_STR, audEvent, AUD_END);
- }
- else /* null conn */
- {
- osi_audit ("AFS_Aud_NoConn", (-1), AUD_STR, audEvent, AUD_END);
+ } else { /* null call */
+ osi_audit("AFS_Aud_NoCall", (-1), AUD_STR, audEvent, AUD_END);
}
- }
- else /* null call */
- {
- osi_audit ("AFS_Aud_NoCall", (-1), AUD_STR, audEvent, AUD_END);
- }
-
- va_start(vaList, errCode);
- osi_audit (audEvent, errCode, AUD_STR, afsName,
- AUD_HOST, hostId,
- AUD_LST, vaList,
- AUD_END);
+ va_start(vaList, errCode);
+ osi_audit_internal(audEvent, errCode, afsName, hostId, vaList);
+ va_end(vaList);
+ return 0;
}
/* ************************************************************************** */
/* Determines whether auditing is on or off by looking at the Audit file.
- * If the string AFS_AUDIT_AllEvents is defined in the file, then auditing will be
+ * If the string AFS_AUDIT_AllEvents is defined in the file, then auditing will be
* enabled.
* ************************************************************************** */
-int osi_audit_check ()
+int
+osi_audit_check(void)
{
- FILE *fds;
- int onoff;
- char event[257];
-
- osi_audit_all = 1; /* say we made check (>= 0) */
- /* and assume audit all events (for now) */
- onoff = 0; /* assume we will turn auditing off */
- osi_echo_trail = 0; /* assume no echoing */
-
- fds = fopen(AFSDIR_SERVER_AUDIT_FILEPATH, "r");
- if (fds)
- {
- while ( fscanf(fds, "%256s", event) > 0)
- {
- if ( strcmp(event,"AFS_AUDIT_AllEvents") == 0 )
- onoff = 1;
-
- if ( strcmp(event,"Echo_Trail") == 0 )
- osi_echo_trail = 1;
- }
- fclose(fds);
- }
-
- /* Audit this event all of the time */
- if (onoff) osi_audit("AFS_Aud_On", 0, AUD_END);
- else osi_audit("AFS_Aud_Off", 0, AUD_END);
-
- /* Now set whether we audit all events from here on out */
- osi_audit_all = onoff;
-}
+ FILE *fds;
+ int onoff;
+ char event[257];
+
+ osi_audit_all = 1; /* say we made check (>= 0) */
+ /* and assume audit all events (for now) */
+ onoff = 0; /* assume we will turn auditing off */
+ osi_echo_trail = 0; /* assume no echoing */
+
+ fds = fopen(AFSDIR_SERVER_AUDIT_FILEPATH, "r");
+ if (fds) {
+ while (fscanf(fds, "%256s", event) > 0) {
+ if (strcmp(event, "AFS_AUDIT_AllEvents") == 0)
+ onoff = 1;
+
+ if (strcmp(event, "Echo_Trail") == 0)
+ osi_echo_trail = 1;
+ }
+ fclose(fds);
+ }
+ /* Audit this event all of the time */
+ if (onoff)
+ osi_audit("AFS_Aud_On", 0, AUD_END);
+ else
+ osi_audit("AFS_Aud_Off", 0, AUD_END);
-#else /* ! AFS_AIX_ENV */
+ /* Now set whether we audit all events from here on out */
+ osi_audit_all = onoff;
-int osi_audit (char *audEvent, afs_int32 errCode, ...)
-{ return 0; }
+ return 0;
+}
-int osi_auditU (struct rx_call *call, char *audEvent, int errCode, ...)
-{ return 0; }
+int
+osi_audit_file(const char *fileName)
+{
+ if(!audit_ops->open_file(fileName)) {
+ auditout_open = 1;
+ return 0;
+ }
+ return 1;
+}
-#endif
+int
+osi_audit_interface(const char *interface)
+{
+ int i;
+ for (i = 0; i < N_INTERFACES; ++i) {
+ if (strcmp(interface, audit_interfaces[i].name) == 0) {
+ audit_ops = audit_interfaces[i].ops;
+ return 0;
+ }
+ }
+
+ return 1;
+}
+
+void
+osi_audit_set_user_check(void *rock,
+ int (*islocal) (void *rock, char *name, char *inst,
+ char *cell))
+{
+ audit_user_check.rock = rock;
+ audit_user_check.islocal = islocal;
+}
+void
+audit_PrintStats(FILE *out)
+{
+ audit_ops->print_interface_stats(out);
+}
git://git.openafs.org / openafs.git / blobdiff