1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
|
/*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 2 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*
* Author : Richard GAYRAUD - 04 Nov 2003
* Olivier Jacques
* From Hewlett Packard Company.
* Peter Higginson
* JPeG
* Guillaume TEISSIER from FTR&D
*/
#ifndef __SCENARIO__
#define __SCENARIO__
#include <map>
#include <sys/socket.h>
#include "actions.hpp"
#include "variables.hpp"
#define SCEN_VARIABLE_SIZE 20
/* MAX_RTD_INFO_LENGTH defines the number of RTD begin and end points a single
* call can have. If you need more than five, you can increase this number,
* but you also need to insert entries into the E_CounterName enum in stat.hpp.
*/
#define MAX_RTD_INFO_LENGTH 5
#ifdef __3PCC__
#define MSG_TYPE_SENDCMD 0
#define MSG_TYPE_RECVCMD 1
#endif
#define MSG_TYPE_SEND 2
#define MSG_TYPE_RECV 3
#define MSG_TYPE_PAUSE 4
#define MSG_TYPE_NOP 5
#define MODE_CLIENT 0
#define MODE_SERVER 1
#define METHOD_LIST_LENGTH 255
#ifdef __3PCC__
#define MODE_3PCC_CONTROLLER_A 2
#define MODE_3PCC_CONTROLLER_B 3
#define MODE_3PCC_A_PASSIVE 4
/* 3pcc extended mode*/
#define MODE_MASTER 5
#define MODE_MASTER_PASSIVE 6
#define MODE_SLAVE 7
#endif
#define OPTIONAL_TRUE 1
#define OPTIONAL_FALSE 0
#define OPTIONAL_GLOBAL 2
#define MAX_LABELS 100
class message {
public:
/* If this is a pause */
unsigned int (*pause_function)(class message *);
/* Type of pause: param param2
* default length N/A Note that -1 signifies global duration.
* uniform min max
* normal mean st. dev
* lognormal mean st. dev (Of the pauses' logarithm.) (doubles)
* exponential lambda N/A
*/
int pause_param;
int pause_param2;
double pause_dparam;
double pause_dparam2;
/* This string is used for the display screen. */
char *pause_desc;
/* Number of sessions in a pause */
int sessions;
/* should collect route set? */
bool bShouldRecordRoutes;
#ifdef _USE_OPENSSL
/* should collect authentication info? */
bool bShouldAuthenticate;
#endif
/* If this is a send */
char * send_scheme;
unsigned int retrans_delay;
/* 3pcc extended mode: if this is a sendCmd */
char * peer_dest;
/* 3pcc extended mode: if this is a recvCmd */
char * peer_src;
/* If this is a recv */
int recv_response;
char * recv_request;
int optional;
int regexp_match;
regex_t * regexp_compile;
/* Anyway */
int start_rtd;
int stop_rtd;
bool repeat_rtd;
int counter;
double lost;
int crlf;
unsigned int next;
int test;
int chance;/* 0=always, RAND_MAX+1=never (test rand() >= chance) */
unsigned int on_timeout;
/* Statistics */
unsigned long nb_sent;
unsigned long nb_recv;
unsigned long nb_sent_retrans;
unsigned long nb_recv_retrans;
unsigned long nb_timeout;
unsigned long nb_unexp;
unsigned long nb_lost;
CActions* M_actions;
int M_type;
#ifdef __3PCC__
char* M_sendCmdData;
unsigned long M_nbCmdSent;
unsigned long M_nbCmdRecv;
#endif
typedef enum {
ContentLengthNoPresent = 0,
ContentLengthValueZero,
ContentLengthValueNoZero
}ContentLengthFlag;
ContentLengthFlag content_length_flag ;
char recv_response_for_cseq_method_list[METHOD_LIST_LENGTH];
message();
~message();
};
/* There are external variable containing the current scenario */
extern message * scenario[SCEN_MAX_MESSAGES];
extern CVariable * scenVariableTable[SCEN_VARIABLE_SIZE][SCEN_MAX_MESSAGES];
extern int scenario_len;
extern char scenario_name[255];
extern int toolMode;
extern bool rtd_stopped[MAX_RTD_INFO_LENGTH];
extern bool rtd_started[MAX_RTD_INFO_LENGTH];
extern unsigned long scenario_duration; /* include -d option if used */
extern message::ContentLengthFlag content_length_flag;
void load_scenario(char * filename,
int deflt);
/* 3pcc extended mode */
void parse_slave_cfg();
void computeSippMode();
void getActionForThisMessage();
int createIntegerTable(char * P_listeStr,
unsigned int ** listeInteger,
int * sizeOfList);
int isWellFormed(char * P_listeStr,
int * nombre);
int find_scenario(const char *scenario);
extern char * default_scenario[10];
extern unsigned int labelArray[MAX_LABELS];
/* Useful utility functions for parsing integers, etc. */
long get_long(const char *ptr, const char *what);
long get_time(const char *ptr, const char *what, int multiplier);
double get_double(const char *ptr, const char *what);
bool get_bool(const char *ptr, const char *what);
#endif
|
