Mirroristas/bigchaindb
2
0
Fork 0
mirror of https://github.com/bigchaindb/bigchaindb.git synced 2024-10-13 13:34:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

Break out of the loop once a connection is established

Browse Source 
closes #1068
This commit is contained in:
vrde 2017-01-30 10:56:46 +01:00
parent 509b590b32
commit 5b084edaf4
No known key found for this signature in database
GPG Key ID: 6581C7C39B3D397D
2 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
bigchaindb/backend/rethinkdb/connection.py
View File

@ -77,3 +77,5 @@ class RethinkDBConnection(Connection):
wait_time = 2**i wait_time = 2**i
logging.debug('Error connecting to database, waiting %ss', wait_time) logging.debug('Error connecting to database, waiting %ss', wait_time)
time.sleep(wait_time) time.sleep(wait_time)
else:
break

13
tests/backend/rethinkdb/test_connection.py
View File

@ -1,6 +1,7 @@
import time import time
import multiprocessing as mp import multiprocessing as mp
from threading import Thread from threading import Thread
from unittest.mock import patch
import pytest import pytest
import rethinkdb as r import rethinkdb as r
@ -118,3 +119,15 @@ def test_changefeed_reconnects_when_connection_lost(monkeypatch):
fact = changefeed.outqueue.get()['fact'] fact = changefeed.outqueue.get()['fact']
assert fact == 'Cats sleep 70% of their lives.' assert fact == 'Cats sleep 70% of their lives.'
@patch('rethinkdb.connect')
def test_connection_happens_one_time_if_successful(mock_connect):
from bigchaindb.backend import connect
query = r.expr('1')
conn = connect('rethinkdb', 'localhost', 1337, 'whatev')
conn.run(query)
mock_connect.assert_called_once_with(host='localhost',
port=1337,
db='whatev')