Add test-run and a test

Author: Konstantin Belyavskiy

.gitmodules

@@ -0,0 +1,3 @@
+[submodule "test-run"]
+	path = test-run
+	url = https://github.com/tarantool/test-run

test-run

@@ -0,0 +1,15 @@
+-- Options for test-run tarantoolctl
+
+local workdir = os.getenv('TEST_WORKDIR')
+default_cfg = {
+    pid_file   = workdir,
+    wal_dir    = workdir,
+    memtx_dir  = workdir,
+    vinyl_dir  = workdir,
+    log        = workdir,
+    background = false,
+}
+
+instance_dir = workdir
+
+-- vim: set ft=lua :

test/.tarantoolctl

@@ -0,0 +1,9 @@
+#!/usr/bin/env tarantool
+os = require('os')
+box.cfg({
+    listen              = os.getenv("LISTEN"),
+    memtx_memory        = 107374182,
+    replication_timeout = 0.1
+})
+
+require('console').listen(os.getenv('ADMIN'))

test/cluster-py/master.lua

@@ -0,0 +1,22 @@
+box.schema.user.grant('guest', 'read,write,execute', 'universe')
+---
+...
+_ = box.schema.space.create('test')
+---
+...
+_ = box.space.test:create_index('primary')
+---
+...
+box.schema.user.grant('guest', 'read,write,execute', 'universe')
+---
+...
+_ = box.schema.space.create('test')
+---
+...
+_ = box.space.test:create_index('primary')
+---
+...
+- [1, 0]
+- [1, 1]
+
+NetworkError !

test/cluster-py/multi.result

@@ -0,0 +1,77 @@
+import sys
+import os
+from threading import Thread
+import time
+import yaml
+from lib.tarantool_server import TarantoolServer
+sys.path.append('../tarantool')
+from mesh_connection import MeshConnection
+from tarantool.const import (
+    SOCKET_TIMEOUT,
+    RECONNECT_DELAY,
+)
+from tarantool.error import NetworkError
+from tarantool.utils import ENCODING_DEFAULT
+
+REPLICA_N = 2
+
+
+def check_cluster(addrs):
+    con = MeshConnection(addrs=addrs,
+                         user=None,
+                         password=None,
+                         socket_timeout=SOCKET_TIMEOUT,
+                         reconnect_max_attempts=1,
+                         reconnect_delay=RECONNECT_DELAY,
+                         connect_now=True,
+                         encoding=ENCODING_DEFAULT)
+    while True:
+        try:
+            s = con.space('test')
+            print s.select()
+        except NetworkError:
+            print 'NetworkError !'
+            break
+        except Exception as e:
+            print e
+        time.sleep(1)
+
+
+# Start replicas
+master = server
+cluster = [master]
+for i in range(REPLICA_N):
+    server = TarantoolServer(server.ini)
+    server.script = 'cluster-py/replica.lua'
+    server.vardir = os.path.join(server.vardir, 'replica', str(i))
+    server.deploy()
+    server.admin("box.schema.user.grant('guest', 'read,write,execute', 'universe')")
+    server.admin("_ = box.schema.space.create('test')")
+    server.admin("_ = box.space.test:create_index('primary')")
+    server.admin("box.space.test:insert{%d, %s}" % (1, i), silent = True)
+    cluster.append(server)
+
+# Make a list of servers
+sources = []
+for server in cluster[1:]:
+    sources.append(yaml.load(server.admin('box.cfg.listen', silent=True))[0])
+
+addrs = []
+for addr in sources:
+    host, port = addr.split(':')
+    addrs.append({'host': host, 'port': int(port)})
+
+thread = Thread(target=check_cluster, args=(addrs, ))
+thread.start()
+
+cluster[0].stop()
+time.sleep(0.5)
+for server in cluster[1:]:
+    server.stop()
+    time.sleep(1)
+print
+
+thread.join()
+
+master.cleanup()
+master.deploy()

test/cluster-py/multi.test.py

@@ -0,0 +1,7 @@
+#!/usr/bin/env tarantool
+require('console').listen(os.getenv('ADMIN'))
+
+box.cfg({
+    listen              = os.getenv("LISTEN"),
+    memtx_memory        = 107374182,
+})

test/cluster-py/replica.lua

@@ -0,0 +1,5 @@
+[default]
+core = tarantool
+script =  master.lua
+description = reconnect
+is_parallel = False

test/cluster-py/suite.ini

@@ -0,0 +1 @@
+../test-run/test-run.py