X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;ds=sidebyside;f=apt_p2p%2Fapt_p2p_conf.py;h=8494a0be7119419cc3e3d7a16fda4c8815a07040;hb=e6042f7b9084b3a317e3b61be4931c5eeed9fa41;hp=e4f0bf9f7733efd94e6498e9789e924b319496cb;hpb=c1a8891e0bfb81e9fc64d271f8e4de059c699921;p=quix0rs-apt-p2p.git diff --git a/apt_p2p/apt_p2p_conf.py b/apt_p2p/apt_p2p_conf.py index e4f0bf9..8494a0b 100644 --- a/apt_p2p/apt_p2p_conf.py +++ b/apt_p2p/apt_p2p_conf.py @@ -71,8 +71,11 @@ DEFAULTS = { # Refresh the DHT keys after this much time has passed. # This should be a time slightly less than the DHT's KEY_EXPIRE value. - 'KEY_REFRESH': '57m', + 'KEY_REFRESH': '2.5h', + # The user name to try and run as (leave blank to run as current user) + 'USERNAME': 'apt-p2p', + # Which DHT implementation to use. # It must be possible to do "from .DHT import DHT" to get a class that # implements the IDHT interface. @@ -118,8 +121,19 @@ DHT_DEFAULTS = { 'BUCKET_STALENESS': '1h', # one hour # expire entries older than this - 'KEY_EXPIRE': '1h', # 60 minutes + 'KEY_EXPIRE': '3h', # 3 hours + + # Timeout KRPC requests to nodes after this time. + 'KRPC_TIMEOUT': '14s', + # KRPC requests are resent using exponential backoff starting with this delay. + # The request will first be resent after the delay set here. + # The request will be resent again after twice the delay set here. etc. + # e.g. if TIMEOUT is 14 sec., and INITIAL_DELAY is 2 sec., then requests will + # be resent at times 0, 2 (2 sec. later), and 6 (4 sec. later), and then will + # timeout at 14. + 'KRPC_INITIAL_DELAY': '2s', + # whether to spew info about the requests/responses in the protocol 'SPEW': 'no', } @@ -148,7 +162,7 @@ class AptP2PConfigParser(SafeConfigParser): if suffix in self.time_multipliers.keys(): mult = self.time_multipliers[suffix] value = value[:-1] - return int(value)*mult + return int(float(value)*mult) def getstring(self, section, option): """Read the config parameter as a string.""" @@ -194,6 +208,14 @@ class TestConfigParser(unittest.TestCase): config.set('DEFAULT', 'time_tester_4', '37s') self.failUnless(config.gettime('DEFAULT', 'time_tester_4') == 37) + def test_floating_time(self): + config.set('DEFAULT', 'time_float_tester_1', '2.5d') + self.failUnless(config.gettime('DEFAULT', 'time_float_tester_1') == int(2.5*86400)) + config.set('DEFAULT', 'time_float_tester_2', '0.5h') + self.failUnless(config.gettime('DEFAULT', 'time_float_tester_2') == int(0.5*3600)) + config.set('DEFAULT', 'time_float_tester_3', '4.3333m') + self.failUnless(config.gettime('DEFAULT', 'time_float_tester_3') == int(4.3333*60)) + def test_string(self): config.set('DEFAULT', 'string_test', 'foobar') self.failUnless(type(config.getstring('DEFAULT', 'string_test')) == str)