mirror of
https://github.com/tahoe-lafs/tahoe-lafs.git
synced 2025-02-07 11:50:21 +00:00
use foolscap.reconnector.ReconnectionInfo where one is required
It's *right* there. Just use it!
This commit is contained in:
parent
c478160988
commit
2f106aa02a
@ -1,21 +1,13 @@
|
|||||||
"""
|
"""
|
||||||
Tests for allmydata.util.connection_status.
|
Tests for allmydata.util.connection_status.
|
||||||
|
|
||||||
Port to Python 3.
|
|
||||||
"""
|
"""
|
||||||
from __future__ import absolute_import
|
|
||||||
from __future__ import division
|
|
||||||
from __future__ import print_function
|
|
||||||
from __future__ import unicode_literals
|
|
||||||
|
|
||||||
from future.utils import PY2
|
|
||||||
if PY2:
|
|
||||||
from builtins import filter, map, zip, ascii, chr, hex, input, next, oct, open, pow, round, super, bytes, dict, list, object, range, str, max, min # noqa: F401
|
|
||||||
|
|
||||||
import mock
|
import mock
|
||||||
|
|
||||||
from twisted.trial import unittest
|
from twisted.trial import unittest
|
||||||
|
|
||||||
|
from foolscap.reconnector import ReconnectionInfo
|
||||||
|
|
||||||
from ..util import connection_status
|
from ..util import connection_status
|
||||||
|
|
||||||
class Status(unittest.TestCase):
|
class Status(unittest.TestCase):
|
||||||
@ -33,7 +25,7 @@ class Status(unittest.TestCase):
|
|||||||
ci.connectionHandlers = {"h1": "hand1"}
|
ci.connectionHandlers = {"h1": "hand1"}
|
||||||
ci.winningHint = "h1"
|
ci.winningHint = "h1"
|
||||||
ci.establishedAt = 120
|
ci.establishedAt = 120
|
||||||
ri = mock.Mock()
|
ri = ReconnectionInfo()
|
||||||
ri.state = "connected"
|
ri.state = "connected"
|
||||||
ri.connectionInfo = ci
|
ri.connectionInfo = ci
|
||||||
rc = mock.Mock
|
rc = mock.Mock
|
||||||
@ -51,7 +43,7 @@ class Status(unittest.TestCase):
|
|||||||
ci.connectionHandlers = {"h1": "hand1"}
|
ci.connectionHandlers = {"h1": "hand1"}
|
||||||
ci.winningHint = "h1"
|
ci.winningHint = "h1"
|
||||||
ci.establishedAt = 120
|
ci.establishedAt = 120
|
||||||
ri = mock.Mock()
|
ri = ReconnectionInfo()
|
||||||
ri.state = "connected"
|
ri.state = "connected"
|
||||||
ri.connectionInfo = ci
|
ri.connectionInfo = ci
|
||||||
rc = mock.Mock
|
rc = mock.Mock
|
||||||
@ -70,7 +62,7 @@ class Status(unittest.TestCase):
|
|||||||
ci.listenerStatus = ("listener1", "successful")
|
ci.listenerStatus = ("listener1", "successful")
|
||||||
ci.winningHint = None
|
ci.winningHint = None
|
||||||
ci.establishedAt = 120
|
ci.establishedAt = 120
|
||||||
ri = mock.Mock()
|
ri = ReconnectionInfo()
|
||||||
ri.state = "connected"
|
ri.state = "connected"
|
||||||
ri.connectionInfo = ci
|
ri.connectionInfo = ci
|
||||||
rc = mock.Mock
|
rc = mock.Mock
|
||||||
@ -87,7 +79,7 @@ class Status(unittest.TestCase):
|
|||||||
ci = mock.Mock()
|
ci = mock.Mock()
|
||||||
ci.connectorStatuses = {"h1": "st1", "h2": "st2"}
|
ci.connectorStatuses = {"h1": "st1", "h2": "st2"}
|
||||||
ci.connectionHandlers = {"h1": "hand1"}
|
ci.connectionHandlers = {"h1": "hand1"}
|
||||||
ri = mock.Mock()
|
ri = ReconnectionInfo()
|
||||||
ri.state = "connecting"
|
ri.state = "connecting"
|
||||||
ri.connectionInfo = ci
|
ri.connectionInfo = ci
|
||||||
rc = mock.Mock
|
rc = mock.Mock
|
||||||
@ -104,7 +96,7 @@ class Status(unittest.TestCase):
|
|||||||
ci = mock.Mock()
|
ci = mock.Mock()
|
||||||
ci.connectorStatuses = {"h1": "st1", "h2": "st2"}
|
ci.connectorStatuses = {"h1": "st1", "h2": "st2"}
|
||||||
ci.connectionHandlers = {"h1": "hand1"}
|
ci.connectionHandlers = {"h1": "hand1"}
|
||||||
ri = mock.Mock()
|
ri = ReconnectionInfo()
|
||||||
ri.state = "waiting"
|
ri.state = "waiting"
|
||||||
ri.lastAttempt = 10
|
ri.lastAttempt = 10
|
||||||
ri.nextAttempt = 20
|
ri.nextAttempt = 20
|
||||||
|
Loading…
x
Reference in New Issue
Block a user