| /* |
| Copyright (C) 1993-2005 Hewlett-Packard Company |
| */ |
| |
| #ifdef HAVE_CONFIG_H |
| #include "config.h" |
| #endif |
| |
| #if defined(HAVE_SYS_SOCKET_H) |
| # include <sys/socket.h> |
| #endif |
| #if defined(HAVE_NETDB_H) |
| # include <netdb.h> |
| #endif |
| #if !defined(HAVE_GETADDRINFO) || !defined(HAVE_GETNAMEINFO) |
| # include "missing/getaddrinfo.h" |
| #endif |
| |
| #define PAD_TIME 4 |
| /* library routine specifc defines */ |
| #define MAXSPECDATA 62 /* how many ints worth of data */ |
| /* can tests send... */ |
| #define MAXTIMES 4 /* how many times may we loop */ |
| /* to calibrate */ |
| #define MAXCPUS 256 /* how many CPU's can we track */ |
| #define MAXMESSAGESIZE 65536 |
| #define MAXALIGNMENT 16384 |
| #define MAXOFFSET 4096 |
| #define DATABUFFERLEN MAXMESSAGESIZE+MAXALIGNMENT+MAXOFFSET |
| |
| #define DEBUG_ON 1 |
| #define DEBUG_OFF 2 |
| #define DEBUG_OK 3 |
| #define NODE_IDENTIFY 4 |
| #define CPU_CALIBRATE 5 |
| |
| #define DO_TCP_STREAM 10 |
| #define TCP_STREAM_RESPONSE 11 |
| #define TCP_STREAM_RESULTS 12 |
| |
| #define DO_TCP_RR 13 |
| #define TCP_RR_RESPONSE 14 |
| #define TCP_RR_RESULTS 15 |
| |
| #define DO_UDP_STREAM 16 |
| #define UDP_STREAM_RESPONSE 17 |
| #define UDP_STREAM_RESULTS 18 |
| |
| #define DO_UDP_RR 19 |
| #define UDP_RR_RESPONSE 20 |
| #define UDP_RR_RESULTS 21 |
| |
| #define DO_DLPI_CO_STREAM 22 |
| #define DLPI_CO_STREAM_RESPONSE 23 |
| #define DLPI_CO_STREAM_RESULTS 24 |
| |
| #define DO_DLPI_CO_RR 25 |
| #define DLPI_CO_RR_RESPONSE 26 |
| #define DLPI_CO_RR_RESULTS 27 |
| |
| #define DO_DLPI_CL_STREAM 28 |
| #define DLPI_CL_STREAM_RESPONSE 29 |
| #define DLPI_CL_STREAM_RESULTS 30 |
| |
| #define DO_DLPI_CL_RR 31 |
| #define DLPI_CL_RR_RESPONSE 32 |
| #define DLPI_CL_RR_RESULTS 33 |
| |
| #define DO_TCP_CRR 34 |
| #define TCP_CRR_RESPONSE 35 |
| #define TCP_CRR_RESULTS 36 |
| |
| #define DO_STREAM_STREAM 37 |
| #define STREAM_STREAM_RESPONSE 38 |
| #define STREAM_STREAM_RESULTS 39 |
| |
| #define DO_STREAM_RR 40 |
| #define STREAM_RR_RESPONSE 41 |
| #define STREAM_RR_RESULTS 42 |
| |
| #define DO_DG_STREAM 43 |
| #define DG_STREAM_RESPONSE 44 |
| #define DG_STREAM_RESULTS 45 |
| |
| #define DO_DG_RR 46 |
| #define DG_RR_RESPONSE 47 |
| #define DG_RR_RESULTS 48 |
| |
| #define DO_FORE_STREAM 49 |
| #define FORE_STREAM_RESPONSE 50 |
| #define FORE_STREAM_RESULTS 51 |
| |
| #define DO_FORE_RR 52 |
| #define FORE_RR_RESPONSE 53 |
| #define FORE_RR_RESULTS 54 |
| |
| #define DO_HIPPI_STREAM 55 |
| #define HIPPI_STREAM_RESPONSE 56 |
| #define HIPPI_STREAM_RESULTS 57 |
| |
| #define DO_HIPPI_RR 52 |
| #define HIPPI_RR_RESPONSE 53 |
| #define HIPPI_RR_RESULTS 54 |
| |
| #define DO_XTI_TCP_STREAM 55 |
| #define XTI_TCP_STREAM_RESPONSE 56 |
| #define XTI_TCP_STREAM_RESULTS 57 |
| |
| #define DO_XTI_TCP_RR 58 |
| #define XTI_TCP_RR_RESPONSE 59 |
| #define XTI_TCP_RR_RESULTS 60 |
| |
| #define DO_XTI_UDP_STREAM 61 |
| #define XTI_UDP_STREAM_RESPONSE 62 |
| #define XTI_UDP_STREAM_RESULTS 63 |
| |
| #define DO_XTI_UDP_RR 64 |
| #define XTI_UDP_RR_RESPONSE 65 |
| #define XTI_UDP_RR_RESULTS 66 |
| |
| #define DO_XTI_TCP_CRR 67 |
| #define XTI_TCP_CRR_RESPONSE 68 |
| #define XTI_TCP_CRR_RESULTS 69 |
| |
| #define DO_TCP_TRR 70 |
| #define TCP_TRR_RESPONSE 71 |
| #define TCP_TRR_RESULTS 72 |
| |
| #define DO_TCP_NBRR 73 |
| #define TCP_NBRR_RESPONSE 74 |
| #define TCP_NBRR_RESULTS 75 |
| |
| #define DO_TCPIPV6_STREAM 76 |
| #define TCPIPV6_STREAM_RESPONSE 77 |
| #define TCPIPV6_STREAM_RESULTS 78 |
| |
| #define DO_TCPIPV6_RR 79 |
| #define TCPIPV6_RR_RESPONSE 80 |
| #define TCPIPV6_RR_RESULTS 81 |
| |
| #define DO_UDPIPV6_STREAM 82 |
| #define UDPIPV6_STREAM_RESPONSE 83 |
| #define UDPIPV6_STREAM_RESULTS 84 |
| |
| #define DO_UDPIPV6_RR 85 |
| #define UDPIPV6_RR_RESPONSE 86 |
| #define UDPIPV6_RR_RESULTS 87 |
| |
| #define DO_TCPIPV6_CRR 88 |
| #define TCPIPV6_CRR_RESPONSE 89 |
| #define TCPIPV6_CRR_RESULTS 90 |
| |
| #define DO_TCPIPV6_TRR 91 |
| #define TCPIPV6_TRR_RESPONSE 92 |
| #define TCPIPV6_TRR_RESULTS 93 |
| |
| #define DO_TCP_MAERTS 94 |
| #define TCP_MAERTS_RESPONSE 95 |
| #define TCP_MAERTS_RESULTS 96 |
| |
| #define DO_LWPSTR_STREAM 100 |
| #define LWPSTR_STREAM_RESPONSE 110 |
| #define LWPSTR_STREAM_RESULTS 120 |
| |
| #define DO_LWPSTR_RR 130 |
| #define LWPSTR_RR_RESPONSE 140 |
| #define LWPSTR_RR_RESULTS 150 |
| |
| #define DO_LWPDG_STREAM 160 |
| #define LWPDG_STREAM_RESPONSE 170 |
| #define LWPDG_STREAM_RESULTS 180 |
| |
| #define DO_LWPDG_RR 190 |
| #define LWPDG_RR_RESPONSE 200 |
| #define LWPDG_RR_RESULTS 210 |
| |
| #define DO_TCP_CC 300 |
| #define TCP_CC_RESPONSE 301 |
| #define TCP_CC_RESULTS 302 |
| |
| /* The DNS_RR test has been removed from netperf but we leave these |
| here for historical purposes. Those wanting to do DNS_RR tests |
| should use netperf4 instead. */ |
| #define DO_DNS_RR 400 |
| #define DNS_RR_RESPONSE 401 |
| #define DNS_RR_RESULTS 402 |
| |
| #define DO_SCTP_STREAM 500 |
| #define SCTP_STREAM_RESPONSE 501 |
| #define SCTP_STREAM_RESULT 502 |
| |
| #define DO_SCTP_STREAM_MANY 510 |
| #define SCTP_STREAM_MANY_RESPONSE 511 |
| #define SCTP_STREAM_MANY_RESULT 512 |
| |
| #define DO_SCTP_RR 520 |
| #define SCTP_RR_RESPONSE 521 |
| #define SCTP_RR_RESULT 502 |
| |
| #define DO_SCTP_RR_MANY 530 |
| #define SCTP_RR_MANY_RESPONSE 531 |
| #define SCTP_RR_MANY_RESULT 532 |
| |
| #define DO_SDP_STREAM 540 |
| #define SDP_STREAM_RESPONSE 541 |
| #define SDP_STREAM_RESULTS 542 |
| |
| #define DO_SDP_RR 543 |
| #define SDP_RR_RESPONSE 544 |
| #define SDP_RR_RESULTS 545 |
| |
| #define DO_SDP_MAERTS 546 |
| #define SDP_MAERTS_RESPONSE 547 |
| #define SDP_MAERTS_RESULTS 548 |
| |
| #define DO_SDP_CRR 549 |
| #define SDP_CRR_RESPONSE 550 |
| #define SDP_CRR_RESULTS 551 |
| |
| #define DO_SDP_CC 552 |
| #define SDP_CC_RESPONSE 553 |
| #define SDP_CC_RESULTS 554 |
| |
| #if HAVE_INTTYPES_H |
| # include <inttypes.h> |
| #else |
| # if HAVE_STDINT_H |
| # include <stdint.h> |
| # endif |
| #endif |
| |
| enum sock_buffer{ |
| SEND_BUFFER, |
| RECV_BUFFER |
| }; |
| |
| /* some of the fields in these structures are going to be doubles and */ |
| /* such. so, we probably want to ensure that they will start on */ |
| /* "double" boundaries. this will break compatability to pre-2.1 */ |
| /* releases, but then, backwards compatability has never been a */ |
| /* stated goal of netperf. raj 11/95 */ |
| |
| union netperf_request_struct { |
| struct { |
| int request_type; |
| int dummy; |
| int test_specific_data[MAXSPECDATA]; |
| } content; |
| double dummy; |
| }; |
| |
| union netperf_response_struct { |
| struct { |
| int response_type; |
| int serv_errno; |
| int test_specific_data[MAXSPECDATA]; |
| } content; |
| double dummy; |
| }; |
| |
| struct ring_elt { |
| struct ring_elt *next; /* next element in the ring */ |
| char *buffer_base; /* in case we have to free it at somepoint */ |
| char *buffer_ptr; /* the aligned and offset pointer */ |
| }; |
| |
| /* +*+ SAF Sorry about the hacks with errno; NT made me do it :( |
| |
| WinNT does define an errno. |
| It is mostly a legacy from the XENIX days. |
| |
| Depending upon the version of the C run time that is linked in, it is |
| either a simple variable (like UNIX code expects), but more likely it |
| is the address of a procedure to return the error number. So any |
| code that sets errno is likely to be overwriting the address of this |
| procedure. Worse, only a tiny fraction of NT's errors get set |
| through errno. |
| |
| So I have changed the netperf code to use a define Set_errno when |
| that is it's intent. On non-windows platforms this is just an |
| assignment to errno. But on NT this calls SetLastError. |
| |
| I also define errno (now only used on right side of assignments) |
| on NT to be GetLastError. |
| |
| Similarly, perror is defined on NT, but it only accesses the same |
| XENIX errors that errno covers. So on NT this is redefined to be |
| Perror and it expands all GetLastError texts. */ |
| |
| |
| #ifdef WIN32 |
| /* INVALID_SOCKET == INVALID_HANDLE_VALUE == (unsigned int)(~0) */ |
| /* SOCKET_ERROR == -1 */ |
| #define ENOTSOCK WSAENOTSOCK |
| #define EINTR WSAEINTR |
| #define ENOBUFS WSAENOBUFS |
| #define EWOULDBLOCK WSAEWOULDBLOCK |
| #define EAFNOSUPPORT WSAEAFNOSUPPORT |
| /* I don't use a C++ style of comment because it upsets some C |
| compilers, possibly even when it is inside an ifdef WIN32... */ |
| /* from public\sdk\inc\crt\errno.h */ |
| #define ENOSPC 28 |
| |
| #ifdef errno |
| /* delete the one from stdlib.h */ |
| /*#define errno (*_errno()) */ |
| #undef errno |
| #endif |
| #define errno GetLastError() |
| #define Set_errno(num) SetLastError((num)) |
| |
| #define perror(text) PrintWin32Error(stderr, (text)) |
| #define Print_errno(stream, text) PrintWin32Error((stream), (text)) |
| |
| extern void PrintWin32Error(FILE *stream, LPSTR text); |
| |
| #if !defined(NT_PERF) && !defined(USE_LOOPER) |
| #define NT_PERF |
| #endif |
| #else |
| /* Really shouldn't use manifest constants! */ |
| /*+*+SAF There are other examples of "== -1" and "<0" that probably */ |
| /*+*+SAF should be cleaned up as well. */ |
| #define INVALID_SOCKET -1 |
| #define SOCKET_ERROR -1 |
| |
| #define SOCKET int |
| #define Set_errno(num) errno = (num) |
| |
| #define Print_errno(stream, text) fprintf((stream), "%s errno %d\n", (text), errno) |
| #endif |
| |
| /* Robin & Rick's kludge to try to have a timer signal EINTR by closing */ |
| /* the socket from another thread can also return several other errors. */ |
| /* Let's define a macro to hide all of this. */ |
| |
| #ifndef WIN32 |
| #define SOCKET_EINTR(return_value) (errno == EINTR) |
| #define SOCKET_EADDRINUSE(return_value) (errno == EADDRINUSE) |
| #define SOCKET_EADDRNOTAVAIL(return_value) (errno == EADDRNOTAVAIL) |
| |
| #else |
| |
| /* not quite sure I like the extra cases for WIN32 but that is what my |
| WIN32 expert sugested. I'm not sure what WSA's to put for |
| EADDRINUSE */ |
| |
| #define SOCKET_EINTR(return_value) \ |
| (((return_value) == SOCKET_ERROR) && \ |
| ((errno == EINTR) || \ |
| (errno == WSAECONNABORTED) || \ |
| (errno == WSAECONNRESET) )) |
| #define SOCKET_EADDRINUSE(return_value) \ |
| (((return_value) == SOCKET_ERROR) && \ |
| ((errno == WSAEADDRINUSE) )) |
| #define SOCKET_EADDRNOTAVAIL(return_value) \ |
| (((return_value) == SOCKET_ERROR) && \ |
| ((errno == WSAEADDRNOTAVAIL) )) |
| #endif |
| |
| #ifdef HAVE_SENDFILE |
| |
| struct sendfile_ring_elt { |
| struct sendfile_ring_elt *next; /* next element in the ring */ |
| int fildes; /* the file descriptor of the source |
| file */ |
| off_t offset; /* the offset from the beginning of |
| the file for this send */ |
| size_t length; /* the number of bytes to send - |
| this is redundant with the |
| send_size variable but I decided |
| to include it anyway */ |
| struct iovec *hdtrl; /* a pointer to a header/trailer |
| that we do not initially use and |
| so should be set to NULL when the |
| ring is setup. */ |
| int flags; /* the flags to pass to sendfile() - |
| presently unused and should be |
| set to zero when the ring is |
| setup. */ |
| }; |
| |
| #endif /* HAVE_SENDFILE */ |
| |
| /* the diferent codes to denote the type of CPU utilization */ |
| /* methods used */ |
| #define CPU_UNKNOWN 0 |
| #define HP_IDLE_COUNTER 1 |
| #define PSTAT 2 |
| #define TIMES 3 |
| #define LOOPER 4 |
| #define GETRUSAGE 5 |
| #define NT_METHOD 6 |
| #define KSTAT 7 |
| #define PROC_STAT 8 |
| #define SYSCTL 9 |
| #define PERFSTAT 10 |
| #define KSTAT_10 11 |
| #define OSX 12 |
| |
| #define BADCH ('?') |
| |
| #ifndef NETLIB |
| #ifdef WIN32 |
| #ifndef _GETOPT_ |
| #define _GETOPT_ |
| |
| int getopt(int argc, char **argv, char *optstring); |
| |
| extern char *optarg; /* returned arg to go with this option */ |
| extern int optind; /* index to next argv element to process */ |
| extern int opterr; /* should error messages be printed? */ |
| extern int optopt; /* */ |
| |
| #endif /* _GETOPT_ */ |
| |
| extern SOCKET win_kludge_socket, win_kludge_socket2; |
| #endif /* WIN32 */ |
| |
| extern int local_proc_affinity, remote_proc_affinity; |
| |
| /* these are to allow netperf to be run easily through those evil, |
| end-to-end breaking things known as firewalls */ |
| extern char local_data_port[10]; |
| extern char remote_data_port[10]; |
| |
| extern char *local_data_address; |
| extern char *remote_data_address; |
| |
| extern int local_data_family; |
| extern int remote_data_family; |
| |
| extern union netperf_request_struct netperf_request; |
| extern union netperf_response_struct netperf_response; |
| |
| extern float lib_local_cpu_util; |
| extern float lib_elapsed; |
| extern float lib_local_maxrate; |
| |
| extern char libfmt; |
| |
| extern int cpu_method; |
| extern int lib_num_loc_cpus; |
| extern int lib_num_rem_cpus; |
| extern SOCKET server_sock; |
| extern int times_up; |
| extern FILE *where; |
| extern int loops_per_msec; |
| extern float lib_local_per_cpu_util[]; |
| |
| extern void netlib_init(); |
| extern int netlib_get_page_size(); |
| extern void install_signal_catchers(); |
| extern void establish_control(char hostname[], |
| char port[], |
| int af, |
| char local_hostname[], |
| char local_port[], |
| int local_af); |
| extern void shutdown_control(); |
| extern void init_stat(); |
| extern void send_request(); |
| extern void recv_response(); |
| extern void send_response(); |
| extern void recv_request(); |
| extern void dump_request(); |
| extern void dump_addrinfo(FILE *dumploc, struct addrinfo *info, |
| char *host, char *port, int family); |
| extern void start_timer(int time); |
| extern void stop_timer(); |
| extern void cpu_start(int measure_cpu); |
| extern void cpu_stop(int measure_cpu, float *elapsed); |
| extern void calculate_confidence(int confidence_iterations, |
| float time, |
| double result, |
| float loc_cpu, |
| float rem_cpu, |
| float loc_sd, |
| float rem_sd); |
| extern void retrieve_confident_values(float *elapsed_time, |
| double *thruput, |
| float *local_cpu_utilization, |
| float *remote_cpu_utilization, |
| float *local_service_demand, |
| float *remote_service_demand); |
| extern void display_confidence(); |
| extern void set_sock_buffer(SOCKET sd, |
| enum sock_buffer which, |
| int requested_size, |
| int *effective_sizep); |
| extern char *format_units(); |
| |
| extern char *inet_ftos(int family); |
| extern char *inet_ttos(int type); |
| extern char *inet_ptos(int protocol); |
| extern double ntohd(double net_double); |
| extern double htond(double host_double); |
| extern int inet_nton(int af, const void *src, char *dst, int cnt); |
| extern void libmain(); |
| extern double calc_thruput(double units_received); |
| extern double calc_thruput_interval(double units_received,double elapsed); |
| extern double calc_thruput_omni(double units_received); |
| extern double calc_thruput_interval_omni(double units_received,double elapsed); |
| extern float calibrate_local_cpu(float local_cpu_rate); |
| extern float calibrate_remote_cpu(); |
| extern void bind_to_specific_processor(int processor_affinity,int use_cpu_map); |
| extern int set_nonblock (SOCKET sock); |
| |
| #ifndef WIN32 |
| |
| /* WIN32 requires that at least one of the file sets to select be |
| non-null. Since msec_sleep routine is only called by nettest_dlpi & |
| nettest_unix, let's duck this issue. */ |
| |
| extern int msec_sleep( int msecs ); |
| #endif /* WIN32 */ |
| extern float calc_cpu_util(float elapsed_time); |
| extern float calc_service_demand(double units_sent, |
| float elapsed_time, |
| float cpu_utilization, |
| int num_cpus); |
| extern float calc_service_demand_trans(double units_sent, |
| float elapsed_time, |
| float cpu_utilization, |
| int num_cpus); |
| #if defined(__hpux) |
| extern void catcher(int, siginfo_t *,void *); |
| #else |
| extern void catcher(int); |
| #endif /* __hpux */ |
| extern struct ring_elt *allocate_buffer_ring(); |
| extern void access_buffer(char *buffer_ptr, |
| int length, |
| int dirty_count, |
| int clean_count); |
| |
| #ifdef HAVE_ICSC_EXS |
| extern struct ring_elt *allocate_exs_buffer_ring(); |
| #endif /* HAVE_ICSC_EXS */ |
| #ifdef HAVE_SENDFILE |
| extern struct sendfile_ring_elt *alloc_sendfile_buf_ring(); |
| #endif /* HAVE_SENDFILE */ |
| #ifdef WANT_DLPI |
| /* it seems that AIX in its finite wisdom has some bogus define in an |
| include file which defines "rem_addr" which then screws-up this extern |
| unless we change the names to protect the guilty. reported by Eric |
| Jones */ |
| extern int dl_connect(int fd, unsigned char *remote_addr, int remote_addr_len); |
| extern int dl_bind(int fd, int sap, int mode, char *dlsap_ptr, int *dlsap_len); |
| extern int dl_open(char devfile[], int ppa); |
| #endif /* WANT_DLPI */ |
| extern char format_cpu_method(int method); |
| extern unsigned int convert(char *string); |
| extern unsigned int convert_timespec(char *string); |
| |
| #ifdef WANT_INTERVALS |
| extern void start_itimer(unsigned int interval_len_msec); |
| #endif |
| /* these are all for the confidence interval stuff */ |
| extern double confidence; |
| |
| #endif |
| |
| #ifdef WIN32 |
| #define close(x) closesocket(x) |
| #define strcasecmp(a,b) _stricmp(a,b) |
| #define getpid() ((int)GetCurrentProcessId()) |
| #endif |
| |
| #ifdef WIN32 |
| #if 0 |
| /* Should really use safe string functions; but not for now... */ |
| #include <strsafe.h> |
| /* Microsoft has deprecated _snprintf; it isn't guarenteed to null terminate the result buffer. */ |
| /* They want us to call StringCbPrintf instead; it always null terminates the string. */ |
| #endif |
| |
| #define snprintf _snprintf |
| #endif |
| |
| /* Define a macro to align a buffer with an offset from a power of 2 |
| boundary. */ |
| |
| #ifndef WIN32 |
| #define ULONG_PTR unsigned long |
| #endif |
| |
| #define ALIGN_BUFFER(BufPtr, Align, Offset) \ |
| (char *)(( (ULONG_PTR)(BufPtr) + \ |
| (ULONG_PTR) (Align) -1) & \ |
| ~((ULONG_PTR) (Align) - 1)) + (ULONG_PTR)(Offset) |
| |
| /* if your system has bcopy and bzero, include it here, otherwise, we */ |
| /* will try to use memcpy aand memset. fix from Bruce Barnett @ GE. */ |
| #if defined(hpux) || defined (__VMS) |
| #define HAVE_BCOPY |
| #define HAVE_BZERO |
| #endif |
| |
| #ifdef WIN32 |
| #define HAVE_MIN |
| #else |
| #define _stdcall |
| #define _cdecl |
| #endif |
| |
| #ifndef HAVE_BCOPY |
| #define bcopy(s,d,h) memcpy((d),(s),(h)) |
| #endif /* HAVE_BCOPY */ |
| |
| #ifndef HAVE_BZERO |
| #define bzero(p,h) memset((p),0,(h)) |
| #endif /* HAVE_BZERO */ |
| |
| #ifndef HAVE_MIN |
| #define min(a,b) ((a < b) ? a : b) |
| #endif /* HAVE_MIN */ |
| |
| #ifdef USE_PERFSTAT |
| # include <libperfstat.h> |
| #endif |
