extern int ADMINAPI CellHandleIsValid(const void *cellHandle,
afs_status_p st);
+struct rpcStats;
extern int ADMINAPI util_RPCStatsGetBegin(struct rx_connection *conn,
int (*rpc) (struct rx_connection *,
afs_uint32, afs_uint32 *,
static char *processTypes[] = { "simple", "fs", "cron", 0 };
int ADMINAPI
-bos_ProcessCreate(const void *serverHandle, const char *processName,
- bos_ProcessType_t processType, const char *process,
- const char *cronTime, const char *notifier, afs_status_p st)
+bos_ProcessCreate(const void *serverHandle, char *processName,
+ bos_ProcessType_t processType, char *process,
+ char *cronTime, char *notifier, afs_status_p st)
{
int rc = 0;
afs_status_t tst = 0;
*/
int ADMINAPI
-bos_FSProcessCreate(const void *serverHandle, const char *processName,
- const char *fileserverPath, const char *volserverPath,
- const char *salvagerPath, const char *notifier,
+bos_FSProcessCreate(const void *serverHandle, char *processName,
+ char *fileserverPath, char *volserverPath,
+ char *salvagerPath, char *notifier,
afs_status_p st)
{
int rc = 0;
*/
int ADMINAPI
-bos_ProcessDelete(const void *serverHandle, const char *processName,
+bos_ProcessDelete(const void *serverHandle, char *processName,
afs_status_p st)
{
int rc = 0;
int ADMINAPI
bos_ProcessExecutionStateGet(const void *serverHandle,
- const char *processName,
+ char *processName,
bos_ProcessExecutionState_p processStatusP,
char *auxiliaryProcessStatus, afs_status_p st)
{
static int
SetExecutionState(const void *serverHandle, const char *processName,
const bos_ProcessExecutionState_t processStatus,
- int (*func) (struct rx_connection *, const char *,
+ int (*func) (struct rx_connection *, char *,
afs_int32), afs_status_p st)
{
int rc = 0;
state = (afs_int32) processStatus;
- tst = func(b_handle->server, processName, state);
+ tst = func(b_handle->server, (char *)processName, state);
if (tst == 0) {
rc = 1;
int ADMINAPI
bos_ProcessExecutionStateSet(const void *serverHandle,
const char *processName,
- bos_ProcessExecutionState_t processStatus,
+ const bos_ProcessExecutionState_t processStatus,
afs_status_p st)
{
return SetExecutionState(serverHandle, processName, processStatus,
int ADMINAPI
bos_ProcessExecutionStateSetTemporary(const void *serverHandle,
- const char *processName,
+ char *processName,
bos_ProcessExecutionState_t
processStatus, afs_status_p st)
{
*/
int ADMINAPI
-bos_ProcessInfoGet(const void *serverHandle, const char *processName,
+bos_ProcessInfoGet(const void *serverHandle, char *processName,
bos_ProcessType_p processTypeP,
bos_ProcessInfo_p processInfoP, afs_status_p st)
{
goto fail_bos_ProcessNotifierGet;
}
- tst = BOZO_GetInstanceParm(b_handle->server, processName, 999, ¬ifier);
+ tst = BOZO_GetInstanceParm(b_handle->server, (char *)processName,
+ 999, ¬ifier);
if (tst == 0) {
rc = 1;
goto fail_bos_ProcessRestart;
}
- tst = BOZO_Restart(b_handle->server, processName);
+ tst = BOZO_Restart(b_handle->server, (char *)processName);
if (tst == 0) {
rc = 1;
goto fail_bos_AdminCreate;
}
- tst = BOZO_AddSUser(b_handle->server, adminName);
+ tst = BOZO_AddSUser(b_handle->server, (char *)adminName);
if (tst == 0) {
rc = 1;
goto fail_bos_AdminDelete;
}
- tst = BOZO_DeleteSUser(b_handle->server, adminName);
+ tst = BOZO_DeleteSUser(b_handle->server, (char *)adminName);
if (tst == 0) {
rc = 1;
goto fail_bos_CellSet;
}
- tst = BOZO_SetCellName(b_handle->server, cellName);
+ tst = BOZO_SetCellName(b_handle->server, (char *)cellName);
if (tst == 0) {
rc = 1;
goto fail_bos_HostCreate;
}
- tst = BOZO_AddCellHost(b_handle->server, hostName);
+ tst = BOZO_AddCellHost(b_handle->server, (char *)hostName);
if (tst == 0) {
rc = 1;
goto fail_bos_HostDelete;
}
- tst = BOZO_DeleteCellHost(b_handle->server, hostName);
+ tst = BOZO_DeleteCellHost(b_handle->server, (char *)hostName);
if (tst == 0) {
rc = 1;
tcall = rx_NewCall(b_handle->server);
tst =
- StartBOZO_Install(tcall, destFile, estat.st_size,
+ StartBOZO_Install(tcall, (char *)destFile, estat.st_size,
(afs_int32) estat.st_mode, estat.st_mtime);
if (tst) {
goto fail_bos_ExecutableRevert;
}
- tst = BOZO_UnInstall(b_handle->server, execFile);
+ tst = BOZO_UnInstall(b_handle->server, (char *)execFile);
if (tst == 0) {
rc = 1;
}
tst =
- BOZO_GetDates(b_handle->server, execFile, newTime, bakTime, oldTime);
+ BOZO_GetDates(b_handle->server, (char *)execFile, newTime, bakTime, oldTime);
if (tst == 0) {
rc = 1;
afs_status_p st);
extern int ADMINAPI bos_ProcessCreate(const void *serverHandle,
- const char *processName,
+ char *processName,
bos_ProcessType_t processType,
- const char *process,
- const char *cronTime,
- const char *notifier, afs_status_p st);
+ char *process,
+ char *cronTime,
+ char *notifier, afs_status_p st);
extern int ADMINAPI bos_FSProcessCreate(const void *serverHandle,
- const char *processName,
- const char *fileserverPath,
- const char *volserverPath,
- const char *salvagerPath,
- const char *notifier,
+ char *processName,
+ char *fileserverPath,
+ char *volserverPath,
+ char *salvagerPath,
+ char *notifier,
afs_status_p st);
extern int ADMINAPI bos_ProcessDelete(const void *serverHandle,
- const char *processName,
+ char *processName,
afs_status_p st);
extern int ADMINAPI bos_ProcessExecutionStateGet(const void *serverHandle,
- const char *processName,
+ char *processName,
bos_ProcessExecutionState_p
processStatusP,
char *auxiliaryProcessStatus,
extern int ADMINAPI bos_ProcessExecutionStateSet(const void *serverHandle,
const char *processName,
- bos_ProcessExecutionState_t
+ const bos_ProcessExecutionState_t
processStatus,
afs_status_p st);
extern int ADMINAPI bos_ProcessExecutionStateSetTemporary(const void
- *serverHandle, const char
+ *serverHandle, char
*processName,
bos_ProcessExecutionState_t
processStatus,
afs_status_p st);
extern int ADMINAPI bos_ProcessInfoGet(const void *serverHandle,
- const char *processName,
+ char *processName,
bos_ProcessType_p processTypeP,
bos_ProcessInfo_p processInfoP,
afs_status_p st);
CacheManagerStart(unsigned timeout, afs_status_p st)
{
int rc = 1;
- afs_status_t tst2, tst = 0;
+#ifdef AFS_NT40_ENV
+ afs_status_t tst2;
+#endif
+ afs_status_t tst = 0;
#ifdef AFS_NT40_ENV
/* Windows - cache manager is a service */
CacheManagerStop(unsigned timeout, afs_status_p st)
{
int rc = 1;
- afs_status_t tst2, tst = 0;
+#ifdef AFS_NT40_ENV
+ afs_status_t tst2;
+#endif
+ afs_status_t tst = 0;
#ifdef AFS_NT40_ENV
/* Windows - cache manager is a service */
afs_status_p st)
{ /* completion status */
int rc = 1;
- afs_status_t tst2, tst = 0;
+ afs_status_t tst = 0;
+#ifdef AFS_NT40_ENV
+ afs_status_t tst2;
cfg_host_p cfg_host = (cfg_host_p) hostHandle;
+#endif
#ifdef AFS_NT40_ENV
/* validate parameters */
afs_status_p st)
{ /* completion status */
int rc = 1;
- afs_status_t tst2, tst = 0;
+ afs_status_t tst = 0;
+#ifdef AFS_NT40_ENV
+ afs_status_t tst2;
cfg_host_p cfg_host = (cfg_host_p) hostHandle;
+#endif
#ifdef AFS_NT40_ENV
/* validate parameters */
}
if (!bos_ProcessCreate
- (bosHandle, instance, BOS_PROCESS_SIMPLE, cmd, NULL, NULL, &tst2)
+ (bosHandle, (char *)instance, BOS_PROCESS_SIMPLE, cmd, NULL, NULL, &tst2)
&& tst2 != BZEXISTS) {
/* failed to create instance (and not because existed) */
tst = tst2;
} else
if (!bos_ProcessExecutionStateSet
- (bosHandle, instance, BOS_PROCESS_RUNNING, &tst2)) {
+ (bosHandle, (char *)instance, BOS_PROCESS_RUNNING, &tst2)) {
/* failed to set instance state to running */
tst = tst2;
}
afs_status_t tst2, tst = 0;
if (!bos_FSProcessCreate
- (bosHandle, instance, fileserverExe, volserverExe, salvagerExe, NULL,
+ (bosHandle, (char *)instance, (char *)fileserverExe, (char *)volserverExe, (char *)salvagerExe, NULL,
&tst2) && tst2 != BZEXISTS) {
/* failed to create instance (and not because existed) */
tst = tst2;
/* failed to wait for process to stop */
tst = tst2;
- } else if (!bos_ProcessDelete(bosHandle, instance, &tst2)) {
+ } else if (!bos_ProcessDelete(bosHandle, (char *)instance, &tst2)) {
/* failed to delete instance (or does not exist) */
if (tst2 != BZNOENT) {
tst = tst2;
} else {
int rpcCode;
struct ubik_debug udebugInfo;
- extern int VOTE_Debug(), VOTE_DebugOld();
if ((rpcCode = VOTE_Debug(serverConn, &udebugInfo)) == 0) {
/* talking to a 3.5 or later server */
#endif /* AFS_DARWIN_ENV */
void
-Usage()
+Usage(void)
{
fprintf(stderr, "Usage: cm_list_cells <host> <port>\n");
exit(1);
#endif /* AFS_DARWIN_ENV */
void
-Usage()
+Usage(void)
{
fprintf(stderr, "Usage: cm_local_cell <host> <port>\n");
exit(1);
#endif /* AFS_DARWIN_ENV */
void
-Usage()
+Usage(void)
{
fprintf(stderr, "Usage: cm_server_prefs <host> <port>\n");
exit(1);
#endif /* AFS_DARWIN_ENV */
void
-Usage()
+Usage(void)
{
fprintf(stderr, "Usage: rxdebug_basic_stats <host> <port>\n");
exit(1);
#endif /* AFS_DARWIN_ENV */
void
-Usage()
+Usage(void)
{
fprintf(stderr, "Usage: rxdebug_conns <host> <port>\n");
exit(1);
#endif /* AFS_DARWIN_ENV */
void
-Usage()
+Usage(void)
{
fprintf(stderr, "Usage: rxdebug_peers <host> <port>\n");
exit(1);
void *iterator;
struct rx_debugPeer peer;
afs_uint32 supportedValues;
- int i;
ParseArgs(argc, argv, &srvrName, &srvrPort);
#endif /* AFS_DARWIN_ENV */
void
-Usage()
+Usage(void)
{
fprintf(stderr, "Usage: rxdebug_rx_stats <host> <port>\n");
exit(1);
#endif /* AFS_DARWIN_ENV */
void
-Usage()
+Usage(void)
{
fprintf(stderr, "Usage: rxdebug_version <host> <port>\n");
exit(1);
extern int RXSTATS_EnableProcessRPCStats();
void
-Usage()
+Usage(void)
{
fprintf(stderr, "Usage: rxstat_enable_process <cell> <host> <port>\n");
exit(1);
extern int RXSTATS_QueryProcessRPCStats();
void
-Usage()
+Usage(void)
{
fprintf(stderr, "Usage: rxstat_query_process <host> <port>\n");
exit(1);
{
afs_status_t st = 0;
int no_auth = 0;
- int auth = 0;
char auth_cell[MAXCELLCHARS];
char exec_cell[MAXCELLCHARS];
{
int code;
afs_status_t st;
- char *whoami = argv[0];
/* perform client initialization */
#include <afsconfig.h>
#include <afs/param.h>
+#include <ctype.h>
#include "bos.h"
"sat"
};
-static
+static int
LocalFreeTokens(struct token *alist)
{
register struct token *nlist;
return 0;
}
-static
+static int
space(int x)
{
if (x == 0 || x == ' ' || x == '\t' || x == '\n')
return 0;
}
-static
+static int
LocalParseLine(char *aline, struct token **alist)
{
char tbuffer[256];
char *key;
afs_int32 value;
} ptkeys[] = {
-"sun", 0x10000, "mon", 0x10001, "tue", 0x10002, "wed", 0x10003, "thu",
- 0x10004, "fri", 0x10005, "sat", 0x10006, "sunday", 0x10000,
- "monday", 0x10001, "tuesday", 0x10002, "wednesday", 0x10003,
- "thursday", 0x10004, "thur", 0x10004, "friday", 0x10005,
- "saturday", 0x10006, "am", 0x20000, "pm", 0x20001, "a.m.",
- 0x20000, "p.m.", 0x20001, 0, 0,};
-
-static
+ {"sun", 0x10000}, {"mon", 0x10001}, {"tue", 0x10002},
+ {"wed", 0x10003}, {"thu", 0x10004}, {"fri", 0x10005},
+ {"sat", 0x10006},
+ {"sunday", 0x10000}, {"monday", 0x10001},
+ {"tuesday", 0x10002}, {"wednesday", 0x10003},
+ {"thursday", 0x10004}, {"thur", 0x10004},
+ {"friday", 0x10005}, {"saturday", 0x10006},
+ {"am", 0x20000}, {"pm", 0x20001},
+ {"a.m.", 0x20000}, {"p.m.", 0x20001}, {0, 0}};
+
+static int
ParseTime(bos_RestartTime_p ak, char *astr)
{
int field;
}
if (!bos_ProcessCreate
- (bos_server, process, process_type, binary, cron_time, notifier,
+ (bos_server, (char *)process, process_type, (char *)binary, (char *)cron_time, (char *)notifier,
&st)) {
ERR_ST_EXT("bos_ProcessCreate", st);
}
}
if (!bos_FSProcessCreate
- (bos_server, process, fileserver, volserver, salvager, notifier,
+ (bos_server, (char *)process, (char *)fileserver, (char *)volserver, (char *)salvager, (char *)notifier,
&st)) {
ERR_ST_EXT("bos_FSProcessCreate", st);
}
process = as->parms[PROCESS].items->data;
}
- if (!bos_ProcessDelete(bos_server, process, &st)) {
+ if (!bos_ProcessDelete(bos_server, (char *)process, &st)) {
ERR_ST_EXT("bos_ProcessDelete", st);
}
}
if (!bos_ProcessExecutionStateGet
- (bos_server, process, &state, aux_status, &st)) {
+ (bos_server, (char *)process, &state, aux_status, &st)) {
ERR_ST_EXT("bos_ProcessExecutionStateGet", st);
}
}
if (!bos_ProcessExecutionStateSetTemporary
- (bos_server, process, state, &st)) {
+ (bos_server, (char *)process, state, &st)) {
ERR_ST_EXT("bos_ProcessExecutionStateSetTemporary", st);
}
process = as->parms[PROCESS].items->data;
}
- if (!bos_ProcessInfoGet(bos_server, process, &type, &info, &st)) {
+ if (!bos_ProcessInfoGet(bos_server, (char *)process, &type, &info, &st)) {
ERR_ST_EXT("bos_ProcessInfoGet", st);
}
#include <afs/cellconfig.h>
#include <afs/bosint.h>
#include <rx/rxstat.h>
+#include <rx/rxstat_prototypes.h>
#include <afs/afsint.h>
#define FSINT_COMMON_XG
#include <afs/afscbint.h>
#include <pthread.h>
#endif
-/* These aren't coming from a header, currently, so they must stay here.
- Fix elsewhere, or leave alone. */
-extern int RXSTATS_RetrieveProcessRPCStats();
-extern int RXSTATS_RetrievePeerRPCStats();
-extern int RXSTATS_QueryProcessRPCStats();
-extern int RXSTATS_QueryPeerRPCStats();
-extern int RXSTATS_EnableProcessRPCStats();
-extern int RXSTATS_EnablePeerRPCStats();
-extern int RXSTATS_DisableProcessRPCStats();
-extern int RXSTATS_DisablePeerRPCStats();
-extern int RXSTATS_ClearProcessRPCStats();
-extern int RXSTATS_ClearPeerRPCStats();
-
/*
* This structure stores the client and server function lists.
* This is kept separate from the actual interface definitions
} DoClientRPCStatsStateGet_parm_t;
afs_status_t st = 0;
struct rx_connection *conn;
- int servAddr = 0;
afs_stat_source_t type;
int srvrPort;
int typeIsValid = 0;
typedef enum { SERVER, PROCESS, STAT_TYPE } DoClientRPCStatsEnable_parm_t;
afs_status_t st = 0;
struct rx_connection *conn;
- int servAddr = 0;
afs_stat_source_t type;
int srvrPort;
int typeIsValid = 0;
} DoClientRPCStatsDisable_parm_t;
afs_status_t st = 0;
struct rx_connection *conn;
- int servAddr = 0;
afs_stat_source_t type;
int srvrPort;
int typeIsValid = 0;
typedef enum { SERVER, PROCESS, STAT_TYPE } DoClientRPCStatsList_parm_t;
afs_status_t st = 0;
struct rx_connection *conn;
- int servAddr = 0;
afs_stat_source_t type;
int srvrPort;
int typeIsValid = 0;
} DoClientRPCStatsClear_parm_t;
afs_status_t st = 0;
struct rx_connection *conn;
- int servAddr = 0;
afs_stat_source_t type;
int srvrPort;
int typeIsValid = 0;
afs_status_t st = 0;
struct rx_connection *conn;
afs_stat_source_t type;
- int servAddr = 0;
int srvrPort;
int typeIsValid = 0;
afs_RPCStatsVersion_t version;
afs_status_t st = 0;
typedef enum { SERVER, PORT } DoClientCMGetServerPrefs_parm_t;
struct rx_connection *conn;
- int servAddr = 0;
int srvrPort = AFSCONF_CALLBACKPORT;
afs_CMServerPref_t prefs;
void *iter;
afs_status_t st = 0;
typedef enum { SERVER, PORT } DoClientCMListCells_parm_t;
struct rx_connection *conn;
- int servAddr = 0;
int srvrPort = AFSCONF_CALLBACKPORT;
afs_CMListCell_t cellInfo;
void *iter;
afs_status_t st = 0;
typedef enum { SERVER, PORT } DoClientCMLocalCell_parm_t;
struct rx_connection *conn;
- int servAddr = 0;
int srvrPort = AFSCONF_CALLBACKPORT;
afs_CMCellName_t cellname;
afs_status_t st = 0;
typedef enum { SERVER, PORT } DoClientCMLocalCell_parm_t;
struct rx_connection *conn;
- int servAddr = 0;
int srvrPort = AFSCONF_CALLBACKPORT;
afs_ClientConfig_t config;
PASSWORD
} DoKasPrincipalCreate_parm_t;
afs_status_t st = 0;
- const char *instance = NULL;
kas_identity_t user;
const char *password;
{
typedef enum { PRINCIPAL, INSTANCE } DoKasPrincipalGet_parm_t;
afs_status_t st = 0;
- const char *instance = NULL;
kas_identity_t user;
strcpy(user.principal, as->parms[PRINCIPAL].items->data);
{
typedef enum { PRINCIPAL, INSTANCE } DoKasPrincipalGet_parm_t;
afs_status_t st = 0;
- const char *instance = NULL;
kas_identity_t user;
kas_principalEntry_t principal;
typedef enum { PRINCIPAL, INSTANCE } DoKasPrincipalUnlock_parm_t;
afs_status_t st = 0;
kas_identity_t user;
- unsigned int lock_end_time = 0;
strcpy(user.principal, as->parms[PRINCIPAL].items->data);
#include <afs/volser.h>
#include <afs/volint.h>
#include "../../volser/lockdata.h"
-#include "../../vlserver/vlclient.h"
+#include <afs/vldbint.h>
#include <afs/com_err.h>
#include <rx/rxkad.h>
#include <afs/kautils.h>
#define CLOCKSKEW 2 /* not really skew, but resolution */
-extern int ubik_Call();
-extern int ubik_Call_New();
-
-
extern int UV_NukeVolume(afs_cell_handle_p cellHandle,
struct rx_connection *server, unsigned int partition,
afs_uint32 volumeId, afs_status_p st);