(self)
| 108 | self.env.assertEquals(master_resultset, replica_resultset) |
| 109 | |
| 110 | def __init__(self): |
| 111 | self.env = Env(decodeResponses=True, env='oss', useSlaves=True) |
| 112 | self.monitor = [] |
| 113 | self.master = self.env.getConnection() |
| 114 | self.replica = self.env.getSlaveConnection() |
| 115 | self.master_graph = Graph(self.master, GRAPH_ID) |
| 116 | self.replica_graph = Graph(self.replica, GRAPH_ID) |
| 117 | |
| 118 | # create indices |
| 119 | self.master_graph.query("CREATE INDEX FOR (n:L) ON (n.a, n.b, n.c)") |
| 120 | self.master_graph.query("CREATE INDEX FOR ()-[e:R]->() ON (e.a, e.b, e.c)") |
| 121 | |
| 122 | # wait for replica and master to sync |
| 123 | self.master.wait(1, 0) |
| 124 | |
| 125 | self.effects_enable() |
| 126 | |
| 127 | self.monitor_thread = threading.Thread(target=self.monitor_thread) |
| 128 | self.monitor_thread.start() |
| 129 | # wait for monitor thread to attach |
| 130 | while MONITOR_ATTACHED is False: |
| 131 | time.sleep(0.2) |
| 132 | |
| 133 | def __del__(self): |
| 134 | # all done, shutdown replica |
nothing calls this directly
no test coverage detected