afs_stat_type_t which = 0;
afs_RPCStatsState_t state;
- if (as->parms[PROCESS].items) {
- typeIsValid =
- GetStatSourceFromString(as->parms[PROCESS].items->data, &type,
- &srvrPort);
- }
+ typeIsValid = GetStatSourceFromString(as->parms[PROCESS].items->data,
+ &type, &srvrPort);
- if (as->parms[STAT_TYPE].items) {
- which = GetStatTypeFromString(as->parms[STAT_TYPE].items->data);
- }
+ which = GetStatTypeFromString(as->parms[STAT_TYPE].items->data);
- if (as->parms[SERVER].items) {
- if (typeIsValid) {
- if (!afsclient_RPCStatOpen
- (cellHandle, as->parms[SERVER].items->data, type, &conn,
- &st)) {
- ERR_ST_EXT("afsclient_RPCStatOpen", st);
- }
- } else {
- if (!afsclient_RPCStatOpenPort
- (cellHandle, as->parms[SERVER].items->data, srvrPort, &conn,
- &st)) {
- ERR_ST_EXT("afsclient_RPCStatOpenPort", st);
- }
+ if (typeIsValid) {
+ if (!afsclient_RPCStatOpen(cellHandle,
+ as->parms[SERVER].items->data,
+ type, &conn, &st)) {
+ ERR_ST_EXT("afsclient_RPCStatOpen", st);
+ }
+ } else {
+ if (!afsclient_RPCStatOpenPort(cellHandle,
+ as->parms[SERVER].items->data,
+ srvrPort, &conn, &st)) {
+ ERR_ST_EXT("afsclient_RPCStatOpenPort", st);
}
}
struct rx_connection *conn;
afs_stat_source_t type;
int srvrPort;
- int typeIsValid = 0;
- afs_stat_type_t which = 0;
+ int typeIsValid;
+ afs_stat_type_t which;
- if (as->parms[PROCESS].items) {
- typeIsValid =
- GetStatSourceFromString(as->parms[PROCESS].items->data, &type,
- &srvrPort);
- }
+ typeIsValid = GetStatSourceFromString(as->parms[PROCESS].items->data,
+ &type, &srvrPort);
- if (as->parms[STAT_TYPE].items) {
- which = GetStatTypeFromString(as->parms[STAT_TYPE].items->data);
- }
+ which = GetStatTypeFromString(as->parms[STAT_TYPE].items->data);
- if (as->parms[SERVER].items) {
- if (typeIsValid) {
- if (!afsclient_RPCStatOpen
- (cellHandle, as->parms[SERVER].items->data, type, &conn,
- &st)) {
- ERR_ST_EXT("afsclient_RPCStatOpen", st);
- }
- } else {
- if (!afsclient_RPCStatOpenPort
- (cellHandle, as->parms[SERVER].items->data, srvrPort, &conn,
- &st)) {
- ERR_ST_EXT("afsclient_RPCStatOpenPort", st);
- }
+ if (typeIsValid) {
+ if (!afsclient_RPCStatOpen(cellHandle,
+ as->parms[SERVER].items->data,
+ type, &conn, &st)) {
+ ERR_ST_EXT("afsclient_RPCStatOpen", st);
+ }
+ } else {
+ if (!afsclient_RPCStatOpenPort(cellHandle,
+ as->parms[SERVER].items->data,
+ srvrPort, &conn, &st)) {
+ ERR_ST_EXT("afsclient_RPCStatOpenPort", st);
}
}
struct rx_connection *conn;
afs_stat_source_t type;
int srvrPort;
- int typeIsValid = 0;
- afs_stat_type_t which = 0;
+ int typeIsValid;
+ afs_stat_type_t which;
- if (as->parms[PROCESS].items) {
- typeIsValid =
- GetStatSourceFromString(as->parms[PROCESS].items->data, &type,
- &srvrPort);
- }
+ typeIsValid = GetStatSourceFromString(as->parms[PROCESS].items->data,
+ &type, &srvrPort);
- if (as->parms[STAT_TYPE].items) {
- which = GetStatTypeFromString(as->parms[STAT_TYPE].items->data);
- }
+ which = GetStatTypeFromString(as->parms[STAT_TYPE].items->data);
- if (as->parms[SERVER].items) {
- if (typeIsValid) {
- if (!afsclient_RPCStatOpen
- (cellHandle, as->parms[SERVER].items->data, type, &conn,
- &st)) {
- ERR_ST_EXT("afsclient_RPCStatOpen", st);
- }
- } else {
- if (!afsclient_RPCStatOpenPort
- (cellHandle, as->parms[SERVER].items->data, srvrPort, &conn,
- &st)) {
- ERR_ST_EXT("afsclient_RPCStatOpenPort", st);
- }
+ if (typeIsValid) {
+ if (!afsclient_RPCStatOpen(cellHandle,
+ as->parms[SERVER].items->data,
+ type, &conn, &st)) {
+ ERR_ST_EXT("afsclient_RPCStatOpen", st);
+ }
+ } else {
+ if (!afsclient_RPCStatOpenPort(cellHandle,
+ as->parms[SERVER].items->data,
+ srvrPort, &conn, &st)) {
+ ERR_ST_EXT("afsclient_RPCStatOpenPort", st);
}
}
struct rx_connection *conn;
afs_stat_source_t type;
int srvrPort;
- int typeIsValid = 0;
- afs_stat_type_t which = 0;
+ int typeIsValid;
+ afs_stat_type_t which;
afs_RPCStats_t stats;
void *iter;
int i = 0;
|| pthread_once(&pthread_func_list_once, cr_list));
#endif
- if (as->parms[PROCESS].items) {
- typeIsValid =
- GetStatSourceFromString(as->parms[PROCESS].items->data, &type,
- &srvrPort);
- }
+ typeIsValid = GetStatSourceFromString(as->parms[PROCESS].items->data,
+ &type, &srvrPort);
- if (as->parms[STAT_TYPE].items) {
- which = GetStatTypeFromString(as->parms[STAT_TYPE].items->data);
- }
+ which = GetStatTypeFromString(as->parms[STAT_TYPE].items->data);
- if (as->parms[SERVER].items) {
- if (typeIsValid) {
- if (!afsclient_RPCStatOpen
- (cellHandle, as->parms[SERVER].items->data, type, &conn,
- &st)) {
- ERR_ST_EXT("afsclient_RPCStatOpen", st);
- }
- } else {
- if (!afsclient_RPCStatOpenPort
- (cellHandle, as->parms[SERVER].items->data, srvrPort, &conn,
- &st)) {
- ERR_ST_EXT("afsclient_RPCStatOpenPort", st);
- }
+ if (typeIsValid) {
+ if (!afsclient_RPCStatOpen(cellHandle,
+ as->parms[SERVER].items->data,
+ type, &conn, &st)) {
+ ERR_ST_EXT("afsclient_RPCStatOpen", st);
+ }
+ } else {
+ if (!afsclient_RPCStatOpenPort(cellHandle,
+ as->parms[SERVER].items->data,
+ srvrPort, &conn, &st)) {
+ ERR_ST_EXT("afsclient_RPCStatOpenPort", st);
}
}
struct rx_connection *conn;
afs_stat_source_t type;
int srvrPort;
- int typeIsValid = 0;
- afs_stat_type_t which = 0;
+ int typeIsValid;
+ afs_stat_type_t which;
afs_RPCStatsClearFlag_t flag = 0;
int seen_all = 0;
int seen_any = 0;
- if (as->parms[PROCESS].items) {
- typeIsValid =
- GetStatSourceFromString(as->parms[PROCESS].items->data, &type,
- &srvrPort);
- }
+ typeIsValid = GetStatSourceFromString(as->parms[PROCESS].items->data,
+ &type, &srvrPort);
- if (as->parms[STAT_TYPE].items) {
- which = GetStatTypeFromString(as->parms[STAT_TYPE].items->data);
- }
+ which = GetStatTypeFromString(as->parms[STAT_TYPE].items->data);
- if (as->parms[SERVER].items) {
- if (typeIsValid) {
- if (!afsclient_RPCStatOpen
- (cellHandle, as->parms[SERVER].items->data, type, &conn,
- &st)) {
- ERR_ST_EXT("afsclient_RPCStatOpen", st);
- }
- } else {
- if (!afsclient_RPCStatOpenPort
- (cellHandle, as->parms[SERVER].items->data, srvrPort, &conn,
- &st)) {
- ERR_ST_EXT("afsclient_RPCStatOpenPort", st);
- }
+ if (typeIsValid) {
+ if (!afsclient_RPCStatOpen(cellHandle,
+ as->parms[SERVER].items->data,
+ type, &conn, &st)) {
+ ERR_ST_EXT("afsclient_RPCStatOpen", st);
+ }
+ } else {
+ if (!afsclient_RPCStatOpenPort(cellHandle,
+ as->parms[SERVER].items->data,
+ srvrPort, &conn, &st)) {
+ ERR_ST_EXT("afsclient_RPCStatOpenPort", st);
}
}
struct rx_connection *conn;
afs_stat_source_t type;
int srvrPort;
- int typeIsValid = 0;
+ int typeIsValid;
afs_RPCStatsVersion_t version;
- if (as->parms[PROCESS].items) {
- typeIsValid =
- GetStatSourceFromString(as->parms[PROCESS].items->data, &type,
- &srvrPort);
- }
+ typeIsValid = GetStatSourceFromString(as->parms[PROCESS].items->data,
+ &type, &srvrPort);
- if (as->parms[SERVER].items) {
- if (typeIsValid) {
- if (!afsclient_RPCStatOpen
- (cellHandle, as->parms[SERVER].items->data, type, &conn,
- &st)) {
- ERR_ST_EXT("afsclient_RPCStatOpen", st);
- }
- } else {
- if (!afsclient_RPCStatOpenPort
- (cellHandle, as->parms[SERVER].items->data, srvrPort, &conn,
- &st)) {
- ERR_ST_EXT("afsclient_RPCStatOpenPort", st);
- }
+ if (typeIsValid) {
+ if (!afsclient_RPCStatOpen(cellHandle,
+ as->parms[SERVER].items->data,
+ type, &conn, &st)) {
+ ERR_ST_EXT("afsclient_RPCStatOpen", st);
+ }
+ } else {
+ if (!afsclient_RPCStatOpenPort(cellHandle,
+ as->parms[SERVER].items->data,
+ srvrPort, &conn, &st)) {
+ ERR_ST_EXT("afsclient_RPCStatOpenPort", st);
}
}
}
}
- if (as->parms[SERVER].items) {
- if (!afsclient_CMStatOpenPort
- (cellHandle, as->parms[SERVER].items->data, srvrPort, &conn,
- &st)) {
- ERR_ST_EXT("afsclient_CMStatOpenPort", st);
- }
+ if (!afsclient_CMStatOpenPort(cellHandle,
+ as->parms[SERVER].items->data,
+ srvrPort, &conn, &st)) {
+ ERR_ST_EXT("afsclient_CMStatOpenPort", st);
}
if (!util_CMGetServerPrefsBegin(conn, &iter, &st)) {
}
}
- if (as->parms[SERVER].items) {
- if (!afsclient_CMStatOpenPort
- (cellHandle, as->parms[SERVER].items->data, srvrPort, &conn,
- &st)) {
- ERR_ST_EXT("afsclient_CMStatOpenPort", st);
- }
+ if (!afsclient_CMStatOpenPort(cellHandle,
+ as->parms[SERVER].items->data,
+ srvrPort, &conn, &st)) {
+ ERR_ST_EXT("afsclient_CMStatOpenPort", st);
}
if (!util_CMListCellsBegin(conn, &iter, &st)) {
}
}
- if (as->parms[SERVER].items) {
- if (!afsclient_CMStatOpenPort
- (cellHandle, as->parms[SERVER].items->data, srvrPort, &conn,
- &st)) {
- ERR_ST_EXT("afsclient_CMStatOpenPort", st);
- }
+ if (!afsclient_CMStatOpenPort(cellHandle,
+ as->parms[SERVER].items->data,
+ srvrPort, &conn, &st)) {
+ ERR_ST_EXT("afsclient_CMStatOpenPort", st);
}
if (!util_CMLocalCell(conn, cellname, &st)) {
}
}
- if (as->parms[SERVER].items) {
- if (!afsclient_CMStatOpenPort
- (cellHandle, as->parms[SERVER].items->data, srvrPort, &conn,
- &st)) {
- ERR_ST_EXT("afsclient_CMStatOpenPort", st);
- }
+ if (!afsclient_CMStatOpenPort(cellHandle,
+ as->parms[SERVER].items->data,
+ srvrPort, &conn, &st)) {
+ ERR_ST_EXT("afsclient_CMStatOpenPort", st);
}
if (!util_CMClientConfig(conn, &config, &st)) {