-
-
#include “pong.h”
-
-
int hdr_pong::offset_;
-
-
// PacketHeaderClass를 상속받아 PongHeaderClass를 선언
-
// 이미 많은 protocol header들이 PacketHeaderClass를 상속받아 정의되어 있다.
-
// 동일한 방법으로 PacketHeader 아래에 Pong header를 둔다.
-
// pong.h 에서 정의한 hdr_pong의 offset를 연결한다.
-
static class PongHeaderClass : public PacketHeaderClass {
-
public:
-
PongHeaderClass() : PacketHeaderClass(“PacketHeader/Pong”, sizeof(hdr_pong)) {
-
bind_offset(&hdr_pong::offset_);
-
}
-
} class_ponghdr;
-
-
// TclClass를 상속받아 PongClass를 선언
-
// Agent 하위에 Pong을 두기 위해 “Agent/Pong”을 지정
-
// 이 부분은 tcl 파일을 작성할 때 “set p0 [new Agent/Pong]”와 같이 사용됨
-
// PongAgent를 TclObject로 생성하여 반환
-
static class PongClass : public TclClass {
-
public:
-
PongClass() : TclClass(“Agent/Pong”) { }
-
TclObject* create(int, const char*const*) {
-
return (new PongAgent);
-
}
-
} class_pong;
-
-
// PongAgent의 생성자를 구체적으로 정의하는 부분
-
// 생성자에서는 C++과 Tcl을 바인드하도록 함.
-
PongAgent::PongAgent() : Agent(PT_PONG) {
-
bind(“packetSize_”, &size_);
-
}
-
-
// PongAgent의 command 메소드를 정의
-
// 궁극적으로 이 부분은 pong packet을 send하는 부분이다.
-
// Packet을 생성하고, pong header의 시작지점으로 이동하여,
-
// ret를 0으로 설정하고, 시간을 설정한 다음, Packet을 전송한다.
-
int PongAgent::command(int argc, const char*const* argv) {
-
if(argc == 2) {
-
if(strcmp(argv[1], “send”) == 0) {
-
-
// 새로운 packet을 준비
-
// Creaqte a new packet
-
Packet* pkt = allocpkt();
-
-
// packet의 pong header 시작 지점으로 이동
-
// Access the Pong header for the new packet
-
hdr_pong* hdr = hdr_pong::access(pkt);
-
-
// pong header의 ret를 0으로 설정
-
// Set the ‘ret’ field to 0, so the receiving node
-
// knows that it to generate an echo packet
-
hdr->ret = 0;
-
-
// pong header의 send time을 현재의 시간으로 설정
-
// Store the current time in the ‘send_time’ field
-
hdr->send_time = Scheduler::instance().clock();
-
-
// 만들어진 packet을 전송
-
// Send the packet
-
send(pkt, 0);
-
-
// Return TCL_OK, so the calling function knows that
-
// the command has been procoessed
-
return (TCL_OK);
-
}
-
}
-
-
// If the command hasn’t been proceesed by PongAgent()::command,
-
// call the command() function for the base class
-
return (Agent::command(argc, argv));
-
}
-
-
// PongAgent의 recv() 메소드를 정의
-
// Pong Packet을 수신하였을 때 수행하는 부분을 정의
-
void PongAgent::recv(Packet* pkt, Handler*) {
-
// ip header의 시작 지점으로 이동
-
// Access the IP header for the received packet
-
hdr_ip* hdrip = hdr_ip::access(pkt);
-
-
// pong header의 시작 지점으로 이동
-
// Access the pong header for the received packet
-
hdr_pong* hdr = hdr_pong::access(pkt);
-
-
// ret = 0 이면, 즉 처음 수신한 packet일 때 처리하는 부분
-
if(hdr->ret == 0) {
-
// packet에 있는 시간을 stime에 할당
-
double stime = hdr->send_time;
-
-
// packet을 폐기
-
Packet::free(pkt);
-
-
// 응답을 위한 packet을 생성
-
Packet* pktret = allocpkt();
-
-
// packet의 pong header 시작지점으로 이동
-
hdr_pong* hdrret = hdr_pong::access(pktret);
-
-
// packet의 ret를 1로 설정
-
hdrret->ret = 1;
-
-
// packet의 send_time에 packet을 수신한 시간을 설정
-
hdrret->send_time = stime;
-
-
// packet을 전송
-
send(pktret, 0);
-
} else { // ret = 1 이면, 즉 보낸 packet이 다시 되돌아왔을 때 처리하는 부분
-
// 출력을 위한 변수 out을 선언
-
char out[100];
-
-
// out 변수에 내용을 기록
-
// “이름(Agent/Pong) recv from(Source address) rtt(round-trip-time)”의 형태를 갖추어 기록
-
sprintf(out, “%s recv %d %3.1f”,
-
-
// %s에 해당하는 부분(노드 이름)
-
name(),
-
-
// %d에 해당하는 부분(노드 주소)
-
hdrip->src_.addr_ >> Address::instance().NodeShift_[1],
-
-
// %3.1f에 해당하는 부분(응답시간)
-
// (현재시간 – send_time * 1000) –> round-trip-time
-
(Scheduler::instance().clock() – hdr->send_time) * 1000);
-
-
// tcl instance를 생성
-
Tcl& tcl =Tcl::instance();
-
-
// tcl instance로 out을 반환
-
tcl.eval(out);
-
-
// packet을 폐기
-
Packet::free(pkt);
-
}
-
}
