@@ -141,6 +141,16 @@ def run_test(self):
141
141
self .nodes [2 ].syncwithvalidationinterfacequeue () # Flush mempool to wallet
142
142
assert_equal (node2_balance , wallet_watch .getbalance ())
143
143
144
+ mempooldat0 = os .path .join (self .nodes [0 ].datadir , self .chain , 'mempool.dat' )
145
+ mempooldat1 = os .path .join (self .nodes [1 ].datadir , self .chain , 'mempool.dat' )
146
+
147
+ self .log .debug ("Force -persistmempool=0 node1 to savemempool to disk via RPC" )
148
+ assert not os .path .exists (mempooldat1 )
149
+ result1 = self .nodes [1 ].savemempool ()
150
+ assert os .path .isfile (mempooldat1 )
151
+ assert_equal (result1 ['filename' ], mempooldat1 )
152
+ os .remove (mempooldat1 )
153
+
144
154
self .log .debug ("Stop-start node0 with -persistmempool=0. Verify that it doesn't load its mempool.dat file." )
145
155
self .stop_nodes ()
146
156
self .start_node (0 , extra_args = ["-persistmempool=0" ])
@@ -153,8 +163,6 @@ def run_test(self):
153
163
assert self .nodes [0 ].getmempoolinfo ()["loaded" ]
154
164
assert_equal (len (self .nodes [0 ].getrawmempool ()), 7 )
155
165
156
- mempooldat0 = os .path .join (self .nodes [0 ].datadir , self .chain , 'mempool.dat' )
157
- mempooldat1 = os .path .join (self .nodes [1 ].datadir , self .chain , 'mempool.dat' )
158
166
self .log .debug ("Remove the mempool.dat file. Verify that savemempool to disk via RPC re-creates it" )
159
167
os .remove (mempooldat0 )
160
168
result0 = self .nodes [0 ].savemempool ()
0 commit comments