~ubuntu-branches/ubuntu/utopic/sip-tester/utopic : revision 10

1

/*

2

* This program is free software; you can redistribute it and/or modify

3

* it under the terms of the GNU General Public License as published by

4

* the Free Software Foundation; either version 2 of the License, or

5

* (at your option) any later version.

6

*

7

* This program is distributed in the hope that it will be useful,

8

* but WITHOUT ANY WARRANTY; without even the implied warranty of

9

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

10

* GNU General Public License for more details.

11

*

12

* You should have received a copy of the GNU General Public License

13

* along with this program; if not, write to the Free Software

14

* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA

15

*

16

* Author : Richard GAYRAUD - 04 Nov 2003

17

* Olivier Jacques

18

* From Hewlett Packard Company.

19

* Shriram Natarajan

20

* Peter Higginson

21

* Venkatesh

22

* Lee Ballard

23

* Guillaume TEISSIER from FTR&D

24

* Wolfgang Beck

25

* Marc Van Diest from Belgacom

26

* Charles P. Wright from IBM Research

27

* Michael Stovenour

28

*/

29

30

#include <stdlib.h>

31

#include <limits.h>

32

#include "sipp.hpp"

33

#include <gsl/gsl_rng.h>

34

#include <gsl/gsl_randist.h>

35

#include <gsl/gsl_cdf.h>

36

37

/************************ Class Constructor *************************/

38

39

message::message(int index, const char *desc)

40

{

41

this->index = index;

42

this->desc = desc;

43

pause_distribution = NULL;

44

pause_variable = -1;

45

pause_desc = NULL;

46

sessions = 0;

47

bShouldRecordRoutes = 0;

48

#ifdef _USE_OPENSSL

49

bShouldAuthenticate = 0;

50

#endif

51

52

send_scheme = NULL;

53

retrans_delay = 0;

54

timeout = 0;

55

56

recv_response = 0;

57

recv_request = NULL;

58

optional = 0;

59

advance_state = true;

60

regexp_match = 0;

61

regexp_compile = NULL;

62

63

/* Anyway */

64

start_rtd = 0;

65

stop_rtd = 0;

66

repeat_rtd = 0;

67

lost = -1;

68

crlf = 0;

69

hide = 0;

70

display_str = NULL;

71

test = -1;

72

condexec = -1;

73

condexec_inverse = false;

74

chance = 0;/* meaning always */

75

next = -1;

76

nextLabel = NULL;

77

on_timeout = -1;

78

onTimeoutLabel = NULL;

79

timewait = false;

80

81

/* 3pcc extended mode */

82

peer_dest = NULL;

83

peer_src = NULL;

84

85

/* Statistics */

86

nb_sent = 0;

87

nb_recv = 0;

88

nb_sent_retrans = 0;

89

nb_recv_retrans = 0;

90

nb_timeout = 0;

91

nb_unexp = 0;

92

nb_lost = 0;

93

counter = 0;

94

95

M_actions = NULL;

96

97

M_type = 0;

98

99

M_sendCmdData = NULL;

100

M_nbCmdSent = 0;

101

M_nbCmdRecv = 0;

102

103

content_length_flag = ContentLengthNoPresent;

104

105

/* How to match responses to this message. */

106

start_txn = 0;

107

response_txn = 0;

108

ack_txn = 0;

109

recv_response_for_cseq_method_list = NULL;

110

}

111

112

message::~message()

113

{

114

if(M_actions != NULL)

115

delete(M_actions);

116

117

if(send_scheme != NULL)

118

delete send_scheme;

119

120

if(recv_request != NULL)

121

free (recv_request);

122

123

if(regexp_compile != NULL)

124

regfree(regexp_compile);

125

free(regexp_compile);

126

127

128

if (pause_distribution) {

129

delete pause_distribution;

130

}

131

132

if(M_sendCmdData != NULL)

133

delete M_sendCmdData;

134

135

free(display_str);

136

free(peer_dest);

137

free(peer_src);

138

free(pause_desc);

139

free(recv_response_for_cseq_method_list);

140

}

141

142

/******** Global variables which compose the scenario file **********/

143

144

scenario *main_scenario;

145

scenario *ooc_scenario;

146

scenario *display_scenario;

147

148

/* This mode setting refers to whether we open calls autonomously (MODE_CLIENT)

149

* or in response to requests (MODE_SERVER). */

150

int creationMode = MODE_CLIENT;

151

/* Send mode. Do we send to a fixed address or to the last one we got. */

152

int sendMode = MODE_CLIENT;

153

/* This describes what our 3PCC behavior is. */

154

int thirdPartyMode = MODE_3PCC_NONE;

155

156

/*************** Helper functions for various types *****************/

157

long get_long(const char *ptr, const char *what) {

158

char *endptr;

159

long ret;

160

161

ret = strtol(ptr, &endptr, 0);

162

if (*endptr) {

163

ERROR("%s, \"%s\" is not a valid integer!\n", what, ptr);

164

}

165

return ret;

166

}

167

168

unsigned long long get_long_long(const char *ptr, const char *what) {

169

char *endptr;

170

unsigned long long ret;

171

172

ret = strtoull(ptr, &endptr, 0);

173

if (*endptr) {

174

ERROR("%s, \"%s\" is not a valid integer!\n", what, ptr);

175

}

176

return ret;

177

}

178

179

/* This function returns a time in milliseconds from a string.

180

* The multiplier is used to convert from the default input type into

181

* milliseconds. For example, for seconds you should use 1000 and for

182

* milliseconds use 1. */

183

long get_time(const char *ptr, const char *what, int multiplier) {

184

char *endptr;

185

const char *p;

186

long ret;

187

double dret;

188

int i;

189

190

if (!isdigit(*ptr)) {

191

ERROR("%s, \"%s\" is not a valid time!\n", what, ptr);

192

}

193

194

for (i = 0, p = ptr; *p; p++) {

195

if (*p == ':') {

196

i++;

197

}

198

}

199

200

if (i == 1) { /* mm:ss */

201

ERROR("%s, \"%s\" mm:ss not implemented yet!\n", what, ptr);

202

}

203

else if (i == 2) { /* hh:mm:ss */

204

ERROR("%s, \"%s\" hh:mm:ss not implemented yet!\n", what, ptr);

205

} else if (i != 0) {

206

ERROR("%s, \"%s\" is not a valid time!\n", what, ptr);

207

}

208

209

dret = strtod(ptr, &endptr);

210

if (*endptr) {

211

if (!strcmp(endptr, "s")) { /* Seconds */

212

ret = (long)(dret * 1000);

213

} else if (!strcmp(endptr, "ms")) { /* Milliseconds. */

214

ret = (long)dret;

215

} else if (!strcmp(endptr, "m")) { /* Minutes. */

216

ret = (long)(dret * 60000);

217

} else if (!strcmp(endptr, "h")) { /* Hours. */

218

ret = (long)(dret * 60 * 60 * 1000);

219

} else {

220

ERROR("%s, \"%s\" is not a valid time!\n", what, ptr);

221

}

222

} else {

223

ret = (long)(dret * multiplier);

224

}

225

return ret;

226

}

227

228

double get_double(const char *ptr, const char *what) {

229

char *endptr;

230

double ret;

231

232

ret = strtod(ptr, &endptr);

233

if (*endptr) {

234

ERROR("%s, \"%s\" is not a floating point number!\n", what, ptr);

235

}

236

return ret;

237

}

238

239

char * xp_get_string(const char *name, const char *what) {

240

char *ptr;

241

242

if (!(ptr = xp_get_value(name))) {

243

ERROR("%s is missing the required '%s' parameter.", what, name);

244

}

245

246

return strdup(ptr);

247

}

248

249

double xp_get_double(const char *name, const char *what) {

250

char *ptr;

251

char *helptext;

252

double val;

253

254

if (!(ptr = xp_get_value(name))) {

255

ERROR("%s is missing the required '%s' parameter.", what, name);

256

}

257

helptext = (char *)malloc(100 + strlen(name) + strlen(what));

258

sprintf(helptext, "%s '%s' parameter", what, name);

259

val = get_double(ptr, helptext);

260

free(helptext);

261

262

return val;

263

}

264

265

double xp_get_double(const char *name, const char *what, double defval) {

266

if (!(xp_get_value(name))) {

267

return defval;

268

}

269

return xp_get_double(name, what);

270

}

271

272

long xp_get_long(const char *name, const char *what) {

273

char *ptr;

274

char *helptext;

275

long val;

276

277

if (!(ptr = xp_get_value(name))) {

278

ERROR("%s is missing the required '%s' parameter.", what, name);

279

}

280

helptext = (char *)malloc(100 + strlen(name) + strlen(what));

281

sprintf(helptext, "%s '%s' parameter", what, name);

282

val = get_long(ptr, helptext);

283

free(helptext);

284

285

return val;

286

}

287

288

long xp_get_long(const char *name, const char *what, long defval) {

289

if (!(xp_get_value(name))) {

290

return defval;

291

}

292

return xp_get_long(name, what);

293

}

294

295

296

double xp_get_bool(const char *name, const char *what) {

297

char *ptr;

298

char *helptext;

299

bool val;

300

301

if (!(ptr = xp_get_value(name))) {

302

ERROR("%s is missing the required '%s' parameter.", what, name);

303

}

304

helptext = (char *)malloc(100 + strlen(name) + strlen(what));

305

sprintf(helptext, "%s '%s' parameter", what, name);

306

val = get_bool(ptr, helptext);

307

free(helptext);

308

309

return val;

310

}

311

312

double xp_get_bool(const char *name, const char *what, bool defval) {

313

if (!(xp_get_value(name))) {

314

return defval;

315

}

316

return xp_get_bool(name, what);

317

}

318

319

int scenario::get_txn(const char *txnName, const char *what, bool start, bool isInvite, bool isAck) {

320

/* Check the name's validity. */

321

if (txnName[0] == '\0') {

322

ERROR("Variable names may not be empty for %s\n", what);

323

}

324

if (strcspn(txnName, "$,") != strlen(txnName)) {

325

ERROR("Variable names may not contain $ or , for %s\n", what);

326

}

327

328

/* If this transaction has already been used, then we have nothing to do. */

329

str_int_map::iterator txn_it = txnMap.find(txnName);

330

if (txn_it != txnMap.end()) {

331

if (start) {

332

/* We need to fill in the invite field. */

333

transactions[txn_it->second - 1].started++;

334

} else if (isAck) {

335

transactions[txn_it->second - 1].acks++;

336

} else {

337

transactions[txn_it->second - 1].responses++;

338

}

339

return txn_it->second;

340

}

341

342

/* Assign this variable the next slot. */

343

struct txnControlInfo transaction;

344

345

transaction.name = strdup(txnName);

346

if (start) {

347

transaction.started = 1;

348

transaction.responses = 0;

349

transaction.acks = 0;

350

transaction.isInvite = isInvite;

351

} else if (isAck) {

352

/* Does not start or respond to this txn. */

353

transaction.started = 0;

354

transaction.responses = 0;

355

transaction.acks = 1;

356

transaction.isInvite = false;

357

} else {

358

transaction.started = 0;

359

transaction.responses = 1;

360

transaction.acks = 0;

361

transaction.isInvite = false;

362

}

363

364

transactions.push_back(transaction);

365

int txnNum = transactions.size();

366

txnMap[txnName] = txnNum;

367

368

return txnNum;

369

}

370

371

int scenario::find_var(const char *varName, const char *what) {

372

return allocVars->find(varName, false);

373

}

374

375

int scenario::get_var(const char *varName, const char *what) {

376

/* Check the name's validity. */

377

if (varName[0] == '\0') {

378

ERROR("Transaction names may not be empty for %s\n", what);

379

}

380

if (strcspn(varName, "$,") != strlen(varName)) {

381

ERROR("Transaction names may not contain $ or , for %s\n", what);

382

}

383

384

return allocVars->find(varName, true);

385

}

386

387

int scenario::xp_get_var(const char *name, const char *what) {

388

char *ptr;

389

390

if (!(ptr = xp_get_value(name))) {

391

ERROR("%s is missing the required '%s' variable parameter.", what, name);

392

}

393

394

return get_var(ptr, what);

395

}

396

397

int xp_get_optional(const char *name, const char *what) {

398

char *ptr = xp_get_value(name);

399

400

if (!(ptr = xp_get_value(name))) {

401

return OPTIONAL_FALSE;

402

}

403

404

if(!strcmp(ptr, "true")) {

405

return OPTIONAL_TRUE;

406

} else if(!strcmp(ptr, "global")) {

407

return OPTIONAL_GLOBAL;

408

} else if(!strcmp(ptr, "false")) {

409

return OPTIONAL_FALSE;

410

} else {

411

ERROR("Could not understand optional value for %s: %s", what, ptr);

412

}

413

414

return OPTIONAL_FALSE;

415

}

416

417

418

int scenario::xp_get_var(const char *name, const char *what, int defval) {

419

char *ptr;

420

421

if (!(ptr = xp_get_value(name))) {

422

return defval;

423

}

424

425

return xp_get_var(name, what);

426

}

427

428

bool get_bool(const char *ptr, const char *what) {

429

char *endptr;

430

long ret;

431

432

if (!strcmp(ptr, "true")) {

433

return true;

434

}

435

if (!strcmp(ptr, "false")) {

436

return false;

437

}

438

439

ret = strtol(ptr, &endptr, 0);

440

if (*endptr) {

441

ERROR("%s, \"%s\" is not a valid boolean!\n", what, ptr);

442

}

443

return ret ? true : false;

444

}

445

446

/* Pretty print a time. */

447

char *time_string(int ms) {

448

static char tmp[20];

449

450

if (ms < 10000) {

451

snprintf(tmp, sizeof(tmp), "%dms", ms);

452

} else if (ms < 100000) {

453

snprintf(tmp, sizeof(tmp), "%.1fs", ((float)ms)/1000);

454

} else {

455

snprintf(tmp, sizeof(tmp), "%ds", ms/1000);

456

}

457

458

return tmp;

459

}

460

461

int time_string(double ms, char *res, int reslen) {

462

if (ms < 10000) {

463

/* Less then 10 seconds we represent accurately. */

464

if ((int)(ms + 0.9999) == (int)(ms)) {

465

/* We have an integer, or close enough to it. */

466

return snprintf(res, reslen, "%dms", (int)ms);

467

} else {

468

if (ms < 1000) {

469

return snprintf(res, reslen, "%.2lfms", ms);

470

} else {

471

return snprintf(res, reslen, "%.1lfms", ms);

472

}

473

}

474

} else if (ms < 60000) {

475

/* We round to 100ms for times less than a minute. */

476

return snprintf(res, reslen, "%.1fs", ms/1000);

477

} else if (ms < 60 * 60000) {

478

/* We round to 1s for times more than a minute. */

479

int s = (unsigned int)(ms / 1000);

480

int m = s / 60;

481

s %= 60;

482

return snprintf(res, reslen, "%d:%02d", m, s);

483

} else {

484

int s = (unsigned int)(ms / 1000);

485

int m = s / 60;

486

int h = m / 60;

487

s %= 60;

488

m %= 60;

489

return snprintf(res, reslen, "%d:%02d:%02d", h, m, s);

490

}

491

}

492

493

char *double_time_string(double ms) {

494

static char tmp[20];

495

496

if (ms < 1000) {

497

snprintf(tmp, sizeof(tmp), "%.2lfms", ms);

498

} else if (ms < 10000) {

499

snprintf(tmp, sizeof(tmp), "%.1lfms", ms);

500

} else if (ms < 100000) {

501

snprintf(tmp, sizeof(tmp), "%.1lfs", ms / 1000);

502

} else {

503

snprintf(tmp, sizeof(tmp), "%ds", (int)(ms/1000));

504

}

505

506

return tmp;

507

}

508

509

/* For backwards compatibility, we assign "true" to slot 1, false to 0, and

510

* allow other valid integers. */

511

int scenario::get_rtd(const char *ptr, bool start) {

512

if(!strcmp(ptr, (char *)"false"))

513

return 0;

514

515

if(!strcmp(ptr, (char *)"true"))

516

return stats->findRtd("1", start);

517

518

return stats->findRtd(ptr, start);

519

}

520

521

/* Get a counter */

522

int scenario::get_counter(const char *ptr, const char *what) {

523

/* Check the name's validity. */

524

if (ptr[0] == '\0') {

525

ERROR("Counter names names may not be empty for %s\n", what);

526

}

527

if (strcspn(ptr, "$,") != strlen(ptr)) {

528

ERROR("Counter names may not contain $ or , for %s\n", what);

529

}

530

531

return stats->findCounter(ptr, true);

532

}

533

534

535

/* Some validation functions. */

536

537

void scenario::validate_variable_usage() {

538

allocVars->validate();

539

}

540

541

void scenario::validate_txn_usage() {

542

for (unsigned int i = 0; i < transactions.size(); i++) {

543

if(transactions[i].started == 0) {

544

ERROR("Transaction %s is never started!\n", transactions[i].name);

545

} else if(transactions[i].responses == 0) {

546

ERROR("Transaction %s has no responses defined!\n", transactions[i].name);

547

}

548

if (transactions[i].isInvite && transactions[i].acks == 0) {

549

ERROR("Transaction %s is an INVITE transaction without an ACK!\n", transactions[i].name);

550

}

551

if (!transactions[i].isInvite && (transactions[i].acks > 0)) {

552

ERROR("Transaction %s is a non-INVITE transaction with an ACK!\n", transactions[i].name);

553

}

554

}

555

}

556

557

/* Apply the next and ontimeout labels according to our map. */

558

void scenario::apply_labels(msgvec v, str_int_map labels) {

559

for (unsigned int i = 0; i < v.size(); i++) {

560

if (v[i]->nextLabel) {

561

str_int_map::iterator label_it = labels.find(v[i]->nextLabel);

562

if (label_it == labels.end()) {

563

ERROR("The label '%s' was not defined (index %d, next attribute)\n", v[i]->nextLabel, i);

564

}

565

v[i]->next = label_it->second;

566

}

567

if (v[i]->onTimeoutLabel) {

568

str_int_map::iterator label_it = labels.find(v[i]->onTimeoutLabel);

569

if (label_it == labels.end()) {

570

ERROR("The label '%s' was not defined (index %d, ontimeout attribute)\n", v[i]->onTimeoutLabel, i);

571

}

572

v[i]->on_timeout = label_it->second;

573

}

574

}

575

}

576

577

int get_cr_number(char *src)

578

{

579

int res=0;

580

char *ptr = src;

581

while(*ptr) {

582

if(*ptr == '\n') res++;

583

*ptr++;

584

}

585

return res;

586

}

587

588

char *clean_cdata(char *ptr, int *removed_crlf = NULL) {

589

char * msg;

590

591

while((*ptr == ' ') || (*ptr == '\t') || (*ptr == '\n')) ptr++;

592

593

msg = (char *) malloc(strlen(ptr) + 3);

594

if(!msg) { ERROR("Memory Overflow"); }

595

strcpy(msg, ptr);

596

597

ptr = msg + strlen(msg);

598

ptr --;

599

600

while((ptr >= msg) &&

601

((*ptr == ' ') ||

602

(*ptr == '\t') ||

603

(*ptr == '\n'))) {

604

if(*ptr == '\n' && removed_crlf) {

605

(*removed_crlf)++;

606

}

607

*ptr-- = 0;

608

}

609

610

if(!strstr(msg, "\n\n")) {

611

strcat(msg, "\n\n");

612

}

613

614

if(ptr == msg) {

615

ERROR("Empty cdata in xml scenario file");

616

}

617

while ((ptr = strstr(msg, "\n "))) {

618

memmove(ptr + 1, ptr + 2, strlen(ptr) - 1);

619

}

620

while ((ptr = strstr(msg, " \n"))) {

621

memmove(ptr, ptr + 1, strlen(ptr));

622

}

623

while ((ptr = strstr(msg, "\n\t"))) {

624

memmove(ptr + 1, ptr + 2, strlen(ptr) - 1);

625

}

626

while ((ptr = strstr(msg, "\t\n"))) {

627

memmove(ptr, ptr + 1, strlen(ptr));

628

}

629

630

return msg;

631

}

632

633

634

635

/********************** Scenario File analyser **********************/

636

637

void scenario::checkOptionalRecv(char *elem, unsigned int scenario_file_cursor) {

638

if (last_recv_optional) {

639

ERROR("<recv> before <%s> sequence without a mandatory message. Please remove one 'optional=true' (element %d).", elem, scenario_file_cursor);

640

}

641

last_recv_optional = false;

642

}

643

644

scenario::scenario(char * filename, int deflt)

645

{

646

char * elem;

647

char *method_list = NULL;

648

unsigned int scenario_file_cursor = 0;

649

int L_content_length = 0 ;

650

char * peer;

651

652

last_recv_optional = false;

653

654

if(filename) {

655

if(!xp_set_xml_buffer_from_file(filename)) {

656

ERROR("Unable to load or parse '%s' xml scenario file", filename);

657

}

658

} else {

659

if(!xp_set_xml_buffer_from_string(default_scenario[deflt])) {

660

ERROR("Unable to load default xml scenario file");

661

}

662

}

663

664

stats = new CStat();

665

allocVars = new AllocVariableTable(userVariables);

666

667

hidedefault = false;

668

669

elem = xp_open_element(0);

670

if (!elem) {

671

ERROR("No element in xml scenario file");

672

}

673

if(strcmp("scenario", elem)) {

674

ERROR("No 'scenario' section in xml scenario file");

675

}

676

677

if(char *ptr = xp_get_value((char *)"name")) {

678

name = strdup(ptr);

679

} else {

680

name = strdup("");

681

}

682

683

duration = 0;

684

found_timewait = false;

685

686

scenario_file_cursor = 0;

687

688

while ((elem = xp_open_element(scenario_file_cursor))) {

689

char * ptr;

690

scenario_file_cursor ++;

691

692

if(!strcmp(elem, "CallLengthRepartition")) {

693

ptr = xp_get_string("value", "CallLengthRepartition");

694

stats->setRepartitionCallLength(ptr);

695

free(ptr);

696

} else if(!strcmp(elem, "ResponseTimeRepartition")) {

697

ptr = xp_get_string("value", "ResponseTimeRepartition");

698

stats->setRepartitionResponseTime(ptr);

699

free(ptr);

700

} else if(!strcmp(elem, "Global")) {

701

ptr = xp_get_string("variables", "Global");

702

703

char ** currentTabVarName = NULL;

704

int currentNbVarNames;

705

706

createStringTable(ptr, &currentTabVarName, &currentNbVarNames);

707

for (int i = 0; i < currentNbVarNames; i++) {

708

globalVariables->find(currentTabVarName[i], true);

709

}

710

freeStringTable(currentTabVarName, currentNbVarNames);

711

free(ptr);

712

} else if(!strcmp(elem, "User")) {

713

ptr = xp_get_string("variables", "User");

714

715

char ** currentTabVarName = NULL;

716

int currentNbVarNames;

717

718

createStringTable(ptr, &currentTabVarName, &currentNbVarNames);

719

for (int i = 0; i < currentNbVarNames; i++) {

720

userVariables->find(currentTabVarName[i], true);

721

}

722

freeStringTable(currentTabVarName, currentNbVarNames);

723

free(ptr);

724

} else if(!strcmp(elem, "Reference")) {

725

ptr = xp_get_string("variables", "Reference");

726

727

char ** currentTabVarName = NULL;

728

int currentNbVarNames;

729

730

createStringTable(ptr, &currentTabVarName, &currentNbVarNames);

731

for (int i = 0; i < currentNbVarNames; i++) {

732

int id = allocVars->find(currentTabVarName[i], false);

733

if (id == -1) {

734

ERROR("Could not reference non-existant variable '%s'", currentTabVarName[i]);

735

}

736

}

737

freeStringTable(currentTabVarName, currentNbVarNames);

738

free(ptr);

739

} else if(!strcmp(elem, "DefaultMessage")) {

740

char *id = xp_get_string("id", "DefaultMessage");

741

if(!(ptr = xp_get_cdata())) {

742

ERROR("No CDATA in 'send' section of xml scenario file");

743

}

744

char *msg = clean_cdata(ptr);

745

set_default_message(id, msg);

746

free(id);

747

/* XXX: This should really be per scenario. */

748

} else if(!strcmp(elem, "label")) {

749

ptr = xp_get_string("id", "label");

750

if (labelMap.find(ptr) != labelMap.end()) {

751

ERROR("The label name '%s' is used twice.", ptr);

752

}

753

labelMap[ptr] = messages.size();

754

free(ptr);

755

} else if (!strcmp(elem, "init")) {

756

/* We have an init section, which must be full of nops or labels. */

757

int nop_cursor = 0;

758

char *initelem;

759

while ((initelem = xp_open_element(nop_cursor++))) {

760

if (!strcmp(initelem, "nop")) {

761

/* We should parse this. */

762

message *nopmsg = new message(initmessages.size(), "scenario initialization");

763

initmessages.push_back(nopmsg);

764

nopmsg->M_type = MSG_TYPE_NOP;

765

getCommonAttributes(nopmsg);

766

} else if (!strcmp(initelem, "label")) {

767

/* Add an init label. */

768

ptr = xp_get_value((char *)"id");

769

if (initLabelMap.find(ptr) != initLabelMap.end()) {

770

ERROR("The label name '%s' is used twice.", ptr);

771

}

772

initLabelMap[ptr] = initmessages.size();

773

} else {

774

ERROR("Invalid element in an init stanza: '%s'", initelem);

775

}

776

xp_close_element();

777

}

778

} else { /** Message Case */

779

if (found_timewait) {

780

ERROR("<timewait> can only be the last message in a scenario!\n");

781

}

782

message *curmsg = new message(messages.size(), name ? name : "unknown scenario");

783

messages.push_back(curmsg);

784

785

if(!strcmp(elem, "send")) {

786

checkOptionalRecv(elem, scenario_file_cursor);

787

curmsg->M_type = MSG_TYPE_SEND;

788

/* Sent messages descriptions */

789

if(!(ptr = xp_get_cdata())) {

790

ERROR("No CDATA in 'send' section of xml scenario file");

791

}

792

793

int removed_clrf = 0;

794

char * msg = clean_cdata(ptr, &removed_clrf);

795

796

L_content_length = xp_get_content_length(msg);

797

switch (L_content_length) {

798

case -1 :

799

// the msg does not contain content-length field

800

break ;

801

case 0 :

802

curmsg -> content_length_flag =

803

message::ContentLengthValueZero; // Initialize to No present

804

break ;

805

default :

806

curmsg -> content_length_flag =

807

message::ContentLengthValueNoZero; // Initialize to No present

808

break ;

809

}

810

811

if((msg[strlen(msg) - 1] != '\n') && (removed_clrf)) {

812

strcat(msg, "\n");

813

}

814

char *tsrc = msg;

815

while(*tsrc++);

816

curmsg -> send_scheme = new SendingMessage(this, msg);

817

free(msg);

818

819

// If this is a request we are sending, then store our transaction/method matching information.

820

if (!curmsg->send_scheme->isResponse()) {

821

char *method = curmsg->send_scheme->getMethod();

822

bool isInvite = !strcmp(method, "INVITE");

823

bool isAck = !strcmp(method, "ACK");

824

825

if ((ptr = xp_get_value("start_txn"))) {

826

if (isAck) {

827

ERROR("An ACK message can not start a transaction!");

828

}

829

curmsg->start_txn = get_txn(ptr, "start transaction", true, isInvite, false);

830

} else if ((ptr = xp_get_value("ack_txn"))) {

831

if (!isAck) {

832

ERROR("The ack_txn attribute is valid only for ACK messages!");

833

}

834

curmsg->ack_txn = get_txn(ptr, "ack transaction", false, false, true);

835

} else {

836

int len = method_list ? strlen(method_list) : 0;

837

method_list = (char *)realloc(method_list, len + strlen(method) + 1);

838

if (!method_list) {

839

ERROR_NO("Out of memory allocating method_list!");

840

}

841

strcpy(method_list + len, method);

842

}

843

} else {

844

if ((ptr = xp_get_value("start_txn"))) {

845

ERROR("Responses can not start a transaction");

846

}

847

if ((ptr = xp_get_value("ack_txn"))) {

848

ERROR("Responses can not ACK a transaction");

849

}

850

}

851

852

if ((ptr = xp_get_value("response_txn"))) {

853

ERROR("response_txn can only be used for recieved messages.");

854

}

855

856

curmsg -> retrans_delay = xp_get_long("retrans", "retransmission timer", 0);

857

curmsg -> timeout = xp_get_long("timeout", "message send timeout", 0);

858

} else if(!strcmp(elem, (char *)"recv")) {

859

curmsg->M_type = MSG_TYPE_RECV;

860

/* Received messages descriptions */

861

if((ptr = xp_get_value((char *)"response"))) {

862

curmsg ->recv_response = get_long(ptr, "response code");

863

if (method_list) {

864

curmsg->recv_response_for_cseq_method_list = strdup(method_list);

865

}

866

if ((ptr = xp_get_value("response_txn"))) {

867

curmsg->response_txn = get_txn(ptr, "transaction response", false, false, false);

868

}

869

}

870

871

if((ptr = xp_get_value((char *)"request"))) {

872

curmsg -> recv_request = strdup(ptr);

873

if ((ptr = xp_get_value("response_txn"))) {

874

ERROR("response_txn can only be used for recieved responses.");

875

}

876

}

877

878

curmsg->optional = xp_get_optional("optional", "recv");

879

last_recv_optional = curmsg->optional;

880

curmsg->advance_state = xp_get_bool("advance_state", "recv", true);

881

if (!curmsg->advance_state && curmsg->optional == OPTIONAL_FALSE) {

882

ERROR("advance_state is allowed only for optional messages (index = %d)\n", messages.size() - 1);

883

}

884

885

if (0 != (ptr = xp_get_value((char *)"regexp_match"))) {

886

if(!strcmp(ptr, "true")) {

887

curmsg -> regexp_match = 1;

888

}

889

}

890

891

curmsg->timeout = xp_get_long("timeout", "message timeout", 0);

892

893

/* record the route set */

894

/* TODO disallow optional and rrs to coexist? */

895

if((ptr = xp_get_value((char *)"rrs"))) {

896

curmsg -> bShouldRecordRoutes = get_bool(ptr, "record route set");

897

}

898

899

/* record the authentication credentials */

900

if((ptr = xp_get_value((char *)"auth"))) {

901

bool temp = get_bool(ptr, "message authentication");

902

#ifdef _USE_OPENSSL

903

curmsg -> bShouldAuthenticate = temp;

904

#else

905

if (temp) {

906

ERROR("Authentication requires OpenSSL support!");

907

}

908

#endif

909

}

910

} else if(!strcmp(elem, "pause") || !strcmp(elem, "timewait")) {

911

checkOptionalRecv(elem, scenario_file_cursor);

912

curmsg->M_type = MSG_TYPE_PAUSE;

913

if (!strcmp(elem, "timewait")) {

914

curmsg->timewait = true;

915

found_timewait = true;

916

}

917

918

int var;

919

if ((var = xp_get_var("variable", "pause", -1)) != -1) {

920

curmsg->pause_variable = var;

921

} else {

922

CSample *distribution = parse_distribution(true);

923

924

bool sanity_check = xp_get_bool("sanity_check", "pause", true);

925

926

double pause_duration = distribution->cdfInv(0.99);

927

if (sanity_check && (pause_duration > INT_MAX)) {

928

char percentile[100];

929

char desc[100];

930

931

distribution->timeDescr(desc, sizeof(desc));

932

time_string(pause_duration, percentile, sizeof(percentile));

933

934

ERROR("The distribution %s has a 99th percentile of %s, which is larger than INT_MAX. You should chose different parameters.", desc, percentile);

935

}

936

937

curmsg->pause_distribution = distribution;

938

/* Update scenario duration with max duration */

939

duration += (int)pause_duration;

940

}

941

}

942

else if(!strcmp(elem, "nop")) {

943

checkOptionalRecv(elem, scenario_file_cursor);

944

/* Does nothing at SIP level. This message type can be used to handle

945

* actions, increment counters, or for RTDs. */

946

curmsg->M_type = MSG_TYPE_NOP;

947

}

948

else if(!strcmp(elem, "recvCmd")) {

949

curmsg->M_type = MSG_TYPE_RECVCMD;

950

curmsg->optional = xp_get_optional("optional", "recv");

951

last_recv_optional = curmsg->optional;

952

953

/* 3pcc extended mode */

954

if((ptr = xp_get_value((char *)"src"))) {

955

curmsg ->peer_src = strdup(ptr);

956

} else if (extendedTwinSippMode) {

957

ERROR("You must specify a 'src' for recvCmd when using extended 3pcc mode!");

958

}

959

} else if(!strcmp(elem, "sendCmd")) {

960

checkOptionalRecv(elem, scenario_file_cursor);

961

curmsg->M_type = MSG_TYPE_SENDCMD;

962

/* Sent messages descriptions */

963

964

/* 3pcc extended mode */

965

if((ptr = xp_get_value((char *)"dest"))) {

966

peer = strdup(ptr) ;

967

curmsg ->peer_dest = peer ;

968

peer_map::iterator peer_it;

969

peer_it = peers.find(peer_map::key_type(peer));

970

if(peer_it == peers.end()) /* the peer (slave or master)

971

has not been added in the map

972

(first occurence in the scenario) */

973

{

974

T_peer_infos infos;

975

infos.peer_socket = 0;

976

strcpy(infos.peer_host, get_peer_addr(peer));

977

peers[std::string(peer)] = infos;

978

}

979

} else if (extendedTwinSippMode) {

980

ERROR("You must specify a 'dest' for sendCmd with extended 3pcc mode!");

981

}

982

983

if(!(ptr = xp_get_cdata())) {

984

ERROR("No CDATA in 'sendCmd' section of xml scenario file");

985

}

986

char *msg = clean_cdata(ptr);

987

988

curmsg -> M_sendCmdData = new SendingMessage(this, msg, true /* skip sanity */);

989

free(msg);

990

}

991

else {

992

ERROR("Unknown element '%s' in xml scenario file", elem);

993

}

994

995

getCommonAttributes(curmsg);

996

} /** end * Message case */

997

xp_close_element();

998

} // end while

999

1000

free(method_list);

1001

1002

str_int_map::iterator label_it = labelMap.find("_unexp.main");

1003

if (label_it != labelMap.end()) {

1004

unexpected_jump = label_it->second;

1005

} else {

1006

unexpected_jump = -1;

1007

}

1008

retaddr = find_var("_unexp.retaddr", "unexpected return address");

1009

pausedaddr = find_var("_unexp.pausedaddr", "unexpected paused until");

1010

1011

/* Patch up the labels. */

1012

apply_labels(messages, labelMap);

1013

apply_labels(initmessages, initLabelMap);

1014

1015

/* Some post-scenario loading validation. */

1016

stats->validateRtds();

1017

1018

/* Make sure that all variables are used more than once. */

1019

validate_variable_usage();

1020

1021

/* Make sure that all started transactions have responses, and vice versa. */

1022

validate_txn_usage();

1023

1024

if (messages.size() == 0) {

1025

ERROR("Did not find any messages inside of scenario!");

1026

}

1027

}

1028

1029

void scenario::runInit() {

1030

call *initcall;

1031

if (initmessages.size() > 0) {

1032

initcall = new call(main_scenario, NULL, NULL, "///main-init", 0, false, false, true);

1033

initcall->run();

1034

}

1035

}

1036

1037

void clear_int_str(int_str_map m) {

1038

for(int_str_map::iterator it = m.begin(); it != m.end(); it = m.begin()) {

1039

free(it->second);

1040

m.erase(it);

1041

}

1042

}

1043

1044

void clear_str_int(str_int_map m) {

1045

for(str_int_map::iterator it = m.begin(); it != m.end(); it = m.begin()) {

1046

m.erase(it);

1047

}

1048

}

1049

1050

void clear_int_int(int_int_map m) {

1051

for(int_int_map::iterator it = m.begin(); it != m.end(); it = m.begin()) {

1052

m.erase(it);

1053

}

1054

}

1055

1056

scenario::~scenario() {

1057

for (msgvec::iterator i = messages.begin(); i != messages.end(); i++) {

1058

delete *i;

1059

}

1060

messages.clear();

1061

1062

free(name);

1063

1064

allocVars->putTable();

1065

delete stats;

1066

1067

for (unsigned int i = 0; i < transactions.size(); i++) {

1068

free(transactions[i].name);

1069

}

1070

transactions.clear();

1071

1072

clear_str_int(labelMap);

1073

clear_str_int(initLabelMap);

1074

clear_str_int(txnMap);

1075

}

1076

1077

CSample *parse_distribution(bool oldstyle = false) {

1078

CSample *distribution;

1079

char *distname;

1080

char *ptr;

1081

1082

if(!(distname = xp_get_value("distribution"))) {

1083

if (!oldstyle) {

1084

ERROR("statistically distributed actions or pauses requires 'distribution' parameter");

1085

}

1086

if ((ptr = xp_get_value("normal"))) {

1087

distname = "normal";

1088

} else if ((ptr = xp_get_value("exponential"))) {

1089

distname = "exponential";

1090

} else if ((ptr = xp_get_value("lognormal"))) {

1091

distname = "lognormal";

1092

} else if ((ptr = xp_get_value("weibull"))) {

1093

distname = "weibull";

1094

} else if ((ptr = xp_get_value("pareto"))) {

1095

distname = "pareto";

1096

} else if ((ptr = xp_get_value("gamma"))) {

1097

distname = "gamma";

1098

} else if ((ptr = xp_get_value("min"))) {

1099

distname = "uniform";

1100

} else if ((ptr = xp_get_value("max"))) {

1101

distname = "uniform";

1102

} else if ((ptr = xp_get_value("milliseconds"))) {

1103

double val = get_double(ptr, "Pause milliseconds");

1104

return new CFixed(val);

1105

} else {

1106

return new CDefaultPause();

1107

}

1108

}

1109

1110

if (!strcmp(distname, "fixed")) {

1111

double value = xp_get_double("value", "Fixed distribution");

1112

distribution = new CFixed(value);

1113

} else if (!strcmp(distname, "uniform")) {

1114

double min = xp_get_double("min", "Uniform distribution");

1115

double max = xp_get_double("max", "Uniform distribution");

1116

distribution = new CUniform(min, max);

1117

} else if (!strcmp(distname, "normal")) {

1118

double mean = xp_get_double("mean", "Normal distribution");

1119

double stdev = xp_get_double("stdev", "Normal distribution");

1120

distribution = new CNormal(mean, stdev);

1121

} else if (!strcmp(distname, "lognormal")) {

1122

double mean = xp_get_double("mean", "Lognormal distribution");

1123

double stdev = xp_get_double("stdev", "Lognormal distribution");

1124

distribution = new CLogNormal(mean, stdev);

1125

} else if (!strcmp(distname, "exponential")) {

1126

double mean = xp_get_double("mean", "Exponential distribution");

1127

distribution = new CExponential(mean);

1128

} else if (!strcmp(distname, "weibull")) {

1129

double lambda = xp_get_double("lambda", "Weibull distribution");

1130

double k = xp_get_double("k", "Weibull distribution");

1131

distribution = new CWeibull(lambda, k);

1132

} else if (!strcmp(distname, "pareto")) {

1133

double k = xp_get_double("k", "Pareto distribution");

1134

double xsubm = xp_get_double("x_m", "Pareto distribution");

1135

distribution = new CPareto(k, xsubm);

1136

} else if (!strcmp(distname, "gpareto")) {

1137

double shape = xp_get_double("shape", "Generalized Pareto distribution");

1138

double scale = xp_get_double("scale", "Generalized Pareto distribution");

1139

double location = xp_get_double("location", "Generalized Pareto distribution");

1140

distribution = new CGPareto(shape, scale, location);

1141

} else if (!strcmp(distname, "gamma")) {

1142

double k = xp_get_double("k", "Gamma distribution");

1143

double theta = xp_get_double("theta", "Gamma distribution");

1144

distribution = new CGamma(k, theta);

1145

} else if (!strcmp(distname, "negbin")) {

1146

double n = xp_get_double("n", "Negative Binomial distribution");

1147

double p = xp_get_double("p", "Negative Binomial distribution");

1148

distribution = new CNegBin(n, p);

1149

} else {

1150

ERROR("Unknown distribution: %s\n", ptr);

1151

}

1152

1153

return distribution;

1154

}

1155

1156

1157

1158

/* 3pcc extended mode:

1159

get the correspondances between

1160

slave and master names and their

1161

addresses */

1162

1163

void parse_slave_cfg()

1164

{

1165

FILE * f;

1166

char line[MAX_PEER_SIZE];

1167

char * temp_peer;

1168

char * temp_host;

1169

char * peer_host;

1170

1171

f = fopen(slave_cfg_file, "r");

1172

if(f){

1173

while (fgets(line, MAX_PEER_SIZE, f) != NULL)

1174

{

1175

if((temp_peer = strtok(line, ";"))) {

1176

if((peer_host = (char *) malloc(MAX_PEER_SIZE))){

1177

if((temp_host = strtok(NULL, ";"))){

1178

strcpy(peer_host, temp_host);

1179

peer_addrs[std::string(temp_peer)] = peer_host;

1180

}

1181

}else {

1182

ERROR("Cannot allocate memory!\n");

1183

}

1184

}

1185

}

1186

}else{

1187

ERROR("Can not open slave_cfg file %s\n", slave_cfg_file);

1188

}

1189

1190

}

1191

1192

// Determine in which mode the sipp tool has been

1193

// launched (client, server, 3pcc client, 3pcc server, 3pcc extended master or slave)

1194

void scenario::computeSippMode()

1195

{

1196

bool isRecvCmdFound = false;

1197

bool isSendCmdFound = false;

1198

1199

creationMode = -1;

1200

sendMode = -1;

1201

thirdPartyMode = MODE_3PCC_NONE;

1202

1203

assert(messages.size() > 0);

1204

1205

for(unsigned int i=0; i<messages.size(); i++)

1206

{

1207

switch(messages[i]->M_type)

1208

{

1209

case MSG_TYPE_PAUSE:

1210

case MSG_TYPE_NOP:

1211

/* Allow pauses or nops to go first. */

1212

continue;

1213

case MSG_TYPE_SEND:

1214

if (sendMode == -1) {

1215

sendMode = MODE_CLIENT;

1216

}

1217

if (creationMode == -1) {

1218

creationMode = MODE_CLIENT;

1219

}

1220

break;

1221

1222

case MSG_TYPE_RECV:

1223

if (sendMode == -1) {

1224

sendMode = MODE_SERVER;

1225

}

1226

if (creationMode == -1) {

1227

creationMode = MODE_SERVER;

1228

}

1229

break;

1230

case MSG_TYPE_SENDCMD:

1231

isSendCmdFound = true;

1232

if (creationMode == -1) {

1233

creationMode = MODE_CLIENT;

1234

}

1235

if(!isRecvCmdFound) {

1236

if (creationMode == MODE_SERVER) {

1237

/*

1238

* If it is a server already, then start it in

1239

* 3PCC A passive mode

1240

*/

1241

if(twinSippMode){

1242

thirdPartyMode = MODE_3PCC_A_PASSIVE;

1243

}else if (extendedTwinSippMode){

1244

thirdPartyMode = MODE_MASTER_PASSIVE;

1245

}

1246

} else {

1247

if(twinSippMode){

1248

thirdPartyMode = MODE_3PCC_CONTROLLER_A;

1249

}else if (extendedTwinSippMode){

1250

thirdPartyMode = MODE_MASTER;

1251

}

1252

}

1253

if((thirdPartyMode == MODE_MASTER_PASSIVE || thirdPartyMode == MODE_MASTER) && !master_name){

1254

ERROR("Inconsistency between command line and scenario: master scenario but -master option not set\n");

1255

}

1256

if(!twinSippMode && !extendedTwinSippMode)

1257

ERROR("sendCmd message found in scenario but no twin sipp"

1258

" address has been passed! Use -3pcc option or 3pcc extended mode.\n");

1259

}

1260

break;

1261

1262

case MSG_TYPE_RECVCMD:

1263

if (creationMode == -1) {

1264

creationMode = MODE_SERVER;

1265

}

1266

isRecvCmdFound = true;

1267

if(!isSendCmdFound)

1268

{

1269

if(twinSippMode){

1270

thirdPartyMode = MODE_3PCC_CONTROLLER_B;

1271

} else if(extendedTwinSippMode){

1272

thirdPartyMode = MODE_SLAVE;

1273

if(!slave_number) {

1274

ERROR("Inconsistency between command line and scenario: slave scenario but -slave option not set\n");

1275

}else{

1276

thirdPartyMode = MODE_SLAVE;

1277

}

1278

}

1279

if(!twinSippMode && !extendedTwinSippMode)

1280

ERROR("recvCmd message found in scenario but no "

1281

"twin sipp address has been passed! Use "

1282

"-3pcc option\n");

1283

}

1284

break;

1285

default:

1286

break;

1287

}

1288

}

1289

if(creationMode == -1)

1290

ERROR("Unable to determine creation mode of the tool (server, client)\n");

1291

if(sendMode == -1)

1292

ERROR("Unable to determine send mode of the tool (server, client)\n");

1293

}

1294

1295

void scenario::handle_rhs(CAction *tmpAction, char *what) {

1296

if (xp_get_value("value")) {

1297

tmpAction->setDoubleValue(xp_get_double("value", what));

1298

if (xp_get_value("variable")) {

1299

ERROR("Value and variable are mutually exclusive for %s action!", what);

1300

}

1301

} else if (xp_get_value("variable")) {

1302

tmpAction->setVarInId(xp_get_var("variable", what));

1303

if (xp_get_value("value")) {

1304

ERROR("Value and variable are mutually exclusive for %s action!", what);

1305

}

1306

} else {

1307

ERROR("No value or variable defined for %s action!", what);

1308

}

1309

}

1310

1311

void scenario::handle_arithmetic(CAction *tmpAction, char *what) {

1312

tmpAction->setVarId(xp_get_var("assign_to", what));

1313

handle_rhs(tmpAction, what);

1314

}

1315

1316

void scenario::parseAction(CActions *actions) {

1317

char * actionElem;

1318

unsigned int recvScenarioLen = 0;

1319

char * currentRegExp = NULL;

1320

char * buffer = NULL;

1321

char ** currentTabVarName = NULL;

1322

int currentNbVarNames;

1323

char * ptr;

1324

int sub_currentNbVarId;

1325

1326

while((actionElem = xp_open_element(recvScenarioLen))) {

1327

CAction *tmpAction = new CAction(this);

1328

1329

if(!strcmp(actionElem, "ereg")) {

1330

ptr = xp_get_string("regexp", "ereg");

1331

1332

// keeping regexp expression in memory

1333

if(currentRegExp != NULL)

1334

delete[] currentRegExp;

1335

currentRegExp = new char[strlen(ptr)+1];

1336

buffer = new char[strlen(ptr)+1];

1337

xp_replace(ptr, buffer, "<", "<");

1338

xp_replace(buffer, currentRegExp, ">", ">");

1339

if(buffer != NULL)

1340

delete[] buffer;

1341

tmpAction->setActionType(CAction::E_AT_ASSIGN_FROM_REGEXP);

1342

1343

// warning - although these are detected for both msg and hdr

1344

// they are only implemented for search_in="hdr"

1345

tmpAction->setCaseIndep(xp_get_bool("case_indep", "ereg", false));

1346

tmpAction->setHeadersOnly(xp_get_bool("start_line", "ereg", false));

1347

1348

free(ptr);

1349

if ( 0 != ( ptr = xp_get_value((char *)"search_in") ) ) {

1350

tmpAction->setOccurence(1);

1351

1352

if ( 0 == strcmp(ptr, (char *)"msg") ) {

1353

tmpAction->setLookingPlace(CAction::E_LP_MSG);

1354

tmpAction->setLookingChar (NULL);

1355

} else if ( 0 == strcmp(ptr, (char *)"body") ) {

1356

tmpAction->setLookingPlace(CAction::E_LP_BODY);

1357

tmpAction->setLookingChar (NULL);

1358

} else if (!strcmp(ptr, (char *)"var")) {

1359

tmpAction->setVarInId(xp_get_var("variable", "ereg"));

1360

tmpAction->setLookingPlace(CAction::E_LP_VAR);

1361

} else if (!strcmp(ptr, (char *)"hdr")) {

1362

ptr = xp_get_value((char *)"header");

1363

if (!ptr || !strlen(ptr)) {

1364

ERROR("search_in=\"hdr\" requires header field");

1365

}

1366

tmpAction->setLookingPlace(CAction::E_LP_HDR);

1367

tmpAction->setLookingChar(ptr);

1368

if (0 != (ptr = xp_get_value((char *)"occurence"))) {

1369

tmpAction->setOccurence (atol(ptr));

1370

}

1371

if (0 != (ptr = xp_get_value((char *)"occurrence"))) {

1372

tmpAction->setOccurence (atol(ptr));

1373

}

1374

} else {

1375

ERROR("Unknown search_in value %s", ptr);

1376

}

1377

} else {

1378

tmpAction->setLookingPlace(CAction::E_LP_MSG);

1379

tmpAction->setLookingChar(NULL);

1380

} // end if-else search_in

1381

1382

if (xp_get_value("check_it")) {

1383

tmpAction->setCheckIt(xp_get_bool("check_it", "ereg", false));

1384

if (xp_get_value("check_it_inverse")) {

1385

ERROR("Can not have both check_it and check_it_inverse for ereg!");

1386

}

1387

} else {

1388

tmpAction->setCheckItInverse(xp_get_bool("check_it_inverse", "ereg", false));

1389

}

1390

1391

if (!(ptr = xp_get_value((char *) "assign_to"))) {

1392

ERROR("assign_to value is missing");

1393

}

1394

1395

createStringTable(ptr, &currentTabVarName, &currentNbVarNames);

1396

1397

int varId = get_var(currentTabVarName[0], "assign_to");

1398

tmpAction->setVarId(varId);

1399

1400

tmpAction->setRegExp(currentRegExp);

1401

if (currentNbVarNames > 1 ) {

1402

sub_currentNbVarId = currentNbVarNames - 1 ;

1403

tmpAction->setNbSubVarId(sub_currentNbVarId);

1404

1405

for(int i=1; i<= sub_currentNbVarId; i++) {

1406

int varId = get_var(currentTabVarName[i], "sub expression assign_to");

1407

tmpAction->setSubVarId(varId);

1408

}

1409

}

1410

1411

freeStringTable(currentTabVarName, currentNbVarNames);

1412

1413

if(currentRegExp != NULL) {

1414

delete[] currentRegExp;

1415

}

1416

currentRegExp = NULL;

1417

} /* end !strcmp(actionElem, "ereg") */ else if(!strcmp(actionElem, "log")) {

1418

tmpAction->setMessage(xp_get_string("message", "log"));

1419

tmpAction->setActionType(CAction::E_AT_LOG_TO_FILE);

1420

} else if(!strcmp(actionElem, "warning")) {

1421

tmpAction->setMessage(xp_get_string("message", "warning"));

1422

tmpAction->setActionType(CAction::E_AT_LOG_WARNING);

1423

} else if(!strcmp(actionElem, "error")) {

1424

tmpAction->setMessage(xp_get_string("message", "error"));

1425

tmpAction->setActionType(CAction::E_AT_LOG_ERROR);

1426

} else if(!strcmp(actionElem, "assign")) {

1427

tmpAction->setActionType(CAction::E_AT_ASSIGN_FROM_VALUE);

1428

handle_arithmetic(tmpAction, "assign");

1429

} else if(!strcmp(actionElem, "assignstr")) {

1430

tmpAction->setActionType(CAction::E_AT_ASSIGN_FROM_STRING);

1431

tmpAction->setVarId(xp_get_var("assign_to", "assignstr"));

1432

tmpAction->setMessage(xp_get_string("value", "assignstr"));

1433

} else if(!strcmp(actionElem, "gettimeofday")) {

1434

tmpAction->setActionType(CAction::E_AT_ASSIGN_FROM_GETTIMEOFDAY);

1435

1436

if (!(ptr = xp_get_value((char *) "assign_to"))) {

1437

ERROR("assign_to value is missing");

1438

}

1439

createStringTable(ptr, &currentTabVarName, &currentNbVarNames);

1440

if (currentNbVarNames != 2 ) {

1441

ERROR("The gettimeofday action requires two output variables!");

1442

}

1443

tmpAction->setNbSubVarId(1);

1444

1445

int varId = get_var(currentTabVarName[0], "gettimeofday seconds assign_to");

1446

tmpAction->setVarId(varId);

1447

varId = get_var(currentTabVarName[1], "gettimeofday useconds assign_to");

1448

tmpAction->setSubVarId(varId);

1449

1450

freeStringTable(currentTabVarName, currentNbVarNames);

1451

} else if(!strcmp(actionElem, "index")) {

1452

tmpAction->setVarId(xp_get_var("assign_to", "index"));

1453

tmpAction->setActionType(CAction::E_AT_ASSIGN_FROM_INDEX);

1454

} else if(!strcmp(actionElem, "jump")) {

1455

tmpAction->setActionType(CAction::E_AT_JUMP);

1456

handle_rhs(tmpAction, "jump");

1457

} else if(!strcmp(actionElem, "pauserestore")) {

1458

tmpAction->setActionType(CAction::E_AT_PAUSE_RESTORE);

1459

handle_rhs(tmpAction, "pauserestore");

1460

} else if(!strcmp(actionElem, "add")) {

1461

tmpAction->setActionType(CAction::E_AT_VAR_ADD);

1462

handle_arithmetic(tmpAction, "add");

1463

} else if(!strcmp(actionElem, "subtract")) {

1464

tmpAction->setActionType(CAction::E_AT_VAR_SUBTRACT);

1465

handle_arithmetic(tmpAction, "subtract");

1466

} else if(!strcmp(actionElem, "multiply")) {

1467

tmpAction->setActionType(CAction::E_AT_VAR_MULTIPLY);

1468

handle_arithmetic(tmpAction, "multiply");

1469

} else if(!strcmp(actionElem, "divide")) {

1470

tmpAction->setActionType(CAction::E_AT_VAR_DIVIDE);

1471

handle_arithmetic(tmpAction, "divide");

1472

if (tmpAction->getVarInId() == 0) {

1473

if (tmpAction->getDoubleValue() == 0.0) {

1474

ERROR("divide actions can not have a value of zero!");

1475

}

1476

}

1477

} else if(!strcmp(actionElem, "sample")) {

1478

tmpAction->setVarId(xp_get_var("assign_to", "sample"));

1479

tmpAction->setActionType(CAction::E_AT_ASSIGN_FROM_SAMPLE);

1480

tmpAction->setDistribution(parse_distribution());

1481

} else if(!strcmp(actionElem, "todouble")) {

1482

tmpAction->setActionType(CAction::E_AT_VAR_TO_DOUBLE);

1483

tmpAction->setVarId(xp_get_var("assign_to", "todouble"));

1484

tmpAction->setVarInId(xp_get_var("variable", "todouble"));

1485

} else if(!strcmp(actionElem, "test")) {

1486

tmpAction->setVarId(xp_get_var("assign_to", "test"));

1487

tmpAction->setVarInId(xp_get_var("variable", "test"));

1488

if (xp_get_value("value")) {

1489

tmpAction->setDoubleValue(xp_get_double("value", "test"));

1490

if (xp_get_value("variable2")) {

1491

ERROR("Can not have both a value and a variable2 for test!");

1492

}

1493

} else {

1494

tmpAction->setVarIn2Id(xp_get_var("variable2", "test"));

1495

}

1496

tmpAction->setActionType(CAction::E_AT_VAR_TEST);

1497

ptr = xp_get_string("compare", "test");

1498

if (!strcmp(ptr, "equal")) {

1499

tmpAction->setComparator(CAction::E_C_EQ);

1500

} else if (!strcmp(ptr, "not_equal")) {

1501

tmpAction->setComparator(CAction::E_C_NE);

1502

} else if (!strcmp(ptr, "greater_than")) {

1503

tmpAction->setComparator(CAction::E_C_GT);

1504

} else if (!strcmp(ptr, "less_than")) {

1505

tmpAction->setComparator(CAction::E_C_LT);

1506

} else if (!strcmp(ptr, "greater_than_equal")) {

1507

tmpAction->setComparator(CAction::E_C_GEQ);

1508

} else if (!strcmp(ptr, "less_than_equal")) {

1509

tmpAction->setComparator(CAction::E_C_LEQ);

1510

} else {

1511

ERROR("Invalid 'compare' parameter: %s", ptr);

1512

}

1513

free(ptr);

1514

} else if(!strcmp(actionElem, "verifyauth")) {

1515

#ifdef _USE_OPENSSL

1516

tmpAction->setVarId(xp_get_var("assign_to", "verifyauth"));

1517

tmpAction->setMessage(xp_get_string("username", "verifyauth"), 0);

1518

tmpAction->setMessage(xp_get_string("password", "verifyauth"), 1);

1519

tmpAction->setActionType(CAction::E_AT_VERIFY_AUTH);

1520

#else

1521

ERROR("The verifyauth action requires OpenSSL support.");

1522

#endif

1523

} else if(!strcmp(actionElem, "lookup")) {

1524

tmpAction->setVarId(xp_get_var("assign_to", "lookup"));

1525

tmpAction->setMessage(xp_get_string("file", "lookup"), 0);

1526

tmpAction->setMessage(xp_get_string("key", "lookup"), 1);

1527

tmpAction->setActionType(CAction::E_AT_LOOKUP);

1528

} else if(!strcmp(actionElem, "insert")) {

1529

tmpAction->setMessage(xp_get_string("file", "insert"), 0);

1530

tmpAction->setMessage(xp_get_string("value", "insert"), 1);

1531

tmpAction->setActionType(CAction::E_AT_INSERT);

1532

} else if(!strcmp(actionElem, "replace")) {

1533

tmpAction->setMessage(xp_get_string("file", "replace"), 0);

1534

tmpAction->setMessage(xp_get_string("line", "replace"), 1);

1535

tmpAction->setMessage(xp_get_string("value", "replace"), 2);

1536

tmpAction->setActionType(CAction::E_AT_REPLACE);

1537

} else if(!strcmp(actionElem, "setdest")) {

1538

tmpAction->setMessage(xp_get_string("host", actionElem), 0);

1539

tmpAction->setMessage(xp_get_string("port", actionElem), 1);

1540

tmpAction->setMessage(xp_get_string("protocol", actionElem), 2);

1541

tmpAction->setActionType(CAction::E_AT_SET_DEST);

1542

} else if(!strcmp(actionElem, "closecon")) {

1543

tmpAction->setActionType(CAction::E_AT_CLOSE_CON);

1544

} else if(!strcmp(actionElem, "strcmp")) {

1545

tmpAction->setVarId(xp_get_var("assign_to", "strcmp"));

1546

tmpAction->setVarInId(xp_get_var("variable", "strcmp"));

1547

if (xp_get_value("value")) {

1548

tmpAction->setStringValue(xp_get_string("value", "strcmp"));

1549

if (xp_get_value("variable2")) {

1550

ERROR("Can not have both a value and a variable2 for strcmp!");

1551

}

1552

} else {

1553

tmpAction->setVarIn2Id(xp_get_var("variable2", "strcmp"));

1554

}

1555

tmpAction->setActionType(CAction::E_AT_VAR_STRCMP);

1556

} else if(!strcmp(actionElem, "trim")) {

1557

tmpAction->setVarId(xp_get_var("assign_to", "trim"));

1558

tmpAction->setActionType(CAction::E_AT_VAR_TRIM);

1559

} else if(!strcmp(actionElem, "exec")) {

1560

if((ptr = xp_get_value((char *)"command"))) {

1561

tmpAction->setActionType(CAction::E_AT_EXECUTE_CMD);

1562

tmpAction->setMessage(ptr);

1563

} /* end (ptr = xp_get_value("command") */ else if((ptr = xp_get_value((char *)"int_cmd"))) {

1564

CAction::T_IntCmdType type(CAction::E_INTCMD_STOPCALL); /* assume the default */

1565

1566

if (!strcmp(ptr, "stop_now")) {

1567

type = CAction::E_INTCMD_STOP_NOW;

1568

} else if (!strcmp(ptr, "stop_gracefully")) {

1569

type = CAction::E_INTCMD_STOP_ALL;

1570

} else if (!strcmp(ptr, "stop_call")) {

1571

type = CAction::E_INTCMD_STOPCALL;

1572

}

1573

1574

/* the action is well formed, adding it in the */

1575

/* tmpActionTable */

1576

tmpAction->setActionType(CAction::E_AT_EXEC_INTCMD);

1577

tmpAction->setIntCmd(type);

1578

#ifdef PCAPPLAY

1579

} else if ((ptr = xp_get_value((char *) "play_pcap_audio"))) {

1580

tmpAction->setPcapArgs(ptr);

1581

tmpAction->setActionType(CAction::E_AT_PLAY_PCAP_AUDIO);

1582

hasMedia = 1;

1583

} else if ((ptr = xp_get_value((char *) "play_pcap_video"))) {

1584

tmpAction->setPcapArgs(ptr);

1585

tmpAction->setActionType(CAction::E_AT_PLAY_PCAP_VIDEO);

1586

hasMedia = 1;

1587

#else

1588

} else if ((ptr = xp_get_value((char *) "play_pcap_audio"))) {

1589

ERROR("play_pcap_audio requires pcap support! Please recompile SIPp");

1590

} else if ((ptr = xp_get_value((char *) "play_pcap_video"))) {

1591

ERROR("play_pcap_video requires pcap support! Please recompile SIPp");

1592

#endif

1593

} else {

1594

ERROR("illegal <exec> in the scenario\n");

1595

}

1596

} else {

1597

ERROR("Unknown action: %s", actionElem);

1598

}

1599

1600

/* If the action was not well-formed, there should have already been an

1601

* ERROR declaration, thus it is safe to add it here at the end of the loop. */

1602

actions->setAction(tmpAction);

1603

1604

xp_close_element();

1605

recvScenarioLen++;

1606

} // end while

1607

}

1608

1609

// Action list for the message indexed by message_index in

1610

// the scenario

1611

void scenario::getActionForThisMessage(message *message)

1612

{

1613

char * actionElem;

1614

1615

if(!(actionElem = xp_open_element(0))) {

1616

return;

1617

}

1618

if(strcmp(actionElem, "action")) {

1619

return;

1620

}

1621

1622

/* We actually have an action element. */

1623

if(message->M_actions != NULL) {

1624

ERROR("Duplicate action for %s index %d", message->desc, message->index);

1625

}

1626

message->M_actions = new CActions();

1627

1628

parseAction(message->M_actions);

1629

xp_close_element();

1630

}

1631

1632

void scenario::getBookKeeping(message *message) {

1633

char *ptr;

1634

1635

if((ptr = xp_get_value((char *)"rtd"))) {

1636

message -> stop_rtd = get_rtd(ptr, false);

1637

}

1638

if ((ptr = xp_get_value((char *)"repeat_rtd"))) {

1639

if (message -> stop_rtd) {

1640

message-> repeat_rtd = get_bool(ptr, "repeat_rtd");

1641

} else {

1642

ERROR("There is a repeat_rtd element without an rtd element");

1643

}

1644

}

1645

1646

if((ptr = xp_get_value((char *)"start_rtd"))) {

1647

message -> start_rtd = get_rtd(ptr, true);

1648

}

1649

1650

if((ptr = xp_get_value((char *)"counter"))) {

1651

message -> counter = get_counter(ptr, "counter");

1652

}

1653

}

1654

1655

void scenario::getCommonAttributes(message *message) {

1656

char *ptr;

1657

1658

getBookKeeping(message);

1659

getActionForThisMessage(message);

1660

1661

if((ptr = xp_get_value((char *)"lost"))) {

1662

message -> lost = get_double(ptr, "lost percentage");

1663

lose_packets = 1;

1664

}

1665

1666

if((ptr = xp_get_value((char *)"crlf"))) {

1667

message -> crlf = 1;

1668

}

1669

1670

if (xp_get_value("hiderest")) {

1671

hidedefault = xp_get_bool("hiderest", "hiderest");

1672

}

1673

message -> hide = xp_get_bool("hide", "hide", hidedefault);

1674

if((ptr = xp_get_value((char *)"display"))) {

1675

message -> display_str = strdup(ptr);

1676

}

1677

1678

message -> condexec = xp_get_var("condexec", "condexec variable", -1);

1679

message -> condexec_inverse = xp_get_bool("condexec_inverse", "condexec_inverse", false);

1680

1681

if ((ptr = xp_get_value((char *)"next"))) {

1682

if (found_timewait) {

1683

ERROR("next labels are not allowed in <timewait> elements.");

1684

}

1685

message -> nextLabel = strdup(ptr);

1686

message -> test = xp_get_var("test", "test variable", -1);

1687

if ( 0 != ( ptr = xp_get_value((char *)"chance") ) ) {

1688

float chance = get_double(ptr,"chance");

1689

/* probability of branch to next */

1690

if (( chance < 0.0 ) || (chance > 1.0 )) {

1691

ERROR("Chance %s not in range [0..1]", ptr);

1692

}

1693

message -> chance = (int)((1.0-chance)*RAND_MAX);

1694

}

1695

else {

1696

message -> chance = 0; /* always */

1697

}

1698

}

1699

1700

if ((ptr = xp_get_value((char *)"ontimeout"))) {

1701

if (found_timewait) {

1702

ERROR("ontimeout labels are not allowed in <timewait> elements.");

1703

}

1704

message -> onTimeoutLabel = strdup(ptr);

1705

}

1706

}

1707

1708

// char* manipulation : create a int[] from a char*

1709

// test first is the char* is formed by int separeted by coma

1710

// and then create the table

1711

1712

int isWellFormed(char * P_listeStr, int * nombre)

1713

{

1714

char * ptr = P_listeStr;

1715

int sizeOf;

1716

bool isANumber;

1717

1718

(*nombre) = 0;

1719

sizeOf = strlen(P_listeStr);

1720

// getting the number

1721

if(sizeOf > 0)

1722

{

1723

// is the string well formed ? [0-9] [,]

1724

isANumber = false;

1725

for(int i=0; i<=sizeOf; i++)

1726

{

1727

switch(ptr[i])

1728

{

1729

case ',':

1730

if(isANumber == false)

1731

{

1732

return(0);

1733

}

1734

else

1735

{

1736

(*nombre)++;

1737

}

1738

isANumber = false;

1739

break;

1740

case '0':

1741

case '1':

1742

case '2':

1743

case '3':

1744

case '4':

1745

case '5':

1746

case '6':

1747

case '7':

1748

case '8':

1749

case '9':

1750

isANumber = true;

1751

break;

1752

case '\t':

1753

case ' ' :

1754

break;

1755

case '\0':

1756

if(isANumber == false)

1757

{

1758

return(0);

1759

}

1760

else

1761

{

1762

(*nombre)++;

1763

}

1764

break;

1765

default:

1766

return(0);

1767

}

1768

} // end for

1769

}

1770

return(1);

1771

}

1772

1773

int createIntegerTable(char * P_listeStr,

1774

unsigned int ** listeInteger,

1775

int * sizeOfList)

1776

{

1777

int nb=0;

1778

char * ptr = P_listeStr;

1779

char * ptr_prev = P_listeStr;

1780

unsigned int current_int;

1781

1782

if(P_listeStr){

1783

if(isWellFormed(P_listeStr, sizeOfList) == 1)

1784

{

1785

(*listeInteger) = new unsigned int[(*sizeOfList)];

1786

while((*ptr) != ('\0'))

1787

{

1788

if((*ptr) == ',')

1789

{

1790

sscanf(ptr_prev, "%u", &current_int);

1791

if (nb<(*sizeOfList))

1792

(*listeInteger)[nb] = current_int;

1793

nb++;

1794

ptr_prev = ptr+1;

1795

}

1796

ptr++;

1797

}

1798

1799

// Read the last

1800

sscanf(ptr_prev, "%u", &current_int);

1801

if (nb<(*sizeOfList))

1802

(*listeInteger)[nb] = current_int;

1803

nb++;

1804

return(1);

1805

}

1806

return(0);

1807

}else return(0);

1808

}

1809

1810

int createStringTable(char * inputString, char *** stringList, int *sizeOfList)

1811

{

1812

if(!inputString) {

1813

return 0;

1814

}

1815

1816

*stringList = NULL;

1817

*sizeOfList = 0;

1818

1819

do

1820

{

1821

char *p = strchr(inputString, ',');

1822

if (p) {

1823

*p++ = '\0';

1824

}

1825

1826

*stringList = (char **)realloc(*stringList, sizeof(char *) * (*sizeOfList + 1));

1827

(*stringList)[*sizeOfList] = strdup(inputString);

1828

(*sizeOfList)++;

1829

1830

inputString = p;

1831

}

1832

while (inputString);

1833

1834

return 1;

1835

}

1836

1837

void freeStringTable(char ** stringList, int sizeOfList) {

1838

for (int i = 0; i < sizeOfList; i++) {

1839

free(stringList[i]);

1840

}

1841

free(stringList);

1842

}

1843

1844

/* These are the names of the scenarios, they must match the default_scenario table. */

1845

char *scenario_table[] = {

1846

"uac",

1847

"uas",

1848

"regexp",

1849

"3pcc-C-A",

1850

"3pcc-C-B",

1851

"3pcc-A",

1852

"3pcc-B",

1853

"branchc",

1854

"branchs",

1855

"uac_pcap",

1856

"ooc_default",

1857

};

1858

1859

int find_scenario(const char *scenario) {

1860

int i, max;

1861

max = sizeof(scenario_table)/sizeof(scenario_table[0]);

1862

1863

for (i = 0; i < max; i++) {

1864

if (!strcmp(scenario_table[i], scenario)) {

1865

return i;

1866

}

1867

}

1868

1869

ERROR("Invalid default scenario name '%s'.\n", scenario);

1870

return -1;

1871

}

1872

1873

// TIP: to integrate an existing XML scenario, use the following sed line:

1874

// cat ../3pcc-controller-B.xml | sed -e 's/\"/\\\"/g' -e 's/$.*$/\"\1\\n\"/'

1875

char * default_scenario [] = {

1876

/************* Default_scenario[0] ***************/

1877

(char *)

1878

"<?xml version=\"1.0\" encoding=\"ISO-8859-1\" ?>\n"

1879

"<!DOCTYPE scenario SYSTEM \"sipp.dtd\">\n"

1880

"\n"

1881

"\n"

1882

"\n"

1883

"\n"

1884

"\n"

1885

"\n"

1886

"\n"

1887

"\n"

1888

"\n"

1889

"\n"

1890

"\n"

1891

"\n"

1892

"\n"

1893

"\n"

1894

"\n"

1895

"\n"

1896

"\n"

1897

"\n"

1898

"\n"

1899

"<scenario name=\"Basic Sipstone UAC\">\n"

1900

" \n"

1901

" \n"

1902

" <send retrans=\"500\">\n"

1903

" <![CDATA[\n"

1904

"\n"

1905

" INVITE sip:[service]@[remote_ip]:[remote_port] SIP/2.0\n"

1906

" Via: SIP/2.0/[transport] [local_ip]:[local_port];branch=[branch]\n"

1907

" From: sipp <sip:sipp@[local_ip]:[local_port]>;tag=[pid]SIPpTag00[call_number]\n"

1908

" To: sut <sip:[service]@[remote_ip]:[remote_port]>\n"

1909

" Call-ID: [call_id]\n"

1910

" CSeq: 1 INVITE\n"

1911

" Contact: sip:sipp@[local_ip]:[local_port]\n"

1912

" Max-Forwards: 70\n"

1913

" Subject: Performance Test\n"

1914

" Content-Type: application/sdp\n"

1915

" Content-Length: [len]\n"

1916

"\n"

1917

" v=0\n"

1918

" o=user1 53655765 2353687637 IN IP[local_ip_type] [local_ip]\n"

1919

" s=-\n"

1920

" c=IN IP[media_ip_type] [media_ip]\n"

1921

" t=0 0\n"

1922

" m=audio [media_port] RTP/AVP 0\n"

1923

" a=rtpmap:0 PCMU/8000\n"

1924

"\n"

1925

" ]]>\n"

1926

" </send>\n"

1927

"\n"

1928

" <recv response=\"100\"\n"

1929

" optional=\"true\">\n"

1930

" </recv>\n"

1931

"\n"

1932

" <recv response=\"180\" optional=\"true\">\n"

1933

" </recv>\n"

1934

"\n"

1935

" <recv response=\"183\" optional=\"true\">\n"

1936

" </recv>\n"

1937

"\n"

1938

" \n"

1939

" \n"

1940

" \n"

1941

" <recv response=\"200\" rtd=\"true\">\n"

1942

" </recv>\n"

1943

"\n"

1944

" \n"

1945

" \n"

1946

" <send>\n"

1947

" <![CDATA[\n"

1948

"\n"

1949

" ACK sip:[service]@[remote_ip]:[remote_port] SIP/2.0\n"

1950

" Via: SIP/2.0/[transport] [local_ip]:[local_port];branch=[branch]\n"

1951

" From: sipp <sip:sipp@[local_ip]:[local_port]>;tag=[pid]SIPpTag00[call_number]\n"

1952

" To: sut <sip:[service]@[remote_ip]:[remote_port]>[peer_tag_param]\n"

1953

" Call-ID: [call_id]\n"

1954

" CSeq: 1 ACK\n"

1955

" Contact: sip:sipp@[local_ip]:[local_port]\n"

1956

" Max-Forwards: 70\n"

1957

" Subject: Performance Test\n"

1958

" Content-Length: 0\n"

1959

"\n"

1960

" ]]>\n"

1961

" </send>\n"

1962

"\n"

1963

" \n"

1964

" \n"

1965

" <pause/>\n"

1966

"\n"

1967

" \n"

1968

" <send retrans=\"500\">\n"

1969

" <![CDATA[\n"

1970

"\n"

1971

" BYE sip:[service]@[remote_ip]:[remote_port] SIP/2.0\n"

1972

" Via: SIP/2.0/[transport] [local_ip]:[local_port];branch=[branch]\n"

1973

" From: sipp <sip:sipp@[local_ip]:[local_port]>;tag=[pid]SIPpTag00[call_number]\n"

1974

" To: sut <sip:[service]@[remote_ip]:[remote_port]>[peer_tag_param]\n"

1975

" Call-ID: [call_id]\n"

1976

" CSeq: 2 BYE\n"

1977

" Contact: sip:sipp@[local_ip]:[local_port]\n"

1978

" Max-Forwards: 70\n"

1979

" Subject: Performance Test\n"

1980

" Content-Length: 0\n"

1981

"\n"

1982

" ]]>\n"

1983

" </send>\n"

1984

"\n"

1985

" <recv response=\"200\" crlf=\"true\">\n"

1986

" </recv>\n"

1987

"\n"

1988

" \n"

1989

" <ResponseTimeRepartition value=\"10, 20, 30, 40, 50, 100, 150, 200\"/>\n"

1990

"\n"

1991

" \n"

1992

" <CallLengthRepartition value=\"10, 50, 100, 500, 1000, 5000, 10000\"/>\n"

1993

"\n"

1994

"</scenario>\n"

1995

"\n"

1996

,

1997

1998

/************* Default_scenario[1] ***************/

1999

(char *)

2000

"<?xml version=\"1.0\" encoding=\"ISO-8859-1\" ?>\n"

2001

"<!DOCTYPE scenario SYSTEM \"sipp.dtd\">\n"

2002

"\n"

2003

"\n"

2004

"\n"

2005

"\n"

2006

"\n"

2007

"\n"

2008

"\n"

2009

"\n"

2010

"\n"

2011

"\n"

2012

"\n"

2013

"\n"

2014

"\n"

2015

"\n"

2016

"\n"

2017

"\n"

2018

"\n"

2019

"\n"

2020

"\n"

2021

"<scenario name=\"Basic UAS responder\">\n"

2022

" \n"

2023

" \n"

2024

" \n"

2025

" <recv request=\"INVITE\" crlf=\"true\">\n"

2026

" </recv>\n"

2027

"\n"

2028

" \n"

2029

" \n"

2030

" \n"

2031

" \n"

2032

" \n"

2033

" \n"

2034

" \n"

2035

" \n"

2036

" \n"

2037

" \n"

2038

"\n"

2039

" <send>\n"

2040

" <![CDATA[\n"

2041

"\n"

2042

" SIP/2.0 180 Ringing\n"

2043

" [last_Via:]\n"

2044

" [last_From:]\n"

2045

" [last_To:];tag=[pid]SIPpTag01[call_number]\n"

2046

" [last_Call-ID:]\n"

2047

" [last_CSeq:]\n"

2048

" Contact: <sip:[local_ip]:[local_port];transport=[transport]>\n"

2049

" Content-Length: 0\n"

2050

"\n"

2051

" ]]>\n"

2052

" </send>\n"

2053

"\n"

2054

" <send retrans=\"500\">\n"

2055

" <![CDATA[\n"

2056

"\n"

2057

" SIP/2.0 200 OK\n"

2058

" [last_Via:]\n"

2059

" [last_From:]\n"

2060

" [last_To:];tag=[pid]SIPpTag01[call_number]\n"

2061

" [last_Call-ID:]\n"

2062

" [last_CSeq:]\n"

2063

" Contact: <sip:[local_ip]:[local_port];transport=[transport]>\n"

2064

" Content-Type: application/sdp\n"

2065

" Content-Length: [len]\n"

2066

"\n"

2067

" v=0\n"

2068

" o=user1 53655765 2353687637 IN IP[local_ip_type] [local_ip]\n"

2069

" s=-\n"

2070

" c=IN IP[media_ip_type] [media_ip]\n"

2071

" t=0 0\n"

2072

" m=audio [media_port] RTP/AVP 0\n"

2073

" a=rtpmap:0 PCMU/8000\n"

2074

"\n"

2075

" ]]>\n"

2076

" </send>\n"

2077

"\n"

2078

" <recv request=\"ACK\"\n"

2079

" optional=\"true\"\n"

2080

" rtd=\"true\"\n"

2081

" crlf=\"true\">\n"

2082

" </recv>\n"

2083

"\n"

2084

" <recv request=\"BYE\">\n"

2085

" </recv>\n"

2086

"\n"

2087

" <send>\n"

2088

" <![CDATA[\n"

2089

"\n"

2090

" SIP/2.0 200 OK\n"

2091

" [last_Via:]\n"

2092

" [last_From:]\n"

2093

" [last_To:]\n"

2094

" [last_Call-ID:]\n"

2095

" [last_CSeq:]\n"

2096

" Contact: <sip:[local_ip]:[local_port];transport=[transport]>\n"

2097

" Content-Length: 0\n"

2098

"\n"

2099

" ]]>\n"

2100

" </send>\n"

2101

"\n"

2102

" \n"

2103

" \n"

2104

" <timewait milliseconds=\"4000\"/>\n"

2105

"\n"

2106

"\n"

2107

" \n"

2108

" <ResponseTimeRepartition value=\"10, 20, 30, 40, 50, 100, 150, 200\"/>\n"

2109

"\n"

2110

" \n"

2111

" <CallLengthRepartition value=\"10, 50, 100, 500, 1000, 5000, 10000\"/>\n"

2112

"\n"

2113

"</scenario>\n"

2114

"\n",

2115

2116

/************* Default_scenario[2] ***************/

2117

(char *)

2118

"<?xml version=\"1.0\" encoding=\"ISO-8859-1\" ?>\n"

2119

"<!DOCTYPE scenario SYSTEM \"sipp.dtd\">\n"

2120

"\n"

2121

"\n"

2122

"\n"

2123

"\n"

2124

"\n"

2125

"\n"

2126

"\n"

2127

"\n"

2128

"\n"

2129

"\n"

2130

"\n"

2131

"\n"

2132

"\n"

2133

"\n"

2134

"\n"

2135

"\n"

2136

"\n"

2137

"\n"

2138

"\n"

2139

"<scenario name=\"Client with regexp scenario\">\n"

2140

" <send retrans=\"500\">\n"

2141

" <![CDATA[\n"

2142

"\n"

2143

" INVITE sip:[service]@[remote_ip]:[remote_port] SIP/2.0\n"

2144

" Via: SIP/2.0/[transport] [local_ip]:[local_port];branch=[branch]\n"

2145

" From: sipp <sip:sipp@[local_ip]:[local_port]>;tag=[pid]SIPpTag02[call_number]\n"

2146

" To: sut <sip:[service]@[remote_ip]:[remote_port]>\n"

2147

" Call-ID: [call_id]\n"

2148

" CSeq: 1 INVITE\n"

2149

" Contact: sip:sipp@[local_ip]:[local_port]\n"

2150

" Max-Forwards: 70\n"

2151

" Subject: Performance Test\n"

2152

" Content-Type: application/sdp\n"

2153

" Content-Length: [len]\n"

2154

"\n"

2155

" v=0\n"

2156

" o=user1 53655765 2353687637 IN IP[local_ip_type] [local_ip]\n"

2157

" s=-\n"

2158

" c=IN IP[media_ip_type] [media_ip]\n"

2159

" t=0 0\n"

2160

" m=audio [media_port] RTP/AVP 0\n"

2161

" a=rtpmap:0 PCMU/8000\n"

2162

"\n"

2163

" ]]>\n"

2164

" </send>\n"

2165

"\n"

2166

" <recv response=\"100\"\n"

2167

" optional=\"true\">\n"

2168

" </recv>\n"

2169

"\n"

2170

" <recv response=\"180\" optional=\"true\">\n"

2171

" </recv>\n"

2172

" <recv response=\"183\" optional=\"true\">\n"

2173

" </recv>\n"

2174

"\n"

2175

" <recv response=\"200\" start_rtd=\"true\">\n"

2176

" \n"

2177

" \n"

2178

" \n"

2179

" \n"

2180

" \n"

2181

" \n"

2182

" \n"

2183

" \n"

2184

" \n"

2185

" \n"

2186

" \n"

2187

" \n"

2188

" \n"

2189

" \n"

2190

" \n"

2191

" \n"

2192

" \n"

2193

" \n"

2194

" \n"

2195

" \n"

2196

" \n"

2197

" \n"

2198

" \n"

2199

" \n"

2200

" \n"

2201

" <action>\n"

2202

" <ereg regexp=\"[0-9]{1,3}[.][0-9]{1,3}[.][0-9]{1,3}[.][0-9]{1,3}[:][0-9]{1,5}\" \n"

2203

" search_in=\"msg\" \n"

2204

" check_it=\"true\" \n"

2205

" assign_to=\"1\"/>\n"

2206

" <ereg regexp=\".*\" \n"

2207

" search_in=\"hdr\" \n"

2208

" header=\"Contact:\" \n"

2209

" check_it=\"true\" \n"

2210

" assign_to=\"6\"/>\n"

2211

" <ereg regexp=\"o=([[:alnum:]]*) ([[:alnum:]]*) ([[:alnum:]]*)\"\n"

2212

" search_in=\"msg\" \n"

2213

" check_it=\"true\" \n"

2214

" assign_to=\"3,4,5,8\"/>\n"

2215

" </action>\n"

2216

" </recv>\n"

2217

"\n"

2218

" <send>\n"

2219

" <![CDATA[\n"

2220

" ACK sip:[service]@[remote_ip]:[remote_port] SIP/2.0\n"

2221

" Via: SIP/2.0/[transport] [local_ip]:[local_port];branch=[branch]\n"

2222

" From: sipp <sip:sipp@[local_ip]:[local_port]>;tag=[pid]SIPpTag02[call_number]\n"

2223

" To: sut <sip:[service]@[remote_ip]:[remote_port]>[peer_tag_param]\n"

2224

" Call-ID: [call_id]\n"

2225

" CSeq: 1 ACK\n"

2226

" retrievedIp: [$1]\n"

2227

" retrievedContact:[$6]\n"

2228

" retrievedSdpOrigin:[$3]\n"

2229

" retrievedSdpOrigin-username:[$4]\n"

2230

" retrievedSdpOrigin-session-id:[$5]\n"

2231

" retrievedSdpOrigin-version:[$8]\n"

2232

" Contact: sip:sipp@[local_ip]:[local_port]\n"

2233

" Max-Forwards: 70\n"

2234

" Subject: Performance Test\n"

2235

" Content-Length: 0\n"

2236

" ]]>\n"

2237

" </send>\n"

2238

"\n"

2239

" \n"

2240

" \n"

2241

" <pause milliseconds = \"1000\"/>\n"

2242

"\n"

2243

" \n"

2244

" <send retrans=\"500\">\n"

2245

" <![CDATA[\n"

2246

"\n"

2247

" BYE sip:[service]@[remote_ip]:[remote_port] SIP/2.0\n"

2248

" Via: SIP/2.0/[transport] [local_ip]:[local_port];branch=[branch]\n"

2249

" From: sipp <sip:sipp@[local_ip]:[local_port]>;tag=[pid]SIPpTag02[call_number]\n"

2250

" To: sut <sip:[service]@[remote_ip]:[remote_port]>[peer_tag_param]\n"

2251

" Call-ID: [call_id]\n"

2252

" CSeq: 2 BYE\n"

2253

" Contact: sip:sipp@[local_ip]:[local_port]\n"

2254

" Max-Forwards: 70\n"

2255

" Subject: Performance Test\n"

2256

" Content-Length: 0\n"

2257

"\n"

2258

" ]]>\n"

2259

" </send>\n"

2260

"\n"

2261

" <recv response=\"200\" crlf=\"true\" rtd=\"true\">\n"

2262

" </recv>\n"

2263

"\n"

2264

" \n"

2265

" <ResponseTimeRepartition value=\"1000, 1040, 1080, 1120, 1160, 1200\"/>\n"

2266

"\n"

2267

" \n"

2268

" <CallLengthRepartition value=\"1000, 1100, 1200, 1300, 1400\"/>\n"

2269

"\n"

2270

"</scenario>\n"

2271

"\n",

2272

2273

/************* Default_scenario[3] ***************/

2274

(char*)

2275

"<?xml version=\"1.0\" encoding=\"ISO-8859-1\" ?>\n"

2276

"<!DOCTYPE scenario SYSTEM \"sipp.dtd\">\n"

2277

"\n"

2278

"\n"

2279

"\n"

2280

"\n"

2281

"\n"

2282

"\n"

2283

"\n"

2284

"\n"

2285

"\n"

2286

"\n"

2287

"\n"

2288

"\n"

2289

"\n"

2290

"\n"

2291

"\n"

2292

"\n"

2293

"\n"

2294

"\n"

2295

"\n"

2296

"\n"

2297

"\n"

2298

"\n"

2299

"\n"

2300

"\n"

2301

"\n"

2302

"\n"

2303

"\n"

2304

"\n"

2305

"\n"

2306

"\n"

2307

"\n"

2308

"\n"

2309

"\n"

2310

"\n"

2311

"\n"

2312

"<scenario name=\"3PCC Controller - A side\">\n"

2313

" <send retrans=\"500\">\n"

2314

" <![CDATA[\n"

2315

"\n"

2316

" INVITE sip:[service]@[remote_ip]:[remote_port] SIP/2.0\n"

2317

" Via: SIP/2.0/[transport] [local_ip]:[local_port];branch=[branch]\n"

2318

" From: sipp <sip:sipp@[local_ip]:[local_port]>;tag=[pid]SIPpTag03[call_number]\n"

2319

" To: sut <sip:[service]@[remote_ip]:[remote_port]>\n"

2320

" Call-ID: [call_id]\n"

2321

" CSeq: 1 INVITE\n"

2322

" Contact: sip:sipp@[local_ip]:[local_port]\n"

2323

" Max-Forwards: 70\n"

2324

" Subject: Performance Test\n"

2325

" Content-Length: 0\n"

2326

"\n"

2327

" ]]>\n"

2328

" </send>\n"

2329

"\n"

2330

" <recv response=\"100\" optional=\"true\"> </recv>\n"

2331

" <recv response=\"180\" optional=\"true\"> </recv>\n"

2332

" <recv response=\"183\" optional=\"true\"> </recv>\n"

2333

" <recv response=\"200\" crlf=\"true\" start_rtd=\"true\">\n"

2334

" <action>\n"

2335

" <ereg regexp=\"Content-Type:.*\" \n"

2336

" search_in=\"msg\" \n"

2337

" assign_to=\"1\" /> \n"

2338

" </action>\n"

2339

" </recv>\n"

2340

"\n"

2341

" <sendCmd>\n"

2342

" <![CDATA[\n"

2343

" Call-ID: [call_id]\n"

2344

" [$1]\n"

2345

"\n"

2346

" ]]>\n"

2347

" </sendCmd>\n"

2348

" \n"

2349

" <recvCmd>\n"

2350

" <action>\n"

2351

" <ereg regexp=\"Content-Type:.*\" \n"

2352

" search_in=\"msg\" \n"

2353

" assign_to=\"2\" /> \n"

2354

" </action>\n"

2355

" \n"

2356

" </recvCmd>\n"

2357

" \n"

2358

" <send rtd=\"true\">\n"

2359

" <![CDATA[\n"

2360

"\n"

2361

" ACK sip:[service]@[remote_ip]:[remote_port] SIP/2.0\n"

2362

" Via: SIP/2.0/[transport] [local_ip]:[local_port];branch=[branch]\n"

2363

" From: sipp <sip:sipp@[local_ip]:[local_port]>;tag=[pid]SIPpTag03[call_number]\n"

2364

" To: sut <sip:[service]@[remote_ip]:[remote_port]>[peer_tag_param]\n"

2365

" Call-ID: [call_id]\n"

2366

" CSeq: 1 ACK\n"

2367

" Contact: sip:sipp@[local_ip]:[local_port]\n"

2368

" Max-Forwards: 70\n"

2369

" Subject: Performance Test\n"

2370

" [$2]\n"

2371

"\n"

2372

" ]]>\n"

2373

" </send>\n"

2374

"\n"

2375

" <pause milliseconds=\"1000\"/>\n"

2376

"\n"

2377

" \n"

2378

" <send retrans=\"500\">\n"

2379

" <![CDATA[\n"

2380

"\n"

2381

" BYE sip:[service]@[remote_ip]:[remote_port] SIP/2.0\n"

2382

" Via: SIP/2.0/[transport] [local_ip]:[local_port];branch=[branch]\n"

2383

" From: sipp <sip:sipp@[local_ip]:[local_port]>;tag=[pid]SIPpTag03[call_number]\n"

2384

" To: sut <sip:[service]@[remote_ip]:[remote_port]>[peer_tag_param]\n"

2385

" Call-ID: [call_id]\n"

2386

" CSeq: 2 BYE\n"

2387

" Contact: sip:sipp@[local_ip]:[local_port]\n"

2388

" Max-Forwards: 70\n"

2389

" Subject: Performance Test\n"

2390

" Content-Length: 0\n"

2391

"\n"

2392

" ]]>\n"

2393

" </send>\n"

2394

"\n"

2395

" <recv response=\"200\" crlf=\"true\"> </recv>\n"

2396

"\n"

2397

"</scenario>\n"

2398

"\n",

2399

2400

/************* Default_scenario[4] ***************/

2401

(char*)

2402

"<?xml version=\"1.0\" encoding=\"ISO-8859-1\" ?>\n"

2403

"<!DOCTYPE scenario SYSTEM \"sipp.dtd\">\n"

2404

"\n"

2405

"\n"

2406

"\n"

2407

"\n"

2408

"\n"

2409

"\n"

2410

"\n"

2411

"\n"

2412

"\n"

2413

"\n"

2414

"\n"

2415

"\n"

2416

"\n"

2417

"\n"

2418

"\n"

2419

"\n"

2420

"\n"

2421

"\n"

2422

"\n"

2423

"\n"

2424

"\n"

2425

"\n"

2426

"\n"

2427

"\n"

2428

"\n"

2429

"\n"

2430

"\n"

2431

"\n"

2432

"\n"

2433

"\n"

2434

"\n"

2435

"\n"

2436

"\n"

2437

"\n"

2438

"\n"

2439

"\n"

2440

"<scenario name=\"3PCC Controller - B side\">\n"

2441

"\n"

2442

"<recvCmd>\n"

2443

" <action>\n"

2444

" <ereg regexp=\"Content-Type:.*\" \n"

2445

" search_in=\"msg\" \n"

2446

" assign_to=\"1\" /> \n"

2447

" </action>\n"

2448

"</recvCmd>\n"

2449

"\n"

2450

" <send retrans=\"500\">\n"

2451

" <![CDATA[\n"

2452

"\n"

2453

" INVITE sip:[service]@[remote_ip]:[remote_port] SIP/2.0\n"

2454

" Via: SIP/2.0/[transport] [local_ip]:[local_port];branch=[branch]\n"

2455

" From: sipp <sip:sipp@[local_ip]:[local_port]>;tag=[pid]SIPpTag04[call_number]\n"

2456

" To: sut <sip:[service]@[remote_ip]:[remote_port]>\n"

2457

" Call-ID: [call_id]\n"

2458

" CSeq: 1 INVITE\n"

2459

" Contact: sip:sipp@[local_ip]:[local_port]\n"

2460

" Max-Forwards: 70\n"

2461

" Subject: Performance Test\n"

2462

" [$1]\n"

2463

"\n"

2464

" ]]>\n"

2465

" </send>\n"

2466

"\n"

2467

" <recv response=\"100\" optional=\"true\"> </recv>\n"

2468

" <recv response=\"180\" optional=\"true\"> </recv>\n"

2469

" <recv response=\"183\" optional=\"true\"> </recv>\n"

2470

" <recv response=\"200\" crlf=\"true\">\n"

2471

" <action>\n"

2472

" <ereg regexp=\"Content-Type:.*\" \n"

2473

" search_in=\"msg\" \n"

2474

" assign_to=\"2\" /> \n"

2475

" </action>\n"

2476

" </recv>\n"

2477

" \n"

2478

" \n"

2479

" <send start_rtd=\"true\">\n"

2480

" <![CDATA[\n"

2481

"\n"

2482

" ACK sip:[service]@[remote_ip]:[remote_port] SIP/2.0\n"

2483

" Via: SIP/2.0/[transport] [local_ip]:[local_port];branch=[branch]\n"

2484

" From: sipp <sip:sipp@[local_ip]:[local_port]>;tag=[pid]SIPpTag04[call_number]\n"

2485

" To: sut <sip:[service]@[remote_ip]:[remote_port]>[peer_tag_param]\n"

2486

" Call-ID: [call_id]\n"

2487

" CSeq: 1 ACK\n"

2488

" Contact: sip:sipp@[local_ip]:[local_port]\n"

2489

" Max-Forwards: 70\n"

2490

" Subject: Performance Test\n"

2491

" Content-Length: 0\n"

2492

"\n"

2493

" ]]>\n"

2494

" </send>\n"

2495

"\n"

2496

" <sendCmd>\n"

2497

" <![CDATA[\n"

2498

" Call-ID: [call_id]\n"

2499

" [$2]\n"

2500

"\n"

2501

" ]]>\n"

2502

" </sendCmd>\n"

2503

" \n"

2504

" <pause milliseconds=\"1000\"/>\n"

2505

"\n"

2506

"\n"

2507

" \n"

2508

" <send retrans=\"500\" rtd=\"true\">\n"

2509

" <![CDATA[\n"

2510

"\n"

2511

" BYE sip:[service]@[remote_ip]:[remote_port] SIP/2.0\n"

2512

" Via: SIP/2.0/[transport] [local_ip]:[local_port];branch=[branch]\n"

2513

" From: sipp <sip:sipp@[local_ip]:[local_port]>;tag=[pid]SIPpTag04[call_number]\n"

2514

" To: sut <sip:[service]@[remote_ip]:[remote_port]>[peer_tag_param]\n"

2515

" Call-ID: [call_id]\n"

2516

" CSeq: 2 BYE\n"

2517

" Contact: sip:sipp@[local_ip]:[local_port]\n"

2518

" Max-Forwards: 70\n"

2519

" Subject: Performance Test\n"

2520

" Content-Length: 0\n"

2521

"\n"

2522

" ]]>\n"

2523

" </send>\n"

2524

"\n"

2525

" <recv response=\"200\" crlf=\"true\">\n"

2526

" </recv>\n"

2527

"\n"

2528

"\n"

2529

"</scenario>\n"

2530

"\n",

2531

2532

/************* Default_scenario[5] ***************/

2533

(char*)

2534

"<?xml version=\"1.0\" encoding=\"ISO-8859-1\" ?>\n"

2535

"<!DOCTYPE scenario SYSTEM \"sipp.dtd\">\n"

2536

"\n"

2537

"\n"

2538

"\n"

2539

"\n"

2540

"\n"

2541

"\n"

2542

"\n"

2543

"\n"

2544

"\n"

2545

"\n"

2546

"\n"

2547

"\n"

2548

"\n"

2549

"\n"

2550

"\n"

2551

"\n"

2552

"\n"

2553

"\n"

2554

"\n"

2555

"\n"

2556

"\n"

2557

"\n"

2558

"\n"

2559

"\n"

2560

"\n"

2561

"\n"

2562

"\n"

2563

"\n"

2564

"\n"

2565

"\n"

2566

"\n"

2567

"\n"

2568

"\n"

2569

"\n"

2570

"\n"

2571

"\n"

2572

"<scenario name=\"3PCC A side\">\n"

2573

" <recv request=\"INVITE\" crlf=\"true\">\n"

2574

" </recv>\n"

2575

"\n"

2576

" <send>\n"

2577

" <![CDATA[\n"

2578

"\n"

2579

" SIP/2.0 200 OK\n"

2580

" [last_Via:]\n"

2581

" [last_From:]\n"

2582

" [last_To:];tag=[pid]SIPpTag05[call_number]\n"

2583

" [last_Call-ID:]\n"

2584

" [last_CSeq:]\n"

2585

" Contact: <sip:[local_ip]:[local_port];transport=[transport]>\n"

2586

" Content-Type: application/sdp\n"

2587

" Content-Length: [len]\n"

2588

"\n"

2589

" v=0\n"

2590

" o=user1 53655765 2353687637 IN IP[local_ip_type] [local_ip]\n"

2591

" s=-\n"

2592

" c=IN IP[media_ip_type] [media_ip]\n"

2593

" t=0 0\n"

2594

" m=audio [media_port] RTP/AVP 0\n"

2595

" a=rtpmap:0 PCMU/8000\n"

2596

"\n"

2597

" ]]>\n"

2598

" </send>\n"

2599

"\n"

2600

" <recv request=\"ACK\" rtd=\"true\" crlf=\"true\"> </recv>\n"

2601

"\n"

2602

" \n"

2603

"\n"

2604

" <recv request=\"BYE\" crlf=\"true\"> </recv>\n"

2605

"\n"

2606

" <send>\n"

2607

" <![CDATA[\n"

2608

"\n"

2609

" SIP/2.0 200 OK\n"

2610

" [last_Via:]\n"

2611

" [last_From:]\n"

2612

" [last_To:]\n"

2613

" [last_Call-ID:]\n"

2614

" [last_CSeq:]\n"

2615

" Contact: <sip:[local_ip]:[local_port];transport=[transport]>\n"

2616

" Content-Length: 0\n"

2617

"\n"

2618

" ]]>\n"

2619

" </send>\n"

2620

"\n"

2621

" \n"

2622

" \n"

2623

" <timewait milliseconds=\"2000\"/>\n"

2624

"\n"

2625

"</scenario>\n"

2626

"\n",

2627

2628

/************* Default_scenario[6] ***************/

2629

(char*)

2630

"<?xml version=\"1.0\" encoding=\"ISO-8859-1\" ?>\n"

2631

"<!DOCTYPE scenario SYSTEM \"sipp.dtd\">\n"

2632

"\n"

2633

"\n"

2634

"\n"

2635

"\n"

2636

"\n"

2637

"\n"

2638

"\n"

2639

"\n"

2640

"\n"

2641

"\n"

2642

"\n"

2643

"\n"

2644

"\n"

2645

"\n"

2646

"\n"

2647

"\n"

2648

"\n"

2649

"\n"

2650

"\n"

2651

"\n"

2652

"\n"

2653

"\n"

2654

"\n"

2655

"\n"

2656

"\n"

2657

"\n"

2658

"\n"

2659

"\n"

2660

"\n"

2661

"\n"

2662

"\n"

2663

"\n"

2664

"\n"

2665

"\n"

2666

"\n"

2667

"\n"

2668

"\n"

2669

"<scenario name=\"3PCC B side\">\n"

2670

" <recv request=\"INVITE\" crlf=\"true\"> </recv>\n"

2671

"\n"

2672

" <send>\n"

2673

" <![CDATA[\n"

2674

"\n"

2675

" SIP/2.0 200 OK\n"

2676

" [last_Via:]\n"

2677

" [last_From:]\n"

2678

" [last_To:];tag=[pid]SIPpTag06[call_number]\n"

2679

" [last_Call-ID:]\n"

2680

" [last_CSeq:]\n"

2681

" Contact: <sip:[local_ip]:[local_port];transport=[transport]>\n"

2682

" Content-Type: application/sdp\n"

2683

" Content-Length: [len]\n"

2684

"\n"

2685

" v=0\n"

2686

" o=user1 53655765 2353687637 IN IP[local_ip_type] [local_ip]\n"

2687

" s=-\n"

2688

" c=IN IP[media_ip_type] [media_ip]\n"

2689

" t=0 0\n"

2690

" m=audio [media_port] RTP/AVP 0\n"

2691

" a=rtpmap:0 PCMU/8000\n"

2692

"\n"

2693

" ]]>\n"

2694

" </send>\n"

2695

"\n"

2696

" <recv request=\"ACK\" rtd=\"true\" crlf=\"true\"> </recv>\n"

2697

"\n"

2698

" \n"

2699

"\n"

2700

" <recv request=\"BYE\"> </recv>\n"

2701

"\n"

2702

" <send>\n"

2703

" <![CDATA[\n"

2704

"\n"

2705

" SIP/2.0 200 OK\n"

2706

" [last_Via:]\n"

2707

" [last_From:]\n"

2708

" [last_To:]\n"

2709

" [last_Call-ID:]\n"

2710

" [last_CSeq:]\n"

2711

" Contact: <sip:[local_ip]:[local_port];transport=[transport]>\n"

2712

" Content-Length: 0\n"

2713

"\n"

2714

" ]]>\n"

2715

" </send>\n"

2716

"\n"

2717

" \n"

2718

" \n"

2719

" <timewait milliseconds=\"2000\"/>\n"

2720

"\n"

2721

"</scenario>\n",

2722

2723

/************* Default_scenario[7] ***************/

2724

(char*)

2725

"<?xml version=\"1.0\" encoding=\"ISO-8859-1\" ?>\n"

2726

"<!DOCTYPE scenario SYSTEM \"sipp.dtd\">\n"

2727

"\n"

2728

"\n"

2729

"\n"

2730

"\n"

2731

"\n"

2732

"\n"

2733

"\n"

2734

"\n"

2735

"\n"

2736

"\n"

2737

"\n"

2738

"\n"

2739

"\n"

2740

"\n"

2741

"\n"

2742

"\n"

2743

"\n"

2744

"\n"

2745

"\n"

2746

"<scenario name=\"branch_client\">\n"

2747

" <send retrans=\"500\">\n"

2748

" <![CDATA[\n"

2749

"\n"

2750

" REGISTER sip:CA.cym.com SIP/2.0\n"

2751

" Via: SIP/2.0/[transport] [local_ip]:[local_port];branch=[branch]\n"

2752

" From: ua1 <sip:ua1@nnl.cym:[local_port]>;tag=[pid]SIPpTag07[call_number]\n"

2753

" To: ua1 <sip:ua1@nnl.cym:[local_port]>\n"

2754

" Call-ID: [call_id]\n"

2755

" CSeq: 1 REGISTER\n"

2756

" Contact: sip:ua1@[local_ip]:[local_port]\n"

2757

" Content-Length: 0\n"

2758

" Expires: 300\n"

2759

"\n"

2760

" ]]>\n"

2761

" </send>\n"

2762

"\n"

2763

" \n"

2764

" <recv response=\"200\" rtd=\"true\" next=\"5\">\n"

2765

" </recv>\n"

2766

"\n"

2767

" <recv response=\"200\">\n"

2768

" </recv>\n"

2769

"\n"

2770

" <label id=\"5\"/>\n"

2771

"\n"

2772

" <send retrans=\"500\">\n"

2773

" <![CDATA[\n"

2774

"\n"

2775

" INVITE sip:ua2@CA.cym.com SIP/2.0\n"

2776

" Via: SIP/2.0/[transport] [local_ip]:[local_port];branch=[branch]\n"

2777

" From: ua[call_number] <sip:ua1@nnl.cym:[local_port]>;tag=[pid]SIPpTag07b[call_number]\n"

2778

" To: ua2 <sip:ua2@nnl.cym:[remote_port]>\n"

2779

" Call-ID: [call_id]\n"

2780

" CSeq: 1 INVITE\n"

2781

" Contact: sip:ua1@[local_ip]:[local_port]\n"

2782

" Max-Forwards: 70\n"

2783

" Subject: Performance Test\n"

2784

" Content-Type: application/sdp\n"

2785

" Content-Length: [len]\n"

2786

"\n"

2787

" v=0\n"

2788

" o=user1 53655765 2353687637 IN IP[local_ip_type] [local_ip]\n"

2789

" s=-\n"

2790

" c=IN IP[media_ip_type] [media_ip]\n"

2791

" t=0 0\n"

2792

" m=audio [media_port] RTP/AVP 0\n"

2793

" a=rtpmap:0 PCMU/8000\n"

2794

"\n"

2795

" ]]>\n"

2796

" </send>\n"

2797

"\n"

2798

" <recv response=\"100\" optional=\"true\">\n"

2799

" </recv>\n"

2800

"\n"

2801

" <recv response=\"180\" optional=\"true\">\n"

2802

" </recv>\n"

2803

"\n"

2804

" <recv response=\"183\" optional=\"true\">\n"

2805

" </recv>\n"

2806

"\n"

2807

" \n"

2808

" <recv response=\"403\" optional=\"true\" next=\"1\">\n"

2809

" </recv>\n"

2810

"\n"

2811

" <recv response=\"200\">\n"

2812

" <action>\n"

2813

" <ereg regexp=\"ua25\"\n"

2814

" search_in=\"hdr\"\n"

2815

" header=\"From: \"\n"

2816

" assign_to=\"8\"/>\n"

2817

" </action>\n"

2818

" </recv>\n"

2819

"\n"

2820

" \n"

2821

" <send next=\"1\" test=\"8\">\n"

2822

" <![CDATA[\n"

2823

"\n"

2824

" ACK sip:ua2@CA.cym.com SIP/2.0\n"

2825

" Via: SIP/2.0/[transport] [local_ip]:[local_port];branch=[branch]\n"

2826

" From: ua1 <sip:ua1@nnl.cym:[local_port]>;tag=[pid]SIPpTag07b[call_number]\n"

2827

" To: ua2 <sip:ua2@nnl.cym:[remote_port]>[peer_tag_param]\n"

2828

" Call-ID: [call_id]\n"

2829

" CSeq: 1 ACK\n"

2830

" Contact: sip:ua1@[local_ip]:[local_port]\n"

2831

" Max-Forwards: 70\n"

2832

" Subject: Performance Test\n"

2833

" Content-Length: 0\n"

2834

"\n"

2835

" ]]>\n"

2836

" </send>\n"

2837

"\n"

2838

" <pause milliseconds=\"5000\"/>\n"

2839

"\n"

2840

" <label id=\"1\"/>\n"

2841

"\n"

2842

" <send retrans=\"500\">\n"

2843

" <![CDATA[\n"

2844

"\n"

2845

" BYE sip:ua2@CA.cym.com SIP/2.0\n"

2846

" Via: SIP/2.0/[transport] [local_ip]:[local_port];branch=[branch]\n"

2847

" From: ua1 <sip:ua1@nnl.cym:[local_port]>;tag=[pid]SIPpTag07b[call_number]\n"

2848

" To: ua2 <sip:ua2@nnl.cym:[remote_port]>[peer_tag_param]\n"

2849

" Call-ID: [call_id]\n"

2850

" CSeq: 2 BYE\n"

2851

" Contact: sip:ua1@[local_ip]:[local_port]\n"

2852

" Max-Forwards: 70\n"

2853

" Subject: Performance Test\n"

2854

" Content-Length: 0\n"

2855

"\n"

2856

" ]]>\n"

2857

" </send>\n"

2858

"\n"

2859

" <recv response=\"200\" crlf=\"true\">\n"

2860

" </recv>\n"

2861

"\n"

2862

" <pause milliseconds=\"4000\"/>\n"

2863

"\n"

2864

" \n"

2865

" <ResponseTimeRepartition value=\"10, 20, 30, 40, 50, 100, 150, 200\"/>\n"

2866

"\n"

2867

" \n"

2868

" <CallLengthRepartition value=\"10, 50, 100, 500, 1000, 5000, 10000\"/>\n"

2869

"\n"

2870

"</scenario>\n"

2871

"\n",

2872

2873

/************* Default_scenario[8] ***************/

2874

(char*)

2875

"<?xml version=\"1.0\" encoding=\"ISO-8859-1\" ?>\n"

2876

"<!DOCTYPE scenario SYSTEM \"sipp.dtd\">\n"

2877

"\n"

2878

"\n"

2879

"\n"

2880

"\n"

2881

"\n"

2882

"\n"

2883

"\n"

2884

"\n"

2885

"\n"

2886

"\n"

2887

"\n"

2888

"\n"

2889

"\n"

2890

"\n"

2891

"\n"

2892

"\n"

2893

"\n"

2894

"\n"

2895

"\n"

2896

"<scenario name=\"branch_server\">\n"

2897

" <recv request=\"REGISTER\">\n"

2898

" </recv>\n"

2899

"\n"

2900

" <send>\n"

2901

" <![CDATA[\n"

2902

"\n"

2903

" SIP/2.0 200 OK\n"

2904

" [last_Via:]\n"

2905

" [last_From:]\n"

2906

" [last_To:];tag=[pid]SIPpTag08[call_number]\n"

2907

" [last_Call-ID:]\n"

2908

" [last_CSeq:]\n"

2909

" Contact: <sip:[local_ip]:[local_port];transport=[transport]>\n"

2910

" Content-Length: 0\n"

2911

" Expires: 300\n"

2912

"\n"

2913

" ]]>\n"

2914

" </send>\n"

2915

"\n"

2916

" \n"

2917

" <recv request=\"INVITE\" crlf=\"true\">\n"

2918

" <action>\n"

2919

" <ereg regexp=\"ua2\"\n"

2920

" search_in=\"hdr\"\n"

2921

" header=\"From: \"\n"

2922

" assign_to=\"3\"/>\n"

2923

" </action>\n"

2924

" </recv>\n"

2925

"\n"

2926

" \n"

2927

" <send next=\"1\" test=\"3\">\n"

2928

" <![CDATA[\n"

2929

"\n"

2930

" SIP/2.0 180 Ringing\n"

2931

" [last_Via:]\n"

2932

" [last_From:]\n"

2933

" [last_To:];tag=[pid]SIPpTag08b[call_number]\n"

2934

" [last_Call-ID:]\n"

2935

" [last_CSeq:]\n"

2936

" Contact: <sip:[local_ip]:[local_port];transport=[transport]>\n"

2937

" Content-Length: 0\n"

2938

"\n"

2939

" ]]>\n"

2940

" </send>\n"

2941

"\n"

2942

" \n"

2943

" <send next=\"2\">\n"

2944

" <![CDATA[\n"

2945

"\n"

2946

" SIP/2.0 403 Error\n"

2947

" [last_Via:]\n"

2948

" [last_From:]\n"

2949

" [last_To:];tag=[pid]SIPpTag08b[call_number]\n"

2950

" [last_Call-ID:]\n"

2951

" [last_CSeq:]\n"

2952

" Contact: <sip:[local_ip]:[local_port];transport=[transport]>\n"

2953

" Content-Length: 0\n"

2954

"\n"

2955

" ]]>\n"

2956

" </send>\n"

2957

"\n"

2958

" <label id=\"1\"/>\n"

2959

"\n"

2960

" <send>\n"

2961

" <![CDATA[\n"

2962

"\n"

2963

" SIP/2.0 100 Trying\n"

2964

" [last_Via:]\n"

2965

" [last_From:]\n"

2966

" [last_To:];tag=[pid]SIPpTag08b[call_number]\n"

2967

" [last_Call-ID:]\n"

2968

" [last_CSeq:]\n"

2969

" Contact: <sip:[local_ip]:[local_port];transport=[transport]>\n"

2970

" Content-Length: 0\n"

2971

"\n"

2972

" ]]>\n"

2973

" </send>\n"

2974

"\n"

2975

" <send retrans=\"500\">\n"

2976

" <![CDATA[\n"

2977

"\n"

2978

" SIP/2.0 200 OK\n"

2979

" [last_Via:]\n"

2980

" [last_From:]\n"

2981

" [last_To:];tag=[pid]SIPpTag08b[call_number]\n"

2982

" [last_Call-ID:]\n"

2983

" [last_CSeq:]\n"

2984

" Contact: <sip:[local_ip]:[local_port];transport=[transport]>\n"

2985

" Content-Type: application/sdp\n"

2986

" Content-Length: [len]\n"

2987

"\n"

2988

" v=0\n"

2989

" o=user1 53655765 2353687637 IN IP[local_ip_type] [local_ip]\n"

2990

" s=-\n"

2991

" c=IN IP[media_ip_type] [media_ip]\n"

2992

" t=0 0\n"

2993

" m=audio [media_port] RTP/AVP 0\n"

2994

" a=rtpmap:0 PCMU/8000\n"

2995

"\n"

2996

" ]]>\n"

2997

" </send>\n"

2998

"\n"

2999

" <recv request=\"ACK\"\n"

3000

" optional=\"true\"\n"

3001

" rtd=\"true\"\n"

3002

" crlf=\"true\">\n"

3003

" </recv>\n"

3004

"\n"

3005

" <label id=\"2\"/>\n"

3006

"\n"

3007

" <recv request=\"BYE\">\n"

3008

" </recv>\n"

3009

"\n"

3010

" <send>\n"

3011

" <![CDATA[\n"

3012

"\n"

3013

" SIP/2.0 200 OK\n"

3014

" [last_Via:]\n"

3015

" [last_From:]\n"

3016

" [last_To:]\n"

3017

" [last_Call-ID:]\n"

3018

" [last_CSeq:]\n"

3019

" Contact: <sip:[local_ip]:[local_port];transport=[transport]>\n"

3020

" Content-Length: 0\n"

3021

"\n"

3022

" ]]>\n"

3023

" </send>\n"

3024

"\n"

3025

" \n"

3026

" \n"

3027

" <timewait milliseconds=\"4000\"/>\n"

3028

"\n"

3029

" \n"

3030

" <ResponseTimeRepartition value=\"10, 20, 30, 40, 50, 100, 150, 200\"/>\n"

3031

"\n"

3032

" \n"

3033

" <CallLengthRepartition value=\"10, 50, 100, 500, 1000, 5000, 10000\"/>\n"

3034

"\n"

3035

"</scenario>\n"

3036

"\n",

3037

3038

/* Although this scenario will not work without pcap play enabled, there is no

3039

* harm in including it in the binary anyway, because the user could have

3040

* dumped it and passed it with -sf. */

3041

3042

/************* Default_scenario[9] ***************/

3043

(char*)

3044

"<?xml version=\"1.0\" encoding=\"ISO-8859-1\" ?>\n"

3045

"<!DOCTYPE scenario SYSTEM \"sipp.dtd\">\n"

3046

"\n"

3047

"\n"

3048

"\n"

3049

"\n"

3050

"\n"

3051

"\n"

3052

"\n"

3053

"\n"

3054

"\n"

3055

"\n"

3056

"\n"

3057

"\n"

3058

"\n"

3059

"\n"

3060

"\n"

3061

"\n"

3062

"\n"

3063

"\n"

3064

"\n"

3065

"<scenario name=\"UAC with media\">\n"

3066

" \n"

3067

" \n"

3068

" <send retrans=\"500\">\n"

3069

" <![CDATA[\n"

3070

"\n"

3071

" INVITE sip:[service]@[remote_ip]:[remote_port] SIP/2.0\n"

3072

" Via: SIP/2.0/[transport] [local_ip]:[local_port];branch=[branch]\n"

3073

" From: sipp <sip:sipp@[local_ip]:[local_port]>;tag=[pid]SIPpTag09[call_number]\n"

3074

" To: sut <sip:[service]@[remote_ip]:[remote_port]>\n"

3075

" Call-ID: [call_id]\n"

3076

" CSeq: 1 INVITE\n"

3077

" Contact: sip:sipp@[local_ip]:[local_port]\n"

3078

" Max-Forwards: 70\n"

3079

" Subject: Performance Test\n"

3080

" Content-Type: application/sdp\n"

3081

" Content-Length: [len]\n"

3082

"\n"

3083

" v=0\n"

3084

" o=user1 53655765 2353687637 IN IP[local_ip_type] [local_ip]\n"

3085

" s=-\n"

3086

" c=IN IP[local_ip_type] [local_ip]\n"

3087

" t=0 0\n"

3088

" m=audio [auto_media_port] RTP/AVP 8 101\n"

3089

" a=rtpmap:8 PCMA/8000\n"

3090

" a=rtpmap:101 telephone-event/8000\n"

3091

" a=fmtp:101 0-11,16\n"

3092

"\n"

3093

" ]]>\n"

3094

" </send>\n"

3095

"\n"

3096

" <recv response=\"100\" optional=\"true\">\n"

3097

" </recv>\n"

3098

"\n"

3099

" <recv response=\"180\" optional=\"true\">\n"

3100

" </recv>\n"

3101

"\n"

3102

" \n"

3103

" \n"

3104

" \n"

3105

" <recv response=\"200\" rtd=\"true\" crlf=\"true\">\n"

3106

" </recv>\n"

3107

"\n"

3108

" \n"

3109

" \n"

3110

" <send>\n"

3111

" <![CDATA[\n"

3112

"\n"

3113

" ACK sip:[service]@[remote_ip]:[remote_port] SIP/2.0\n"

3114

" Via: SIP/2.0/[transport] [local_ip]:[local_port];branch=[branch]\n"

3115

" From: sipp <sip:sipp@[local_ip]:[local_port]>;tag=[pid]SIPpTag09[call_number]\n"

3116

" To: sut <sip:[service]@[remote_ip]:[remote_port]>[peer_tag_param]\n"

3117

" Call-ID: [call_id]\n"

3118

" CSeq: 1 ACK\n"

3119

" Contact: sip:sipp@[local_ip]:[local_port]\n"

3120

" Max-Forwards: 70\n"

3121

" Subject: Performance Test\n"

3122

" Content-Length: 0\n"

3123

"\n"

3124

" ]]>\n"

3125

" </send>\n"

3126

"\n"

3127

" \n"

3128

" <nop>\n"

3129

" <action>\n"

3130

" <exec play_pcap_audio=\"pcap/g711a.pcap\"/>\n"

3131

" </action>\n"

3132

" </nop>\n"

3133

"\n"

3134

" \n"

3135

" \n"

3136

" <pause milliseconds=\"8000\"/>\n"

3137

"\n"

3138

" \n"

3139

" <nop>\n"

3140

" <action>\n"

3141

" <exec play_pcap_audio=\"pcap/dtmf_2833_1.pcap\"/>\n"

3142

" </action>\n"

3143

" </nop>\n"

3144

"\n"

3145

" <pause milliseconds=\"1000\"/>\n"

3146

"\n"

3147

" \n"

3148

" <send retrans=\"500\">\n"

3149

" <![CDATA[\n"

3150

"\n"

3151

" BYE sip:[service]@[remote_ip]:[remote_port] SIP/2.0\n"

3152

" Via: SIP/2.0/[transport] [local_ip]:[local_port];branch=[branch]\n"

3153

" From: sipp <sip:sipp@[local_ip]:[local_port]>;tag=[pid]SIPpTag09[call_number]\n"

3154

" To: sut <sip:[service]@[remote_ip]:[remote_port]>[peer_tag_param]\n"

3155

" Call-ID: [call_id]\n"

3156

" CSeq: 2 BYE\n"

3157

" Contact: sip:sipp@[local_ip]:[local_port]\n"

3158

" Max-Forwards: 70\n"

3159

" Subject: Performance Test\n"

3160

" Content-Length: 0\n"

3161

"\n"

3162

" ]]>\n"

3163

" </send>\n"

3164

"\n"

3165

" <recv response=\"200\" crlf=\"true\">\n"

3166

" </recv>\n"

3167

"\n"

3168

" \n"

3169

" <ResponseTimeRepartition value=\"10, 20, 30, 40, 50, 100, 150, 200\"/>\n"

3170

"\n"

3171

" \n"

3172

" <CallLengthRepartition value=\"10, 50, 100, 500, 1000, 5000, 10000\"/>\n"

3173

"\n"

3174

"</scenario>\n"

3175

"\n",

3176

"<?xml version=\"1.0\" encoding=\"ISO-8859-1\" ?>\n"

3177

"<!DOCTYPE scenario SYSTEM \"sipp.dtd\">\n"

3178

"\n"

3179

"\n"

3180

"\n"

3181

"\n"

3182

"\n"

3183

"\n"

3184

"\n"

3185

"\n"

3186

"\n"

3187

"\n"

3188

"\n"

3189

"\n"

3190

"\n"

3191

"\n"

3192

"\n"

3193

"\n"

3194

"\n"

3195

"\n"

3196

"\n"

3197

"<scenario name=\"Out-of-call UAS\">\n"

3198

" <recv request=\".*\" regexp_match=\"true\" />\n"

3199

"\n"

3200

" <send>\n"

3201

" <![CDATA[\n"

3202

" SIP/2.0 200 OK\n"

3203

" [last_Via:]\n"

3204

" [last_From:]\n"

3205

" [last_To:]\n"

3206

" [last_Call-ID:]\n"

3207

" [last_CSeq:]\n"

3208

" Contact: <sip:[local_ip]:[local_port];transport=[transport]>\n"

3209

" Content-Length: 0\n"

3210

"\n"

3211

" ]]>\n"

3212

" </send>\n"

3213

"\n"

3214

" \n"

3215

" \n"

3216

" <timewait milliseconds=\"4000\"/>\n"

3217

"\n"

3218

"\n"

3219

" \n"

3220

" <ResponseTimeRepartition value=\"10, 20, 30, 40, 50, 100, 150, 200\"/>\n"

3221

"\n"

3222

" \n"

3223

" <CallLengthRepartition value=\"10, 50, 100, 500, 1000, 5000, 10000\"/>\n"

3224

"\n"

3225

"</scenario>\n",

3226

};