Skip to content

Commit 5dfb81b

Browse files
Add unit test for unix domain sockets support in WhiteListRoundRobinPolicy
1 parent 669e516 commit 5dfb81b

File tree

1 file changed

+12
-1
lines changed

1 file changed

+12
-1
lines changed

tests/unit/test_policies.py

Lines changed: 12 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@
3434
LoadBalancingPolicy, ConvictionPolicy, ReconnectionPolicy, FallthroughRetryPolicy,
3535
IdentityTranslator, EC2MultiRegionTranslator, HostFilterPolicy)
3636
from cassandra.pool import Host
37-
from cassandra.connection import DefaultEndPoint
37+
from cassandra.connection import DefaultEndPoint, UnixSocketEndPoint
3838
from cassandra.query import Statement
3939

4040
from six.moves import xrange
@@ -1254,6 +1254,17 @@ def test_hosts_with_hostname(self):
12541254
self.assertEqual(sorted(qplan), [host])
12551255

12561256
self.assertEqual(policy.distance(host), HostDistance.LOCAL)
1257+
1258+
def test_hosts_with_socket_hostname(self):
1259+
hosts = [UnixSocketEndPoint('/tmp/scylla-workdir/cql.m')]
1260+
policy = WhiteListRoundRobinPolicy(hosts)
1261+
host = Host(UnixSocketEndPoint('/tmp/scylla-workdir/cql.m'), SimpleConvictionPolicy)
1262+
policy.populate(None, [host])
1263+
1264+
qplan = list(policy.make_query_plan())
1265+
self.assertEqual(sorted(qplan), [host])
1266+
1267+
self.assertEqual(policy.distance(host), HostDistance.LOCAL)
12571268

12581269

12591270
class AddressTranslatorTest(unittest.TestCase):

0 commit comments

Comments
 (0)