55#include < test/util/setup_common.h>
66
77#include < coinjoin/coinjoin.h>
8- #include < cstddef>
98#include < uint256.h>
109
1110#include < boost/test/unit_test.hpp>
1211
13- class TestBaseManager : public CCoinJoinBaseManager
14- {
15- public:
16- void PushQueue (const CCoinJoinQueue& q)
17- {
18- LOCK (cs_vecqueue);
19- vecCoinJoinQueue.push_back (q);
20- }
21- size_t QueueSize () const
22- {
23- LOCK (cs_vecqueue);
24- return vecCoinJoinQueue.size ();
25- }
26- void CallCheckQueue () { CheckQueue (); }
27- };
28-
2912BOOST_FIXTURE_TEST_SUITE (coinjoin_basemanager_tests, BasicTestingSetup)
3013
3114static CCoinJoinQueue MakeQueue (int denom, int64_t nTime, bool fReady , const COutPoint& outpoint)
@@ -41,27 +24,27 @@ static CCoinJoinQueue MakeQueue(int denom, int64_t nTime, bool fReady, const COu
4124
4225BOOST_AUTO_TEST_CASE (checkqueue_removes_timeouts)
4326{
44- TestBaseManager man;
27+ CCoinJoinBaseManager man;
4528 const int denom = CoinJoin::AmountToDenomination (CoinJoin::GetSmallestDenomination ());
4629 const int64_t now = GetAdjustedTime ();
4730 // Non-expired
48- man.PushQueue (MakeQueue (denom, now, false , COutPoint (uint256S (" 11" ), 0 )));
31+ man.AddQueue (MakeQueue (denom, now, false , COutPoint (uint256S (" 11" ), 0 )));
4932 // Expired (too old)
50- man.PushQueue (MakeQueue (denom, now - COINJOIN_QUEUE_TIMEOUT - 1 , false , COutPoint (uint256S (" 12" ), 0 )));
33+ man.AddQueue (MakeQueue (denom, now - COINJOIN_QUEUE_TIMEOUT - 1 , false , COutPoint (uint256S (" 12" ), 0 )));
5134
52- BOOST_CHECK_EQUAL (man.QueueSize (), 2U );
53- man.CallCheckQueue ();
35+ BOOST_CHECK_EQUAL (man.GetQueueSize (), 2 );
36+ man.CheckQueue ();
5437 // One should be removed
55- BOOST_CHECK_EQUAL (man.QueueSize (), 1U );
38+ BOOST_CHECK_EQUAL (man.GetQueueSize (), 1 );
5639}
5740
5841BOOST_AUTO_TEST_CASE (getqueueitem_marks_tried_once)
5942{
60- TestBaseManager man;
43+ CCoinJoinBaseManager man;
6144 const int denom = CoinJoin::AmountToDenomination (CoinJoin::GetSmallestDenomination ());
6245 const int64_t now = GetAdjustedTime ();
6346 CCoinJoinQueue dsq = MakeQueue (denom, now, false , COutPoint (uint256S (" 21" ), 0 ));
64- man.PushQueue (dsq);
47+ man.AddQueue (dsq);
6548
6649 CCoinJoinQueue picked;
6750 // First retrieval should succeed
0 commit comments