autorun: server can control NextShare
authorAdriana Draghici <adriana.draghici@cti.pub.ro>
Fri, 24 Sep 2010 17:30:51 +0000 (20:30 +0300)
committerP2P-Next <p2p-next@cs.pub.ro>
Fri, 24 Sep 2010 17:31:35 +0000 (20:31 +0300)
autorun/server/BTClientsControl.py
autorun/server/Client.py
autorun/server/NextShareRun.py

index 810b6dd..e0b9302 100644 (file)
@@ -4,9 +4,10 @@ import logging
 from Util import *
 
 from BitTorrentClientRun import *
+from HrktorrentRun import *
 from TransmissionRun import *
 from TriblerRun import *
-from HrktorrentRun import *
+from NextShareRun import *
 from TriblerStatusParser import *
 
 class BTClientsControl:
@@ -34,10 +35,12 @@ class BTClientsControl:
 
         if bt_client_data[CLIENT] == TRANSMISSION:
             btcr = TransmissionRun(bt_client_data[BASE_DIR])
-        elif bt_client_data[CLIENT] == TRIBLER:
-            btcr = TriblerRun(bt_client_data[BASE_DIR])
         elif bt_client_data[CLIENT] == HRKTORRENT:
             btcr = HrktorrentRun(bt_client_data[BASE_DIR])
+        elif bt_client_data[CLIENT] == TRIBLER:
+            btcr = TriblerRun(bt_client_data[BASE_DIR])
+        elif bt_client_data[CLIENT] == NEXTSHARE:
+            btcr = NextShareRun(bt_client_data[BASE_DIR])
         else:
             self.error_msg = "Unknown BitTorrent client: " + bt_client_data[CLIENT] + "."
             return -1
index 2f16dcb..c20feba 100644 (file)
@@ -94,7 +94,18 @@ def test_all_commands(torrent_file):
             LOG_FILE: "tribler-" + torrent_name + ".log", #verbose messages
             DL_LIMIT: 250,
             UP_LIMIT: 250
-
+            }
+    start_data_nextshare = {
+            CLIENT: NEXTSHARE, PORT:10150,
+            BASE_DIR:"/home/p2p/p2p-clients/next-share",
+            TORRENT: torrent_file,
+            DL_DIR: "/home/p2p/p2p-dld/next-share",
+            LOG_DIR: "/home/p2p/p2p-log/next-share",
+            OUT_DIR: "/home/p2p/p2p-log/next-share",
+            OUT_FILE: torrent_name + ".out", #status messages
+            LOG_FILE: "next-share-" + torrent_name + ".log", #verbose messages
+            DL_LIMIT: 250,
+            UP_LIMIT: 250
             }
     start_data_transmission = {
             CLIENT: TRANSMISSION, PORT:10250,
@@ -125,7 +136,7 @@ def test_all_commands(torrent_file):
             }
     #print s.send_command(GET_OUTPUT, "")
    
-    response = s.send_command(START_MSG, start_data_tribler)
+    response = s.send_command(START_MSG, start_data_nextshare)
     print response
     pid1 = response[1]
     print pid1
index a652417..5bd86f5 100644 (file)
@@ -15,7 +15,7 @@ from BitTorrentClientRun import BitTorrentClientRun
 DEBUG = True
 
 
-class TriblerRun(BitTorrentClientRun):
+class NextShareRun(BitTorrentClientRun):
     def __init__(self, base_path):
 
         os.environ["PYTHONPATH"] = base_path