Search Site ~Apps~  btpeer   trackerbt   Socks4   The Minder   duct  ~Projects~  RobotWorld   Cgi++   IBank   SDL C++ Gui   Applesoft   Wolfshade   Legend  ~Contact~ message board  email author   visit project   homepage at   freshmeat.net

tSocket Class Reference Tracker connection socket. More... #include <tSocket.h> Collaboration diagram for tSocket: [legend]List of all members. Public Member Functions   tSocket (ISocketHandler &, const std::string &hash)   ~tSocket () void  OnConnect () void  OnFirst () void  OnHeader (const std::string &key, const std::string &value) void  OnDelete () Private Attributes std::string  m_hash std::string  m_filename bool  m_gzip Static Private Attributes static int  m_next_id = 0 Detailed Description Tracker connection socket. File ......... tSocket.h Published .... 2005-06-14 Author ....... grymse@alhem.net Definition at line 31 of file tSocket.h. Constructor & Destructor Documentation tSocket::tSocket ( ISocketHandler &  , const std::string &  hash   ) Definition at line 47 of file tSocket.cpp. References DEB, m_filename, and m_next_id. :HttpGetSocket(h) ,m_hash(hash) ,m_gzip(false) { DEB(printf("tSocket()\n");) Session *p = static_cast<PeerHandler&>(Handler()).GetSession(hash); if (p) { std::string announce = p -> GetAnnounceUrl("started"); std::string host; port_t port; Url(announce, host, port); if (host.size() && port) { PeerHandler& ref = static_cast<PeerHandler&>(Handler()); m_filename = ref.GetTorrentDirectory() + "/" + hash + "/tracker." + Utility::l2string(++m_next_id); ref.mkpath( m_filename ); SetFilename(m_filename); SetConnectTimeout(30); Open(host, port); DEB(printf("Tracker host : %s\n", host.c_str());) DEB(printf("Tracker port : %d\n", port);) DEB(printf("Tracker URL : %s\n", announce.c_str());) } else SetCloseAndDelete(); } else SetCloseAndDelete(); } tSocket::~tSocket (  )  Definition at line 80 of file tSocket.cpp. References DEB, and m_filename. { DEB(printf("~tSocket()\n");) unlink(m_filename.c_str()); } Member Function Documentation void tSocket::OnConnect (  )  Definition at line 231 of file tSocket.cpp. { HttpGetSocket::OnConnect(); #ifdef _WIN32 // makes no difference :( AddResponseHeader( "Accept-Encoding", "gzip;q=0"); #endif } void tSocket::OnFirst (  )  Definition at line 192 of file tSocket.cpp. References DEB. { HttpGetSocket::OnFirst(); DEB( printf("IsRequest: %s\n",IsRequest() ? "YES" : "NO"); if (IsRequest()) { printf(" Method: %s\n",GetMethod().c_str()); printf(" URL: %s\n",GetUrl().c_str()); printf(" Http version: %s\n",GetHttpVersion().c_str()); }) DEB( printf("IsResponse: %s\n",IsResponse() ? "YES" : "NO"); if (IsResponse()) { printf(" Http version: %s\n",GetHttpVersion().c_str()); printf(" Status: %s\n",GetStatus().c_str()); printf(" Status text: %s\n",GetStatusText().c_str()); }) } void tSocket::OnHeader ( const std::string &  key, const std::string &  value   ) Definition at line 214 of file tSocket.cpp. References DEB, m_filename, and m_gzip. { HttpGetSocket::OnHeader(key,value); DEB(printf("%s: %s\n", key.c_str(), value.c_str());) if (!strcasecmp(key.c_str(), "content-encoding")) { DEB(printf(" *** ENCODING: %s\n", value.c_str());) if (!strcasecmp(value.c_str(), "gzip")) { m_filename += ".gz"; SetFilename(m_filename); m_gzip = true; } } } void tSocket::OnDelete (  )  Definition at line 87 of file tSocket.cpp. References DEB, Exception::GetText(), m_filename, m_gzip, and m_hash. { HttpGetSocket::OnDelete(); if (!Complete()) { DEB(printf("Tracker reply incomplete\n");) return; } Session *sess = static_cast<PeerHandler&>(Handler()).GetSession(m_hash); if (!sess) { return; } if (m_gzip) { char cmd[1000]; DEB(printf("Tracker reply gzipped\n");) unlink(m_filename.substr(0, m_filename.size() - 3).c_str()); #ifdef _WIN32 sprintf(cmd, "gzip.exe -d %s", m_filename.c_str()); #else sprintf(cmd, "/usr/bin/gzip -d %s", m_filename.c_str()); #endif system( cmd ); m_filename = m_filename.substr(0, m_filename.size() - 3); // remove .gz } DEB(printf("TrackerReply() in file '%s'\n",m_filename.c_str());) try { FILE *fil; if ((fil = fopen(m_filename.c_str(),"rb")) != NULL) { BString bstr; bstr.read_file(fil); fclose(fil); BTInteger *p = dynamic_cast<BTInteger *>(bstr.GetBTObject("interval")); if (p) { int interval = atoi(p -> GetValue().c_str()); DEB(printf("Tracker contact interval: %d\n",interval);) sess -> SetInterval( interval ); } BTList *l = dynamic_cast<BTList *>(bstr.GetBTObject("peers")); if (l) { DEB(printf(" peers found\n");) for (btobject_v::iterator it = l -> GetList().begin(); it != l -> GetList().end(); it++) { BTDictionary *p = dynamic_cast<BTDictionary *>(*it); std::string ip; std::string id; int port = 0; if (p) { DEB(printf(" dictionary found\n");) for (btmap_t::iterator it = p -> GetMap().begin(); it != p -> GetMap().end(); it++) { std::string key = (*it).first; BTObject *p0 = (*it).second; if (key == "ip") { BTString *p = dynamic_cast<BTString *>(p0); if (p) ip = p -> GetValue(); } else if (key == "peer id") { BTString *p = dynamic_cast<BTString *>(p0); if (p) id = p -> GetValue(); } else if (key == "port") { BTInteger *p = dynamic_cast<BTInteger *>(p0); if (p) port = atoi(p -> GetValue().c_str()); } } } if (ip.size() && id.size() == 20 && port) { Peer *p = sess -> GetPeer(ip); if (!p) { Peer *p = new Peer(Handler(),m_hash,ip,id,port); sess -> AddPeer(p); } else { p -> SetPort(port); } } } } } } catch (const Exception& DEB(e)) { DEB(printf("Exception when reading response from tracker: %s\n", e.GetText().c_str());) } } Member Data Documentation std::string tSocket::m_hash [private] Definition at line 44 of file tSocket.h. Referenced by OnDelete(). std::string tSocket::m_filename [private] Definition at line 45 of file tSocket.h. Referenced by OnDelete(), OnHeader(), tSocket(), and ~tSocket(). int tSocket::m_next_id = 0 [static, private] Definition at line 46 of file tSocket.h. Referenced by tSocket(). bool tSocket::m_gzip [private] Definition at line 47 of file tSocket.h. Referenced by OnDelete(), and OnHeader(). The documentation for this class was generated from the following files: tSocket.h tSocket.cpp

Page, code, and content Copyright (C) 2006 by Anders Hedström

---