开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Windows编程 > 通讯编程 > 查看源码
empweb.cc
资源名称：ns-allinone-2.33.tar.gz　[点击查看]
上传用户：rrhhcc
上传日期：2015-12-11
资源大小：54129k
文件大小：18k
源码类别：

通讯编程

开发平台：

Visual C++

empweb.cc：源码内容
  1. /* -*- Mode:C++; c-basic-offset:8; tab-width:8; indent-tabs-mode:t -*- */
  3. /*
  4.  * empweb.cc
  5.  * Copyright (C) 2001 by the University of Southern California
  6.  * $Id: empweb.cc,v 1.20 2005/09/18 23:33:32 tomh Exp $
  7.  *
  8.  * This program is free software; you can redistribute it and/or
  9.  * modify it under the terms of the GNU General Public License,
  10.  * version 2, as published by the Free Software Foundation.
  11.  *
  12.  * This program is distributed in the hope that it will be useful,
  13.  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  14.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  15.  * GNU General Public License for more details.
  16.  *
  17.  * You should have received a copy of the GNU General Public License along
  18.  * with this program; if not, write to the Free Software Foundation, Inc.,
  19.  * 59 Temple Place, Suite 330, Boston, MA 02111-1307, USA.
  20.  *
  21.  *
  22.  * The copyright of this module includes the following
  23.  * linking-with-specific-other-licenses addition:
  24.  *
  25.  * In addition, as a special exception, the copyright holders of
  26.  * this module give you permission to combine (via static or
  27.  * dynamic linking) this module with free software programs or
  28.  * libraries that are released under the GNU LGPL and with code
  29.  * included in the standard release of ns-2 under the Apache 2.0
  30.  * license or under otherwise-compatible licenses with advertising
  31.  * requirements (or modified versions of such code, with unchanged
  32.  * license).  You may copy and distribute such a system following the
  33.  * terms of the GNU GPL for this module and the licenses of the
  34.  * other code concerned, provided that you include the source code of
  35.  * that other code when and as the GNU GPL requires distribution of
  36.  * source code.
  37.  *
  38.  * Note that people who make modified versions of this module
  39.  * are not obligated to grant this special exception for their
  40.  * modified versions; it is their choice whether to do so.  The GNU
  41.  * General Public License gives permission to release a modified
  42.  * version without this exception; this exception also makes it
  43.  * possible to release a modified version which carries forward this
  44.  * exception.
  45.  *
  46.  */
  48. //
  49. // Empirical Web traffic model that simulates Web traffic based on a set of
  50. // CDF (Cumulative Distribution Function) data derived from live tcpdump trace
  51. // The structure of this file is largely borrowed from webtraf.cc
  52. //
  53. // $Header: /cvsroot/nsnam/ns-2/empweb/empweb.cc,v 1.20 2005/09/18 23:33:32 tomh Exp $
  55. #include <tclcl.h>
  57. #include "empweb.h"
  60. // Data structures that are specific to this web traffic model and 
  61. // should not be used outside this file.
  62. //
  63. // - EmpWebTrafPage
  64. // - EmpWebTrafObject
  66. class EmpWebPage : public TimerHandler {
  67. public:
  68. EmpWebPage(int id, EmpWebTrafSession* sess, int nObj, Node* dst, int svrId) :
  69. persistOption_(0), id_(id), sess_(sess), nObj_(nObj), curObj_(0), doneObj_(0), dst_(dst), svrId_(svrId) {}
  70. virtual ~EmpWebPage() {}
  72. inline void start() {
  73. // Call expire() and schedule the next one if needed
  74. status_ = TIMER_PENDING;
  75. handle(&event_);
  76. }
  77. inline int id() const { return id_; }
  78. inline int svrId() const { return svrId_; }
  79. Node* dst() { return dst_; }
  81. void doneObject() {
  82. if (sess_->mgr()->isdebug())
  83.     printf("doneObject: %g done=%d total=%d n", Scheduler::instance().clock(), doneObj_, nObj_);
  85.   if (++doneObj_ >= nObj_) {
  86.     printf("doneObject: %g %d %d n", Scheduler::instance().clock(), doneObj_, nObj_);
  87.         sess_->donePage((void*)this);
  88. // }
  89. // sched(sess_->interObj()->value());
  90.   } else if (persistOption_) {
  91. sched(sess_->interObj()->value());
  92. }
  94. }
  95.         inline int curObj() const { return curObj_; }
  96. inline int doneObj() const { return doneObj_; }
  98. inline void set_persistOption(int opt) { persistOption_ = opt; }
  99. int persistOption_ ;  //0: http1.0  1: http1.1 ; use http1.0 as default
  101. private:
  102. virtual void expire(Event* = 0) {
  103. // Launch a request. Make sure size is not 0!
  104. if (curObj_ >= nObj_) 
  105. return;
  106. sess_->launchReq(this, LASTOBJ_++, 
  107.  (int)ceil(sess_->objSize()->value()),
  108.  (int)ceil(sess_->reqSize()->value()), sess_->id(), persistOption_);
  109. if (sess_->mgr()->isdebug())
  110. printf("expire: Session %d launched page %d obj %d nObj %d n",
  111.        sess_->id(), id_, curObj_, nObj_);
  112. }
  113. virtual void handle(Event *e) {
  114. if (sess_->mgr()->isdebug())
  115. printf("handle: Session %d launched page %d obj %dn",
  116.        sess_->id(), id_, curObj_);
  118. TimerHandler::handle(e);
  119. curObj_++;
  120. if (!persistOption_) {
  121. if (curObj_ <  nObj_) sched(sess_->interObj()->value());
  122. }
  123. }
  124. int id_;
  125. EmpWebTrafSession* sess_;
  126. int nObj_, curObj_;
  127. int doneObj_;
  128. Node* dst_;
  129. int svrId_ ;
  130. static int LASTOBJ_;
  131. };
  133. int EmpWebPage::LASTOBJ_ = 1;
  135. int EmpWebTrafSession::LASTPAGE_ = 1;
  137. int EmpWebTrafPool::LASTFLOW_ = 1;
  140. // XXX Must delete this after all pages are done!!
  141. EmpWebTrafSession::~EmpWebTrafSession() 
  142. {
  143. if (donePage_ != curPage_) {
  144. fprintf(stderr, "done pages %d != all pages %dn",
  145. donePage_, curPage_);
  146. abort();
  147. }
  148. if (status_ != TIMER_IDLE) {
  149. fprintf(stderr, "EmpWebTrafSession must be idle when deleted.n");
  150. abort();
  151. }
  152. /*
  153. if (rvInterPage_ != NULL)
  154. Tcl::instance().evalf("delete %s", rvInterPage_->name());
  155. if (rvPageSize_ != NULL)
  156. Tcl::instance().evalf("delete %s", rvPageSize_->name());
  157. if (rvInterObj_ != NULL)
  158. Tcl::instance().evalf("delete %s", rvInterObj_->name());
  159. if (rvObjSize_ != NULL)
  160. Tcl::instance().evalf("delete %s", rvObjSize_->name());
  161. if (rvReqSize_ != NULL)
  162. Tcl::instance().evalf("delete %s", rvReqSize_->name());
  163. if (rvPersistSel_ != NULL)
  164. Tcl::instance().evalf("delete %s", rvPersistSel_->name());
  165. if (rvServerSel_ != NULL)
  166. Tcl::instance().evalf("delete %s", rvServerSel_->name());
  168. */
  170. }
  172. void EmpWebTrafSession::donePage(void* ClntData) 
  173. {
  174. EmpWebPage* pg = (EmpWebPage*)ClntData;
  175. if (mgr_->isdebug()) 
  176. printf("Session %d done page %dn", id_, pg->id());
  178. if (pg->doneObj() != pg->curObj()) {
  179.         fprintf(stderr, "done objects %d != all objects %dn",
  180.                 pg->doneObj(), pg->curObj());
  181.                 abort();
  182. }
  185. //for HTTP1.1 persistent-connection
  186.         if (pg->persistOption_) {
  187.    if (!fulltcp_) { 
  188.          //recycle TCP connection
  189. mgr_->recycleTcp(ctcp_);
  190. mgr_->recycleTcp(stcp_);
  191. mgr_->recycleSink(csnk_);
  192. mgr_->recycleSink(ssnk_);
  193. } else {
  194. Tcl::instance().evalf("%s disconnect-full %s %s %s %s",
  195.         mgr_->name(),
  196. src_->name(), pg->dst()->name(),
  197.         ctcp_->name(),  stcp_->name());
  198. }
  199. }
  201. delete pg;
  203. // If all pages are done, tell my parent to delete myself
  204. if (++donePage_ >= nPage_) {
  205.     mgr_->doneSession(id_);
  206.         } else if (interPageOption_) {
  207. sched(rvInterPage_->value());
  208. // printf("donePage: %g %d %dn", Scheduler::instance().clock(), donePage_, curPage_);
  209. }
  210. }
  212. // Launch the current page
  213. void EmpWebTrafSession::expire(Event *)
  214. {
  215. // Pick destination for this page
  216. //temporary hack for isi traffic
  217. int n;
  219.         if (clientIdx_ < mgr()->nClientL_) n = 0 ; //ISI server
  220. else
  221.            n = int(ceil(serverSel()->value()));
  224.         assert((n >= 0) && (n < mgr()->nSrc_));
  225.         Node* dst = mgr()->server_[n];
  228. // Make sure page size is not 0!
  229. EmpWebPage* pg = new EmpWebPage(LASTPAGE_++, this, 
  230.   (int)ceil(rvPageSize_->value()), dst, n);
  232.         //each page either use persistent or non-persistent connection
  233. int opt = (int)ceil(this->persistSel()->value());
  234.         pg->set_persistOption(opt);
  236. if (mgr_->isdebug())
  237. printf("Session %d starting page %d, curpage %d n", 
  238.        id_, LASTPAGE_-1, curPage_);
  240.         if (pg->persistOption_) { //for HTTP1.1 persistent-connection
  242.                 mgr_->LASTFLOW_++;
  244.   int wins = int(ceil(serverWin()->value()));
  245.      int winc = int(ceil(clientWin()->value()));
  246.   int window = (wins >= winc) ? wins : winc;
  248.   int m = int(ceil(mtu()->value()));
  250.    // Choose source and dest TCP agents for both source and destination
  251. if (fulltcp_) {
  252.    ctcp_ = mgr_->picktcp(window,m);
  253.    stcp_ = mgr_->picktcp(window,m);
  255. Tcl::instance().evalf("%s connect-full %s %s %s %s",
  256.         mgr_->name(),
  257. src_->name(), pg->dst()->name(),
  258.         ctcp_->name(),  stcp_->name());
  260.                 } else {
  261.    ctcp_ = mgr_->picktcp(window,m);
  262.    stcp_ = mgr_->picktcp(window,m);
  263.    csnk_ = mgr_->picksink();
  264.    ssnk_ = mgr_->picksink();
  265. }
  267. // Tcl::instance().evalf("%s set-fid %d %s %s",                              mgr_->name(), mgr_->LASTFLOW_-1, ctcp_->name(), stcp_->name());
  268. Tcl::instance().evalf("%s set-fid %d %s %s",                              mgr_->name(), mgr_->color_, ctcp_->name(), stcp_->name());
  270. }
  272. pg->start();
  273. }
  275. void EmpWebTrafSession::handle(Event *e)
  276. {
  277. // If I haven't scheduled all my pages, do the next one
  278. TimerHandler::handle(e);
  279. ++curPage_;
  280. // XXX Notice before each page is done, it will schedule itself 
  281. // one more time, this makes sure that this session will not be
  282. // deleted after the above call. Thus the following code will not
  283. // be executed in the context of a deleted object. 
  284. if (!interPageOption_) {
  285. if (curPage_ < nPage_) {
  286. sched(rvInterPage_->value());
  287. // printf("schedule: %g %d %dn", Scheduler::instance().clock(), donePage_, curPage_);
  288. }
  289. }
  290. }
  292. // Launch a request for a particular object
  293. void EmpWebTrafSession::launchReq(void* ClntData, int obj, int size, int reqSize, int sid, int persist)
  294. {
  296.    TcpAgent* ctcp;
  297.    TcpAgent* stcp;
  298.    TcpSink* csnk;
  299.    TcpSink* ssnk;
  301. EmpWebPage* pg = (EmpWebPage*)ClntData;
  303.         if (persist) { //for HTTP1.1 persistent-connection
  304. if (mgr_->isdebug()) {
  305. printf("HTTP1.1n");
  306. }
  308. // use the same connection
  309. ctcp = ctcp_;
  310. stcp = stcp_;
  311. if (fulltcp_) {
  312. csnk = 0;
  313. ssnk = 0;
  314. } else {
  315.    csnk = csnk_;
  316.    ssnk = ssnk_;
  317. }
  319.         } else { //for HTTP1.0 non-consistent connection
  320. if (mgr_->isdebug()) {
  321. printf("HTTP1.0n");
  322. }
  324. mgr_->LASTFLOW_++;
  326.   int wins = int(ceil(serverWin()->value()));
  327.      int winc = int(ceil(clientWin()->value()));
  328.   int window = (wins >= winc) ? wins : winc;
  330.   int m = int(ceil(mtu()->value()));
  332.    // Choose source and dest TCP agents for both source and destination
  334. ctcp = mgr_->picktcp(window,m);
  335. stcp = mgr_->picktcp(window,m);
  336. Tcl::instance().evalf("%s set-fid %d %s %s",
  337.       mgr_->name(), mgr_->color_, ctcp->name(), stcp->name());
  338. if (fulltcp_) {
  339. csnk = 0;
  340. ssnk = 0;
  341. } else {
  342.    csnk = mgr_->picksink();
  343.    ssnk = mgr_->picksink();
  344. }
  345. }
  347. // Setup new TCP connection and launch request
  348. // size and reqSize are in the unit of bytes in fulltcp mode
  349. // but in the unit of packet in halftcp mode
  350. if (fulltcp_) {
  351. Tcl::instance().evalf("%s launch-req-full %d %d %s %s %s %s %d %d %d %d",
  352.                               mgr_->name(), obj, pg->id(), 
  353.       src_->name(), pg->dst()->name(),
  354.       ctcp->name(),  
  355.       stcp->name(),  
  356.       size, reqSize, ClntData,persist);
  357. } else {
  358. assert (csnk != 0 && ssnk != 0);
  359. Tcl::instance().evalf("%s launch-req %d %d %s %s %s %s %s %s %d %d %d %d",
  360.                               mgr_->name(), obj, pg->id(), 
  361.       src_->name(), pg->dst()->name(),
  362.       ctcp->name(), csnk->name(), 
  363.       stcp->name(), ssnk->name(), 
  364.       size, reqSize, ClntData,
  365.       persist);
  366. }
  368. if (mgr_->isdebug()) {
  369.   printf("size=%d  obj=%d  page=%d  sess=%d  %g src=%d dst=%dn", size, obj, pg->id(), id_, Scheduler::instance().clock(), src_->address(), pg->dst()->address());
  370. }
  371. }
  374. static class EmpWebTrafPoolClass : public TclClass {
  375. public:
  376.         EmpWebTrafPoolClass() : TclClass("PagePool/EmpWebTraf") {}
  377.         TclObject* create(int, const char*const*) {
  378. return (new EmpWebTrafPool());
  379. }
  380. } class_empwebtrafpool;
  382. EmpWebTrafPool::~EmpWebTrafPool()
  383. {
  384. if (session_ != NULL) {
  385. for (int i = 0; i < nSession_; i++)
  386. delete session_[i];
  387. delete []session_;
  388. }
  389. if (server_ != NULL)
  390. delete []server_;
  391. if (client_ != NULL)
  392. delete []client_;
  393. // XXX Destroy tcpPool_ and sinkPool_ ?
  394. }
  396. void EmpWebTrafPool::delay_bind_init_all()
  397. {
  398. delay_bind_init_one("debug_");
  399. PagePool::delay_bind_init_all();
  400. }
  402. int EmpWebTrafPool::delay_bind_dispatch(const char *varName,const char *localName,
  403.      TclObject *tracer)
  404. {
  405. if (delay_bind_bool(varName, localName, "debug_", &debug_, tracer)) 
  406. return TCL_OK;
  407. return PagePool::delay_bind_dispatch(varName, localName, tracer);
  408. }
  410. EmpWebTrafPool::EmpWebTrafPool() : 
  411. concurrentSess_(0), nSrc_(0), server_(NULL), session_(NULL), nClient_(0), client_(NULL), nTcp_(0), nSink_(0), fulltcp_(0)
  412. {
  413.         bind("fulltcp_", &fulltcp_);
  415. LIST_INIT(&tcpPool_);
  416. LIST_INIT(&sinkPool_);
  417. }
  419. TcpAgent* EmpWebTrafPool::picktcp(int win, int mtu)
  420. {
  423. TcpAgent* a = (TcpAgent*)detachHead(&tcpPool_);
  424. if (a == NULL) {
  425. Tcl& tcl = Tcl::instance();
  426. tcl.evalf("%s alloc-tcp %d %d", name(), win, mtu);
  427. a = (TcpAgent*)lookup_obj(tcl.result());
  428. if (a == NULL) {
  429. fprintf(stderr, "Failed to allocate a TCP agentn");
  430. abort();
  431. }
  432. } else 
  433. nTcp_--;
  434. return a;
  435. }
  437. TcpSink* EmpWebTrafPool::picksink()
  438. {
  439. TcpSink* a = (TcpSink*)detachHead(&sinkPool_);
  440. if (a == NULL) {
  441. Tcl& tcl = Tcl::instance();
  442. tcl.evalf("%s alloc-tcp-sink", name());
  443. a = (TcpSink*)lookup_obj(tcl.result());
  444. if (a == NULL) {
  445. fprintf(stderr, "Failed to allocate a TCP sinkn");
  446. abort();
  447. }
  448. } else 
  449. nSink_--;
  450. return a;
  451. }
  453. void EmpWebTrafPool::recycleTcp(Agent* a)
  454. {
  455. if (fulltcp_) {
  456. delete a;
  457. } else {
  459. if (a == NULL) {
  460. fprintf(stderr, "Failed to recycle TCP agentn");
  461. abort();
  462. }
  463. nTcp_++;
  464. insertAgent(&tcpPool_, a);
  465. }
  466. }
  468. void EmpWebTrafPool::recycleSink(Agent* a)
  469. {
  470. if (fulltcp_) {
  471. delete a;
  472. } else {
  474. if (a == NULL) {
  475. fprintf(stderr, "Failed to recycle Sink agentn");
  476. abort();
  477. }
  478. nSink_++;
  479. insertAgent(&sinkPool_, a);
  480. }
  481. }
  483. int EmpWebTrafPool::command(int argc, const char*const* argv)
  484. {
  485. if (argc == 3) {
  486. if (strcmp(argv[1], "set-num-session") == 0) {
  487. if (session_ != NULL) {
  488. for (int i = 0; i < nSession_; i++) 
  489. delete session_[i];
  490. delete []session_;
  491. }
  492. nSession_ = atoi(argv[2]);
  493. session_ = new EmpWebTrafSession*[nSession_];
  494. memset(session_, 0, sizeof(EmpWebTrafSession*)*nSession_);
  495. return (TCL_OK);
  496. } else if (strcmp(argv[1], "set-num-server-lan") == 0) {
  497. nSrcL_ = atoi(argv[2]);
  498. if (nSrcL_ >  nSrc_) {
  499. fprintf(stderr, "Wrong server index %dn", nSrcL_);
  500. return TCL_ERROR;
  501. }
  502. return (TCL_OK);
  503. } else if (strcmp(argv[1], "set-num-remote-client") == 0) {
  504. nClientL_ = atoi(argv[2]);
  505. if (nClientL_ > nClient_) {
  506. fprintf(stderr, "Wrong client index %dn", nClientL_);
  507. return TCL_ERROR;
  508. }
  509. return (TCL_OK);
  510. } else if (strcmp(argv[1], "set-num-server") == 0) {
  511. nSrc_ = atoi(argv[2]);
  512. if (server_ != NULL) 
  513. delete []server_;
  514. server_ = new Node*[nSrc_];
  515. return (TCL_OK);
  516. } else if (strcmp(argv[1], "set-num-client") == 0) {
  517. nClient_ = atoi(argv[2]);
  518. if (client_ != NULL) 
  519. delete []client_;
  520. client_ = new Node*[nClient_];
  521. return (TCL_OK);
  522. } else if (strcmp(argv[1], "set-interPageOption") == 0) {
  523. int option = atoi(argv[2]);
  524. if (session_ != NULL) {
  525. for (int i = 0; i < nSession_; i++) {
  526. EmpWebTrafSession* p = session_[i];
  527. p->set_interPageOption(option);
  528. }
  529. }
  530. return (TCL_OK);
  531. } else if (strcmp(argv[1], "doneObj") == 0) {
  532.         EmpWebPage* p = (EmpWebPage*)atol(argv[2]);
  534. p->doneObject();
  535.                 
  536. return (TCL_OK);
  537. }
  538. } else if (argc == 4) {
  539. if (strcmp(argv[1], "set-server") == 0) {
  540. Node* cli = (Node*)lookup_obj(argv[3]);
  541. if (cli == NULL)
  542. return (TCL_ERROR);
  543. int nc = atoi(argv[2]);
  544. if (nc >= nSrc_) {
  545. fprintf(stderr, "Wrong server index %dn", nc);
  546. return TCL_ERROR;
  547. }
  548. server_[nc] = cli;
  549. return (TCL_OK);
  550. } else if (strcmp(argv[1], "set-client") == 0) {
  551. Node* s = (Node*)lookup_obj(argv[3]);
  552. if (s == NULL)
  553. return (TCL_ERROR);
  554. int n = atoi(argv[2]);
  555. if (n >= nClient_) {
  556. fprintf(stderr, "Wrong client index %dn", n);
  557. return TCL_ERROR;
  558. }
  559. client_[n] = s;
  560. return (TCL_OK);
  561. } else if (strcmp(argv[1], "recycle") == 0) {
  562. // <obj> recycle <tcp> <sink>
  563. //
  564. // Recycle a TCP source/sink pair
  565. Agent* tcp = (Agent*)lookup_obj(argv[2]);
  566. Agent* snk = (Agent*)lookup_obj(argv[3]);
  567. if ((tcp == NULL) || (snk == NULL))
  568. return (TCL_ERROR);
  569. // XXX TBA: recycle tcp agents
  570. if (fulltcp_) {
  571. delete tcp;
  572. delete snk;
  573. } else {
  574. nTcp_++, nSink_++;
  575. insertAgent(&tcpPool_, tcp);
  576. insertAgent(&sinkPool_, snk);
  577. }
  578. return (TCL_OK);
  579. }
  580. } else if (argc == 17) {
  581. if (strcmp(argv[1], "create-session") == 0) {
  582. // <obj> create-session <session_index>
  583. //   <pages_per_sess> <launch_time>
  584. //   <inter_page_rv> <page_size_rv>
  585. //   <inter_obj_rv> <obj_size_rv>
  586. //   <req_size_rv> <persist_sel_rv> <server_sel_rv>
  587. //   <client_win_rv> <server_win_rv> <mtu_rv>
  588. //   <inbound/outbound flag> <color>
  589. int n = atoi(argv[2]);
  590. if ((n < 0)||(n >= nSession_)||(session_[n] != NULL)) {
  591. fprintf(stderr,"Invalid session index %dn",n);
  592. return (TCL_ERROR);
  593. }
  594. int npg = (int)strtod(argv[3], NULL);
  595. double lt = strtod(argv[4], NULL);
  597. int flip = atoi(argv[15]);
  598. if ((flip < 0)||(flip > 1)) {
  599. fprintf(stderr,"Invalid I/O flag %dn",flip);
  600. return (TCL_ERROR);
  601. }
  603.                         //for SPAWAR demo
  604. color_ = atoi(argv[16]);
  606.                         int cl;
  607. if (flip == 1) 
  608.                           cl = int(floor(Random::uniform(0, nClientL_)));
  609. else
  610.                           cl = int(floor(Random::uniform(nClientL_, nClient_)));
  612.                         assert((cl >= 0) && (cl < nClient_));
  613.                         Node* c=client_[cl];
  615. EmpWebTrafSession* p = 
  616. new EmpWebTrafSession(this, c, npg, n, nSrc_, cl,fulltcp_);
  618. int res = lookup_rv(p->interPage(), argv[5]);
  619. res = (res == TCL_OK) ? 
  620. lookup_rv(p->pageSize(), argv[6]) : TCL_ERROR;
  621. res = (res == TCL_OK) ? 
  622. lookup_rv(p->interObj(), argv[7]) : TCL_ERROR;
  623. res = (res == TCL_OK) ? 
  624. lookup_rv(p->objSize(), argv[8]) : TCL_ERROR;
  625. res = (res == TCL_OK) ? 
  626. lookup_rv(p->reqSize(), argv[9]) : TCL_ERROR;
  627. res = (res == TCL_OK) ? 
  628. lookup_rv(p->persistSel(), argv[10]) : TCL_ERROR;
  629. res = (res == TCL_OK) ? 
  630. lookup_rv(p->serverSel(), argv[11]) : TCL_ERROR;
  631. res = (res == TCL_OK) ? 
  632. lookup_rv(p->serverWin(), argv[12]) : TCL_ERROR;
  633. res = (res == TCL_OK) ? 
  634. lookup_rv(p->clientWin(), argv[13]) : TCL_ERROR;
  635. res = (res == TCL_OK) ? 
  636. lookup_rv(p->mtu(), argv[14]) : TCL_ERROR;
  637. if (res == TCL_ERROR) {
  638. delete p;
  639. fprintf(stderr, "Invalid random variablen");
  640. return (TCL_ERROR);
  641. }
  642. p->sched(lt);
  643. session_[n] = p;
  645.                            
  646. return (TCL_OK);
  647. }
  648. }
  649. return PagePool::command(argc, argv);
  650. }