ftpc.cc
上传用户:rrhhcc
上传日期:2015-12-11
资源大小:54129k
文件大小:4k
源码类别:

通讯编程

开发平台:

Visual C++

  1. /*
  2.  * Copyright (c) 1994 Regents of the University of California.
  3.  * All rights reserved.
  4.  *
  5.  * Redistribution and use in source and binary forms, with or without
  6.  * modification, are permitted provided that the following conditions
  7.  * are met:
  8.  * 1. Redistributions of source code must retain the above copyright
  9.  *    notice, this list of conditions and the following disclaimer.
  10.  * 2. Redistributions in binary form must reproduce the above copyright
  11.  *    notice, this list of conditions and the following disclaimer in the
  12.  *    documentation and/or other materials provided with the distribution.
  13.  * 3. All advertising materials mentioning features or use of this software
  14.  *    must display the following acknowledgement:
  15.  * This product includes software developed by the Computer Systems
  16.  * Engineering Group at Lawrence Berkeley Laboratory.
  17.  * 4. Neither the name of the University nor of the Laboratory may be used
  18.  *    to endorse or promote products derived from this software without
  19.  *    specific prior written permission.
  20.  *
  21.  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
  22.  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  23.  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  24.  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
  25.  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
  26.  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
  27.  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
  28.  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
  29.  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
  30.  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
  31.  * SUCH DAMAGE.
  32.  */
  33. /*
  34.  * For use with "full tcp" model.
  35.  */
  36. static const char rcsid[] =
  37.     "@(#) $Header: /cvsroot/nsnam/ns-2/baytcp/ftpc.cc,v 1.5 2001/09/06 21:01:18 johnh Exp $ (LBL)";
  38. #include "tcp-full-bay.h"
  39. #include "tclcl.h"
  40. #include "trace.h"
  41. #include "random.h"
  42. #include "ftp.h"
  43. static class FtpClientClass : public TclClass {
  44. public:
  45. FtpClientClass() : TclClass("Agent/BayTcpApp/FtpClient") {}
  46. TclObject* create(int, const char*const*) {
  47. return (new FtpClientAgent());
  48. }
  49. } class_ftpcli;
  50. FtpClientAgent::FtpClientAgent() : BayTcpAppAgent(PT_NTYPE), running_(0), newfile_timer_(this)
  51. {
  52. }
  53. void FtpClientAgent::start()
  54. {
  55. running_ = 1;
  56. newfile_timer_.resched(0.);
  57. }
  58. void FtpClientAgent::stop()
  59. {
  60. running_ = 0;
  61. }
  62. void FtpClientAgent::timeout(int event_type)
  63. {
  64. if (running_)
  65. if(event_type == NEW_FILE) {
  66. if(sendget()) {
  67. state_ = REQ_SENT;
  68. start_trans_ = now();
  69. }
  70. else {
  71. printf("ftpclient:timeout erroneous tcp staten");
  72. }
  73. }
  74. }
  75. //assumes 80 bytes
  76. int FtpClientAgent::sendget()
  77. {
  78. return tcp_->advance(80, 0);
  79. }
  80. //scheduled only when the tcp connection(s) are upcalling
  81. // ask for another file after a delay to allow connection to close
  82. // 6/8/00 shouldn't need the delay. Consider reducing or removing -kmn
  83. void FtpClientAgent::recv(Packet*, BayFullTcpAgent*, int code)
  84. {
  85.   //at data complete time, schedule a "far out" event to ensure
  86.   // simulator doesn't terminate
  87.   if(running_ && code == DATA_PUSH) {
  88.   state_ = DATA_RCVD;
  89.   newfile_timer_.resched(5.0);
  90.   }
  91.   else if(running_ && code == CONNECTION_END) {
  92.     state_ = END_RCVD;
  93.     newfile_timer_.cancel();
  94.     newfile_timer_.resched(.0);
  95.   }
  96. }
  97. int FtpClientAgent::command(int argc, const char*const* argv)
  98. {
  99. Tcl& tcl = Tcl::instance();
  100. if (argc == 2) {
  101. if (strcmp(argv[1], "start") == 0) {
  102. start();
  103. return(TCL_OK);
  104. } else if (strcmp(argv[1], "stop") == 0) {
  105. stop();
  106. return(TCL_OK);
  107. }
  108. } else if(argc == 3) {
  109. if(strcmp(argv[1], "tcp") == 0) {
  110. tcp_ = (BayFullTcpAgent*)TclObject::lookup(argv[2]);
  111. if(tcp_ == 0) {
  112. tcl.resultf("no such agent %s", argv[2]);
  113. return(TCL_ERROR);
  114. }
  115. return(TCL_OK);
  116. }
  117. }
  118. return (Agent::command(argc, argv));
  119. }
  120. void NewFileTimer::expire(Event *e) {
  121. a_->timeout(NEW_FILE);
  122. }