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
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
|
/*
* 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
* From Hewlett Packard Company.
*/
#ifndef __SIPP__
#define __SIPP__
/* Std C includes */
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <pthread.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/tcp.h>
#include <sys/time.h>
#include <sys/poll.h>
#include <sys/resource.h>
#include <fcntl.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <errno.h>
#include <netdb.h>
#include <ctype.h>
#include <signal.h>
#include <time.h>
#include <limits.h>
#include <vector>
#include <string>
#include <map>
#include <set>
#include <math.h>
#ifndef __SUNOS
#include <curses.h>
#else
#include <stdarg.h>
#endif
#if defined(__HPUX) || defined(__SUNOS)
#include <alloca.h>
#endif
/* Sipp includes */
#include "xp_parser.h"
#include "scenario.hpp"
#include "screen.hpp"
#include "task.hpp"
#include "listener.hpp"
#include "socketowner.hpp"
#include "call.hpp"
#include "comp.h"
#include "variables.hpp"
#include "stat.hpp"
#include "actions.hpp"
#include "infile.hpp"
#include "opentask.hpp"
#include "reporttask.hpp"
#include "watchdog.hpp"
/* Open SSL stuff */
#ifdef _USE_OPENSSL
#include "sslcommon.h"
#endif
#ifndef __CYGWIN
#ifndef FD_SETSIZE
#define FD_SETSIZE 65000
#endif
#else
#ifndef FD_SETSIZE
#define FD_SETSIZE 1024
#endif
#endif
/*
* If this files is included in the Main, then extern definitions
* are removed, and the _DEFAULT macro becomes '= value;'. Else
* extern definition does not contain default values assignment
*/
#ifdef GLOBALS_FULL_DEFINITION
#define extern
#define _DEFVAL(value) = value
#else
#define _DEFVAL(value)
#endif
/************************** Constants **************************/
#ifdef SVN_VERSION
# ifdef LOCAL_VERSION_EXTRA
# define SIPP_VERSION SVN_VERSION LOCAL_VERSION_EXTRA
# else
# define SIPP_VERSION SVN_VERSION
# endif
#else
# define SIPP_VERSION "unknown"
#endif
#define T_UDP 0
#define T_TCP 1
#define T_TLS 2
#ifdef _USE_OPENSSL
#define DEFAULT_TLS_CERT ((char *)"cacert.pem")
#define DEFAULT_TLS_KEY ((char *)"cakey.pem")
#define DEFAULT_TLS_CRL ((char *)"")
#endif
#define TRANSPORT_TO_STRING(p) ((p==T_TCP) ? "TCP" : ((p==T_TLS)? "TLS" :"UDP"))
#define SIPP_MAXFDS 65536
#define SIPP_MAX_MSG_SIZE 65536
#define MSG_RETRANS_FIRST 0
#define MSG_RETRANS_RETRANSMISSION 1
#define MSG_RETRANS_NEVER 2
#define DISPLAY_STAT_SCREEN 1
#define DISPLAY_REPARTITION_SCREEN 2
#define DISPLAY_SCENARIO_SCREEN 3
#define DISPLAY_VARIABLE_SCREEN 4
#define DISPLAY_TDM_MAP_SCREEN 5
#define DISPLAY_SECONDARY_REPARTITION_SCREEN 6
#define MAX_RECV_LOOPS_PER_CYCLE 1000
#define MAX_SCHED_LOOPS_PER_CYCLE 1000
#define NB_UPDATE_PER_CYCLE 1
#define MAX_PATH 250
#define MAX_PEER_SIZE 4096 /* 3pcc extended mode: max size of peer names */
#define MAX_LOCAL_TWIN_SOCKETS 10 /*3pcc extended mode:max number of peers from which
cmd messages are received */
/******************** Default parameters ***********************/
#define DEFAULT_RATE 10.0
#define DEFAULT_RATE_SCALE 1.0
#define DEFAULT_RATE_PERIOD_MS 1000
#define DEFAULT_TRANSPORT T_UDP
#define DEFAULT_PORT 5060
#define DEFAULT_MEDIA_PORT 6000
#define DEFAULT_3PCC_PORT 6060
#define DEFAULT_SERVICE ((char *)"service")
#define DEFAULT_AUTH_PASSWORD ((char *)"password")
#define DEFAULT_REPORT_FREQ 1000
#define DEFAULT_REPORT_FREQ_DUMP_LOG 60000
#define DEFAULT_TIMER_RESOLUTION 1
#define DEFAULT_FREQ_DUMP_RTT 200
#define DEFAULT_MAX_MULTI_SOCKET 50000
#define DEFAULT_CTRL_SOCKET_PORT 8888
#define DEFAULT_DEADCALL_WAIT 33000
#define DEFAULT_BEHAVIOR_NONE 0
#define DEFAULT_BEHAVIOR_BYE 1
#define DEFAULT_BEHAVIOR_ABORTUNEXP 2
#define DEFAULT_BEHAVIOR_PINGREPLY 4
#define DEFAULT_BEHAVIOR_ALL (DEFAULT_BEHAVIOR_BYE | DEFAULT_BEHAVIOR_ABORTUNEXP | DEFAULT_BEHAVIOR_PINGREPLY)
/************ User controls and command line options ***********/
extern int duration _DEFVAL(0);
extern double rate _DEFVAL(DEFAULT_RATE);
extern double rate_scale _DEFVAL(DEFAULT_RATE_SCALE);
extern int rate_increase _DEFVAL(0);
extern int rate_max _DEFVAL(0);
extern bool rate_quit _DEFVAL(true);
extern int users _DEFVAL(-1);
extern int rate_period_ms _DEFVAL(DEFAULT_RATE_PERIOD_MS);
extern int sleeptime _DEFVAL(0);
extern unsigned long defl_recv_timeout _DEFVAL(0);
extern unsigned long defl_send_timeout _DEFVAL(0);
extern unsigned long global_timeout _DEFVAL(0);
extern int transport _DEFVAL(DEFAULT_TRANSPORT);
extern bool retrans_enabled _DEFVAL(1);
extern int rtcheck _DEFVAL(RTCHECK_FULL);
extern int max_udp_retrans _DEFVAL(UDP_MAX_RETRANS);
extern int max_invite_retrans _DEFVAL(UDP_MAX_RETRANS_INVITE_TRANSACTION);
extern int max_non_invite_retrans _DEFVAL(UDP_MAX_RETRANS_NON_INVITE_TRANSACTION);
extern unsigned long default_behaviors _DEFVAL(DEFAULT_BEHAVIOR_ALL);
extern unsigned long deadcall_wait _DEFVAL(DEFAULT_DEADCALL_WAIT);
extern bool pause_msg_ign _DEFVAL(0);
extern bool auto_answer _DEFVAL(false);
extern int multisocket _DEFVAL(0);
extern int compression _DEFVAL(0);
extern int peripsocket _DEFVAL(0);
extern int peripfield _DEFVAL(0);
extern bool bind_local _DEFVAL(false);
extern void * monosocket_comp_state _DEFVAL(0);
extern char * service _DEFVAL(DEFAULT_SERVICE);
extern char * auth_password _DEFVAL(DEFAULT_AUTH_PASSWORD);
extern unsigned long report_freq _DEFVAL(DEFAULT_REPORT_FREQ);
extern unsigned long report_freq_dumpLog _DEFVAL
(DEFAULT_REPORT_FREQ_DUMP_LOG);
extern bool periodic_rtd _DEFVAL(false);
extern char * stat_delimiter _DEFVAL(";");
extern bool timeout_exit _DEFVAL(false);
extern bool timeout_error _DEFVAL(false);
extern unsigned long report_freq_dumpRtt _DEFVAL
(DEFAULT_FREQ_DUMP_RTT);
extern int max_multi_socket _DEFVAL
(DEFAULT_MAX_MULTI_SOCKET);
extern bool skip_rlimit _DEFVAL(false);
extern unsigned int timer_resolution _DEFVAL(DEFAULT_TIMER_RESOLUTION);
extern int max_recv_loops _DEFVAL(MAX_RECV_LOOPS_PER_CYCLE);
extern int max_sched_loops _DEFVAL(MAX_SCHED_LOOPS_PER_CYCLE);
extern unsigned int global_t2 _DEFVAL(DEFAULT_T2_TIMER_VALUE);
extern char local_ip[40];
extern char local_ip_escaped[42];
extern bool local_ip_is_ipv6;
extern int local_port _DEFVAL(0);
extern char control_ip[40];
extern int control_port _DEFVAL(0);
extern int buff_size _DEFVAL(65535);
extern int tcp_readsize _DEFVAL(65535);
#ifdef PCAPPLAY
extern int hasMedia _DEFVAL(0);
#endif
extern bool rtp_echo_enabled _DEFVAL(0);
extern char media_ip[40];
extern char media_ip_escaped[42];
extern int user_media_port _DEFVAL(0);
extern int media_port _DEFVAL(0);
extern size_t media_bufsize _DEFVAL(2048);
extern bool media_ip_is_ipv6;
extern char remote_ip[40];
extern char remote_ip_escaped[42];
extern int remote_port _DEFVAL(DEFAULT_PORT);
extern unsigned int pid _DEFVAL(0);
extern bool print_all_responses _DEFVAL(false);
extern unsigned long stop_after _DEFVAL(0xffffffff);
extern int quitting _DEFVAL(0);
extern int interrupt _DEFVAL(0);
extern bool paused _DEFVAL(false);
extern int lose_packets _DEFVAL(0);
extern double global_lost _DEFVAL(0.0);
extern char remote_host[255];
extern char twinSippHost[255];
extern char twinSippIp[40];
extern char * master_name;
extern char * slave_number;
extern int twinSippPort _DEFVAL(DEFAULT_3PCC_PORT);
extern bool twinSippMode _DEFVAL(false);
extern bool extendedTwinSippMode _DEFVAL(false);
extern bool nostdin _DEFVAL(false);
extern bool backgroundMode _DEFVAL(false);
extern bool signalDump _DEFVAL(false);
extern int currentScreenToDisplay _DEFVAL
(DISPLAY_SCENARIO_SCREEN);
extern int currentRepartitionToDisplay _DEFVAL(1);
extern unsigned int base_cseq _DEFVAL(0);
extern char * auth_uri _DEFVAL(0);
extern char * call_id_string _DEFVAL("%u-%p@%s");
extern char **generic[100];
/* TDM map */
extern bool use_tdmmap _DEFVAL(false);
extern unsigned int tdm_map_a _DEFVAL(0);
extern unsigned int tdm_map_b _DEFVAL(0);
extern unsigned int tdm_map_c _DEFVAL(0);
extern unsigned int tdm_map_x _DEFVAL(0);
extern unsigned int tdm_map_y _DEFVAL(0);
extern unsigned int tdm_map_z _DEFVAL(0);
extern unsigned int tdm_map_h _DEFVAL(0);
extern bool tdm_map[1024];
#ifdef _USE_OPENSSL
extern BIO *twinSipp_bio ;
extern SSL *twinSipp_ssl ;
extern char *tls_cert_name _DEFVAL(DEFAULT_TLS_CERT) ;
extern char *tls_key_name _DEFVAL(DEFAULT_TLS_KEY) ;
extern char *tls_crl_name _DEFVAL(DEFAULT_TLS_CRL) ;
#endif
// extern field file management
typedef std::map<string, FileContents *> file_map;
extern file_map inFiles;
typedef std::map<string, str_int_map *> file_index;
extern char *ip_file _DEFVAL(NULL);
extern char *default_file _DEFVAL(NULL);
// free user id list
extern list<int> freeUsers;
extern list<int> retiredUsers;
extern AllocVariableTable *globalVariables _DEFVAL(NULL);
extern AllocVariableTable *userVariables _DEFVAL(NULL);
typedef std::map<int, VariableTable *> int_vt_map;
extern int_vt_map userVarMap;
//extern int new_socket(bool P_use_ipv6, int P_type_socket, int * P_status);
extern struct sipp_socket *new_sipp_socket(bool use_ipv6, int transport);
struct sipp_socket *new_sipp_call_socket(bool use_ipv6, int transport, bool *existing);
struct sipp_socket *sipp_accept_socket(struct sipp_socket *accept_socket);
extern int sipp_bind_socket(struct sipp_socket *socket, struct sockaddr_storage *saddr, int *port);
extern int sipp_connect_socket(struct sipp_socket *socket, struct sockaddr_storage *dest);
extern int sipp_reconnect_socket(struct sipp_socket *socket);
extern void sipp_customize_socket(struct sipp_socket *socket);
extern int delete_socket(int P_socket);
extern int min_socket _DEFVAL(65535);
extern int select_socket _DEFVAL(0);
extern bool socket_close _DEFVAL(true);
extern bool test_socket _DEFVAL(true);
extern bool maxSocketPresent _DEFVAL(false);
extern unsigned long getmilliseconds();
extern unsigned long long getmicroseconds();
/************************ Statistics **************************/
extern unsigned long last_report_calls _DEFVAL(0);
extern unsigned long nb_net_send_errors _DEFVAL(0);
extern unsigned long nb_net_cong _DEFVAL(0);
extern unsigned long nb_net_recv_errors _DEFVAL(0);
extern bool cpu_max _DEFVAL(false);
extern bool outbound_congestion _DEFVAL(false);
extern int open_calls_user_setting _DEFVAL(0);
extern int resynch_send _DEFVAL(0);
extern int resynch_recv _DEFVAL(0);
extern unsigned long rtp_pckts _DEFVAL(0);
extern unsigned long rtp_bytes _DEFVAL(0);
extern unsigned long rtp_pckts_pcap _DEFVAL(0);
extern unsigned long rtp_bytes_pcap _DEFVAL(0);
extern unsigned long rtp2_pckts _DEFVAL(0);
extern unsigned long rtp2_bytes _DEFVAL(0);
extern unsigned long rtp2_pckts_pcap _DEFVAL(0);
extern unsigned long rtp2_bytes_pcap _DEFVAL(0);
/************* Rate Control & Contexts variables **************/
extern int last_running_calls _DEFVAL(0);
extern int last_woken_calls _DEFVAL(0);
extern int last_paused_calls _DEFVAL(0);
extern unsigned int open_calls_allowed _DEFVAL(0);
extern unsigned long last_report_time _DEFVAL(0);
extern unsigned long last_dump_time _DEFVAL(0);
/********************** Clock variables ***********************/
extern unsigned long clock_tick _DEFVAL(0);
extern unsigned long scheduling_loops _DEFVAL(0);
extern unsigned long last_timer_cycle _DEFVAL(0);
extern unsigned long watchdog_interval _DEFVAL(400);
extern unsigned long watchdog_minor_threshold _DEFVAL(500);
extern unsigned long watchdog_minor_maxtriggers _DEFVAL(120);
extern unsigned long watchdog_major_threshold _DEFVAL(3000);
extern unsigned long watchdog_major_maxtriggers _DEFVAL(10);
extern unsigned long watchdog_reset _DEFVAL(600000);
/********************* dynamic Id ************************* */
extern int maxDynamicId _DEFVAL(12000); // max value for dynamicId; this value is reached
extern int startDynamicId _DEFVAL(10000); // offset for first dynamicId FIXME:in CmdLine
extern int stepDynamicId _DEFVAL(4); // step of increment for dynamicId
#define GET_TIME(clock) \
{ \
struct timezone tzp; \
gettimeofday (clock, &tzp); \
}
/*********************** Global Sockets **********************/
extern struct sipp_socket *main_socket _DEFVAL(NULL);
extern struct sipp_socket *main_remote_socket _DEFVAL(NULL);
extern struct sipp_socket *tcp_multiplex _DEFVAL(NULL);
extern int media_socket _DEFVAL(0);
extern int media_socket_video _DEFVAL(0);
extern struct sockaddr_storage local_sockaddr;
extern struct sockaddr_storage localTwin_sockaddr;
extern int user_port _DEFVAL(0);
extern char hostname[80];
extern bool is_ipv6 _DEFVAL(false);
extern int reset_number _DEFVAL(0);
extern bool reset_close _DEFVAL(true);
extern int reset_sleep _DEFVAL(1000);
extern bool sendbuffer_warn _DEFVAL(false);
/* A list of sockets pending reset. */
extern set<struct sipp_socket *> sockets_pending_reset;
extern struct addrinfo * local_addr_storage;
extern struct sipp_socket *twinSippSocket _DEFVAL(NULL);
extern struct sipp_socket *localTwinSippSocket _DEFVAL(NULL);
extern struct sockaddr_storage twinSipp_sockaddr;
/* 3pcc extended mode */
typedef struct _T_peer_infos {
char peer_host[40];
int peer_port;
struct sockaddr_storage peer_sockaddr;
char peer_ip[40];
struct sipp_socket *peer_socket ;
} T_peer_infos;
typedef std::map<std::string, char * > peer_addr_map;
extern peer_addr_map peer_addrs;
typedef std::map<std::string, T_peer_infos> peer_map;
extern peer_map peers;
typedef std::map<struct sipp_socket *, std::string > peer_socket_map;
extern peer_socket_map peer_sockets;
extern struct sipp_socket *local_sockets[MAX_LOCAL_TWIN_SOCKETS];
extern int local_nb _DEFVAL(0);
extern int peers_connected _DEFVAL(0);
extern struct sockaddr_storage remote_sockaddr;
extern short use_remote_sending_addr _DEFVAL(0);
extern struct sockaddr_storage remote_sending_sockaddr;
enum E_Alter_YesNo
{
E_ALTER_YES=0,
E_ALTER_NO
};
/************************** Trace Files ***********************/
extern FILE * screenf _DEFVAL(0);
extern FILE * countf _DEFVAL(0);
// extern FILE * timeoutf _DEFVAL(0);
extern bool useMessagef _DEFVAL(0);
extern bool useCallDebugf _DEFVAL(0);
extern bool useShortMessagef _DEFVAL(0);
extern bool useScreenf _DEFVAL(0);
extern bool useLogf _DEFVAL(0);
//extern bool useTimeoutf _DEFVAL(0);
extern bool dumpInFile _DEFVAL(0);
extern bool dumpInRtt _DEFVAL(0);
extern bool useCountf _DEFVAL(0);
extern char * scenario_file;
extern char * slave_cfg_file;
extern unsigned long long max_log_size _DEFVAL(0);
extern unsigned long long ringbuffer_size _DEFVAL(0);
extern int ringbuffer_files _DEFVAL(0);
extern char screen_last_error[32768];
extern char screen_logfile[MAX_PATH] _DEFVAL("");
/* Log Rotation Functions. */
struct logfile_id {
time_t start;
int n;
};
struct logfile_info {
char *name;
bool check;
FILE *fptr;
int nfiles;
struct logfile_id *ftimes;
char file_name[MAX_PATH];
bool overwrite;
bool fixedname;
time_t starttime;
unsigned int count;
};
#ifdef GLOBALS_FULL_DEFINITION
#define LOGFILE(name, s, check) \
struct logfile_info name = { s, check, NULL, 0, NULL, "", true, false, 0, 0};
#else
#define LOGFILE(name, s, check) \
extern struct logfile_info name;
#endif
LOGFILE(calldebug_lfi, "calldebug", true);
LOGFILE(message_lfi, "messages", true);
LOGFILE(shortmessage_lfi, "shortmessages", true);
LOGFILE(log_lfi, "logs", true);
LOGFILE(error_lfi, "errors", false);
void rotate_errorf();
/* Screen/Statistics Printing Functions. */
void print_statistics(int last);
void print_count_file(FILE *f, int header);
/********************* Mini-Parser Routines *******************/
int get_method(char *msg);
char * get_peer_tag(char *msg);
unsigned long int get_cseq_value(char *msg);
unsigned long get_reply_code(char *msg);
/********************** Network Interfaces ********************/
int send_message(int s, void ** comp_state, char * msg);
#ifdef _USE_OPENSSL
int send_message_tls(SSL *s, void ** comp_state, char * msg);
#endif
/* Socket Buffer Management. */
#define NO_COPY 0
#define DO_COPY 1
struct socketbuf *alloc_socketbuf(char *buffer, size_t size, int copy);
void free_socketbuf(struct socketbuf *socketbuf);
/* These buffers lets us read past the end of the message, and then split it if
* required. This eliminates the need for reading a message octet by octet and
* performing a second read for the content length. */
struct socketbuf {
char *buf;
size_t len;
size_t offset;
struct sockaddr_storage addr;
struct socketbuf *next;
};
/* This is an abstraction of a socket, which provides buffers for input and
* output. */
struct sipp_socket {
int ss_count; /* How many users are there of this socket? */
int ss_transport; /* T_TCP, T_UDP, or T_TLS. */
bool ss_ipv6;
bool ss_control; /* Is this a control socket? */
bool ss_call_socket; /* Is this a call socket? */
bool ss_changed_dest; /* Has the destination changed from default. */
int ss_fd; /* The underlying file descriptor for this socket. */
void *ss_comp_state; /* The compression state. */
#ifdef _USE_OPENSSL
SSL *ss_ssl; /* The underlying SSL descriptor for this socket. */
BIO *ss_bio; /* The underlying BIO descriptor for this socket. */
#endif
struct sockaddr_storage ss_remote_sockaddr; /* Who we are talking to. */
struct sockaddr_storage ss_dest; /* Who we are talking to. */
int ss_pollidx; /* The index of this socket in our poll structures. */
bool ss_congested; /* Is this socket congested? */
bool ss_invalid; /* Has this socket been closed remotely? */
struct socketbuf *ss_in; /* Buffered input. */
size_t ss_msglen; /* Is there a complete SIP message waiting, and if so how big? */
struct socketbuf *ss_out; /* Buffered output. */
};
/* Write data to a socket. */
int write_socket(struct sipp_socket *socket, char *buffer, ssize_t len, int flags, struct sockaddr_storage *dest);
/* Mark a socket as "bad". */
void sipp_socket_invalidate(struct sipp_socket *socket);
/* Actually free the socket. */
void sipp_close_socket(struct sipp_socket *socket);
#define WS_EAGAIN 1 /* Return EAGAIN if there is no room for writing the message. */
#define WS_BUFFER 2 /* Buffer the message if there is no room for writing the message. */
#if defined (__hpux) || defined (__digital__) && defined(__unix__)
#define sipp_socklen_t int
#else
#define sipp_socklen_t socklen_t
#endif
#define SOCK_ADDR_SIZE(a) \
(((a)->ss_family == AF_INET) ? sizeof(struct sockaddr_in) \
: sizeof(struct sockaddr_in6))
#if defined(__cplusplus) && defined (__hpux)
#define _RCAST(type, val) (reinterpret_cast<type> (val))
#else
#define _RCAST(type, val) ((type)(val))
#endif
/********************* Utilities functions *******************/
char *strcasestr2 ( char *__haystack, char *__needle);
char *get_peer_addr(char *);
int get_decimal_from_hex(char hex);
bool reconnect_allowed();
void reset_connection(struct sipp_socket *);
void close_calls(struct sipp_socket *);
int close_connections();
int open_connections();
void timeout_alarm(int);
/* extended 3PCC mode */
struct sipp_socket **get_peer_socket(char *);
bool is_a_peer_socket(struct sipp_socket *);
bool is_a_local_socket(struct sipp_socket *);
void connect_to_peer (char *, int , sockaddr_storage *, char *, struct sipp_socket **);
void connect_to_all_peers ();
void connect_local_twin_socket(char *);
void close_peer_sockets();
void close_local_sockets();
void free_peer_addr_map();
/********************* Reset global kludge *******************/
#ifdef GLOBALS_FULL_DEFINITION
#undef extern
#endif
/* THis must go after the GLOBALS_FULL_DEFINITION, because we need the extern keyword. */
#ifdef __cplusplus
extern "C" {
#endif
int TRACE_MSG(char *fmt, ...);
int TRACE_CALLDEBUG(char *fmt, ...);
int TRACE_SHORTMSG(char *fmt, ...);
int LOG_MSG(char *fmt, ...);
#ifdef __cplusplus
}
#endif
#endif // __SIPP__
|
