(conf_name, src_url, dst_url)
| 162 | |
| 163 | |
| 164 | def run_incr_sync(conf_name, src_url, dst_url): |
| 165 | src_client = pymongo.MongoClient(_get_mongodb_addr(src_url)) |
| 166 | src_client.get_database(test_db).drop_collection(test_coll) |
| 167 | src_client.drop_database(test_checkpoint_db) |
| 168 | dst_client = pymongo.MongoClient(dst_url) |
| 169 | dst_client.get_database(test_db).drop_collection(test_coll) |
| 170 | gevent.joinall([ |
| 171 | gevent.spawn(_incr_sync_inject_src_and_check, src_url, dst_url, src_client), |
| 172 | gevent.spawn(_run_shake, conf_name), |
| 173 | ]) |
| 174 | return None |
| 175 | |
| 176 | |
| 177 | def _incr_sync_inject_src_and_check(src_url, dst_url, client): |
no test coverage detected