#include <sys/types.h>
#include <afs/procmgmt.h> /* signal(), kill(), wait(), etc. */
#include <sys/stat.h>
-#ifdef AFS_NT40_ENV
#include <fcntl.h>
+#ifdef AFS_NT40_ENV
#include <io.h>
#include <windows.h>
#include <WINNT/afsevent.h>
#endif
}
+#if defined(AFS_PTHREAD_ENV)
+char *
+threadNum(void)
+{
+ return pthread_getspecific(rx_thread_id_key);
+}
+#endif
/* proc called by rxkad module to get a key */
static int
Do_VLRegisterRPC();
/* Force wakeup in case we missed something; pthreads does timedwait */
#ifndef AFS_PTHREAD_ENV
- LWP_NoYieldSignal(&fsync_wait);
+ LWP_NoYieldSignal(fsync_wait);
#endif
if (printBanner && (++msg & 1)) { /* Every 10 minutes */
time_t now = FT_ApproxTime();
assert(pthread_mutex_init(&fsync_glock_mutex, NULL) == 0);
#endif
- FSYNC_LOCK;
while (1) {
+ FSYNC_LOCK;
#ifdef AFS_PTHREAD_ENV
/* rounding is fine */
fsync_next.tv_nsec = 0;
if (code != 0 && code != ETIMEDOUT)
ViceLog(0, ("pthread_cond_timedwait returned %d\n", code));
#else /* AFS_PTHREAD_ENV */
- if ((code = LWP_WaitProcess(&fsync_wait)) != LWP_SUCCESS)
+ if ((code = LWP_WaitProcess(fsync_wait)) != LWP_SUCCESS)
ViceLog(0, ("LWP_WaitProcess returned %d\n", code));
#endif /* AFS_PTHREAD_ENV */
+ FSYNC_UNLOCK;
ViceLog(2, ("Checking for fsync events\n"));
do {
code = BreakLaterCallBacks();
ShutDownAndCore(int dopanic)
{
time_t now = time(0);
- char *tstr;
char tbuffer[32];
ViceLog(0,
/* default supports help flag */
strcpy(buffer, "Usage: fileserver ");
+ strcpy(buffer, "[-auditlog <log path>] ");
strcat(buffer, "[-d <debug level>] ");
strcat(buffer, "[-p <number of processes>] ");
strcat(buffer, "[-spare <number of spare blocks>] ");
strcat(buffer, "[-rxpck <number of rx extra packets>] ");
strcat(buffer, "[-rxdbg (enable rx debugging)] ");
strcat(buffer, "[-rxdbge (enable rxevent debugging)] ");
+#if AFS_PTHREAD_ENV
+ strcat(buffer, "[-vattachpar <number of volume attach threads>] ");
+#endif
#ifdef AFS_AIX32_ENV
strcat(buffer, "[-m <min percentage spare in partition>] ");
#endif
strcat(buffer, "[-realm <Kerberos realm name>] ");
strcat(buffer, "[-udpsize <size of socket buffer in bytes>] ");
strcat(buffer, "[-sendsize <size of send buffer in bytes>] ");
+ strcat(buffer, "[-abortthreshold <abort threshold>] ");
/* strcat(buffer, "[-enable_peer_stats] "); */
/* strcat(buffer, "[-enable_process_stats] "); */
strcat(buffer, "[-help]\n");
for (i = 1; i < argc; i++) {
if (!strcmp(argv[i], "-d")) {
+ if ((i + 1) >= argc) {
+ fprintf(stderr, "missing argument for -d\n");
+ return -1;
+ }
debuglevel = atoi(argv[++i]);
LogLevel = debuglevel;
} else if (!strcmp(argv[i], "-banner")) {
printBanner = 1;
} else if (!strcmp(argv[i], "-implicit")) {
+ if ((i + 1) >= argc) {
+ fprintf(stderr, "missing argument for -implicit\n");
+ return -1;
+ }
implicitAdminRights = ParseRights(argv[++i]);
if (implicitAdminRights < 0)
return implicitAdminRights;
int lwps_max =
max_fileserver_thread() - FILESERVER_HELPER_THREADS;
Sawlwps = 1;
+ if ((i + 1) >= argc) {
+ fprintf(stderr, "missing argument for -p\n");
+ return -1;
+ }
lwps = atoi(argv[++i]);
if (lwps > lwps_max)
lwps = lwps_max;
lwps = 6;
} else if (!strcmp(argv[i], "-b")) {
Sawbufs = 1;
+ if ((i + 1) >= argc) {
+ fprintf(stderr, "missing argument for -b\n");
+ return -1;
+ }
buffs = atoi(argv[++i]);
} else if (!strcmp(argv[i], "-l")) {
Sawlarge = 1;
+ if ((i + 1) >= argc) {
+ fprintf(stderr, "missing argument for -l\n");
+ return -1;
+ }
large = atoi(argv[++i]);
} else if (!strcmp(argv[i], "-vc")) {
SawVC = 1;
+ if ((i + 1) >= argc) {
+ fprintf(stderr, "missing argument for -vc\n");
+ return -1;
+ }
volcache = atoi(argv[++i]);
} else if (!strcmp(argv[i], "-novbc")) {
novbc = 1;
} else if (!strcmp(argv[i], "-rxpck")) {
Sawrxpck = 1;
+ if ((i + 1) >= argc) {
+ fprintf(stderr, "missing argument for -rxpck\n");
+ return -1;
+ }
rxpackets = atoi(argv[++i]);
+#ifdef AFS_PTHREAD_ENV
+ } else if (!strcmp(argv[i], "-vattachpar")) {
+ if ((i + 1) >= argc) {
+ fprintf(stderr, "missing argument for -vattachpar\n");
+ return -1;
+ }
+ vol_attach_threads = atoi(argv[++i]);
+#endif /* AFS_PTHREAD_ENV */
} else if (!strcmp(argv[i], "-s")) {
Sawsmall = 1;
+ if ((i + 1) >= argc) {
+ fprintf(stderr, "missing argument for -s\n");
+ return -1;
+ }
nSmallVns = atoi(argv[++i]);
} else if (!strcmp(argv[i], "-abortthreshold")) {
+ if ((i + 1) >= argc) {
+ fprintf(stderr, "missing argument for -abortthreshold\n");
+ return -1;
+ }
abort_threshold = atoi(argv[++i]);
- } else if (!strcmp(argv[i], "-k"))
+ } else if (!strcmp(argv[i], "-k")) {
+ if ((i + 1) >= argc) {
+ fprintf(stderr, "missing argument for -k\n");
+ return -1;
+ }
stack = atoi(argv[++i]);
+ }
#if defined(AFS_SGI_ENV)
else if (!strcmp(argv[i], "-lock")) {
SawLock = 1;
}
#endif
else if (!strcmp(argv[i], "-spare")) {
+ if ((i + 1) >= argc) {
+ fprintf(stderr, "missing argument for -spare\n");
+ return -1;
+ }
BlocksSpare = atoi(argv[++i]);
SawSpare = 1;
} else if (!strcmp(argv[i], "-pctspare")) {
+ if ((i + 1) >= argc) {
+ fprintf(stderr, "missing argument for -pctspare\n");
+ return -1;
+ }
PctSpare = atoi(argv[++i]);
BlocksSpare = 0; /* has non-zero default */
SawPctSpare = 1;
- } else if (!strcmp(argv[i], "-w"))
+ } else if (!strcmp(argv[i], "-w")) {
+ if ((i + 1) >= argc) {
+ fprintf(stderr, "missing argument for -w\n");
+ return -1;
+ }
fiveminutes = atoi(argv[++i]);
- else if (!strcmp(argv[i], "-hr")) {
- int hr = atoi(argv[++i]);
+ } else if (!strcmp(argv[i], "-hr")) {
+ int hr;
+ if ((i + 1) >= argc) {
+ fprintf(stderr, "missing argument for -hr\n");
+ return -1;
+ }
+ hr = atoi(argv[++i]);
if ((hr < 1) || (hr > 36)) {
printf
("host acl refresh interval of %d hours is invalid; hours must be between 1 and 36\n\n",
eventlog = 1;
else if (!strcmp(argv[i], "-cb")) {
Sawcbs = 1;
+ if ((i + 1) >= argc) {
+ fprintf(stderr, "missing argument for -cb\n");
+ return -1;
+ }
numberofcbs = atoi(argv[++i]);
if ((numberofcbs < 10000) || (numberofcbs > 2147483647)) {
printf
}
} else if (!strcmp(argv[i], "-busyat")) {
Sawbusy = 1;
+ if ((i + 1) >= argc) {
+ fprintf(stderr, "missing argument for -busyat\n");
+ return -1;
+ }
busy_threshold = atoi(argv[++i]);
if (busy_threshold < 10) {
printf
#ifdef AFS_AIX32_ENV
else if (!strcmp(argv[i], "-m")) {
extern int aixlow_water;
+ if ((i + 1) >= argc) {
+ fprintf(stderr, "missing argument for -m\n");
+ return -1;
+ }
aixlow_water = atoi(argv[++i]);
if ((aixlow_water < 0) || (aixlow_water > 30)) {
printf("space reserved %d% invalid; must be between 0-30%\n",
else if (!strcmp(argv[i], "-nojumbo")) {
rxJumbograms = 0;
} else if (!strcmp(argv[i], "-realm")) {
- extern char local_realm[AFS_REALM_SZ];
+ extern char local_realms[AFS_NUM_LREALMS][AFS_REALM_SZ];
+ extern int num_lrealms;
+ if ((i + 1) >= argc) {
+ fprintf(stderr, "missing argument for -realm\n");
+ return -1;
+ }
if (strlen(argv[++i]) >= AFS_REALM_SZ) {
printf
("-realm argument must contain fewer than %d characters.\n",
AFS_REALM_SZ);
return -1;
}
- strncpy(local_realm, argv[i], AFS_REALM_SZ);
+ if (num_lrealms == -1)
+ num_lrealms = 0;
+ if (num_lrealms >= AFS_NUM_LREALMS) {
+ printf
+ ("a maximum of %d -realm arguments can be specified.\n",
+ AFS_NUM_LREALMS);
+ return -1;
+ }
+ strncpy(local_realms[num_lrealms++], argv[i], AFS_REALM_SZ);
} else if (!strcmp(argv[i], "-udpsize")) {
if ((i + 1) >= argc) {
printf("You have to specify -udpsize <integer value>\n");
} else if (!strcmp(argv[i], "-enable_process_stats")) {
rx_enableProcessRPCStats();
}
+ else if (strcmp(argv[i], "-auditlog") == 0) {
+ int tempfd, flags;
+ FILE *auditout;
+ char oldName[MAXPATHLEN];
+ char *fileName = argv[++i];
+
+#ifndef AFS_NT40_ENV
+ struct stat statbuf;
+
+ if ((lstat(fileName, &statbuf) == 0)
+ && (S_ISFIFO(statbuf.st_mode))) {
+ flags = O_WRONLY | O_NONBLOCK;
+ } else
+#endif
+ {
+ strcpy(oldName, fileName);
+ strcat(oldName, ".old");
+ renamefile(fileName, oldName);
+ flags = O_WRONLY | O_TRUNC | O_CREAT;
+ }
+ tempfd = open(fileName, flags, 0666);
+ if (tempfd > -1) {
+ auditout = fdopen(tempfd, "a");
+ if (auditout) {
+ osi_audit_file(auditout);
+ } else
+ printf("Warning: auditlog %s not writable, ignored.\n", fileName);
+ } else
+ printf("Warning: auditlog %s not writable, ignored.\n", fileName);
+ }
#ifndef AFS_NT40_ENV
else if (strcmp(argv[i], "-syslog") == 0) {
/* set syslog logging flag */
serverLogSyslogFacility = atoi(argv[i] + 8);
}
#endif
+ else if (strcmp(argv[i], "-mrafslogs") == 0) {
+ /* set syslog logging flag */
+ mrafsStyleLogs = 1;
+ }
else {
return (-1);
}
afs_int32
WriteSysIdFile()
{
- afs_int32 fd, nentries, i;
+ afs_int32 fd, i;
struct versionStamp vsn;
struct afs_stat status;
afsUUID uuid;
if (code) {
if (code == VL_MULTIPADDR) {
ViceLog(0,
- ("VL_RegisterAddrs rpc failed; The ethernet address exist on a different server; repair it\n"));
+ ("VL_RegisterAddrs rpc failed; The IP address exists on a different server; repair it\n"));
ViceLog(0,
("VL_RegisterAddrs rpc failed; See VLLog for details\n"));
return code;
afs_int32
InitVL()
{
- int (*old) ();
afs_int32 code;
- afs_int32 cnt, i;
extern int rxi_numNetAddrs;
extern afs_uint32 rxi_NetAddrs[];
int
main(int argc, char *argv[])
{
- int i;
afs_int32 code;
- FILE *file;
char tbuffer[32];
struct rx_securityClass *sc[4];
struct rx_service *tservice;
#ifdef AFS_PTHREAD_ENV
- pthread_t parentPid, serverPid;
+ pthread_t serverPid;
pthread_attr_t tattr;
#else /* AFS_PTHREAD_ENV */
PROCESS parentPid, serverPid;
struct rlimit rlim; /* max number of open file descriptors */
#endif
int curLimit;
+ time_t t;
#ifdef AFS_AIX32_ENV
struct sigaction nsa;
sigaction(SIGABRT, &nsa, NULL);
sigaction(SIGSEGV, &nsa, NULL);
#endif
+ osi_audit_init();
/* Initialize dirpaths */
if (!(initAFSDirPath() & AFSDIR_SERVER_PATHS_OK)) {
NewParms(1);
/* Open FileLog on stdout, stderr, fd 1 and fd2 (for perror), sigh. */
+#ifndef AFS_NT40_ENV
serverLogSyslogTag = "fileserver";
+#endif
OpenLog(AFSDIR_SERVER_FILELOG_FILEPATH);
SetupLogSignals();
V_BreakVolumeCallbacks = BreakVolumeCallBacksLater;
}
+#ifdef AFS_PTHREAD_ENV
+ SetLogThreadNumProgram( threadNum );
+#endif
+
/* initialize libacl routines */
acl_Initialize(ACL_VERSION);
TM_GetTimeOfDay(&tp, 0);
#ifndef AFS_QUIETFS_ENV
- if (console != NULL) {
+ if (console != NULL) {
+ time_t t = tp.tv_sec;
fprintf(console, "File server has started at %s\r",
- afs_ctime(&tp.tv_sec, tbuffer, sizeof(tbuffer)));
+ afs_ctime(&t, tbuffer, sizeof(tbuffer)));
}
#endif
(void)signal(SIGQUIT, ShutDown_Signal);
#endif
+ t = tp.tv_sec;
ViceLog(0,
("File Server started %s",
- afs_ctime(&tp.tv_sec, tbuffer, sizeof(tbuffer))));
+ afs_ctime(&t, tbuffer, sizeof(tbuffer))));
#if FS_STATS_DETAILED
afs_FullPerfStats.det.epoch.tv_sec = StartTime = tp.tv_sec;
#endif
git://git.openafs.org / openafs.git / blobdiff