#include <afsconfig.h>
#include <afs/param.h>
-
+#include <roken.h>
#include <sys/types.h>
#include <stdio.h>
#endif
#include <sys/stat.h>
#include <signal.h>
-#include "rx_clock.h"
-#include "rx.h"
-#include "rx_globals.h"
-#include "rx_null.h"
+#include <rx/rx_clock.h>
+#include <rx/rx.h>
+#include <rx/rx_globals.h>
+#include <rx/rx_null.h>
#include <errno.h>
#include <afs/afsutil.h>
int timeout;
struct clock waitTime, computeTime;
-void OpenFD();
+void OpenFD(int n);
+void Abort(const char *msg, ...);
+void Quit(char *msg);
+int SendFile(char *file, struct rx_connection *conn);
void
intSignal(int ignore)
Quit("testclient: done!\n");
}
-int SendFile(file, conn)
- char *file;
- struct rx_connection *conn;
+int
+SendFile(char *file, struct rx_connection *conn)
{
struct rx_call *call;
int fd;
return(0);
}
-Abort(msg, a, b, c, d, e)
+void
+Abort(char *msg, ...)
{
- printf((char *)msg, a, b, c, d, e);
+ va_list args;
+
+ va_start(args, msg);
+ printf((char *)msg, args);
+ va_end(args);
+
printf("\n");
if (debugFile) {
rx_PrintStats(debugFile);
exit(1);
}
-Quit(char *msg, int a, int b, int c, int d, int e)
+void
+Quit(char *msg)
{
- printf((char *)msg, a, b, c, d, e);
- printf("\n");
+ printf("%s\n", msg);
if (debugFile) {
rx_PrintStats(debugFile);
fflush(debugFile);
*/
#include <sys/stat.h>
void
-OpenFD(n)
- int n;
+OpenFD(int n)
{
int i;
struct stat sbuf;
#include <afsconfig.h>
#include <afs/param.h>
-
+#include <roken.h>
#include <sys/types.h>
#include <stdio.h>
#endif
#include <signal.h>
#include <sys/stat.h>
-#include "rx_clock.h"
-#include "rx.h"
-#include "rx_globals.h"
-#include "rx_null.h"
+#include <rx/rx_clock.h>
+#include <rx/rx.h>
+#include <rx/rx_globals.h>
+#include <rx/rx_null.h>
int error; /* Return this error number on a call */
int print = 0, eventlog = 0, rxlog = 0;
char *rcvFile;
int logstdout = 0;
-void Abort(char *msg, int a, int b, int c, int d, int e);
-void Quit(char *msg, int a, int b, int c, int d, int e);
+void Abort(char *msg, ...);
+void Quit(char *msg);
void OpenFD(int n);
int FileRequest(struct rx_call *call);
int SimpleRequest(struct rx_call *call);
void
intSignal(int ignore)
{
- Quit("Interrupted",0,0,0,0,0);
+ Quit("Interrupted");
}
void
{
static int quitCount = 0;
if (++quitCount > 1)
- Quit("rx_ctest: second quit signal, aborting",0,0,0,0,0);
+ Quit("rx_ctest: second quit signal, aborting");
rx_debugFile = debugFile = fopen("rx_stest.db", "w");
if (debugFile)
rx_PrintStats(debugFile);
argv++, argc--;
}
if (err || argc != 0)
- Quit("usage: rx_stest [-silent] [-rxlog] [-eventlog]",0,0,0,0,0);
+ Quit("usage: rx_stest [-silent] [-rxlog] [-eventlog]");
if (rxlog || eventlog) {
if (logstdout)
else
debugFile = fopen("rx_stest.db", "w");
if (debugFile == NULL)
- Quit("Couldn't open rx_stest.db",0,0,0,0,0);
+ Quit("Couldn't open rx_stest.db");
if (rxlog)
rx_debugFile = debugFile;
if (eventlog)
1, /*Execute request */
rcvFile ? FileRequest : SimpleRequest);
if (!service)
- Abort("rx_NewService returned 0!\n",0,0,0,0,0);
+ Abort("rx_NewService returned 0!\n");
rx_SetMinProcs(service, 2);
rx_SetMaxProcs(service, 100);
t.tv_usec = computeTime.usec;
#ifdef AFS_PTHREAD_ENV
if (select(0, 0, 0, 0, &t) != 0)
- Quit("Select didn't return 0",0,0,0,0,0);
+ Quit("Select didn't return 0");
#else
IOMGR_Sleep(t.tv_sec);
#endif
while (nbytes = rx_Read(call, buffer, blockSize)) {
if (write(fd, buffer, nbytes) != nbytes) {
perror("writev");
- Abort("Write Failed.\n",0,0,0,0,0);
+ Abort("Write Failed.\n");
break;
}
}
}
void
-Abort(char *msg, int a, int b, int c, int d, int e)
+Abort(char *msg, ...)
{
- printf((char *)msg, a, b, c, d, e);
+ va_list args;
+
+ va_start(args, msg);
+ printf((char *)msg, args);
+ va_end(args);
+
printf("\n");
if (debugFile) {
rx_PrintStats(debugFile);
fflush(debugFile);
}
- abort();
+ afs_abort();
+ exit(1);
}
void
-Quit(char *msg, int a, int b, int c, int d, int e)
+Quit(char *msg)
{
- printf((char *)msg, a, b, c, d, e);
- printf("\n");
+ printf("%s\n", msg);
if (debugFile) {
rx_PrintStats(debugFile);
fflush(debugFile);