client/TestCacheXfer.cpp

   1 /*
   2  * This file is part of TouristP2PImpl
   3  *
   4  * Copyright (C) 2007,2008 NUST Institute of Information Technology
   5  * Author: Faisal Khan <faisal.khan at [niit.edu.pk | cern.ch ]>
   6  *
   7  * TouristP2PImpl is free software; you can redistribute it and/or modify
   8  * it under the terms of the GNU General Public License as published by
   9  * the Free Software Foundation; either version 2 of the License, or
  10  * (at your option) any later version.
  11  *
  12  * TouristP2PImpl 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
  18  * along with TouristP2PImpl; if not, write to the Free Software
  19  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  20 */
  21 #include "Tourist/LocalNode.h"
  22 #include "Tourist/App/Application.h"
  23 #include "Tourist/Message/RemoteNode.h"
  24 #include "Tourist/LocalNode.h"
  25 #include "Tourist/AvlCache.h"
  26 #include "Tourist/Util/Util.h"
  27 #include "Poco/Thread.h"
  28
  29 using Tourist::App::Application;
  30 using Tourist::Message::RemoteNode;
  31 //using Tourist::LocalNode;
  32
  33 using Poco::Thread;
  34
  35 using namespace Tourist::Util;
  36
  37 int main(int argc, char **argv)
  38 {
  39
  40   /*LocalNode node1;
  41   std::cout<<"Node ID = " <<node1.getID()<<endl;
  42
  43   RemoteNode rNode(NULL, node1.getID(), 0);
  44   std::cout<<"rNode ID = " <<rNode.toString()<<std::endl;
  45   std::cout<<"rNode ID = " <<rNode.toString()<<std::endl;*/
  46   if (argc < 2)
  47   {
  48     fprintf(stderr, "Missing arguments!
  49 ");
  50     return -1;
  51   }
  52
  53   Config config;
  54   config.setTCPEnable(true);
  55   config.setTCPPort(5001);
  56
  57   Application app(config);
  58   app.init();
  59
  60   Thread t;
  61   t.start(app);
  62
  63   int rPort = atoi(argv[1]);
  64
  65   RemoteNode *rnode = NULL;
  66   int status = app.connectionTo("localhost", rPort, TCP, &rnode, 25);
  67   fprintf(stderr, "Status of remote connection is %d
  68 ", status);
  69
  70   if (rnode == NULL)
  71   {
  72     fprintf(stderr, "Failed to connect to remote node");
  73     app.stopApp();
  74     t.join();
  75     return -1;
  76   }
  77
  78   std::cout<<"Handshake completed node "<<rnode -> toString()<<std::endl;
  79
  80   Tourist::NodeSet result;
  81   status = app.getRemoteCache(rnode, PREFIX, 0, 5, 500, result);
  82   fprintf(stderr, "status = %d , result.treeSize = %d
  83 ", status, result.treeSize);
  84
  85   while (1)
  86   {
  87     Thread::sleep(5000);
  88   }
  89 }