

def recycle(self):
    if self._started:
        with self._lock:
            stdin = self._server.stdin
            if (self._kv_backend() == 'riak_kv_test_backend'):
                stdin.write('riak_kv_test_backend:reset().\n')
                stdin.flush()
                self.wait_for_erlang_prompt()
                if self.app_config['riak_search']['enabled']:
                    stdin.write('riak_search_test_backend:reset().\n')
                    stdin.flush()
                    self.wait_for_erlang_prompt()
            else:
                stdin.write('init:restart().\n')
                stdin.flush()
                stdin.wait_for_erlang_prompt()
                self.wait_for_startup()

dataset/ETHPy150Open basho/riak-python-client/riak/test_server.py TestServer.recycle/VarMisuse@115/192 `self`->`stdin`