@@ -95,7 +95,7 @@ def start_simple_weave_server(self, cmd_path, server_addr, node_id, tag, quiet =
9595 if listen :
9696 cmd += " --listen"
9797
98- persistent_storage_file = self .main_conf [ 'log_directory' ] + "/" + self .getStateId () + "_persistent_state." + tag
98+ persistent_storage_file = self .getHappyLogDir () + "/" + self .getStateId () + "_persistent_state." + tag
9999
100100 if use_persistent_storage :
101101 cmd += " --persistent-cntr-file " + persistent_storage_file
@@ -128,7 +128,8 @@ def jitter(self, jitter_distribution_curve):
128128 else :
129129 self .logger .debug ("Expect that jitter_distribution_curve is integer and not less than 0 %d" % jitter_distribution_curve )
130130
131- def start_simple_weave_client (self , cmd_path , client_addr , server_addr , server_id , node_id , tag , quiet = None , strace = True , env = {}, use_persistent_storage = True , reset_persistent_storage = True ):
131+ def start_simple_weave_client (self , cmd_path , client_addr , server_addr , server_id , node_id , tag ,
132+ quiet = None , strace = True , env = {}, use_persistent_storage = True , reset_persistent_storage = True ):
132133 cmd = cmd_path
133134
134135 if client_addr != None :
@@ -137,7 +138,7 @@ def start_simple_weave_client(self, cmd_path, client_addr, server_addr, server_i
137138 if server_addr != None :
138139 cmd += " --dest-addr " + str (server_addr )
139140
140- persistent_storage_file = self .main_conf [ 'log_directory' ] + "/" + self .getStateId () + "_persistent_state." + tag
141+ persistent_storage_file = self .getHappyLogDir () + "/" + self .getStateId () + "_persistent_state." + tag
141142
142143 if use_persistent_storage :
143144 cmd += " --persistent-cntr-file " + persistent_storage_file
0 commit comments