#include <afsconfig.h>
#include "afs/param.h"
-RCSID
- ("$Header$");
#include "afs/sysincludes.h" /* Standard vendor system headers */
#include "afsincludes.h" /* Afs-based standard headers */
#ifdef AFS_SGI62_ENV
#include "h/hashing.h"
#endif
-#if !defined(AFS_HPUX110_ENV) && !defined(AFS_DARWIN60_ENV)
+#if !defined(AFS_HPUX110_ENV) && !defined(AFS_DARWIN_ENV)
#include "netinet/in_var.h"
#endif
#endif /* !defined(UKERNEL) */
#ifdef AFS_LINUX22_ENV
#include "h/smp_lock.h"
#endif
+#ifdef AFS_SUN510_ENV
+#include "h/ksynch.h"
+#include "h/sunddi.h"
+#endif
-
-#if defined(AFS_AIX_ENV) || defined(AFS_SGI_ENV) || defined(AFS_SUN_ENV) || defined(AFS_HPUX_ENV)
+#if defined(AFS_SUN5_ENV) || defined(AFS_AIX_ENV) || defined(AFS_SGI_ENV) || defined(AFS_HPUX_ENV)
#define AFS_MINBUFFERS 100
#else
#define AFS_MINBUFFERS 50
#endif
struct afsop_cell {
- afs_int32 hosts[MAXCELLHOSTS];
+ afs_int32 hosts[AFS_MAXCELLHOSTS];
char cellName[100];
};
char afs_zeros[AFS_ZEROS];
char afs_rootVolumeName[64] = "";
-struct afs_icl_set *afs_iclSetp = (struct afs_icl_set *)0;
-struct afs_icl_set *afs_iclLongTermSetp = (struct afs_icl_set *)0;
-
-#if defined(AFS_SUN5_ENV) || defined(AFS_SGI_ENV)
-kmutex_t afs_global_lock;
-kmutex_t afs_rxglobal_lock;
-#endif
-
-#if defined(AFS_SGI_ENV) && !defined(AFS_SGI64_ENV)
-long afs_global_owner;
-#endif
-
-#if defined(AFS_OSF_ENV)
-simple_lock_data_t afs_global_lock;
-#endif
+afs_uint32 rx_bindhost;
-#if defined(AFS_DARWIN_ENV)
-struct lock__bsd__ afs_global_lock;
-#endif
-
-#if defined(AFS_XBSD_ENV)
-struct lock afs_global_lock;
-#ifdef AFS_FBSD50_ENV
-struct thread *afs_global_owner;
-#else
-struct proc *afs_global_owner;
-#endif
-#endif
-
-#if defined(AFS_OSF_ENV) || defined(AFS_DARWIN_ENV)
-thread_t afs_global_owner;
-#endif /* AFS_OSF_ENV */
-
-#if defined(AFS_AIX41_ENV)
-simple_lock_data afs_global_lock;
+#ifdef AFS_SUN510_ENV
+ddi_taskq_t *afs_taskq;
+krwlock_t afsifinfo_lock;
#endif
afs_int32 afs_initState = 0;
extern struct interfaceAddr afs_cb_interface;
static int afs_RX_Running = 0;
static int afs_InitSetup_done = 0;
+afs_int32 afs_numcachefiles = -1;
+afs_int32 afs_numfilesperdir = -1;
+char afs_cachebasedir[1024];
afs_int32 afs_rx_deadtime = AFS_RXDEADTIME;
afs_int32 afs_rx_harddead = AFS_HARDDEADTIME;
+afs_int32 afs_rx_idledead = AFS_IDLEDEADTIME;
-static int
- Afscall_icl(long opcode, long p1, long p2, long p3, long p4, long *retval);
+static int afscall_set_rxpck_received = 0;
#if defined(AFS_HPUX_ENV)
extern int afs_vfs_mount();
static int
afs_InitSetup(int preallocs)
{
- extern void afs_InitStats();
int code;
if (afs_InitSetup_done)
return EAGAIN;
+#ifdef AFS_SUN510_ENV
+ /* Initialize a RW lock for the ifinfo global array */
+ rw_init(&afsifinfo_lock, NULL, RW_DRIVER, NULL);
+
+ /* Create a taskq */
+ afs_taskq = ddi_taskq_create(NULL, "afs_taskq", 2, TASKQ_DEFAULTPRI, 0);
+
+ osi_StartNetIfPoller();
+#endif
+
#ifndef AFS_NOSTATS
/*
* Set up all the AFS statistics variables. This should be done
memset(afs_zeros, 0, AFS_ZEROS);
/* start RX */
+ if(!afscall_set_rxpck_received)
rx_extraPackets = AFS_NRXPACKETS; /* smaller # of packets */
- code = rx_Init(htons(7001));
+ code = rx_InitHost(rx_bindhost, htons(7001));
if (code) {
- printf("AFS: RX failed to initialize.\n");
+ afs_warn("AFS: RX failed to initialize %d).\n", code);
return code;
}
rx_SetRxDeadTime(afs_rx_deadtime);
return code;
}
+#if defined(AFS_DARWIN80_ENV)
+struct afsd_thread_info {
+ unsigned long parm;
+};
+static int
+afsd_thread(int *rock)
+{
+ struct afsd_thread_info *arg = (struct afsd_thread_info *)rock;
+ unsigned long parm = arg->parm;
+
+ switch (parm) {
+ case AFSOP_START_RXCALLBACK:
+ AFS_GLOCK();
+ wakeup(arg);
+ afs_CB_Running = 1;
+ while (afs_RX_Running != 2)
+ afs_osi_Sleep(&afs_RX_Running);
+ afs_RXCallBackServer();
+ AFS_GUNLOCK();
+ thread_terminate(current_thread());
+ break;
+ case AFSOP_START_AFS:
+ AFS_GLOCK();
+ wakeup(arg);
+ AFS_Running = 1;
+ while (afs_initState < AFSOP_START_AFS)
+ afs_osi_Sleep(&afs_initState);
+ afs_initState = AFSOP_START_BKG;
+ afs_osi_Wakeup(&afs_initState);
+ afs_Daemon();
+ AFS_GUNLOCK();
+ thread_terminate(current_thread());
+ break;
+ case AFSOP_START_BKG:
+ afs_warn("Install matching afsd! Old background daemons not supported.\n");
+ thread_terminate(current_thread());
+ break;
+ case AFSOP_START_TRUNCDAEMON:
+ AFS_GLOCK();
+ wakeup(arg);
+ while (afs_initState < AFSOP_GO)
+ afs_osi_Sleep(&afs_initState);
+ afs_CacheTruncateDaemon();
+ AFS_GUNLOCK();
+ thread_terminate(current_thread());
+ break;
+ case AFSOP_START_CS:
+ AFS_GLOCK();
+ wakeup(arg);
+ afs_CheckServerDaemon();
+ AFS_GUNLOCK();
+ thread_terminate(current_thread());
+ break;
+ case AFSOP_RXEVENT_DAEMON:
+ AFS_GLOCK();
+ wakeup(arg);
+ while (afs_initState < AFSOP_START_BKG)
+ afs_osi_Sleep(&afs_initState);
+ afs_rxevent_daemon();
+ AFS_GUNLOCK();
+ thread_terminate(current_thread());
+ break;
+ case AFSOP_RXLISTENER_DAEMON:
+ AFS_GLOCK();
+ wakeup(arg);
+ afs_initState = AFSOP_START_AFS;
+ afs_osi_Wakeup(&afs_initState);
+ afs_RX_Running = 2;
+ afs_osi_Wakeup(&afs_RX_Running);
+ afs_osi_RxkRegister();
+ rxk_Listener();
+ AFS_GUNLOCK();
+ thread_terminate(current_thread());
+ break;
+ default:
+ afs_warn("Unknown op %ld in StartDaemon()\n", (long)parm);
+ break;
+ }
+}
+
+void
+afs_DaemonOp(long parm, long parm2, long parm3, long parm4, long parm5,
+ long parm6)
+{
+ int code;
+ struct afsd_thread_info info;
+ thread_t thread;
+
+ if (parm == AFSOP_START_RXCALLBACK) {
+ if (afs_CB_Running)
+ return;
+ } else if (parm == AFSOP_RXLISTENER_DAEMON) {
+ if (afs_RX_Running)
+ return;
+ afs_RX_Running = 1;
+ code = afs_InitSetup(parm2);
+ if (parm3) {
+ rx_enablePeerRPCStats();
+ }
+ if (parm4) {
+ rx_enableProcessRPCStats();
+ }
+ if (code)
+ return;
+ } else if (parm == AFSOP_START_AFS) {
+ if (AFS_Running)
+ return;
+ } /* other functions don't need setup in the parent */
+ info.parm = parm;
+ kernel_thread_start((thread_continue_t)afsd_thread, &info, &thread);
+ AFS_GUNLOCK();
+ /* we need to wait cause we passed stack pointers around.... */
+ msleep(&info, NULL, PVFS, "afs_DaemonOp", NULL);
+ AFS_GLOCK();
+ thread_deallocate(thread);
+}
+#endif
+
-#if defined(AFS_LINUX24_ENV) && defined(COMPLETION_H_EXISTS)
+#if defined(AFS_LINUX24_ENV) && defined(HAVE_LINUX_COMPLETION_H)
struct afsd_thread_info {
+#if defined(AFS_LINUX26_ENV) && !defined(INIT_WORK_HAS_DATA)
+ struct work_struct tq;
+#endif
unsigned long parm;
struct completion *complete;
};
#ifdef SYS_SETPRIORITY_EXPORTED
int (*sys_setpriority) (int, int, int) = sys_call_table[__NR_setpriority];
#endif
- daemonize(); /* doesn't do much, since we were forked from keventd, but
+#if defined(AFS_LINUX26_ENV)
+ daemonize("afsd");
+#else
+ daemonize();
+#endif
+ /* doesn't do much, since we were forked from keventd, but
* does call mm_release, which wakes up our parent (since it
* used CLONE_VFORK) */
+#if !defined(AFS_LINUX26_ENV)
reparent_to_init();
+#endif
afs_osi_MaskSignals();
switch (parm) {
case AFSOP_START_RXCALLBACK:
complete_and_exit(0, 0);
break;
default:
- printf("Unknown op %d in StartDaemon()\n");
+ afs_warn("Unknown op %ld in StartDaemon()\n", (long)parm);
break;
}
return 0;
}
void
+#if defined(AFS_LINUX26_ENV) && !defined(INIT_WORK_HAS_DATA)
+afsd_launcher(struct work_struct *work)
+#else
afsd_launcher(void *rock)
+#endif
{
- if (!kernel_thread(afsd_thread, rock, CLONE_VFORK | SIGCHLD))
- printf("kernel_thread failed. afs startup will not complete\n");
+#if defined(AFS_LINUX26_ENV) && !defined(INIT_WORK_HAS_DATA)
+ struct afsd_thread_info *rock = container_of(work, struct afsd_thread_info, tq);
+#endif
+
+ if (!kernel_thread(afsd_thread, (void *)rock, CLONE_VFORK | SIGCHLD))
+ afs_warn("kernel_thread failed. afs startup will not complete\n");
}
void
{
int code;
DECLARE_COMPLETION(c);
+#if defined(AFS_LINUX26_ENV)
+#if defined(INIT_WORK_HAS_DATA)
+ struct work_struct tq;
+#endif
+#else
struct tq_struct tq;
+#endif
struct afsd_thread_info info;
if (parm == AFSOP_START_RXCALLBACK) {
if (afs_CB_Running)
} /* other functions don't need setup in the parent */
info.complete = &c;
info.parm = parm;
+#if defined(AFS_LINUX26_ENV)
+#if !defined(INIT_WORK_HAS_DATA)
+ INIT_WORK(&info.tq, afsd_launcher);
+ schedule_work(&info.tq);
+#else
+ INIT_WORK(&tq, afsd_launcher, &info);
+ schedule_work(&tq);
+#endif
+#else
tq.sync = 0;
INIT_LIST_HEAD(&tq.list);
tq.routine = afsd_launcher;
tq.data = &info;
schedule_task(&tq);
+#endif
AFS_GUNLOCK();
/* we need to wait cause we passed stack pointers around.... */
wait_for_completion(&c);
}
#endif
-/* leaving as is, probably will barf if we add prototypes here since it's likely being called
-with partial list */
+#ifdef AFS_DARWIN100_ENV
+#define AFSKPTR(X) k ## X
+int
+afs_syscall_call(long parm, long parm2, long parm3,
+ long parm4, long parm5, long parm6)
+{
+ return afs_syscall64_call(CAST_USER_ADDR_T((parm)),
+ CAST_USER_ADDR_T((parm2)),
+ CAST_USER_ADDR_T((parm3)),
+ CAST_USER_ADDR_T((parm4)),
+ CAST_USER_ADDR_T((parm5)),
+ CAST_USER_ADDR_T((parm6)));
+}
+#else
+#define AFSKPTR(X) ((caddr_t)X)
+#endif
int
-afs_syscall_call(parm, parm2, parm3, parm4, parm5, parm6)
- long parm, parm2, parm3, parm4, parm5, parm6;
+#ifdef AFS_DARWIN100_ENV
+afs_syscall64_call(user_addr_t kparm, user_addr_t kparm2, user_addr_t kparm3,
+ user_addr_t kparm4, user_addr_t kparm5, user_addr_t kparm6)
+#else
+afs_syscall_call(long parm, long parm2, long parm3,
+ long parm4, long parm5, long parm6)
+#endif
{
afs_int32 code = 0;
#if defined(AFS_SGI61_ENV) || defined(AFS_SUN57_ENV) || defined(AFS_DARWIN_ENV) || defined(AFS_XBSD_ENV)
#else /* AFS_SGI61_ENV */
u_int bufferSize;
#endif /* AFS_SGI61_ENV */
+#ifdef AFS_DARWIN100_ENV
+ /* AFSKPTR macro relies on this name format/mapping */
+ afs_uint32 parm = (afs_uint32)kparm;
+ afs_uint32 parm2 = (afs_uint32)kparm2;
+ afs_uint32 parm3 = (afs_uint32)kparm3;
+ afs_uint32 parm4 = (afs_uint32)kparm4;
+ afs_uint32 parm5 = (afs_uint32)kparm5;
+ afs_uint32 parm6 = (afs_uint32)kparm6;
+#endif
AFS_STATCNT(afs_syscall_call);
+ if (
#ifdef AFS_SUN5_ENV
- if (!afs_suser(CRED()) && (parm != AFSOP_GETMTU)
- && (parm != AFSOP_GETMASK)) {
- /* only root can run this code */
- return (EACCES);
+ !afs_suser(CRED())
#else
- if (!afs_suser() && (parm != AFSOP_GETMTU)
- && (parm != AFSOP_GETMASK)) {
+ !afs_suser(NULL)
+#endif
+ && (parm != AFSOP_GETMTU) && (parm != AFSOP_GETMASK)) {
/* only root can run this code */
+#if defined(AFS_SUN5_ENV) || defined(KERNEL_HAVE_UERROR)
#if defined(KERNEL_HAVE_UERROR)
setuerror(EACCES);
- return (EACCES);
+#endif
+ code = EACCES;
#else
-#if defined(AFS_OSF_ENV)
- return EACCES;
-#else /* AFS_OSF_ENV */
- return EPERM;
-#endif /* AFS_OSF_ENV */
+ code = EPERM;
#endif
+ AFS_GLOCK();
+#ifdef AFS_DARWIN80_ENV
+ put_vfs_context();
#endif
+ goto out;
}
AFS_GLOCK();
-#if defined(AFS_LINUX24_ENV) && defined(COMPLETION_H_EXISTS) && !defined(UKERNEL)
+#ifdef AFS_DARWIN80_ENV
+ put_vfs_context();
+#endif
+#if ((defined(AFS_LINUX24_ENV) && defined(HAVE_LINUX_COMPLETION_H)) || defined(AFS_DARWIN80_ENV)) && !defined(UKERNEL)
+#if defined(AFS_DARWIN80_ENV)
+ if (parm == AFSOP_BKG_HANDLER) {
+ /* if afs_uspc_param grows this should be checked */
+ struct afs_uspc_param *mvParam = osi_AllocSmallSpace(AFS_SMALLOCSIZ);
+ void *param2;
+ void *param1;
+ int namebufsz;
+
+ AFS_COPYIN(AFSKPTR(parm2), (caddr_t)mvParam,
+ sizeof(struct afs_uspc_param), code);
+ namebufsz = mvParam->bufSz;
+ param1 = afs_osi_Alloc(namebufsz);
+ param2 = afs_osi_Alloc(namebufsz);
+
+ while (afs_initState < AFSOP_START_BKG)
+ afs_osi_Sleep(&afs_initState);
+ if (afs_initState < AFSOP_GO) {
+ afs_initState = AFSOP_GO;
+ afs_osi_Wakeup(&afs_initState);
+ }
+
+ code = afs_BackgroundDaemon(mvParam, param1, param2);
+
+ if (!code) {
+ mvParam->retval = 0;
+ /* for reqs where pointers are strings: */
+ if (mvParam->reqtype == AFS_USPC_UMV) {
+ /* don't copy out random kernel memory */
+ AFS_COPYOUT(param2, AFSKPTR(parm4),
+ MIN(namebufsz, strlen((char *)param2)+1), code);
+ AFS_COPYOUT(param1, AFSKPTR(parm3),
+ MIN(namebufsz, strlen((char *)param1)+1), code);
+ }
+ AFS_COPYOUT((caddr_t)mvParam, AFSKPTR(parm2),
+ sizeof(struct afs_uspc_param), code);
+ }
+
+ afs_osi_Free(param1, namebufsz);
+ afs_osi_Free(param2, namebufsz);
+ osi_FreeSmallSpace(mvParam);
+ } else
+#endif /* DARWIN80 */
if (parm < AFSOP_ADDCELL || parm == AFSOP_RXEVENT_DAEMON
|| parm == AFSOP_RXLISTENER_DAEMON) {
afs_DaemonOp(parm, parm2, parm3, parm4, parm5, parm6);
#endif /* RXK_LISTENER_ENV */
afs_osi_Invisible();
afs_RXCallBackServer();
+ afs_osi_Visible();
}
#ifdef AFS_SGI_ENV
AFS_GUNLOCK();
afs_osi_RxkRegister();
#endif /* !UKERNEL */
rxk_Listener();
+ afs_osi_Visible();
}
#ifdef AFS_SGI_ENV
AFS_GUNLOCK();
afs_osi_Wakeup(&afs_initState);
afs_osi_Invisible();
afs_Daemon();
+ afs_osi_Visible();
#ifdef AFS_SGI_ENV
AFS_GUNLOCK();
exit(CLD_EXITED, 0);
} else if (parm == AFSOP_START_CS) {
afs_osi_Invisible();
afs_CheckServerDaemon();
+ afs_osi_Visible();
#ifdef AFS_SGI_ENV
AFS_GUNLOCK();
exit(CLD_EXITED, 0);
#endif /* AFS_SGI_ENV */
+#ifndef AFS_DARWIN80_ENV
} else if (parm == AFSOP_START_BKG) {
while (afs_initState < AFSOP_START_BKG)
afs_osi_Sleep(&afs_initState);
}
/* start the bkg daemon */
afs_osi_Invisible();
-#ifdef AFS_AIX32_ENV
+# ifdef AFS_AIX32_ENV
if (parm2)
afs_BioDaemon(parm2);
else
-#endif /* AFS_AIX32_ENV */
+# endif /* AFS_AIX32_ENV */
afs_BackgroundDaemon();
-#ifdef AFS_SGI_ENV
+ afs_osi_Visible();
+# ifdef AFS_SGI_ENV
AFS_GUNLOCK();
exit(CLD_EXITED, 0);
-#endif /* AFS_SGI_ENV */
+# endif /* AFS_SGI_ENV */
+#endif /* ! AFS_DARWIN80_ENV */
} else if (parm == AFSOP_START_TRUNCDAEMON) {
while (afs_initState < AFSOP_GO)
afs_osi_Sleep(&afs_initState);
/* start the bkg daemon */
afs_osi_Invisible();
afs_CacheTruncateDaemon();
+ afs_osi_Visible();
#ifdef AFS_SGI_ENV
AFS_GUNLOCK();
exit(CLD_EXITED, 0);
afs_osi_Sleep(&afs_initState);
afs_osi_Invisible();
afs_rxevent_daemon();
+ afs_osi_Visible();
#ifdef AFS_SGI_ENV
AFS_GUNLOCK();
exit(CLD_EXITED, 0);
while (!afs_InitSetup_done)
afs_osi_Sleep(&afs_InitSetup_done);
-#if defined(AFS_SUN_ENV) || defined(AFS_SGI_ENV) || defined(AFS_HPUX_ENV) || defined(AFS_LINUX20_ENV) || defined(AFS_DARWIN_ENV) || defined(AFS_XBSD_ENV)
+#if defined(AFS_SGI_ENV) || defined(AFS_HPUX_ENV) || defined(AFS_LINUX20_ENV) || defined(AFS_DARWIN_ENV) || defined(AFS_XBSD_ENV) || defined(AFS_SUN5_ENV)
temp = AFS_MINBUFFERS; /* Should fix this soon */
#else
/* number of 2k buffers we could get from all of the buffer space */
DInit(temp);
afs_rootFid.Fid.Volume = 0;
code = 0;
+ } else if (parm == AFSOP_BUCKETPCT) {
+ /* need to enable this now, will disable again before GO
+ if we don't have 100% */
+ splitdcache = 1;
+ switch (parm2) {
+ case 1:
+ afs_tpct1 = parm3;
+ break;
+ case 2:
+ afs_tpct2 = parm3;
+ break;
+ }
} else if (parm == AFSOP_ADDCELL) {
/* add a cell. Parameter 2 is 8 hosts (in net order), parm 3 is the null-terminated
* name. Parameter 4 is the length of the name, including the null. Parm 5 is the
* home cell flag (0x1 bit) and the nosuid flag (0x2 bit) */
struct afsop_cell *tcell = afs_osi_Alloc(sizeof(struct afsop_cell));
- AFS_COPYIN((char *)parm2, (char *)tcell->hosts, sizeof(tcell->hosts),
- code);
+ code = afs_InitDynroot();
+ if (!code) {
+ AFS_COPYIN(AFSKPTR(parm2), (caddr_t)tcell->hosts, sizeof(tcell->hosts),
+ code);
+ }
if (!code) {
if (parm4 > sizeof(tcell->cellName))
code = EFAULT;
else {
- AFS_COPYIN((char *)parm3, tcell->cellName, parm4, code);
+ AFS_COPYIN(AFSKPTR(parm3), (caddr_t)tcell->cellName, parm4, code);
if (!code)
afs_NewCell(tcell->cellName, tcell->hosts, parm5, NULL, 0,
0, 0);
char *tbuffer1 = osi_AllocSmallSpace(AFS_SMALLOCSIZ);
int cflags = parm4;
+ code = afs_InitDynroot();
+ if (!code) {
#if 0
- /* wait for basic init - XXX can't find any reason we need this? */
- while (afs_initState < AFSOP_START_BKG)
- afs_osi_Sleep(&afs_initState);
+ /* wait for basic init - XXX can't find any reason we need this? */
+ while (afs_initState < AFSOP_START_BKG)
+ afs_osi_Sleep(&afs_initState);
#endif
- AFS_COPYIN((char *)parm2, (char *)tcell->hosts, sizeof(tcell->hosts),
- code);
+ AFS_COPYIN(AFSKPTR(parm2), (caddr_t)tcell->hosts, sizeof(tcell->hosts),
+ code);
+ }
if (!code) {
- AFS_COPYINSTR((char *)parm3, tbuffer1, AFS_SMALLOCSIZ,
+ AFS_COPYINSTR(AFSKPTR(parm3), tbuffer1, AFS_SMALLOCSIZ,
&bufferSize, code);
if (!code) {
if (parm4 & 4) {
- AFS_COPYINSTR((char *)parm5, tbuffer, AFS_SMALLOCSIZ,
+ AFS_COPYINSTR(AFSKPTR(parm5), tbuffer, AFS_SMALLOCSIZ,
&bufferSize, code);
if (!code) {
lcnamep = tbuffer;
char *aliasName = osi_AllocSmallSpace(AFS_SMALLOCSIZ);
char *cellName = osi_AllocSmallSpace(AFS_SMALLOCSIZ);
- AFS_COPYINSTR((char *)parm2, aliasName, AFS_SMALLOCSIZ, &bufferSize,
- code);
+ code = afs_InitDynroot();
+ if (!code) {
+ AFS_COPYINSTR(AFSKPTR(parm2), aliasName, AFS_SMALLOCSIZ, &bufferSize,
+ code);
+ }
if (!code)
- AFS_COPYINSTR((char *)parm3, cellName, AFS_SMALLOCSIZ,
+ AFS_COPYINSTR(AFSKPTR(parm3), cellName, AFS_SMALLOCSIZ,
&bufferSize, code);
if (!code)
afs_NewCellAlias(aliasName, cellName);
*/
char *cell = osi_AllocSmallSpace(AFS_SMALLOCSIZ);
- AFS_COPYINSTR((char *)parm2, cell, AFS_SMALLOCSIZ, &bufferSize, code);
+ afs_CellInit();
+ AFS_COPYINSTR(AFSKPTR(parm2), cell, AFS_SMALLOCSIZ, &bufferSize, code);
if (!code)
afs_SetPrimaryCell(cell);
osi_FreeSmallSpace(cell);
+ if (!code) {
+ code = afs_InitDynroot();
+ }
} else if (parm == AFSOP_CACHEINIT) {
struct afs_cacheParams cparms;
if (afs_CacheInit_Done)
goto out;
- AFS_COPYIN((char *)parm2, (caddr_t) & cparms, sizeof(cparms), code);
+ AFS_COPYIN(AFSKPTR(parm2), (caddr_t) & cparms, sizeof(cparms), code);
if (code) {
#if defined(KERNEL_HAVE_UERROR)
setuerror(code);
goto out;
}
afs_CacheInit_Done = 1;
- {
- struct afs_icl_log *logp;
- /* initialize the ICL system */
- code = afs_icl_CreateLog("cmfx", 60 * 1024, &logp);
- if (code == 0)
- code =
- afs_icl_CreateSetWithFlags("cm", logp, NULL,
- ICL_CRSET_FLAG_DEFAULT_OFF,
- &afs_iclSetp);
- code =
- afs_icl_CreateSet("cmlongterm", logp, NULL,
- &afs_iclLongTermSetp);
- }
+ code = afs_icl_InitLogs();
afs_setTime = cparms.setTimeFlag;
code =
afs_CacheInit(cparms.cacheScaches, cparms.cacheFiles,
cparms.cacheBlocks, cparms.cacheDcaches,
cparms.cacheVolumes, cparms.chunkSize,
- cparms.memCacheFlag, cparms.inodes, cparms.users);
+ cparms.memCacheFlag, cparms.inodes, cparms.users,
+ cparms.dynamic_vcaches);
} else if (parm == AFSOP_CACHEINODE) {
ino_t ainode = parm2;
while (afs_initState < AFSOP_START_BKG)
afs_osi_Sleep(&afs_initState);
+#ifdef AFS_DARWIN80_ENV
+ get_vfs_context();
+#endif
/* do it by inode */
#ifdef AFS_SGI62_ENV
ainode = (ainode << 32) | (parm3 & 0xffffffff);
#endif
code = afs_InitCacheFile(NULL, ainode);
+#ifdef AFS_DARWIN80_ENV
+ put_vfs_context();
+#endif
+ } else if (parm == AFSOP_CACHEDIRS) {
+ afs_numfilesperdir = parm2;
+ afs_osi_Wakeup(&afs_initState);
+ } else if (parm == AFSOP_CACHEFILES) {
+ afs_numcachefiles = parm2;
+ afs_osi_Wakeup(&afs_initState);
} else if (parm == AFSOP_ROOTVOLUME) {
/* wait for basic init */
while (afs_initState < AFSOP_START_BKG)
afs_osi_Sleep(&afs_initState);
if (parm2) {
- AFS_COPYINSTR((char *)parm2, afs_rootVolumeName,
+ AFS_COPYINSTR(AFSKPTR(parm2), afs_rootVolumeName,
sizeof(afs_rootVolumeName), &bufferSize, code);
afs_rootVolumeName[sizeof(afs_rootVolumeName) - 1] = 0;
} else
code = 0;
} else if (parm == AFSOP_CACHEFILE || parm == AFSOP_CACHEINFO
- || parm == AFSOP_VOLUMEINFO || parm == AFSOP_AFSLOG
- || parm == AFSOP_CELLINFO) {
+ || parm == AFSOP_VOLUMEINFO || parm == AFSOP_CELLINFO) {
char *tbuffer = osi_AllocSmallSpace(AFS_SMALLOCSIZ);
code = 0;
- AFS_COPYINSTR((char *)parm2, tbuffer, AFS_SMALLOCSIZ, &bufferSize,
+ AFS_COPYINSTR(AFSKPTR(parm2), tbuffer, AFS_SMALLOCSIZ, &bufferSize,
code);
if (code) {
osi_FreeSmallSpace(tbuffer);
if (!code) {
tbuffer[AFS_SMALLOCSIZ - 1] = '\0'; /* null-terminate the name */
/* We have the cache dir copied in. Call the cache init routine */
- if (parm == AFSOP_CACHEFILE)
+#ifdef AFS_DARWIN80_ENV
+ get_vfs_context();
+#endif
+ if (parm == AFSOP_CACHEFILE) {
code = afs_InitCacheFile(tbuffer, 0);
- else if (parm == AFSOP_CACHEINFO)
+ } else if (parm == AFSOP_CACHEINFO) {
code = afs_InitCacheInfo(tbuffer);
- else if (parm == AFSOP_VOLUMEINFO)
+ } else if (parm == AFSOP_VOLUMEINFO) {
code = afs_InitVolumeInfo(tbuffer);
- else if (parm == AFSOP_CELLINFO)
+ } else if (parm == AFSOP_CELLINFO) {
code = afs_InitCellInfo(tbuffer);
+ }
+#ifdef AFS_DARWIN80_ENV
+ put_vfs_context();
+#endif
}
osi_FreeSmallSpace(tbuffer);
} else if (parm == AFSOP_GO) {
afs_osi_Sleep(&afs_initState);
afs_initState = 101;
afs_setTime = parm2;
+ if (afs_tpct1 + afs_tpct2 != 100) {
+ afs_tpct1 = 0;
+ afs_tpct2 = 0;
+ splitdcache = 0;
+ } else {
+ splitdcache = 1;
+ }
afs_osi_Wakeup(&afs_initState);
-#if (!defined(AFS_NONFSTRANS) && !defined(AFS_DEC_ENV)) || defined(AFS_AIX_IAUTH_ENV)
+#if (!defined(AFS_NONFSTRANS)) || defined(AFS_AIX_IAUTH_ENV)
afs_nfsclient_init();
#endif
+ afs_uuid_create(&afs_cb_interface.uuid);
printf("found %d non-empty cache files (%d%%).\n",
afs_stats_cmperf.cacheFilesReused,
(100 * afs_stats_cmperf.cacheFilesReused) /
cacheNumEntries : 1));
} else if (parm == AFSOP_ADVISEADDR) {
/* pass in the host address to the rx package */
+ int rxbind = 0;
+ int refresh = 0;
+
afs_int32 count = parm2;
afs_int32 *buffer =
afs_osi_Alloc(sizeof(afs_int32) * AFS_MAX_INTERFACE_ADDR);
afs_int32 *mtubuffer =
afs_osi_Alloc(sizeof(afs_int32) * AFS_MAX_INTERFACE_ADDR);
int i;
- int code;
+
+ /* This is a refresh */
+ if (count & 0x40000000) {
+ count &= ~0x40000000;
+ /* Can't bind after we start. Fix? */
+ count &= ~0x80000000;
+ refresh = 1;
+ }
+
+ /* Bind, but only if there's only one address configured */
+ if ( count & 0x80000000) {
+ count &= ~0x80000000;
+ if (count == 1)
+ rxbind=1;
+ }
if (count > AFS_MAX_INTERFACE_ADDR) {
code = ENOMEM;
count = AFS_MAX_INTERFACE_ADDR;
}
- AFS_COPYIN((char *)parm3, (char *)buffer, count * sizeof(afs_int32),
+ AFS_COPYIN(AFSKPTR(parm3), (caddr_t)buffer, count * sizeof(afs_int32),
code);
- if (parm4)
- AFS_COPYIN((char *)parm4, (char *)maskbuffer,
+ if (parm4 && !code)
+ AFS_COPYIN(AFSKPTR(parm4), (caddr_t)maskbuffer,
count * sizeof(afs_int32), code);
- if (parm5)
- AFS_COPYIN((char *)parm5, (char *)mtubuffer,
+ if (parm5 && !code)
+ AFS_COPYIN(AFSKPTR(parm5), (caddr_t)mtubuffer,
count * sizeof(afs_int32), code);
- afs_cb_interface.numberOfInterfaces = count;
- for (i = 0; i < count; i++) {
- afs_cb_interface.addr_in[i] = buffer[i];
+ if (!code) {
+ afs_cb_interface.numberOfInterfaces = count;
+ for (i = 0; i < count; i++) {
+ afs_cb_interface.addr_in[i] = buffer[i];
#ifdef AFS_USERSPACE_IP_ADDR
- /* AFS_USERSPACE_IP_ADDR means we have no way of finding the
- * machines IP addresses when in the kernel (the in_ifaddr
- * struct is not available), so we pass the info in at
- * startup. We also pass in the subnetmask and mtu size. The
- * subnetmask is used when setting the rank:
- * afsi_SetServerIPRank(); and the mtu size is used when
- * finding the best mtu size. rxi_FindIfnet() is replaced
- * with rxi_Findcbi().
- */
- afs_cb_interface.subnetmask[i] =
- (parm4 ? maskbuffer[i] : 0xffffffff);
- afs_cb_interface.mtu[i] = (parm5 ? mtubuffer[i] : htonl(1500));
+ /* AFS_USERSPACE_IP_ADDR means we have no way of finding the
+ * machines IP addresses when in the kernel (the in_ifaddr
+ * struct is not available), so we pass the info in at
+ * startup. We also pass in the subnetmask and mtu size. The
+ * subnetmask is used when setting the rank:
+ * afsi_SetServerIPRank(); and the mtu size is used when
+ * finding the best mtu size. rxi_FindIfnet() is replaced
+ * with rxi_Findcbi().
+ */
+ afs_cb_interface.subnetmask[i] =
+ (parm4 ? maskbuffer[i] : 0xffffffff);
+ afs_cb_interface.mtu[i] = (parm5 ? mtubuffer[i] : htonl(1500));
#endif
+ }
+ rxi_setaddr(buffer[0]);
+ if (!refresh) {
+ if (rxbind)
+ rx_bindhost = buffer[0];
+ else
+ rx_bindhost = htonl(INADDR_ANY);
+ }
+ } else {
+ refresh = 0;
}
- afs_uuid_create(&afs_cb_interface.uuid);
- rxi_setaddr(buffer[0]);
+
afs_osi_Free(buffer, sizeof(afs_int32) * AFS_MAX_INTERFACE_ADDR);
afs_osi_Free(maskbuffer, sizeof(afs_int32) * AFS_MAX_INTERFACE_ADDR);
afs_osi_Free(mtubuffer, sizeof(afs_int32) * AFS_MAX_INTERFACE_ADDR);
+
+ if (refresh) {
+ afs_CheckServers(1, NULL); /* check down servers */
+ afs_CheckServers(0, NULL); /* check down servers */
+ }
}
#ifdef AFS_SGI53_ENV
else if (parm == AFSOP_NFSSTATICADDR) {
#endif /* AFS_SGI53_ENV */
else if (parm == AFSOP_SHUTDOWN) {
afs_cold_shutdown = 0;
- if (parm == 1)
+ if (parm2 == 1)
afs_cold_shutdown = 1;
-#ifndef AFS_DARWIN_ENV
if (afs_globalVFS != 0) {
afs_warn("AFS isn't unmounted yet! Call aborted\n");
code = EACCES;
} else
-#endif
afs_shutdown();
} else if (parm == AFSOP_AFS_VFSMOUNT) {
#ifdef AFS_HPUX_ENV
i = rxi_Findcbi(parm2);
mtu = ((i == -1) ? htonl(1500) : afs_cb_interface.mtu[i]);
#else /* AFS_USERSPACE_IP_ADDR */
- struct ifnet *tifnp;
+ rx_ifnet_t tifnp;
tifnp = rxi_FindIfnet(parm2, NULL); /* make iterative */
- mtu = (tifnp ? tifnp->if_mtu : htonl(1500));
+ mtu = (tifnp ? rx_ifnet_mtu(tifnp) : htonl(1500));
#endif /* else AFS_USERSPACE_IP_ADDR */
#endif /* !AFS_SUN5_ENV */
if (!code)
- AFS_COPYOUT((caddr_t) & mtu, (caddr_t) parm3, sizeof(afs_int32),
- code);
+ AFS_COPYOUT((caddr_t) & mtu, AFSKPTR(parm3),
+ sizeof(afs_int32), code);
#ifdef AFS_AIX32_ENV
/* this is disabled for now because I can't figure out how to get access
* to these kernel variables. It's only for supporting user-mode rx
code = -1;
}
#else /* AFS_USERSPACE_IP_ADDR */
- struct ifnet *tifnp;
+ rx_ifnet_t tifnp;
tifnp = rxi_FindIfnet(parm2, &mask); /* make iterative */
if (!tifnp)
#endif /* else AFS_USERSPACE_IP_ADDR */
#endif /* !AFS_SUN5_ENV */
if (!code)
- AFS_COPYOUT((caddr_t) & mask, (caddr_t) parm3, sizeof(afs_int32),
- code);
+ AFS_COPYOUT((caddr_t) & mask, AFSKPTR(parm3),
+ sizeof(afs_int32), code);
}
-#ifdef AFS_AFSDB_ENV
else if (parm == AFSOP_AFSDB_HANDLER) {
int sizeArg = (int)parm4;
int kmsgLen = sizeArg & 0xffff;
char *cellname = afs_osi_Alloc(cellLen);
#ifndef UKERNEL
- afs_osi_MaskSignals();
+ afs_osi_MaskUserLoop();
#endif
- AFS_COPYIN((afs_int32 *) parm2, cellname, cellLen, code);
- AFS_COPYIN((afs_int32 *) parm3, kmsg, kmsgLen, code);
+ AFS_COPYIN(AFSKPTR(parm2), cellname, cellLen, code);
+ AFS_COPYIN(AFSKPTR(parm3), kmsg, kmsgLen, code);
if (!code) {
code = afs_AFSDBHandler(cellname, cellLen, kmsg);
if (*cellname == 1)
}
}
if (!code)
- AFS_COPYOUT(cellname, (char *)parm2, cellLen, code);
+ AFS_COPYOUT(cellname, AFSKPTR(parm2), cellLen, code);
afs_osi_Free(kmsg, kmsgLen);
afs_osi_Free(cellname, cellLen);
}
-#endif
else if (parm == AFSOP_SET_DYNROOT) {
code = afs_SetDynrootEnable(parm2);
} else if (parm == AFSOP_SET_FAKESTAT) {
afs_fakestat_enable = parm2;
code = 0;
- } else
+ } else if (parm == AFSOP_SET_BACKUPTREE) {
+ afs_bkvolpref = parm2;
+ } else if (parm == AFSOP_SET_RXPCK) {
+ rx_extraPackets = parm2;
+ afscall_set_rxpck_received = 1;
+ } else if (parm == AFSOP_SET_RXMAXMTU) {
+ rx_MyMaxSendSize = rx_maxReceiveSizeUser = rx_maxReceiveSize = parm2;
+ } else {
code = EINVAL;
+ }
out:
AFS_GUNLOCK();
#endif
}
-#ifdef AFS_AIX32_ENV
-
-#include "sys/lockl.h"
-
/*
- * syscall - this is the VRMIX system call entry point.
- *
- * NOTE:
- * THIS SHOULD BE CHANGED TO afs_syscall(), but requires
- * all the user-level calls to `syscall' to change.
+ * Initstate in the range 0 < x < 100 are early initialization states.
+ * Initstate of 100 means a AFSOP_START operation has been done. After this,
+ * the cache may be initialized.
+ * Initstate of 101 means a AFSOP_GO operation has been done. This operation
+ * is done after all the cache initialization has been done.
+ * Initstate of 200 means that the volume has been looked up once, possibly
+ * incorrectly.
+ * Initstate of 300 means that the volume has been *successfully* looked up.
*/
-syscall(syscall, p1, p2, p3, p4, p5, p6)
+int
+afs_CheckInit(void)
{
- register rval1 = 0, code;
- register monster;
- int retval = 0;
-#ifndef AFS_AIX41_ENV
- extern lock_t kernel_lock;
- monster = lockl(&kernel_lock, LOCK_SHORT);
-#endif /* !AFS_AIX41_ENV */
-
- AFS_STATCNT(syscall);
- setuerror(0);
- switch (syscall) {
- case AFSCALL_CALL:
- rval1 = afs_syscall_call(p1, p2, p3, p4, p5, p6);
- break;
-
- case AFSCALL_SETPAG:
- AFS_GLOCK();
- rval1 = afs_setpag();
- AFS_GUNLOCK();
- break;
+ register int code = 0;
- case AFSCALL_PIOCTL:
- AFS_GLOCK();
- rval1 = afs_syscall_pioctl(p1, p2, p3, p4);
- AFS_GUNLOCK();
- break;
+ AFS_STATCNT(afs_CheckInit);
+ if (afs_initState <= 100)
+ code = ENXIO; /* never finished init phase */
+ else if (afs_initState == 101) { /* init done, wait for afs_daemon */
+ while (afs_initState < 200)
+ afs_osi_Sleep(&afs_initState);
+ } else if (afs_initState == 200)
+ code = ETIMEDOUT; /* didn't find root volume */
+ return code;
+}
- case AFSCALL_ICREATE:
- rval1 = afs_syscall_icreate(p1, p2, p3, p4, p5, p6);
- break;
+int afs_shuttingdown = 0;
+void
+afs_shutdown(void)
+{
+ extern short afs_brsDaemons;
+ extern afs_int32 afs_CheckServerDaemonStarted;
+ extern struct afs_osi_WaitHandle AFS_WaitHandler, AFS_CSWaitHandler;
+ extern struct osi_file *afs_cacheInodep;
- case AFSCALL_IOPEN:
- rval1 = afs_syscall_iopen(p1, p2, p3);
- break;
+ AFS_STATCNT(afs_shutdown);
+ if (afs_initState == 0) {
+ afs_warn("AFS not initialized - not shutting down\n");
+ return;
+ }
- case AFSCALL_IDEC:
- rval1 = afs_syscall_iincdec(p1, p2, p3, -1);
- break;
-
- case AFSCALL_IINC:
- rval1 = afs_syscall_iincdec(p1, p2, p3, 1);
- break;
-
- case AFSCALL_ICL:
- AFS_GLOCK();
- code = Afscall_icl(p1, p2, p3, p4, p5, &retval);
- AFS_GUNLOCK();
- if (!code)
- rval1 = retval;
- if (!rval1)
- rval1 = code;
- break;
-
- default:
- rval1 = EINVAL;
- setuerror(EINVAL);
- break;
- }
-
- out:
-#ifndef AFS_AIX41_ENV
- if (monster != LOCK_NEST)
- unlockl(&kernel_lock);
-#endif /* !AFS_AIX41_ENV */
- return getuerror()? -1 : rval1;
-}
-
-/*
- * lsetpag - interface to afs_setpag().
- */
-lsetpag()
-{
-
- AFS_STATCNT(lsetpag);
- return syscall(AFSCALL_SETPAG, 0, 0, 0, 0, 0);
-}
-
-/*
- * lpioctl - interface to pioctl()
- */
-lpioctl(path, cmd, cmarg, follow)
- char *path, *cmarg;
-{
-
- AFS_STATCNT(lpioctl);
- return syscall(AFSCALL_PIOCTL, path, cmd, cmarg, follow);
-}
-
-#else /* !AFS_AIX32_ENV */
-
-#if defined(AFS_SGI_ENV)
-struct afsargs {
- sysarg_t syscall;
- sysarg_t parm1;
- sysarg_t parm2;
- sysarg_t parm3;
- sysarg_t parm4;
- sysarg_t parm5;
-};
-
-
-int
-Afs_syscall(struct afsargs *uap, rval_t * rvp)
-{
- int error;
- long retval;
-
- AFS_STATCNT(afs_syscall);
- switch (uap->syscall) {
- case AFSCALL_ICL:
- retval = 0;
- AFS_GLOCK();
- error =
- Afscall_icl(uap->parm1, uap->parm2, uap->parm3, uap->parm4,
- uap->parm5, &retval);
- AFS_GUNLOCK();
- rvp->r_val1 = retval;
- break;
-#ifdef AFS_SGI_XFS_IOPS_ENV
- case AFSCALL_IDEC64:
- error =
- afs_syscall_idec64(uap->parm1, uap->parm2, uap->parm3, uap->parm4,
- uap->parm5);
- break;
- case AFSCALL_IINC64:
- error =
- afs_syscall_iinc64(uap->parm1, uap->parm2, uap->parm3, uap->parm4,
- uap->parm5);
- break;
- case AFSCALL_ILISTINODE64:
- error =
- afs_syscall_ilistinode64(uap->parm1, uap->parm2, uap->parm3,
- uap->parm4, uap->parm5);
- break;
- case AFSCALL_ICREATENAME64:
- error =
- afs_syscall_icreatename64(uap->parm1, uap->parm2, uap->parm3,
- uap->parm4, uap->parm5);
- break;
-#endif
-#ifdef AFS_SGI_VNODE_GLUE
- case AFSCALL_INIT_KERNEL_CONFIG:
- error = afs_init_kernel_config(uap->parm1);
- break;
-#endif
- default:
- error =
- afs_syscall_call(uap->syscall, uap->parm1, uap->parm2, uap->parm3,
- uap->parm4, uap->parm5);
- }
- return error;
-}
-
-#else /* AFS_SGI_ENV */
-
-struct iparam {
- long param1;
- long param2;
- long param3;
- long param4;
-};
-
-struct iparam32 {
- int param1;
- int param2;
- int param3;
- int param4;
-};
-
-
-static void
-iparam32_to_iparam(const struct iparam32 *src, struct iparam *dst)
-{
- dst->param1 = src->param1;
- dst->param2 = src->param2;
- dst->param3 = src->param3;
- dst->param4 = src->param4;
-}
-
-/*
- * If you need to change copyin_iparam(), you may also need to change
- * copyin_afs_ioctl().
- */
-
-static int
-copyin_iparam(caddr_t cmarg, struct iparam *dst)
-{
- int code;
-
-#if defined(AFS_HPUX_64BIT_ENV)
- struct iparam32 dst32;
-
- if (is_32bit(u.u_procp)) { /* is_32bit() in proc_iface.h */
- AFS_COPYIN(cmarg, (caddr_t) & dst32, sizeof dst32, code);
- if (!code)
- iparam32_to_iparam(&dst32, dst);
- return code;
- }
-#endif /* AFS_HPUX_64BIT_ENV */
-
-#if defined(AFS_SUN57_64BIT_ENV)
- struct iparam32 dst32;
-
- if (get_udatamodel() == DATAMODEL_ILP32) {
- AFS_COPYIN(cmarg, (caddr_t) & dst32, sizeof dst32, code);
- if (!code)
- iparam32_to_iparam(&dst32, dst);
- return code;
- }
-#endif /* AFS_SUN57_64BIT_ENV */
-
-#if defined(AFS_LINUX_64BIT_KERNEL) && !defined(AFS_ALPHA_LINUX20_ENV) && !defined(AFS_IA64_LINUX20_ENV)
- struct iparam32 dst32;
-
-#ifdef AFS_SPARC64_LINUX24_ENV
- if (current->thread.flags & SPARC_FLAG_32BIT)
-#elif defined(AFS_SPARC64_LINUX20_ENV)
- if (current->tss.flags & SPARC_FLAG_32BIT)
-#elif defined(AFS_AMD64_LINUX20_ENV)
- if (current->thread.flags & THREAD_IA32)
-#else
-#error Not done for this linux version
-#endif
- {
- AFS_COPYIN(cmarg, (caddr_t) & dst32, sizeof dst32, code);
- if (!code)
- iparam32_to_iparam(&dst32, dst);
- return code;
- }
-#endif /* AFS_LINUX_64BIT_KERNEL */
-
- AFS_COPYIN(cmarg, (caddr_t) dst, sizeof *dst, code);
- return code;
-}
-
-/* Main entry of all afs system calls */
-#ifdef AFS_SUN5_ENV
-extern int afs_sinited;
-
-/** The 32 bit OS expects the members of this structure to be 32 bit
- * quantities and the 64 bit OS expects them as 64 bit quanties. Hence
- * to accomodate both, *long* is used instead of afs_int32
- */
-
-#ifdef AFS_SUN57_ENV
-struct afssysa {
- long syscall;
- long parm1;
- long parm2;
- long parm3;
- long parm4;
- long parm5;
- long parm6;
-};
-#else
-struct afssysa {
- afs_int32 syscall;
- afs_int32 parm1;
- afs_int32 parm2;
- afs_int32 parm3;
- afs_int32 parm4;
- afs_int32 parm5;
- afs_int32 parm6;
-};
-#endif
-
-Afs_syscall(register struct afssysa *uap, rval_t * rvp)
-{
- int *retval = &rvp->r_val1;
-#else /* AFS_SUN5_ENV */
-#if defined(AFS_OSF_ENV) || defined(AFS_DARWIN_ENV) || defined(AFS_XBSD_ENV)
-int
-afs3_syscall(p, args, retval)
-#ifdef AFS_FBSD50_ENV
- struct thread *p;
-#else
- struct proc *p;
-#endif
- void *args;
- int *retval;
-{
- register struct a {
- long syscall;
- long parm1;
- long parm2;
- long parm3;
- long parm4;
- long parm5;
- long parm6;
- } *uap = (struct a *)args;
-#else /* AFS_OSF_ENV */
-#ifdef AFS_LINUX20_ENV
-struct afssysargs {
- long syscall;
- long parm1;
- long parm2;
- long parm3;
- long parm4;
- long parm5;
- long parm6; /* not actually used - should be removed */
-};
-/* Linux system calls only set up for 5 arguments. */
-asmlinkage long
-afs_syscall(long syscall, long parm1, long parm2, long parm3, long parm4)
-{
- struct afssysargs args, *uap = &args;
- long linux_ret = 0;
- long *retval = &linux_ret;
- long eparm[4]; /* matches AFSCALL_ICL in fstrace.c */
-#ifdef AFS_SPARC64_LINUX24_ENV
- afs_int32 eparm32[4];
-#endif
- /* eparm is also used by AFSCALL_CALL in afsd.c */
-#else
-#if defined(UKERNEL)
-Afs_syscall()
-{
- register struct a {
- long syscall;
- long parm1;
- long parm2;
- long parm3;
- long parm4;
- long parm5;
- long parm6;
- } *uap = (struct a *)u.u_ap;
-#else /* UKERNEL */
-int
-#if defined(AFS_SUN_ENV) && !defined(AFS_SUN5_ENV)
-afs_syscall()
-#else
-Afs_syscall()
-#endif /* SUN && !SUN5 */
-{
- register struct a {
- long syscall;
- long parm1;
- long parm2;
- long parm3;
- long parm4;
- long parm5;
- long parm6;
- } *uap = (struct a *)u.u_ap;
-#endif /* UKERNEL */
-#if defined(AFS_DEC_ENV)
- int *retval = &u.u_r.r_val1;
-#elif defined(AFS_HPUX_ENV)
- long *retval = &u.u_rval1;
-#else
- int *retval = &u.u_rval1;
-#endif
-#endif /* AFS_LINUX20_ENV */
-#endif /* AFS_OSF_ENV */
-#endif /* AFS_SUN5_ENV */
- register int code = 0;
-
- AFS_STATCNT(afs_syscall);
-#ifdef AFS_SUN5_ENV
- rvp->r_vals = 0;
- if (!afs_sinited) {
- return (ENODEV);
- }
-#endif
-#ifdef AFS_LINUX20_ENV
- lock_kernel();
- /* setup uap for use below - pull out the magic decoder ring to know
- * which syscalls have folded argument lists.
- */
- uap->syscall = syscall;
- uap->parm1 = parm1;
- uap->parm2 = parm2;
- uap->parm3 = parm3;
- if (syscall == AFSCALL_ICL || syscall == AFSCALL_CALL) {
-#ifdef AFS_SPARC64_LINUX24_ENV
-/* from arch/sparc64/kernel/sys_sparc32.c */
-#define AA(__x) \
-({ unsigned long __ret; \
- __asm__ ("srl %0, 0, %0" \
- : "=r" (__ret) \
- : "0" (__x)); \
- __ret; \
-})
-
-
- if (current->thread.flags & SPARC_FLAG_32BIT) {
- AFS_COPYIN((char *)parm4, (char *)eparm32, sizeof(eparm32), code);
- eparm[0] = AA(eparm32[0]);
- eparm[1] = AA(eparm32[1]);
- eparm[2] = AA(eparm32[2]);
-#undef AA
- } else
-#endif
- AFS_COPYIN((char *)parm4, (char *)eparm, sizeof(eparm), code);
- uap->parm4 = eparm[0];
- uap->parm5 = eparm[1];
- uap->parm6 = eparm[2];
- } else {
- uap->parm4 = parm4;
- uap->parm5 = 0;
- uap->parm6 = 0;
- }
-#endif
-
-#if defined(AFS_HPUX_ENV)
- /*
- * There used to be code here (duplicated from osi_Init()) for
- * initializing the semaphore used by AFS_GLOCK(). Was the
- * duplication to handle the case of a dynamically loaded kernel
- * module?
- */
- osi_InitGlock();
-#endif
- if (uap->syscall == AFSCALL_CALL) {
-#ifdef AFS_SUN5_ENV
- code =
- afs_syscall_call(uap->parm1, uap->parm2, uap->parm3, uap->parm4,
- uap->parm5, uap->parm6, rvp, CRED());
-#else
- code =
- afs_syscall_call(uap->parm1, uap->parm2, uap->parm3, uap->parm4,
- uap->parm5, uap->parm6);
-#endif
- } else if (uap->syscall == AFSCALL_SETPAG) {
-#ifdef AFS_SUN5_ENV
- register proc_t *procp;
-
- procp = ttoproc(curthread);
- AFS_GLOCK();
- code = afs_setpag(&procp->p_cred);
- AFS_GUNLOCK();
-#else
- AFS_GLOCK();
-#if defined(AFS_OSF_ENV) || defined(AFS_DARWIN_ENV) || defined(AFS_XBSD_ENV)
- code = afs_setpag(p, args, retval);
-#else /* AFS_OSF_ENV */
- code = afs_setpag();
-#endif
- AFS_GUNLOCK();
-#endif
- } else if (uap->syscall == AFSCALL_PIOCTL) {
- AFS_GLOCK();
-#if defined(AFS_SUN5_ENV)
- code =
- afs_syscall_pioctl(uap->parm1, uap->parm2, uap->parm3, uap->parm4,
- rvp, CRED());
-#elif defined(AFS_FBSD50_ENV)
- code =
- afs_syscall_pioctl(uap->parm1, uap->parm2, uap->parm3, uap->parm4,
- p->td_ucred);
-#elif defined(AFS_DARWIN_ENV) || defined(AFS_XBSD_ENV)
- code =
- afs_syscall_pioctl(uap->parm1, uap->parm2, uap->parm3, uap->parm4,
- p->p_cred->pc_ucred);
-#else
- code =
- afs_syscall_pioctl(uap->parm1, uap->parm2, uap->parm3,
- uap->parm4);
-#endif
- AFS_GUNLOCK();
- } else if (uap->syscall == AFSCALL_ICREATE) {
- struct iparam iparams;
-
- code = copyin_iparam((char *)uap->parm3, &iparams);
- if (code) {
-#if defined(KERNEL_HAVE_UERROR)
- setuerror(code);
-#endif
- } else
-#ifdef AFS_SUN5_ENV
- code =
- afs_syscall_icreate(uap->parm1, uap->parm2, iparams.param1,
- iparams.param2, iparams.param3,
- iparams.param4, rvp, CRED());
-#else
- code =
- afs_syscall_icreate(uap->parm1, uap->parm2, iparams.param1,
- iparams.param2,
-#if defined(AFS_OSF_ENV) || defined(AFS_DARWIN_ENV) || defined(AFS_XBSD_ENV)
- iparams.param3, iparams.param4, retval);
-#else
- iparams.param3, iparams.param4);
-#endif
-#endif /* AFS_SUN5_ENV */
- } else if (uap->syscall == AFSCALL_IOPEN) {
-#ifdef AFS_SUN5_ENV
- code =
- afs_syscall_iopen(uap->parm1, uap->parm2, uap->parm3, rvp,
- CRED());
-#else
-#if defined(AFS_OSF_ENV) || defined(AFS_DARWIN_ENV) || defined(AFS_XBSD_ENV)
- code = afs_syscall_iopen(uap->parm1, uap->parm2, uap->parm3, retval);
-#else
- code = afs_syscall_iopen(uap->parm1, uap->parm2, uap->parm3);
-#endif
-#endif /* AFS_SUN5_ENV */
- } else if (uap->syscall == AFSCALL_IDEC) {
-#ifdef AFS_SUN5_ENV
- code =
- afs_syscall_iincdec(uap->parm1, uap->parm2, uap->parm3, -1, rvp,
- CRED());
-#else
- code = afs_syscall_iincdec(uap->parm1, uap->parm2, uap->parm3, -1);
-#endif /* AFS_SUN5_ENV */
- } else if (uap->syscall == AFSCALL_IINC) {
-#ifdef AFS_SUN5_ENV
- code =
- afs_syscall_iincdec(uap->parm1, uap->parm2, uap->parm3, 1, rvp,
- CRED());
-#else
- code = afs_syscall_iincdec(uap->parm1, uap->parm2, uap->parm3, 1);
-#endif /* AFS_SUN5_ENV */
- } else if (uap->syscall == AFSCALL_ICL) {
- AFS_GLOCK();
- code =
- Afscall_icl(uap->parm1, uap->parm2, uap->parm3, uap->parm4,
- uap->parm5, retval);
- AFS_GUNLOCK();
-#ifdef AFS_LINUX20_ENV
- if (!code) {
- /* ICL commands can return values. */
- code = -linux_ret; /* Gets negated again at exit below */
- }
-#else
- if (code) {
-#if defined(KERNEL_HAVE_UERROR)
- setuerror(code);
-#endif
- }
-#endif /* !AFS_LINUX20_ENV */
- } else {
-#if defined(KERNEL_HAVE_UERROR)
- setuerror(EINVAL);
-#else
- code = EINVAL;
-#endif
- }
-
-#ifdef AFS_LINUX20_ENV
- code = -code;
- unlock_kernel();
-#endif
- return code;
-}
-#endif /* AFS_SGI_ENV */
-#endif /* !AFS_AIX32_ENV */
-
-/*
- * Initstate in the range 0 < x < 100 are early initialization states.
- * Initstate of 100 means a AFSOP_START operation has been done. After this,
- * the cache may be initialized.
- * Initstate of 101 means a AFSOP_GO operation has been done. This operation
- * is done after all the cache initialization has been done.
- * Initstate of 200 means that the volume has been looked up once, possibly
- * incorrectly.
- * Initstate of 300 means that the volume has been *successfully* looked up.
- */
-int
-afs_CheckInit(void)
-{
- register int code = 0;
-
- AFS_STATCNT(afs_CheckInit);
- if (afs_initState <= 100)
- code = ENXIO; /* never finished init phase */
- else if (afs_initState == 101) { /* init done, wait for afs_daemon */
- while (afs_initState < 200)
- afs_osi_Sleep(&afs_initState);
- } else if (afs_initState == 200)
- code = ETIMEDOUT; /* didn't find root volume */
- return code;
-}
-
-int afs_shuttingdown = 0;
-void
-afs_shutdown(void)
-{
- extern short afs_brsDaemons;
- extern afs_int32 afs_CheckServerDaemonStarted;
- extern struct afs_osi_WaitHandle AFS_WaitHandler, AFS_CSWaitHandler;
- extern struct osi_file *afs_cacheInodep;
-
- AFS_STATCNT(afs_shutdown);
- if (afs_shuttingdown)
- return;
- afs_shuttingdown = 1;
- if (afs_cold_shutdown)
- afs_warn("COLD ");
- else
- afs_warn("WARM ");
- afs_warn("shutting down of: CB... ");
+ if (afs_shuttingdown)
+ return;
+ afs_shuttingdown = 1;
+ if (afs_cold_shutdown)
+ afs_warn("afs: COLD ");
+ else
+ afs_warn("afs: WARM ");
+ afs_warn("shutting down of: CB... ");
afs_termState = AFSOP_STOP_RXCALLBACK;
rx_WakeupServerProcs();
- /* shutdown_rxkernel(); */
+#ifdef AFS_AIX51_ENV
+ shutdown_rxkernel();
+#endif
+ /* close rx server connections here? */
while (afs_termState == AFSOP_STOP_RXCALLBACK)
afs_osi_Sleep(&afs_termState);
afs_osi_Wakeup((char *)&afs_CacheTruncateDaemon);
afs_osi_Sleep(&afs_termState);
}
-#ifdef AFS_AFSDB_ENV
afs_warn("AFSDB... ");
afs_StopAFSDB();
while (afs_termState == AFSOP_STOP_AFSDB)
afs_osi_Sleep(&afs_termState);
-#endif
#if defined(AFS_SUN5_ENV) || defined(RXK_LISTENER_ENV)
afs_warn("RxEvent... ");
/* cancel rx event daemon */
afs_osi_Sleep(&afs_termState);
}
#endif
-#else
- afs_termState = AFSOP_STOP_COMPLETE;
#endif
- afs_warn("\n");
- /* Close file only after daemons which can write to it are stopped. */
- if (afs_cacheInodep) { /* memcache won't set this */
- osi_UFSClose(afs_cacheInodep); /* Since we always leave it open */
- afs_cacheInodep = 0;
- }
- return; /* Just kill daemons for now */
-#ifdef notdef
+#ifdef AFS_SUN510_ENV
+ afs_warn("NetIfPoller... ");
+ osi_StopNetIfPoller();
+#endif
+
+ afs_termState = AFSOP_STOP_COMPLETE;
+
+#ifdef AFS_AIX51_ENV
+ shutdown_daemons();
+#endif
shutdown_CB();
- shutdown_AFS();
- shutdown_rxkernel();
- shutdown_rxevent();
- shutdown_rx();
- afs_shutdown_BKG();
shutdown_bufferpackage();
- shutdown_daemons();
shutdown_cache();
shutdown_osi();
+ /*
+ * Close file only after daemons which can write to it are stopped.
+ * Need to close before the osinet shutdown to avoid failing check
+ * for dangling memory allocations.
+ */
+ if (afs_cacheInodep) { /* memcache won't set this */
+ osi_UFSClose(afs_cacheInodep); /* Since we always leave it open */
+ afs_cacheInodep = 0;
+ }
+ /*
+ * Shutdown the ICL logs - needed to free allocated memory space and avoid
+ * warnings from shutdown_osinet
+ */
+ shutdown_icl();
shutdown_osinet();
shutdown_osifile();
shutdown_vnodeops();
- shutdown_vfsops();
- shutdown_exporter();
shutdown_memcache();
-#if !defined(AFS_NONFSTRANS) || defined(AFS_AIX_IAUTH_ENV)
-#if !defined(AFS_DEC_ENV) && !defined(AFS_OSF_ENV)
- /* this routine does not exist in Ultrix systems... 93.01.19 */
+ shutdown_xscache();
+#if (!defined(AFS_NONFSTRANS) || defined(AFS_AIX_IAUTH_ENV))
+ shutdown_exporter();
shutdown_nfsclnt();
-#endif /* AFS_DEC_ENV */
#endif
shutdown_afstest();
+ shutdown_AFS();
/* The following hold the cm stats */
-/*
memset(&afs_cmstats, 0, sizeof(struct afs_CMStats));
memset(&afs_stats_cmperf, 0, sizeof(struct afs_stats_CMPerf));
memset(&afs_stats_cmfullperf, 0, sizeof(struct afs_stats_CMFullPerf));
-*/
- afs_warn(" ALL allocated tables\n");
+ afs_warn(" ALL allocated tables... ");
+
afs_shuttingdown = 0;
-#endif
+ afs_warn("done\n");
+
+ return; /* Just kill daemons for now */
}
void
*afs_rootVolumeName = 0;
}
}
-
-
-/* In case there is a bunch of dynamically build bkg daemons to free */
-void
-afs_shutdown_BKG(void)
-{
- AFS_STATCNT(shutdown_BKG);
-}
-
-
-#if defined(AFS_ALPHA_ENV) || defined(AFS_SGI61_ENV)
-/* For SGI 6.2, this can is changed to 1 if it's a 32 bit kernel. */
-#if defined(AFS_SGI62_ENV) && defined(KERNEL) && !defined(_K64U64)
-int afs_icl_sizeofLong = 1;
-#else
-int afs_icl_sizeofLong = 2;
-#endif /* SGI62 */
-#else
-#if defined(AFS_AIX51_ENV) && defined(AFS_64BIT_KERNEL)
-int afs_icl_sizeofLong = 2;
-#else
-int afs_icl_sizeofLong = 1;
-#endif
-#endif
-
-int afs_icl_inited = 0;
-
-/* init function, called once, under afs_icl_lock */
-int
-afs_icl_Init(void)
-{
- afs_icl_inited = 1;
- return 0;
-}
-
-extern struct afs_icl_log *afs_icl_FindLog();
-extern struct afs_icl_set *afs_icl_FindSet();
-
-
-static int
-Afscall_icl(long opcode, long p1, long p2, long p3, long p4, long *retval)
-{
- afs_int32 *lp, elts, flags;
- register afs_int32 code;
- struct afs_icl_log *logp;
- struct afs_icl_set *setp;
-#if defined(AFS_SGI61_ENV) || defined(AFS_SUN57_ENV) || defined(AFS_DARWIN_ENV) || defined(AFS_XBSD_ENV)
- size_t temp;
-#else /* AFS_SGI61_ENV */
-#if defined(AFS_AIX51_ENV) && defined(AFS_64BIT_KERNEL)
- afs_uint64 temp;
-#else
- afs_uint32 temp;
-#endif
-#endif /* AFS_SGI61_ENV */
- char tname[65];
- afs_int32 startCookie;
- afs_int32 allocated;
- struct afs_icl_log *tlp;
-
-#ifdef AFS_SUN5_ENV
- if (!afs_suser(CRED())) { /* only root can run this code */
- return (EACCES);
- }
-#else
- if (!afs_suser()) { /* only root can run this code */
-#if defined(KERNEL_HAVE_UERROR)
- setuerror(EACCES);
- return EACCES;
-#else
- return EPERM;
-#endif
- }
-#endif
- switch (opcode) {
- case ICL_OP_COPYOUTCLR: /* copy out data then clear */
- case ICL_OP_COPYOUT: /* copy ouy data */
- /* copyout: p1=logname, p2=&buffer, p3=size(words), p4=&cookie
- * return flags<<24 + nwords.
- * updates cookie to updated start (not end) if we had to
- * skip some records.
- */
- AFS_COPYINSTR((char *)p1, tname, sizeof(tname), &temp, code);
- if (code)
- return code;
- AFS_COPYIN((char *)p4, (char *)&startCookie, sizeof(afs_int32), code);
- if (code)
- return code;
- logp = afs_icl_FindLog(tname);
- if (!logp)
- return ENOENT;
-#define BUFFERSIZE AFS_LRALLOCSIZ
- lp = (afs_int32 *) osi_AllocLargeSpace(AFS_LRALLOCSIZ);
- elts = BUFFERSIZE / sizeof(afs_int32);
- if (p3 < elts)
- elts = p3;
- flags = (opcode == ICL_OP_COPYOUT) ? 0 : ICL_COPYOUTF_CLRAFTERREAD;
- code =
- afs_icl_CopyOut(logp, lp, &elts, (afs_uint32 *) & startCookie,
- &flags);
- if (code) {
- osi_FreeLargeSpace((struct osi_buffer *)lp);
- break;
- }
- AFS_COPYOUT((char *)lp, (char *)p2, elts * sizeof(afs_int32), code);
- if (code)
- goto done;
- AFS_COPYOUT((char *)&startCookie, (char *)p4, sizeof(afs_int32),
- code);
- if (code)
- goto done;
-#if defined(AFS_AIX51_ENV) && defined(AFS_64BIT_KERNEL)
- if (!(IS64U))
- *retval = ((long)((flags << 24) | (elts & 0xffffff))) << 32;
- else
-#endif
- *retval = (flags << 24) | (elts & 0xffffff);
- done:
- afs_icl_LogRele(logp);
- osi_FreeLargeSpace((struct osi_buffer *)lp);
- break;
-
- case ICL_OP_ENUMLOGS: /* enumerate logs */
- /* enumerate logs: p1=index, p2=&name, p3=sizeof(name), p4=&size.
- * return 0 for success, otherwise error.
- */
- for (tlp = afs_icl_allLogs; tlp; tlp = tlp->nextp) {
- if (p1-- == 0)
- break;
- }
- if (!tlp)
- return ENOENT; /* past the end of file */
- temp = strlen(tlp->name) + 1;
- if (temp > p3)
- return EINVAL;
- AFS_COPYOUT(tlp->name, (char *)p2, temp, code);
- if (!code) /* copy out size of log */
- AFS_COPYOUT((char *)&tlp->logSize, (char *)p4, sizeof(afs_int32),
- code);
- break;
-
- case ICL_OP_ENUMLOGSBYSET: /* enumerate logs by set name */
- /* enumerate logs: p1=setname, p2=index, p3=&name, p4=sizeof(name).
- * return 0 for success, otherwise error.
- */
- AFS_COPYINSTR((char *)p1, tname, sizeof(tname), &temp, code);
- if (code)
- return code;
- setp = afs_icl_FindSet(tname);
- if (!setp)
- return ENOENT;
- if (p2 > ICL_LOGSPERSET)
- return EINVAL;
- if (!(tlp = setp->logs[p2]))
- return EBADF;
- temp = strlen(tlp->name) + 1;
- if (temp > p4)
- return EINVAL;
- AFS_COPYOUT(tlp->name, (char *)p3, temp, code);
- break;
-
- case ICL_OP_CLRLOG: /* clear specified log */
- /* zero out the specified log: p1=logname */
- AFS_COPYINSTR((char *)p1, tname, sizeof(tname), &temp, code);
- if (code)
- return code;
- logp = afs_icl_FindLog(tname);
- if (!logp)
- return ENOENT;
- code = afs_icl_ZeroLog(logp);
- afs_icl_LogRele(logp);
- break;
-
- case ICL_OP_CLRSET: /* clear specified set */
- /* zero out the specified set: p1=setname */
- AFS_COPYINSTR((char *)p1, tname, sizeof(tname), &temp, code);
- if (code)
- return code;
- setp = afs_icl_FindSet(tname);
- if (!setp)
- return ENOENT;
- code = afs_icl_ZeroSet(setp);
- afs_icl_SetRele(setp);
- break;
-
- case ICL_OP_CLRALL: /* clear all logs */
- /* zero out all logs -- no args */
- code = 0;
- ObtainWriteLock(&afs_icl_lock, 178);
- for (tlp = afs_icl_allLogs; tlp; tlp = tlp->nextp) {
- tlp->refCount++; /* hold this guy */
- ReleaseWriteLock(&afs_icl_lock);
- /* don't clear persistent logs */
- if ((tlp->states & ICL_LOGF_PERSISTENT) == 0)
- code = afs_icl_ZeroLog(tlp);
- ObtainWriteLock(&afs_icl_lock, 179);
- if (--tlp->refCount == 0)
- afs_icl_ZapLog(tlp);
- if (code)
- break;
- }
- ReleaseWriteLock(&afs_icl_lock);
- break;
-
- case ICL_OP_ENUMSETS: /* enumerate all sets */
- /* enumerate sets: p1=index, p2=&name, p3=sizeof(name), p4=&states.
- * return 0 for success, otherwise error.
- */
- for (setp = afs_icl_allSets; setp; setp = setp->nextp) {
- if (p1-- == 0)
- break;
- }
- if (!setp)
- return ENOENT; /* past the end of file */
- temp = strlen(setp->name) + 1;
- if (temp > p3)
- return EINVAL;
- AFS_COPYOUT(setp->name, (char *)p2, temp, code);
- if (!code) /* copy out size of log */
- AFS_COPYOUT((char *)&setp->states, (char *)p4, sizeof(afs_int32),
- code);
- break;
-
- case ICL_OP_SETSTAT: /* set status on a set */
- /* activate the specified set: p1=setname, p2=op */
- AFS_COPYINSTR((char *)p1, tname, sizeof(tname), &temp, code);
- if (code)
- return code;
- setp = afs_icl_FindSet(tname);
- if (!setp)
- return ENOENT;
- code = afs_icl_SetSetStat(setp, p2);
- afs_icl_SetRele(setp);
- break;
-
- case ICL_OP_SETSTATALL: /* set status on all sets */
- /* activate the specified set: p1=op */
- code = 0;
- ObtainWriteLock(&afs_icl_lock, 180);
- for (setp = afs_icl_allSets; setp; setp = setp->nextp) {
- setp->refCount++; /* hold this guy */
- ReleaseWriteLock(&afs_icl_lock);
- /* don't set states on persistent sets */
- if ((setp->states & ICL_SETF_PERSISTENT) == 0)
- code = afs_icl_SetSetStat(setp, p1);
- ObtainWriteLock(&afs_icl_lock, 181);
- if (--setp->refCount == 0)
- afs_icl_ZapSet(setp);
- if (code)
- break;
- }
- ReleaseWriteLock(&afs_icl_lock);
- break;
-
- case ICL_OP_SETLOGSIZE: /* set size of log */
- /* set the size of the specified log: p1=logname, p2=size (in words) */
- AFS_COPYINSTR((char *)p1, tname, sizeof(tname), &temp, code);
- if (code)
- return code;
- logp = afs_icl_FindLog(tname);
- if (!logp)
- return ENOENT;
- code = afs_icl_LogSetSize(logp, p2);
- afs_icl_LogRele(logp);
- break;
-
- case ICL_OP_GETLOGINFO: /* get size of log */
- /* zero out the specified log: p1=logname, p2=&logSize, p3=&allocated */
- AFS_COPYINSTR((char *)p1, tname, sizeof(tname), &temp, code);
- if (code)
- return code;
- logp = afs_icl_FindLog(tname);
- if (!logp)
- return ENOENT;
- allocated = !!logp->datap;
- AFS_COPYOUT((char *)&logp->logSize, (char *)p2, sizeof(afs_int32),
- code);
- if (!code)
- AFS_COPYOUT((char *)&allocated, (char *)p3, sizeof(afs_int32),
- code);
- afs_icl_LogRele(logp);
- break;
-
- case ICL_OP_GETSETINFO: /* get state of set */
- /* zero out the specified set: p1=setname, p2=&state */
- AFS_COPYINSTR((char *)p1, tname, sizeof(tname), &temp, code);
- if (code)
- return code;
- setp = afs_icl_FindSet(tname);
- if (!setp)
- return ENOENT;
- AFS_COPYOUT((char *)&setp->states, (char *)p2, sizeof(afs_int32),
- code);
- afs_icl_SetRele(setp);
- break;
-
- default:
- code = EINVAL;
- }
-
- return code;
-}
-
-
-afs_lock_t afs_icl_lock;
-
-/* exported routine: a 4 parameter event */
-int
-afs_icl_Event4(register struct afs_icl_set *setp, afs_int32 eventID,
- afs_int32 lAndT, long p1, long p2, long p3, long p4)
-{
- afs_int32 mask;
- register int i;
- register afs_int32 tmask;
- int ix;
-
- /* If things aren't init'ed yet (or the set is inactive), don't panic */
- if (!ICL_SETACTIVE(setp))
- return 0;
-
- AFS_ASSERT_GLOCK();
- mask = lAndT >> 24 & 0xff; /* mask of which logs to log to */
- ix = ICL_EVENTBYTE(eventID);
- ObtainReadLock(&setp->lock);
- if (setp->eventFlags[ix] & ICL_EVENTMASK(eventID)) {
- for (i = 0, tmask = 1; i < ICL_LOGSPERSET; i++, tmask <<= 1) {
- if (mask & tmask) {
- afs_icl_AppendRecord(setp->logs[i], eventID, lAndT & 0xffffff,
- p1, p2, p3, p4);
- }
- mask &= ~tmask;
- if (mask == 0)
- break; /* break early */
- }
- }
- ReleaseReadLock(&setp->lock);
- return 0;
-}
-
-/* Next 4 routines should be implemented via var-args or something.
- * Whole purpose is to avoid compiler warnings about parameter # mismatches.
- * Otherwise, could call afs_icl_Event4 directly.
- */
-int
-afs_icl_Event3(register struct afs_icl_set *setp, afs_int32 eventID,
- afs_int32 lAndT, long p1, long p2, long p3)
-{
- return afs_icl_Event4(setp, eventID, lAndT, p1, p2, p3, (long)0);
-}
-
-int
-afs_icl_Event2(register struct afs_icl_set *setp, afs_int32 eventID,
- afs_int32 lAndT, long p1, long p2)
-{
- return afs_icl_Event4(setp, eventID, lAndT, p1, p2, (long)0, (long)0);
-}
-
-int
-afs_icl_Event1(register struct afs_icl_set *setp, afs_int32 eventID,
- afs_int32 lAndT, long p1)
-{
- return afs_icl_Event4(setp, eventID, lAndT, p1, (long)0, (long)0,
- (long)0);
-}
-
-int
-afs_icl_Event0(register struct afs_icl_set *setp, afs_int32 eventID,
- afs_int32 lAndT)
-{
- return afs_icl_Event4(setp, eventID, lAndT, (long)0, (long)0, (long)0,
- (long)0);
-}
-
-struct afs_icl_log *afs_icl_allLogs = 0;
-
-/* function to purge records from the start of the log, until there
- * is at least minSpace long's worth of space available without
- * making the head and the tail point to the same word.
- *
- * Log must be write-locked.
- */
-static void
-afs_icl_GetLogSpace(register struct afs_icl_log *logp, afs_int32 minSpace)
-{
- register unsigned int tsize;
-
- while (logp->logSize - logp->logElements <= minSpace) {
- /* eat a record */
- tsize = ((logp->datap[logp->firstUsed]) >> 24) & 0xff;
- logp->logElements -= tsize;
- logp->firstUsed += tsize;
- if (logp->firstUsed >= logp->logSize)
- logp->firstUsed -= logp->logSize;
- logp->baseCookie += tsize;
- }
-}
-
-/* append string astr to buffer, including terminating null char.
- *
- * log must be write-locked.
- */
-#define ICL_CHARSPERLONG 4
-static void
-afs_icl_AppendString(struct afs_icl_log *logp, char *astr)
-{
- char *op; /* ptr to char to write */
- int tc;
- register int bib; /* bytes in buffer */
-
- bib = 0;
- op = (char *)&(logp->datap[logp->firstFree]);
- while (1) {
- tc = *astr++;
- *op++ = tc;
- if (++bib >= ICL_CHARSPERLONG) {
- /* new word */
- bib = 0;
- if (++(logp->firstFree) >= logp->logSize) {
- logp->firstFree = 0;
- op = (char *)&(logp->datap[0]);
- }
- logp->logElements++;
- }
- if (tc == 0)
- break;
- }
- if (bib > 0) {
- /* if we've used this word at all, allocate it */
- if (++(logp->firstFree) >= logp->logSize) {
- logp->firstFree = 0;
- }
- logp->logElements++;
- }
-}
-
-/* add a long to the log, ignoring overflow (checked already) */
-#define ICL_APPENDINT32(lp, x) \
- MACRO_BEGIN \
- (lp)->datap[(lp)->firstFree] = (x); \
- if (++((lp)->firstFree) >= (lp)->logSize) { \
- (lp)->firstFree = 0; \
- } \
- (lp)->logElements++; \
- MACRO_END
-
-#if defined(AFS_ALPHA_ENV) || (defined(AFS_SGI61_ENV) && (_MIPS_SZLONG==64)) || (defined(AFS_AIX51_ENV) && defined(AFS_64BIT_KERNEL))
-#define ICL_APPENDLONG(lp, x) \
- MACRO_BEGIN \
- ICL_APPENDINT32((lp), ((x) >> 32) & 0xffffffffL); \
- ICL_APPENDINT32((lp), (x) & 0xffffffffL); \
- MACRO_END
-
-#else /* AFS_ALPHA_ENV */
-#define ICL_APPENDLONG(lp, x) ICL_APPENDINT32((lp), (x))
-#endif /* AFS_ALPHA_ENV */
-
-/* routine to tell whether we're dealing with the address or the
- * object itself
- */
-int
-afs_icl_UseAddr(int type)
-{
- if (type == ICL_TYPE_HYPER || type == ICL_TYPE_STRING
- || type == ICL_TYPE_FID || type == ICL_TYPE_INT64)
- return 1;
- else
- return 0;
-}
-
-/* Function to append a record to the log. Written for speed
- * since we know that we're going to have to make this work fast
- * pretty soon, anyway. The log must be unlocked.
- */
-
-void
-afs_icl_AppendRecord(register struct afs_icl_log *logp, afs_int32 op,
- afs_int32 types, long p1, long p2, long p3, long p4)
-{
- int rsize; /* record size in longs */
- register int tsize; /* temp size */
- osi_timeval_t tv;
- int t1, t2, t3, t4;
-
- t4 = types & 0x3f; /* decode types */
- types >>= 6;
- t3 = types & 0x3f;
- types >>= 6;
- t2 = types & 0x3f;
- types >>= 6;
- t1 = types & 0x3f;
-
- osi_GetTime(&tv); /* It panics for solaris if inside */
- ObtainWriteLock(&logp->lock, 182);
- if (!logp->datap) {
- ReleaseWriteLock(&logp->lock);
- return;
- }
-
- /* get timestamp as # of microseconds since some time that doesn't
- * change that often. This algorithm ticks over every 20 minutes
- * or so (1000 seconds). Write a timestamp record if it has.
- */
- if (tv.tv_sec - logp->lastTS > 1024) {
- /* the timer has wrapped -- write a timestamp record */
- if (logp->logSize - logp->logElements <= 5)
- afs_icl_GetLogSpace(logp, 5);
-
- ICL_APPENDINT32(logp,
- (afs_int32) (5 << 24) + (ICL_TYPE_UNIXDATE << 18));
- ICL_APPENDINT32(logp, (afs_int32) ICL_INFO_TIMESTAMP);
- ICL_APPENDINT32(logp, (afs_int32) 0); /* use thread ID zero for clocks */
- ICL_APPENDINT32(logp,
- (afs_int32) (tv.tv_sec & 0x3ff) * 1000000 +
- tv.tv_usec);
- ICL_APPENDINT32(logp, (afs_int32) tv.tv_sec);
-
- logp->lastTS = tv.tv_sec;
- }
-
- rsize = 4; /* base case */
- if (t1) {
- /* compute size of parameter p1. Only tricky case is string.
- * In that case, we have to call strlen to get the string length.
- */
- ICL_SIZEHACK(t1, p1);
- }
- if (t2) {
- /* compute size of parameter p2. Only tricky case is string.
- * In that case, we have to call strlen to get the string length.
- */
- ICL_SIZEHACK(t2, p2);
- }
- if (t3) {
- /* compute size of parameter p3. Only tricky case is string.
- * In that case, we have to call strlen to get the string length.
- */
- ICL_SIZEHACK(t3, p3);
- }
- if (t4) {
- /* compute size of parameter p4. Only tricky case is string.
- * In that case, we have to call strlen to get the string length.
- */
- ICL_SIZEHACK(t4, p4);
- }
-
- /* At this point, we've computed all of the parameter sizes, and
- * have in rsize the size of the entire record we want to append.
- * Next, we check that we actually have room in the log to do this
- * work, and then we do the append.
- */
- if (rsize > 255) {
- ReleaseWriteLock(&logp->lock);
- return; /* log record too big to express */
- }
-
- if (logp->logSize - logp->logElements <= rsize)
- afs_icl_GetLogSpace(logp, rsize);
-
- ICL_APPENDINT32(logp,
- (afs_int32) (rsize << 24) + (t1 << 18) + (t2 << 12) +
- (t3 << 6) + t4);
- ICL_APPENDINT32(logp, (afs_int32) op);
- ICL_APPENDINT32(logp, (afs_int32) osi_ThreadUnique());
- ICL_APPENDINT32(logp,
- (afs_int32) (tv.tv_sec & 0x3ff) * 1000000 + tv.tv_usec);
-
- if (t1) {
- /* marshall parameter 1 now */
- if (t1 == ICL_TYPE_STRING) {
- afs_icl_AppendString(logp, (char *)p1);
- } else if (t1 == ICL_TYPE_HYPER) {
- ICL_APPENDINT32(logp,
- (afs_int32) ((struct afs_hyper_t *)p1)->high);
- ICL_APPENDINT32(logp,
- (afs_int32) ((struct afs_hyper_t *)p1)->low);
- } else if (t1 == ICL_TYPE_INT64) {
-#ifdef AFSLITTLE_ENDIAN
-#ifdef AFS_64BIT_CLIENT
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p1)[1]);
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p1)[0]);
-#else /* AFS_64BIT_CLIENT */
- ICL_APPENDINT32(logp, (afs_int32) p1);
- ICL_APPENDINT32(logp, (afs_int32) 0);
-#endif /* AFS_64BIT_CLIENT */
-#else /* AFSLITTLE_ENDIAN */
-#ifdef AFS_64BIT_CLIENT
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p1)[0]);
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p1)[1]);
-#else /* AFS_64BIT_CLIENT */
- ICL_APPENDINT32(logp, (afs_int32) 0);
- ICL_APPENDINT32(logp, (afs_int32) p1);
-#endif /* AFS_64BIT_CLIENT */
-#endif /* AFSLITTLE_ENDIAN */
- } else if (t1 == ICL_TYPE_FID) {
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p1)[0]);
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p1)[1]);
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p1)[2]);
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p1)[3]);
- }
-#if defined(AFS_ALPHA_ENV) || (defined(AFS_SGI61_ENV) && (_MIPS_SZLONG==64)) || (defined(AFS_AIX51_ENV) && defined(AFS_64BIT_KERNEL))
- else if (t1 == ICL_TYPE_INT32)
- ICL_APPENDINT32(logp, (afs_int32) p1);
-#endif /* AFS_ALPHA_ENV */
- else
- ICL_APPENDLONG(logp, p1);
- }
- if (t2) {
- /* marshall parameter 2 now */
- if (t2 == ICL_TYPE_STRING)
- afs_icl_AppendString(logp, (char *)p2);
- else if (t2 == ICL_TYPE_HYPER) {
- ICL_APPENDINT32(logp,
- (afs_int32) ((struct afs_hyper_t *)p2)->high);
- ICL_APPENDINT32(logp,
- (afs_int32) ((struct afs_hyper_t *)p2)->low);
- } else if (t2 == ICL_TYPE_INT64) {
-#ifdef AFSLITTLE_ENDIAN
-#ifdef AFS_64BIT_CLIENT
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p2)[1]);
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p2)[0]);
-#else /* AFS_64BIT_CLIENT */
- ICL_APPENDINT32(logp, (afs_int32) p2);
- ICL_APPENDINT32(logp, (afs_int32) 0);
-#endif /* AFS_64BIT_CLIENT */
-#else /* AFSLITTLE_ENDIAN */
-#ifdef AFS_64BIT_CLIENT
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p2)[0]);
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p2)[1]);
-#else /* AFS_64BIT_CLIENT */
- ICL_APPENDINT32(logp, (afs_int32) 0);
- ICL_APPENDINT32(logp, (afs_int32) p2);
-#endif /* AFS_64BIT_CLIENT */
-#endif /* AFSLITTLE_ENDIAN */
- } else if (t2 == ICL_TYPE_FID) {
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p2)[0]);
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p2)[1]);
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p2)[2]);
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p2)[3]);
- }
-#if defined(AFS_ALPHA_ENV) || (defined(AFS_SGI61_ENV) && (_MIPS_SZLONG==64)) || (defined(AFS_AIX51_ENV) && defined(AFS_64BIT_KERNEL))
- else if (t2 == ICL_TYPE_INT32)
- ICL_APPENDINT32(logp, (afs_int32) p2);
-#endif /* AFS_ALPHA_ENV */
- else
- ICL_APPENDLONG(logp, p2);
- }
- if (t3) {
- /* marshall parameter 3 now */
- if (t3 == ICL_TYPE_STRING)
- afs_icl_AppendString(logp, (char *)p3);
- else if (t3 == ICL_TYPE_HYPER) {
- ICL_APPENDINT32(logp,
- (afs_int32) ((struct afs_hyper_t *)p3)->high);
- ICL_APPENDINT32(logp,
- (afs_int32) ((struct afs_hyper_t *)p3)->low);
- } else if (t3 == ICL_TYPE_INT64) {
-#ifdef AFSLITTLE_ENDIAN
-#ifdef AFS_64BIT_CLIENT
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p3)[1]);
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p3)[0]);
-#else /* AFS_64BIT_CLIENT */
- ICL_APPENDINT32(logp, (afs_int32) p3);
- ICL_APPENDINT32(logp, (afs_int32) 0);
-#endif /* AFS_64BIT_CLIENT */
-#else /* AFSLITTLE_ENDIAN */
-#ifdef AFS_64BIT_CLIENT
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p3)[0]);
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p3)[1]);
-#else /* AFS_64BIT_CLIENT */
- ICL_APPENDINT32(logp, (afs_int32) 0);
- ICL_APPENDINT32(logp, (afs_int32) p3);
-#endif /* AFS_64BIT_CLIENT */
-#endif /* AFSLITTLE_ENDIAN */
- } else if (t3 == ICL_TYPE_FID) {
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p3)[0]);
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p3)[1]);
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p3)[2]);
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p3)[3]);
- }
-#if defined(AFS_ALPHA_ENV) || (defined(AFS_SGI61_ENV) && (_MIPS_SZLONG==64)) || (defined(AFS_AIX51_ENV) && defined(AFS_64BIT_KERNEL))
- else if (t3 == ICL_TYPE_INT32)
- ICL_APPENDINT32(logp, (afs_int32) p3);
-#endif /* AFS_ALPHA_ENV */
- else
- ICL_APPENDLONG(logp, p3);
- }
- if (t4) {
- /* marshall parameter 4 now */
- if (t4 == ICL_TYPE_STRING)
- afs_icl_AppendString(logp, (char *)p4);
- else if (t4 == ICL_TYPE_HYPER) {
- ICL_APPENDINT32(logp,
- (afs_int32) ((struct afs_hyper_t *)p4)->high);
- ICL_APPENDINT32(logp,
- (afs_int32) ((struct afs_hyper_t *)p4)->low);
- } else if (t4 == ICL_TYPE_INT64) {
-#ifdef AFSLITTLE_ENDIAN
-#ifdef AFS_64BIT_CLIENT
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p4)[1]);
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p4)[0]);
-#else /* AFS_64BIT_CLIENT */
- ICL_APPENDINT32(logp, (afs_int32) p4);
- ICL_APPENDINT32(logp, (afs_int32) 0);
-#endif /* AFS_64BIT_CLIENT */
-#else /* AFSLITTLE_ENDIAN */
-#ifdef AFS_64BIT_CLIENT
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p4)[0]);
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p4)[1]);
-#else /* AFS_64BIT_CLIENT */
- ICL_APPENDINT32(logp, (afs_int32) 0);
- ICL_APPENDINT32(logp, (afs_int32) p4);
-#endif /* AFS_64BIT_CLIENT */
-#endif /* AFSLITTLE_ENDIAN */
- } else if (t4 == ICL_TYPE_FID) {
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p4)[0]);
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p4)[1]);
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p4)[2]);
- ICL_APPENDINT32(logp, (afs_int32) ((afs_int32 *) p4)[3]);
- }
-#if defined(AFS_ALPHA_ENV) || (defined(AFS_SGI61_ENV) && (_MIPS_SZLONG==64)) || (defined(AFS_AIX51_ENV) && defined(AFS_64BIT_KERNEL))
- else if (t4 == ICL_TYPE_INT32)
- ICL_APPENDINT32(logp, (afs_int32) p4);
-#endif /* AFS_ALPHA_ENV */
- else
- ICL_APPENDLONG(logp, p4);
- }
- ReleaseWriteLock(&logp->lock);
-}
-
-/* create a log with size logSize; return it in *outLogpp and tag
- * it with name "name."
- */
-int
-afs_icl_CreateLog(char *name, afs_int32 logSize,
- struct afs_icl_log **outLogpp)
-{
- return afs_icl_CreateLogWithFlags(name, logSize, /*flags */ 0, outLogpp);
-}
-
-/* create a log with size logSize; return it in *outLogpp and tag
- * it with name "name." 'flags' can be set to make the log unclearable.
- */
-int
-afs_icl_CreateLogWithFlags(char *name, afs_int32 logSize, afs_uint32 flags,
- struct afs_icl_log **outLogpp)
-{
- register struct afs_icl_log *logp;
-
- /* add into global list under lock */
- ObtainWriteLock(&afs_icl_lock, 183);
- if (!afs_icl_inited)
- afs_icl_Init();
-
- for (logp = afs_icl_allLogs; logp; logp = logp->nextp) {
- if (strcmp(logp->name, name) == 0) {
- /* found it already created, just return it */
- logp->refCount++;
- *outLogpp = logp;
- if (flags & ICL_CRLOG_FLAG_PERSISTENT) {
- ObtainWriteLock(&logp->lock, 184);
- logp->states |= ICL_LOGF_PERSISTENT;
- ReleaseWriteLock(&logp->lock);
- }
- ReleaseWriteLock(&afs_icl_lock);
- return 0;
- }
- }
-
- logp = (struct afs_icl_log *)
- osi_AllocSmallSpace(sizeof(struct afs_icl_log));
- memset((caddr_t) logp, 0, sizeof(*logp));
-
- logp->refCount = 1;
- logp->name = osi_AllocSmallSpace(strlen(name) + 1);
- strcpy(logp->name, name);
- LOCK_INIT(&logp->lock, "logp lock");
- logp->logSize = logSize;
- logp->datap = NULL; /* don't allocate it until we need it */
-
- if (flags & ICL_CRLOG_FLAG_PERSISTENT)
- logp->states |= ICL_LOGF_PERSISTENT;
-
- logp->nextp = afs_icl_allLogs;
- afs_icl_allLogs = logp;
- ReleaseWriteLock(&afs_icl_lock);
-
- *outLogpp = logp;
- return 0;
-}
-
-/* called with a log, a pointer to a buffer, the size of the buffer
- * (in *bufSizep), the starting cookie (in *cookiep, use 0 at the start)
- * and returns data in the provided buffer, and returns output flags
- * in *flagsp. The flag ICL_COPYOUTF_MISSEDSOME is set if we can't
- * find the record with cookie value cookie.
- */
-int
-afs_icl_CopyOut(register struct afs_icl_log *logp, afs_int32 * bufferp,
- afs_int32 * bufSizep, afs_uint32 * cookiep,
- afs_int32 * flagsp)
-{
- afs_int32 nwords; /* number of words to copy out */
- afs_uint32 startCookie; /* first cookie to use */
- afs_int32 outWords; /* words we've copied out */
- afs_int32 inWords; /* max words to copy out */
- afs_int32 code; /* return code */
- afs_int32 ix; /* index we're copying from */
- afs_int32 outFlags; /* return flags */
- afs_int32 inFlags; /* flags passed in */
- afs_int32 end;
-
- inWords = *bufSizep; /* max to copy out */
- outWords = 0; /* amount copied out */
- startCookie = *cookiep;
- outFlags = 0;
- inFlags = *flagsp;
- code = 0;
-
- ObtainWriteLock(&logp->lock, 185);
- if (!logp->datap) {
- ReleaseWriteLock(&logp->lock);
- goto done;
- }
-
- /* first, compute the index of the start cookie we've been passed */
- while (1) {
- /* (re-)compute where we should start */
- if (startCookie < logp->baseCookie) {
- if (startCookie) /* missed some output */
- outFlags |= ICL_COPYOUTF_MISSEDSOME;
- /* skip to the first available record */
- startCookie = logp->baseCookie;
- *cookiep = startCookie;
- }
-
- /* compute where we find the first element to copy out */
- ix = logp->firstUsed + startCookie - logp->baseCookie;
- if (ix >= logp->logSize)
- ix -= logp->logSize;
-
- /* if have some data now, break out and process it */
- if (startCookie - logp->baseCookie < logp->logElements)
- break;
-
- /* At end of log, so clear it if we need to */
- if (inFlags & ICL_COPYOUTF_CLRAFTERREAD) {
- logp->firstUsed = logp->firstFree = 0;
- logp->logElements = 0;
- }
- /* otherwise, either wait for the data to arrive, or return */
- if (!(inFlags & ICL_COPYOUTF_WAITIO)) {
- ReleaseWriteLock(&logp->lock);
- code = 0;
- goto done;
- }
- logp->states |= ICL_LOGF_WAITING;
- ReleaseWriteLock(&logp->lock);
- afs_osi_Sleep(&logp->lock);
- ObtainWriteLock(&logp->lock, 186);
- }
- /* copy out data from ix to logSize or firstFree, depending
- * upon whether firstUsed <= firstFree (no wrap) or otherwise.
- * be careful not to copy out more than nwords.
- */
- if (ix >= logp->firstUsed) {
- if (logp->firstUsed <= logp->firstFree)
- /* no wrapping */
- end = logp->firstFree; /* first element not to copy */
- else
- end = logp->logSize;
- nwords = inWords; /* don't copy more than this */
- if (end - ix < nwords)
- nwords = end - ix;
- if (nwords > 0) {
- memcpy((char *)bufferp, (char *)&logp->datap[ix],
- sizeof(afs_int32) * nwords);
- outWords += nwords;
- inWords -= nwords;
- bufferp += nwords;
- }
- /* if we're going to copy more out below, we'll start here */
- ix = 0;
- }
- /* now, if active part of the log has wrapped, there's more stuff
- * starting at the head of the log. Copy out more from there.
- */
- if (logp->firstUsed > logp->firstFree && ix < logp->firstFree
- && inWords > 0) {
- /* (more to) copy out from the wrapped section at the
- * start of the log. May get here even if didn't copy any
- * above, if the cookie points directly into the wrapped section.
- */
- nwords = inWords;
- if (logp->firstFree - ix < nwords)
- nwords = logp->firstFree - ix;
- memcpy((char *)bufferp, (char *)&logp->datap[ix],
- sizeof(afs_int32) * nwords);
- outWords += nwords;
- inWords -= nwords;
- bufferp += nwords;
- }
-
- ReleaseWriteLock(&logp->lock);
-
- done:
- if (code == 0) {
- *bufSizep = outWords;
- *flagsp = outFlags;
- }
- return code;
-}
-
-/* return basic parameter information about a log */
-int
-afs_icl_GetLogParms(struct afs_icl_log *logp, afs_int32 * maxSizep,
- afs_int32 * curSizep)
-{
- ObtainReadLock(&logp->lock);
- *maxSizep = logp->logSize;
- *curSizep = logp->logElements;
- ReleaseReadLock(&logp->lock);
- return 0;
-}
-
-
-/* hold and release logs */
-int
-afs_icl_LogHold(register struct afs_icl_log *logp)
-{
- ObtainWriteLock(&afs_icl_lock, 187);
- logp->refCount++;
- ReleaseWriteLock(&afs_icl_lock);
- return 0;
-}
-
-/* hold and release logs, called with lock already held */
-int
-afs_icl_LogHoldNL(register struct afs_icl_log *logp)
-{
- logp->refCount++;
- return 0;
-}
-
-/* keep track of how many sets believe the log itself is allocated */
-int
-afs_icl_LogUse(register struct afs_icl_log *logp)
-{
- ObtainWriteLock(&logp->lock, 188);
- if (logp->setCount == 0) {
- /* this is the first set actually using the log -- allocate it */
- if (logp->logSize == 0) {
- /* we weren't passed in a hint and it wasn't set */
- logp->logSize = ICL_DEFAULT_LOGSIZE;
- }
- logp->datap =
- (afs_int32 *) afs_osi_Alloc(sizeof(afs_int32) * logp->logSize);
-#ifdef KERNEL_HAVE_PIN
- pin((char *)logp->datap, sizeof(afs_int32) * logp->logSize);
-#endif
- }
- logp->setCount++;
- ReleaseWriteLock(&logp->lock);
- return 0;
-}
-
-/* decrement the number of real users of the log, free if possible */
-int
-afs_icl_LogFreeUse(register struct afs_icl_log *logp)
-{
- ObtainWriteLock(&logp->lock, 189);
- if (--logp->setCount == 0) {
- /* no more users -- free it (but keep log structure around) */
- afs_osi_Free(logp->datap, sizeof(afs_int32) * logp->logSize);
-#ifdef KERNEL_HAVE_PIN
- unpin((char *)logp->datap, sizeof(afs_int32) * logp->logSize);
-#endif
- logp->firstUsed = logp->firstFree = 0;
- logp->logElements = 0;
- logp->datap = NULL;
- }
- ReleaseWriteLock(&logp->lock);
- return 0;
-}
-
-/* set the size of the log to 'logSize' */
-int
-afs_icl_LogSetSize(register struct afs_icl_log *logp, afs_int32 logSize)
-{
- ObtainWriteLock(&logp->lock, 190);
- if (!logp->datap) {
- /* nothing to worry about since it's not allocated */
- logp->logSize = logSize;
- } else {
- /* reset log */
- logp->firstUsed = logp->firstFree = 0;
- logp->logElements = 0;
-
- /* free and allocate a new one */
- afs_osi_Free(logp->datap, sizeof(afs_int32) * logp->logSize);
-#ifdef KERNEL_HAVE_PIN
- unpin((char *)logp->datap, sizeof(afs_int32) * logp->logSize);
-#endif
- logp->datap =
- (afs_int32 *) afs_osi_Alloc(sizeof(afs_int32) * logSize);
-#ifdef KERNEL_HAVE_PIN
- pin((char *)logp->datap, sizeof(afs_int32) * logSize);
-#endif
- logp->logSize = logSize;
- }
- ReleaseWriteLock(&logp->lock);
-
- return 0;
-}
-
-/* free a log. Called with afs_icl_lock locked. */
-int
-afs_icl_ZapLog(register struct afs_icl_log *logp)
-{
- register struct afs_icl_log **lpp, *tp;
-
- for (lpp = &afs_icl_allLogs, tp = *lpp; tp; lpp = &tp->nextp, tp = *lpp) {
- if (tp == logp) {
- /* found the dude we want to remove */
- *lpp = logp->nextp;
- osi_FreeSmallSpace(logp->name);
- osi_FreeSmallSpace(logp->datap);
- osi_FreeSmallSpace(logp);
- break; /* won't find it twice */
- }
- }
- return 0;
-}
-
-/* do the release, watching for deleted entries */
-int
-afs_icl_LogRele(register struct afs_icl_log *logp)
-{
- ObtainWriteLock(&afs_icl_lock, 191);
- if (--logp->refCount == 0 && (logp->states & ICL_LOGF_DELETED)) {
- afs_icl_ZapLog(logp); /* destroys logp's lock! */
- }
- ReleaseWriteLock(&afs_icl_lock);
- return 0;
-}
-
-/* do the release, watching for deleted entries, log already held */
-int
-afs_icl_LogReleNL(register struct afs_icl_log *logp)
-{
- if (--logp->refCount == 0 && (logp->states & ICL_LOGF_DELETED)) {
- afs_icl_ZapLog(logp); /* destroys logp's lock! */
- }
- return 0;
-}
-
-/* zero out the log */
-int
-afs_icl_ZeroLog(register struct afs_icl_log *logp)
-{
- ObtainWriteLock(&logp->lock, 192);
- logp->firstUsed = logp->firstFree = 0;
- logp->logElements = 0;
- logp->baseCookie = 0;
- ReleaseWriteLock(&logp->lock);
- return 0;
-}
-
-/* free a log entry, and drop its reference count */
-int
-afs_icl_LogFree(register struct afs_icl_log *logp)
-{
- ObtainWriteLock(&logp->lock, 193);
- logp->states |= ICL_LOGF_DELETED;
- ReleaseWriteLock(&logp->lock);
- afs_icl_LogRele(logp);
- return 0;
-}
-
-/* find a log by name, returning it held */
-struct afs_icl_log *
-afs_icl_FindLog(char *name)
-{
- register struct afs_icl_log *tp;
- ObtainWriteLock(&afs_icl_lock, 194);
- for (tp = afs_icl_allLogs; tp; tp = tp->nextp) {
- if (strcmp(tp->name, name) == 0) {
- /* this is the dude we want */
- tp->refCount++;
- break;
- }
- }
- ReleaseWriteLock(&afs_icl_lock);
- return tp;
-}
-
-int
-afs_icl_EnumerateLogs(int (*aproc)
- (char *name, char *arock, struct afs_icl_log * tp),
- char *arock)
-{
- register struct afs_icl_log *tp;
- register afs_int32 code;
-
- code = 0;
- ObtainWriteLock(&afs_icl_lock, 195);
- for (tp = afs_icl_allLogs; tp; tp = tp->nextp) {
- tp->refCount++; /* hold this guy */
- ReleaseWriteLock(&afs_icl_lock);
- ObtainReadLock(&tp->lock);
- code = (*aproc) (tp->name, arock, tp);
- ReleaseReadLock(&tp->lock);
- ObtainWriteLock(&afs_icl_lock, 196);
- if (--tp->refCount == 0)
- afs_icl_ZapLog(tp);
- if (code)
- break;
- }
- ReleaseWriteLock(&afs_icl_lock);
- return code;
-}
-
-struct afs_icl_set *afs_icl_allSets = 0;
-
-int
-afs_icl_CreateSet(char *name, struct afs_icl_log *baseLogp,
- struct afs_icl_log *fatalLogp,
- struct afs_icl_set **outSetpp)
-{
- return afs_icl_CreateSetWithFlags(name, baseLogp, fatalLogp,
- /*flags */ 0, outSetpp);
-}
-
-/* create a set, given pointers to base and fatal logs, if any.
- * Logs are unlocked, but referenced, and *outSetpp is returned
- * referenced. Function bumps reference count on logs, since it
- * addds references from the new afs_icl_set. When the set is destroyed,
- * those references will be released.
- */
-int
-afs_icl_CreateSetWithFlags(char *name, struct afs_icl_log *baseLogp,
- struct afs_icl_log *fatalLogp, afs_uint32 flags,
- struct afs_icl_set **outSetpp)
-{
- register struct afs_icl_set *setp;
- register int i;
- afs_int32 states = ICL_DEFAULT_SET_STATES;
-
- ObtainWriteLock(&afs_icl_lock, 197);
- if (!afs_icl_inited)
- afs_icl_Init();
-
- for (setp = afs_icl_allSets; setp; setp = setp->nextp) {
- if (strcmp(setp->name, name) == 0) {
- setp->refCount++;
- *outSetpp = setp;
- if (flags & ICL_CRSET_FLAG_PERSISTENT) {
- ObtainWriteLock(&setp->lock, 198);
- setp->states |= ICL_SETF_PERSISTENT;
- ReleaseWriteLock(&setp->lock);
- }
- ReleaseWriteLock(&afs_icl_lock);
- return 0;
- }
- }
-
- /* determine initial state */
- if (flags & ICL_CRSET_FLAG_DEFAULT_ON)
- states = ICL_SETF_ACTIVE;
- else if (flags & ICL_CRSET_FLAG_DEFAULT_OFF)
- states = ICL_SETF_FREED;
- if (flags & ICL_CRSET_FLAG_PERSISTENT)
- states |= ICL_SETF_PERSISTENT;
-
- setp = (struct afs_icl_set *)afs_osi_Alloc(sizeof(struct afs_icl_set));
- memset((caddr_t) setp, 0, sizeof(*setp));
- setp->refCount = 1;
- if (states & ICL_SETF_FREED)
- states &= ~ICL_SETF_ACTIVE; /* if freed, can't be active */
- setp->states = states;
-
- LOCK_INIT(&setp->lock, "setp lock");
- /* next lock is obtained in wrong order, hierarchy-wise, but
- * it doesn't matter, since no one can find this lock yet, since
- * the afs_icl_lock is still held, and thus the obtain can't block.
- */
- ObtainWriteLock(&setp->lock, 199);
- setp->name = osi_AllocSmallSpace(strlen(name) + 1);
- strcpy(setp->name, name);
- setp->nevents = ICL_DEFAULTEVENTS;
- setp->eventFlags = afs_osi_Alloc(ICL_DEFAULTEVENTS);
-#ifdef KERNEL_HAVE_PIN
- pin((char *)setp->eventFlags, ICL_DEFAULTEVENTS);
-#endif
- for (i = 0; i < ICL_DEFAULTEVENTS; i++)
- setp->eventFlags[i] = 0xff; /* default to enabled */
-
- /* update this global info under the afs_icl_lock */
- setp->nextp = afs_icl_allSets;
- afs_icl_allSets = setp;
- ReleaseWriteLock(&afs_icl_lock);
-
- /* set's basic lock is still held, so we can finish init */
- if (baseLogp) {
- setp->logs[0] = baseLogp;
- afs_icl_LogHold(baseLogp);
- if (!(setp->states & ICL_SETF_FREED))
- afs_icl_LogUse(baseLogp); /* log is actually being used */
- }
- if (fatalLogp) {
- setp->logs[1] = fatalLogp;
- afs_icl_LogHold(fatalLogp);
- if (!(setp->states & ICL_SETF_FREED))
- afs_icl_LogUse(fatalLogp); /* log is actually being used */
- }
- ReleaseWriteLock(&setp->lock);
-
- *outSetpp = setp;
- return 0;
-}
-
-/* function to change event enabling information for a particular set */
-int
-afs_icl_SetEnable(struct afs_icl_set *setp, afs_int32 eventID, int setValue)
-{
- char *tp;
-
- ObtainWriteLock(&setp->lock, 200);
- if (!ICL_EVENTOK(setp, eventID)) {
- ReleaseWriteLock(&setp->lock);
- return -1;
- }
- tp = &setp->eventFlags[ICL_EVENTBYTE(eventID)];
- if (setValue)
- *tp |= ICL_EVENTMASK(eventID);
- else
- *tp &= ~(ICL_EVENTMASK(eventID));
- ReleaseWriteLock(&setp->lock);
- return 0;
-}
-
-/* return indication of whether a particular event ID is enabled
- * for tracing. If *getValuep is set to 0, the event is disabled,
- * otherwise it is enabled. All events start out enabled by default.
- */
-int
-afs_icl_GetEnable(struct afs_icl_set *setp, afs_int32 eventID, int *getValuep)
-{
- ObtainReadLock(&setp->lock);
- if (!ICL_EVENTOK(setp, eventID)) {
- ReleaseWriteLock(&setp->lock);
- return -1;
- }
- if (setp->eventFlags[ICL_EVENTBYTE(eventID)] & ICL_EVENTMASK(eventID))
- *getValuep = 1;
- else
- *getValuep = 0;
- ReleaseReadLock(&setp->lock);
- return 0;
-}
-
-/* hold and release event sets */
-int
-afs_icl_SetHold(register struct afs_icl_set *setp)
-{
- ObtainWriteLock(&afs_icl_lock, 201);
- setp->refCount++;
- ReleaseWriteLock(&afs_icl_lock);
- return 0;
-}
-
-/* free a set. Called with afs_icl_lock locked */
-int
-afs_icl_ZapSet(register struct afs_icl_set *setp)
-{
- register struct afs_icl_set **lpp, *tp;
- int i;
- register struct afs_icl_log *tlp;
-
- for (lpp = &afs_icl_allSets, tp = *lpp; tp; lpp = &tp->nextp, tp = *lpp) {
- if (tp == setp) {
- /* found the dude we want to remove */
- *lpp = setp->nextp;
- osi_FreeSmallSpace(setp->name);
- afs_osi_Free(setp->eventFlags, ICL_DEFAULTEVENTS);
-#ifdef KERNEL_HAVE_PIN
- unpin((char *)setp->eventFlags, ICL_DEFAULTEVENTS);
-#endif
- for (i = 0; i < ICL_LOGSPERSET; i++) {
- if ((tlp = setp->logs[i]))
- afs_icl_LogReleNL(tlp);
- }
- osi_FreeSmallSpace(setp);
- break; /* won't find it twice */
- }
- }
- return 0;
-}
-
-/* do the release, watching for deleted entries */
-int
-afs_icl_SetRele(register struct afs_icl_set *setp)
-{
- ObtainWriteLock(&afs_icl_lock, 202);
- if (--setp->refCount == 0 && (setp->states & ICL_SETF_DELETED)) {
- afs_icl_ZapSet(setp); /* destroys setp's lock! */
- }
- ReleaseWriteLock(&afs_icl_lock);
- return 0;
-}
-
-/* free a set entry, dropping its reference count */
-int
-afs_icl_SetFree(register struct afs_icl_set *setp)
-{
- ObtainWriteLock(&setp->lock, 203);
- setp->states |= ICL_SETF_DELETED;
- ReleaseWriteLock(&setp->lock);
- afs_icl_SetRele(setp);
- return 0;
-}
-
-/* find a set by name, returning it held */
-struct afs_icl_set *
-afs_icl_FindSet(char *name)
-{
- register struct afs_icl_set *tp;
- ObtainWriteLock(&afs_icl_lock, 204);
- for (tp = afs_icl_allSets; tp; tp = tp->nextp) {
- if (strcmp(tp->name, name) == 0) {
- /* this is the dude we want */
- tp->refCount++;
- break;
- }
- }
- ReleaseWriteLock(&afs_icl_lock);
- return tp;
-}
-
-/* zero out all the logs in the set */
-int
-afs_icl_ZeroSet(struct afs_icl_set *setp)
-{
- register int i;
- int code = 0;
- int tcode;
- struct afs_icl_log *logp;
-
- ObtainReadLock(&setp->lock);
- for (i = 0; i < ICL_LOGSPERSET; i++) {
- logp = setp->logs[i];
- if (logp) {
- afs_icl_LogHold(logp);
- tcode = afs_icl_ZeroLog(logp);
- if (tcode != 0)
- code = tcode; /* save the last bad one */
- afs_icl_LogRele(logp);
- }
- }
- ReleaseReadLock(&setp->lock);
- return code;
-}
-
-int
-afs_icl_EnumerateSets(int (*aproc)
- (char *name, char *arock, struct afs_icl_log * tp),
- char *arock)
-{
- register struct afs_icl_set *tp, *np;
- register afs_int32 code;
-
- code = 0;
- ObtainWriteLock(&afs_icl_lock, 205);
- for (tp = afs_icl_allSets; tp; tp = np) {
- tp->refCount++; /* hold this guy */
- ReleaseWriteLock(&afs_icl_lock);
- code = (*aproc) (tp->name, arock, tp);
- ObtainWriteLock(&afs_icl_lock, 206);
- np = tp->nextp; /* tp may disappear next, but not np */
- if (--tp->refCount == 0 && (tp->states & ICL_SETF_DELETED))
- afs_icl_ZapSet(tp);
- if (code)
- break;
- }
- ReleaseWriteLock(&afs_icl_lock);
- return code;
-}
-
-int
-afs_icl_AddLogToSet(struct afs_icl_set *setp, struct afs_icl_log *newlogp)
-{
- register int i;
- int code = -1;
-
- ObtainWriteLock(&setp->lock, 207);
- for (i = 0; i < ICL_LOGSPERSET; i++) {
- if (!setp->logs[i]) {
- setp->logs[i] = newlogp;
- code = i;
- afs_icl_LogHold(newlogp);
- if (!(setp->states & ICL_SETF_FREED)) {
- /* bump up the number of sets using the log */
- afs_icl_LogUse(newlogp);
- }
- break;
- }
- }
- ReleaseWriteLock(&setp->lock);
- return code;
-}
-
-int
-afs_icl_SetSetStat(struct afs_icl_set *setp, int op)
-{
- int i;
- afs_int32 code;
- struct afs_icl_log *logp;
-
- ObtainWriteLock(&setp->lock, 208);
- switch (op) {
- case ICL_OP_SS_ACTIVATE: /* activate a log */
- /*
- * If we are not already active, see if we have released
- * our demand that the log be allocated (FREED set). If
- * we have, reassert our desire.
- */
- if (!(setp->states & ICL_SETF_ACTIVE)) {
- if (setp->states & ICL_SETF_FREED) {
- /* have to reassert desire for logs */
- for (i = 0; i < ICL_LOGSPERSET; i++) {
- logp = setp->logs[i];
- if (logp) {
- afs_icl_LogHold(logp);
- afs_icl_LogUse(logp);
- afs_icl_LogRele(logp);
- }
- }
- setp->states &= ~ICL_SETF_FREED;
- }
- setp->states |= ICL_SETF_ACTIVE;
- }
- code = 0;
- break;
-
- case ICL_OP_SS_DEACTIVATE: /* deactivate a log */
- /* this doesn't require anything beyond clearing the ACTIVE flag */
- setp->states &= ~ICL_SETF_ACTIVE;
- code = 0;
- break;
-
- case ICL_OP_SS_FREE: /* deassert design for log */
- /*
- * if we are already in this state, do nothing; otherwise
- * deassert desire for log
- */
- if (setp->states & ICL_SETF_ACTIVE)
- code = EINVAL;
- else {
- if (!(setp->states & ICL_SETF_FREED)) {
- for (i = 0; i < ICL_LOGSPERSET; i++) {
- logp = setp->logs[i];
- if (logp) {
- afs_icl_LogHold(logp);
- afs_icl_LogFreeUse(logp);
- afs_icl_LogRele(logp);
- }
- }
- setp->states |= ICL_SETF_FREED;
- }
- code = 0;
- }
- break;
-
- default:
- code = EINVAL;
- }
- ReleaseWriteLock(&setp->lock);
- return code;
-}
git://git.openafs.org / openafs.git / blobdiff