sjero.net Git - iperf/blob - include/Reporter.h

   1 /*---------------------------------------------------------------
   2  * Copyright (c) 1999,2000,2001,2002,2003
   3  * The Board of Trustees of the University of Illinois
   4  * All Rights Reserved.
   5  *---------------------------------------------------------------
   6  * Permission is hereby granted, free of charge, to any person
   7  * obtaining a copy of this software (Iperf) and associated
   8  * documentation files (the "Software"), to deal in the Software
   9  * without restriction, including without limitation the
  10  * rights to use, copy, modify, merge, publish, distribute,
  11  * sublicense, and/or sell copies of the Software, and to permit
  12  * persons to whom the Software is furnished to do
  13  * so, subject to the following conditions:
  14  *
  15  *
  16  * Redistributions of source code must retain the above
  17  * copyright notice, this list of conditions and
  18  * the following disclaimers.
  19  *
  20  *
  21  * Redistributions in binary form must reproduce the above
  22  * copyright notice, this list of conditions and the following
  23  * disclaimers in the documentation and/or other materials
  24  * provided with the distribution.
  25  *
  26  *
  27  * Neither the names of the University of Illinois, NCSA,
  28  * nor the names of its contributors may be used to endorse
  29  * or promote products derived from this Software without
  30  * specific prior written permission.
  31  *
  32  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
  33  * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES
  34  * OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
  35  * NONINFRINGEMENT. IN NO EVENT SHALL THE CONTIBUTORS OR COPYRIGHT
  36  * HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,
  37  * WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE,
  38  * ARISING FROM, OUT OF OR IN CONNECTION WITH THE
  39  * SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
  40  * ________________________________________________________________
  41  * National Laboratory for Applied Network Research
  42  * National Center for Supercomputing Applications
  43  * University of Illinois at Urbana-Champaign
  44  * http://www.ncsa.uiuc.edu
  45  * ________________________________________________________________
  46  *
  47  * Reporter.h
  48  * by Kevin Gibbs <kgibbs@nlanr.net>
  49  *
  50  * Since version 2.0 this handles all reporting.
  51  * ________________________________________________________________ */
  52
  53 #ifndef REPORTER_H
  54 #define REPORTER_H
  55
  56 #include "headers.h"
  57 #include "Mutex.h"
  58
  59 struct thread_Settings;
  60 struct server_hdr;
  61
  62 #include "Settings.hpp"
  63
  64 #define NUM_REPORT_STRUCTS 700
  65 #define NUM_MULTI_SLOTS    5
  66
  67 #ifdef __cplusplus
  68 extern "C" {
  69 #endif
  70
  71 /*
  72  * This struct contains all important information from the sending or
  73  * recieving thread.
  74  */
  75 typedef struct ReportStruct {
  76     int packetID;
  77     int packetLen;
  78     struct timeval packetTime;
  79     struct timeval sentTime;
  80 } ReportStruct;
  81
  82 /*
  83  * The type field of ReporterData is a bitmask
  84  * with one or more of the following
  85  */
  86 #define    TRANSFER_REPORT      0x00000001
  87 #define    SERVER_RELAY_REPORT  0x00000002
  88 #define    SETTINGS_REPORT      0x00000004
  89 #define    CONNECTION_REPORT    0x00000008
  90 #define    MULTIPLE_REPORT      0x00000010
  91
  92 typedef struct Transfer_Info {
  93     void *reserved_delay;
  94     int transferID;
  95     int groupID;
  96     int cntError;
  97     int cntOutofOrder;
  98     int cntDatagrams;
  99     // Hopefully int64_t's
 100     max_size_t TotalLen;
 101     double jitter;
 102     double startTime;
 103     double endTime;
 104     // chars
 105     char   mFormat;                 // -f
 106     u_char mTTL;                    // -T
 107     char   mUDP;
 108     char   free;
 109 } Transfer_Info;
 110
 111 typedef struct Connection_Info {
 112     struct sockaddr_storage peer;
 113     struct sockaddr_storage local;
 114 } Connection_Info;
 115
 116 typedef struct ReporterData {
 117     char*  mHost;                   // -c
 118     char*  mLocalhost;              // -B
 119     // int's
 120     int type;
 121     int cntError;
 122     int lastError;
 123     int cntOutofOrder;
 124     int lastOutofOrder;
 125     int cntDatagrams;
 126     int lastDatagrams;
 127     int PacketID;
 128     int mBufLen;                    // -l
 129     int mMSS;                       // -M
 130     int mWinSize;                    // -w
 131     /*   flags is a BitMask of old bools
 132         bool   mBufLenSet;              // -l
 133         bool   mCompat;                 // -C
 134         bool   mDaemon;                 // -D
 135         bool   mDomain;                 // -V
 136         bool   mFileInput;              // -F or -I
 137         bool   mNodelay;                // -N
 138         bool   mPrintMSS;               // -m
 139         bool   mRemoveService;          // -R
 140         bool   mStdin;                  // -I
 141         bool   mStdout;                 // -o
 142         bool   mSuggestWin;             // -W
 143         bool   mUDP;
 144         bool   mMode_time;*/
 145     int flags;
 146     Protocol   mProtocol;
 147     // enums (which should be special int's)
 148     ThreadMode mThreadMode;         // -s or -c
 149     ReportMode mode;
 150     max_size_t TotalLen;
 151     max_size_t lastTotal;
 152     // doubles
 153     double lastTransit;
 154     // shorts
 155     unsigned short mPort;           // -p
 156     unsigned short mMcastIface;     // -j or -J
 157     // structs or miscellaneous
 158     Transfer_Info info;
 159     Connection_Info connection;
 160     struct timeval startTime;
 161     struct timeval packetTime;
 162     struct timeval nextTime;
 163     struct timeval intervalTime;
 164 } ReporterData;
 165
 166 typedef struct MultiHeader {
 167     int reporterindex;
 168     int agentindex;
 169     int groupID;
 170     int threads;
 171     ReporterData *report;
 172     Transfer_Info *data;
 173     Condition barrier;
 174     struct timeval startTime;
 175 } MultiHeader;
 176
 177 typedef struct ReportHeader {
 178     int reporterindex;
 179     int agentindex;
 180     ReporterData report;
 181     ReportStruct *data;
 182     MultiHeader *multireport;
 183     struct ReportHeader *next;
 184 } ReportHeader;
 185
 186 typedef void* (* report_connection)( Connection_Info*, int );
 187 typedef void (* report_settings)( ReporterData* );
 188 typedef void (* report_statistics)( Transfer_Info* );
 189 typedef void (* report_serverstatistics)( Connection_Info*, Transfer_Info* );
 190
 191 MultiHeader* InitMulti( struct thread_Settings *agent, int inID );
 192 ReportHeader* InitReport( struct thread_Settings *agent );
 193 void ReportPacket( ReportHeader *agent, ReportStruct *packet );
 194 void CloseReport( ReportHeader *agent, ReportStruct *packet );
 195 void EndReport( ReportHeader *agent );
 196 Transfer_Info* GetReport( ReportHeader *agent );
 197 void ReportServerUDP( struct thread_Settings *agent, struct server_hdr *server );
 198 void ReportSettings( struct thread_Settings *agent );
 199 void ReportConnections( struct thread_Settings *agent );
 200
 201 extern report_connection connection_reports[];
 202
 203 extern report_settings settings_reports[];
 204
 205 extern report_statistics statistics_reports[];
 206
 207 extern report_serverstatistics serverstatistics_reports[];
 208
 209 extern report_statistics multiple_reports[];
 210
 211 extern char buffer[64]; // Buffer for printing
 212
 213 #define rMillion 1000000
 214
 215 #define TimeDifference( left, right ) (left.tv_sec  - right.tv_sec) +   \
 216         (left.tv_usec - right.tv_usec) / ((double) rMillion)
 217
 218 #define TimeAdd( left, right )  do {                                    \
 219                                     left.tv_usec += right.tv_usec;      \
 220                                     if ( left.tv_usec > rMillion ) {    \
 221                                         left.tv_usec -= rMillion;       \
 222                                         left.tv_sec++;                  \
 223                                     }                                   \
 224                                     left.tv_sec += right.tv_sec;        \
 225                                 } while ( 0 )
 226 #ifdef __cplusplus
 227 } /* end extern "C" */
 228 #endif
 229
 230 #endif // REPORTER_H