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

通讯编程

开发平台:

Visual C++

  1. /* -*- Mode:C++; c-basic-offset:8; tab-width:8; indent-tabs-mode:t -*- */
  2. /*
  3.  * Copyright (c) 1994-1997 Regents of the University of California.
  4.  * All rights reserved.
  5.  *
  6.  * Redistribution and use in source and binary forms, with or without
  7.  * modification, are permitted provided that the following conditions
  8.  * are met:
  9.  * 1. Redistributions of source code must retain the above copyright
  10.  *    notice, this list of conditions and the following disclaimer.
  11.  * 2. Redistributions in binary form must reproduce the above copyright
  12.  *    notice, this list of conditions and the following disclaimer in the
  13.  *    documentation and/or other materials provided with the distribution.
  14.  * 3. All advertising materials mentioning features or use of this software
  15.  *    must display the following acknowledgement:
  16.  * This product includes software developed by the Computer Systems
  17.  * Engineering Group at Lawrence Berkeley Laboratory.
  18.  * 4. Neither the name of the University nor of the Laboratory may be used
  19.  *    to endorse or promote products derived from this software without
  20.  *    specific prior written permission.
  21.  *
  22.  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
  23.  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  24.  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  25.  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
  26.  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
  27.  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
  28.  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
  29.  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
  30.  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
  31.  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
  32.  * SUCH DAMAGE.
  33.  */
  34. #ifndef lint
  35. static const char rcsid[] =
  36.     "@(#) $Header: /cvsroot/nsnam/ns-2/common/message.cc,v 1.13 1998/08/12 23:41:08 gnguyen Exp $ (LBL)";
  37. #endif
  38. #include "agent.h"
  39. #include "random.h"
  40. #include "message.h"
  41. int hdr_msg::offset_;
  42. static class MessageHeaderClass : public PacketHeaderClass {
  43. public:
  44. MessageHeaderClass() : PacketHeaderClass("PacketHeader/Message",
  45.  sizeof(hdr_msg)) {
  46. bind_offset(&hdr_msg::offset_);
  47. }
  48. } class_msghdr;
  49. class MessageAgent : public Agent {
  50.  public:
  51. MessageAgent();
  52. int command(int argc, const char*const* argv);
  53. void recv(Packet*, Handler*);
  54. };
  55. static class MessageClass : public TclClass {
  56. public:
  57. MessageClass() : TclClass("Agent/Message") {}
  58. TclObject* create(int, const char*const*) {
  59. return (new MessageAgent());
  60. }
  61. } class_message;
  62. MessageAgent::MessageAgent() : Agent(PT_MESSAGE)
  63. {
  64. bind("packetSize_", &size_);
  65. }
  66. void MessageAgent::recv(Packet* pkt, Handler*)
  67. {
  68. hdr_msg* mh = hdr_msg::access(pkt);
  69. char wrk[128];/*XXX*/
  70. sprintf(wrk, "%s recv {%s}", name(), mh->msg());
  71. Tcl& tcl = Tcl::instance();
  72. tcl.eval(wrk);
  73. Packet::free(pkt);
  74. }
  75. /*
  76.  * $proc handler $handler
  77.  * $proc send $msg
  78.  */
  79. int MessageAgent::command(int argc, const char*const* argv)
  80. {
  81. Tcl& tcl = Tcl::instance();
  82. if (argc == 3) {
  83. if (strcmp(argv[1], "send") == 0) {
  84. Packet* pkt = allocpkt();
  85. hdr_msg* mh = hdr_msg::access(pkt);
  86. const char* s = argv[2];
  87. int n = strlen(s);
  88. if (n >= mh->maxmsg()) {
  89. tcl.result("message too big");
  90. Packet::free(pkt);
  91. return (TCL_ERROR);
  92. }
  93. strcpy(mh->msg(), s);
  94. send(pkt, 0);
  95. return (TCL_OK);
  96. }
  97. }
  98. return (Agent::command(argc, argv));
  99. }