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:
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
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,
}
#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
DEBUG = True
-class TriblerRun(BitTorrentClientRun):
+class NextShareRun(BitTorrentClientRun):
def __init__(self, base_path):
os.environ["PYTHONPATH"] = base_path