X-Git-Url: https://git.mxchange.org/?p=quix0rs-apt-p2p.git;a=blobdiff_plain;f=apt-p2p.py;h=8d69b06faee658b52c2fdade8455d0b85b634b15;hp=adbc7bdd72e679c67d3140a756760a71b102217c;hb=c14ca771c67c88699e7b4eb065d834976e4711ba;hpb=19dab12a49b05e17b3fc9e6fc246c31f157b4f48 diff --git a/apt-p2p.py b/apt-p2p.py index adbc7bd..8d69b06 100644 --- a/apt-p2p.py +++ b/apt-p2p.py @@ -1,13 +1,14 @@ -#!/usr/bin/env python +#!/usr/bin/python -# Load apt-p2p application -# -# There are two ways apt-p2p can be started: -# 1. twistd -y apt-p2p -# - twistd will load this file and execute the app -# in 'application' variable -# 2. from command line -# - __name__ will be '__main__' +"""Load the apt-p2p application. + +There are two ways apt-p2p can be started: + 1. twistd -y apt-p2p + - twistd will load this file and execute the app + in 'application' variable + 2. from command line + - __name__ will be '__main__' +""" import pwd,sys @@ -15,7 +16,7 @@ from twisted.application import service, internet, app, strports from twisted.internet import reactor from twisted.python import usage, log -from apt_p2p.apt_p2p_conf import config, version, DEFAULT_CONFIG_FILES +from apt_p2p.apt_p2p_conf import config, version, versionID, DEFAULT_CONFIG_FILES from apt_p2p.interfaces import IDHT, IDHTStatsFactory config_file = '' @@ -52,38 +53,39 @@ if __name__ == '__main__': log.msg("Loading config files: '%s'" % "', '".join(DEFAULT_CONFIG_FILES + [config_file])) config_read = config.read(DEFAULT_CONFIG_FILES + [config_file]) +config.set(config.get('DEFAULT', 'DHT'), 'VERSION', versionID) log.msg("Successfully loaded config files: '%s'" % "', '".join(config_read)) try: uid,gid = pwd.getpwnam(config.get('DEFAULT', 'USERNAME'))[2:4] except: uid,gid = None,None -log.msg('Starting application') +log.msg('Starting application with uid/gid %r/%r' % (uid, gid)) application = service.Application("apt-p2p", uid, gid) #print service.IProcess(application).processName #service.IProcess(application).processName = 'apt-p2p' -log.msg('Starting DHT') DHT = __import__(config.get('DEFAULT', 'DHT')+'.DHT', globals(), locals(), ['DHT']) assert IDHT.implementedBy(DHT.DHT), "You must provide a DHT implementation that implements the IDHT interface." if not config.getboolean('DEFAULT', 'DHT-only'): log.msg('Starting main application server') from apt_p2p.apt_p2p import AptP2P - myapp = AptP2P(DHT.DHT) - factory = myapp.getHTTPFactory() + factory = AptP2P(DHT.DHT) s = strports.service('tcp:'+config.get('DEFAULT', 'port'), factory) s.setServiceParent(application) else: + log.msg('Starting the DHT') myDHT = DHT.DHT() + if IDHTStatsFactory.implementedBy(DHT.DHT): log.msg("Starting the DHT's HTTP stats displayer") factory = myDHT.getStatsFactory() s = strports.service('tcp:'+config.get('DEFAULT', 'port'), factory) s.setServiceParent(application) - myDHT.loadConfig(config, config.get('DEFAULT', 'DHT')) - myDHT.join() + reactor.callLater(0, myDHT.loadConfig, config, config.get('DEFAULT', 'DHT')) + reactor.callLater(0, myDHT.join) if __name__ == '__main__': # Run on command line