From 4b23714658f735351950112899a4412ecb309edd Mon Sep 17 00:00:00 2001 From: moneromooo-monero Date: Fri, 29 Jan 2016 19:44:25 +0000 Subject: [PATCH 1/5] tx_pool: serialize missing kept_by_block flag --- src/cryptonote_core/tx_pool.h | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/cryptonote_core/tx_pool.h b/src/cryptonote_core/tx_pool.h index 34dc1f72f..0d2a81ca5 100644 --- a/src/cryptonote_core/tx_pool.h +++ b/src/cryptonote_core/tx_pool.h @@ -110,7 +110,7 @@ namespace cryptonote /*bool flush_pool(const std::strig& folder); bool inflate_pool(const std::strig& folder);*/ -#define CURRENT_MEMPOOL_ARCHIVE_VER 10 +#define CURRENT_MEMPOOL_ARCHIVE_VER 11 template void serialize(archive_t & a, const unsigned int version) @@ -243,6 +243,9 @@ namespace boost return; ar & td.last_relayed_time; ar & td.relayed; + if (version < 11) + return; + ar & td.kept_by_block; } } } From b11539fda74c0eb1a2b86aa31105eb6addc17256 Mon Sep 17 00:00:00 2001 From: moneromooo-monero Date: Fri, 29 Jan 2016 19:44:48 +0000 Subject: [PATCH 2/5] wallet: detect and handle failed outgoing transfers When a transaction is not found in the pool anymore, it is marked as failed, and displayed as such in show_transfers. --- src/simplewallet/simplewallet.cpp | 3 +- src/wallet/wallet2.cpp | 65 ++++++++++++++++++++++++++++++- src/wallet/wallet2.h | 7 +++- src/wallet/wallet_errors.h | 11 ++++++ 4 files changed, 83 insertions(+), 3 deletions(-) diff --git a/src/simplewallet/simplewallet.cpp b/src/simplewallet/simplewallet.cpp index 053f14349..6a725f720 100644 --- a/src/simplewallet/simplewallet.cpp +++ b/src/simplewallet/simplewallet.cpp @@ -2298,7 +2298,8 @@ bool simple_wallet::show_transfers(const std::vector &args_) std::string payment_id = string_tools::pod_to_hex(i->second.m_payment_id); if (payment_id.substr(16).find_first_not_of('0') == std::string::npos) payment_id = payment_id.substr(0,16); - message_writer() << (boost::format("%8.8s %6.6s %20.20s %s %s %14.14s") % tr("pending") % tr("out") % print_money(amount - pd.m_change) % string_tools::pod_to_hex(i->first) % payment_id % print_money(fee)).str(); + bool failed = pd.m_state == tools::wallet2::unconfirmed_transfer_details::failed; + message_writer() << (boost::format("%8.8s %6.6s %20.20s %s %s %14.14s") % (failed ? tr("failed") : tr("pending")) % tr("out") % print_money(amount - pd.m_change) % string_tools::pod_to_hex(i->first) % payment_id % print_money(fee)).str(); } } diff --git a/src/wallet/wallet2.cpp b/src/wallet/wallet2.cpp index d636b0e4b..4758e13d0 100644 --- a/src/wallet/wallet2.cpp +++ b/src/wallet/wallet2.cpp @@ -674,6 +674,58 @@ void wallet2::pull_next_blocks(uint64_t start_height, uint64_t &blocks_start_hei } } //---------------------------------------------------------------------------------------------------- +void wallet2::check_pending_txes() +{ + // if we don't have any pending txes, we don't need to check anything + if (m_unconfirmed_txs.empty()) + return; + + // we have at least one pending tx, so get the pool state + cryptonote::COMMAND_RPC_GET_TRANSACTION_POOL::request req; + cryptonote::COMMAND_RPC_GET_TRANSACTION_POOL::response res; + m_daemon_rpc_mutex.lock(); + bool r = epee::net_utils::invoke_http_json_remote_command2(m_daemon_address + "/get_transaction_pool", req, res, m_http_client, 200000); + m_daemon_rpc_mutex.unlock(); + THROW_WALLET_EXCEPTION_IF(!r, error::no_connection_to_daemon, "check_pending_txes"); + THROW_WALLET_EXCEPTION_IF(res.status == CORE_RPC_STATUS_BUSY, error::daemon_busy, "is_key_image_spent"); + THROW_WALLET_EXCEPTION_IF(res.status != CORE_RPC_STATUS_OK, error::get_tx_pool_error); + + // remove any pending tx that's not in the pool + std::unordered_map::iterator it = m_unconfirmed_txs.begin(); + while (it != m_unconfirmed_txs.end()) + { + const std::string txid = epee::string_tools::pod_to_hex(cryptonote::get_transaction_hash(it->second.m_tx)); + bool found = false; + for (auto it2: res.transactions) + { + if (it2.id_hash == txid) + { + found = true; + break; + } + } + auto pit = it++; + if (!found) + { + // we want to avoid a false positive when we ask for the pool just after + // a tx is removed from the pool due to being found in a new block, but + // just before the block is visible by refresh. So we keep a boolean, so + // that the first time we don't see the tx, we set that boolean, and only + // delete it the second time it is checked + if (pit->second.m_state == wallet2::unconfirmed_transfer_details::pending) + { + LOG_PRINT_L1("Pending txid " << txid << " not in pool, marking as not in pool"); + pit->second.m_state = wallet2::unconfirmed_transfer_details::pending_not_in_pool; + } + else if (pit->second.m_state == wallet2::unconfirmed_transfer_details::pending_not_in_pool) + { + LOG_PRINT_L1("Pending txid " << txid << " not in pool, marking as failed"); + pit->second.m_state = wallet2::unconfirmed_transfer_details::failed; + } + } + } +} +//---------------------------------------------------------------------------------------------------- void wallet2::refresh(uint64_t start_height, uint64_t & blocks_fetched, bool& received_money) { received_money = false; @@ -735,6 +787,15 @@ void wallet2::refresh(uint64_t start_height, uint64_t & blocks_fetched, bool& re if(last_tx_hash_id != (m_transfers.size() ? get_transaction_hash(m_transfers.back().m_tx) : null_hash)) received_money = true; + try + { + check_pending_txes(); + } + catch (...) + { + LOG_PRINT_L1("Failed to check pending transactions"); + } + LOG_PRINT_L1("Refresh done, blocks received: " << blocks_fetched << ", balance: " << print_money(balance()) << ", unlocked: " << print_money(unlocked_balance())); } //---------------------------------------------------------------------------------------------------- @@ -1342,7 +1403,8 @@ uint64_t wallet2::balance() const BOOST_FOREACH(auto& utx, m_unconfirmed_txs) - amount+= utx.second.m_change; + if (utx.second.m_state != wallet2::unconfirmed_transfer_details::failed) + amount+= utx.second.m_change; return amount; } @@ -1565,6 +1627,7 @@ void wallet2::add_unconfirmed_tx(const cryptonote::transaction& tx, const std::v utd.m_tx = tx; utd.m_dests = dests; utd.m_payment_id = payment_id; + utd.m_state = wallet2::unconfirmed_transfer_details::pending; } //---------------------------------------------------------------------------------------------------- diff --git a/src/wallet/wallet2.h b/src/wallet/wallet2.h index e29619444..6ecfdf026 100644 --- a/src/wallet/wallet2.h +++ b/src/wallet/wallet2.h @@ -119,6 +119,7 @@ namespace tools time_t m_sent_time; std::vector m_dests; crypto::hash m_payment_id; + enum { pending, pending_not_in_pool, failed } m_state; }; struct confirmed_transfer_details @@ -375,6 +376,7 @@ namespace tools void parse_block_round(const cryptonote::blobdata &blob, cryptonote::block &bl, crypto::hash &bl_id, bool &error) const; bool use_fork_rules(uint8_t version); uint64_t get_upper_tranaction_size_limit(); + void check_pending_txes(); cryptonote::account_base m_account; std::string m_daemon_address; @@ -412,7 +414,7 @@ namespace tools } BOOST_CLASS_VERSION(tools::wallet2, 10) BOOST_CLASS_VERSION(tools::wallet2::payment_details, 0) -BOOST_CLASS_VERSION(tools::wallet2::unconfirmed_transfer_details, 1) +BOOST_CLASS_VERSION(tools::wallet2::unconfirmed_transfer_details, 2) BOOST_CLASS_VERSION(tools::wallet2::confirmed_transfer_details, 1) namespace boost @@ -440,6 +442,9 @@ namespace boost return; a & x.m_dests; a & x.m_payment_id; + if (ver < 2) + return; + a & x.m_state; } template diff --git a/src/wallet/wallet_errors.h b/src/wallet/wallet_errors.h index ad475a03a..10d27651f 100644 --- a/src/wallet/wallet_errors.h +++ b/src/wallet/wallet_errors.h @@ -61,6 +61,7 @@ namespace tools // get_blocks_error // get_out_indexes_error // tx_parse_error + // get_tx_pool_error // transfer_error * // get_random_outs_general_error // not_enough_money @@ -307,6 +308,16 @@ namespace tools cryptonote::blobdata m_tx_blob; }; //---------------------------------------------------------------------------------------------------- + struct get_tx_pool_error : public refresh_error + { + explicit get_tx_pool_error(std::string&& loc) + : refresh_error(std::move(loc), "error getting tranaction pool") + { + } + + std::string to_string() const { return refresh_error::to_string(); } + }; + //---------------------------------------------------------------------------------------------------- struct transfer_error : public wallet_logic_error { protected: From b7e37b7763039b0083c9a2e0b782f1f74812d4a7 Mon Sep 17 00:00:00 2001 From: moneromooo-monero Date: Sat, 30 Jan 2016 13:26:57 +0000 Subject: [PATCH 3/5] simplewallet: show_transfers can now show just failed txes --- src/simplewallet/simplewallet.cpp | 19 +++++++++++++------ 1 file changed, 13 insertions(+), 6 deletions(-) diff --git a/src/simplewallet/simplewallet.cpp b/src/simplewallet/simplewallet.cpp index 6a725f720..9e82d29de 100644 --- a/src/simplewallet/simplewallet.cpp +++ b/src/simplewallet/simplewallet.cpp @@ -2194,18 +2194,19 @@ bool simple_wallet::show_transfers(const std::vector &args_) bool in = true; bool out = true; bool pending = true; + bool failed = true; uint64_t min_height = 0; uint64_t max_height = (uint64_t)-1; if(local_args.size() > 3) { - fail_msg_writer() << tr("usage: show_transfers [in|out|all|pending] [ []]"); + fail_msg_writer() << tr("usage: show_transfers [in|out|all|pending|failed] [ []]"); return true; } // optional in/out selector if (local_args.size() > 0) { if (local_args[0] == "in" || local_args[0] == "incoming") { - out = pending = false; + out = pending = failed = false; local_args.erase(local_args.begin()); } else if (local_args[0] == "out" || local_args[0] == "outgoing") { @@ -2213,7 +2214,11 @@ bool simple_wallet::show_transfers(const std::vector &args_) local_args.erase(local_args.begin()); } else if (local_args[0] == "pending") { - in = out = false; + in = out = failed = false; + local_args.erase(local_args.begin()); + } + else if (local_args[0] == "failed") { + in = out = pending = false; local_args.erase(local_args.begin()); } else if (local_args[0] == "all" || local_args[0] == "both") { @@ -2287,7 +2292,7 @@ bool simple_wallet::show_transfers(const std::vector &args_) } // print unconfirmed last - if (pending) { + if (pending || failed) { std::list> upayments; m_wallet->get_unconfirmed_payments_out(upayments); for (std::list>::const_iterator i = upayments.begin(); i != upayments.end(); ++i) { @@ -2298,8 +2303,10 @@ bool simple_wallet::show_transfers(const std::vector &args_) std::string payment_id = string_tools::pod_to_hex(i->second.m_payment_id); if (payment_id.substr(16).find_first_not_of('0') == std::string::npos) payment_id = payment_id.substr(0,16); - bool failed = pd.m_state == tools::wallet2::unconfirmed_transfer_details::failed; - message_writer() << (boost::format("%8.8s %6.6s %20.20s %s %s %14.14s") % (failed ? tr("failed") : tr("pending")) % tr("out") % print_money(amount - pd.m_change) % string_tools::pod_to_hex(i->first) % payment_id % print_money(fee)).str(); + bool is_failed = pd.m_state == tools::wallet2::unconfirmed_transfer_details::failed; + if ((failed && is_failed) || (!is_failed && pending)) { + message_writer() << (boost::format("%8.8s %6.6s %20.20s %s %s %14.14s") % (is_failed ? tr("failed") : tr("pending")) % tr("out") % print_money(amount - pd.m_change) % string_tools::pod_to_hex(i->first) % payment_id % print_money(fee)).str(); + } } } From 6288295f8e4c7807dba73cbdddd375f105ea5af6 Mon Sep 17 00:00:00 2001 From: moneromooo-monero Date: Sat, 30 Jan 2016 13:28:12 +0000 Subject: [PATCH 4/5] rpc: add missing return on error when getting a tx --- src/rpc/core_rpc_server.cpp | 1 + 1 file changed, 1 insertion(+) diff --git a/src/rpc/core_rpc_server.cpp b/src/rpc/core_rpc_server.cpp index adcaf036d..4a6f8e671 100644 --- a/src/rpc/core_rpc_server.cpp +++ b/src/rpc/core_rpc_server.cpp @@ -224,6 +224,7 @@ namespace cryptonote if(b.size() != sizeof(crypto::hash)) { res.status = "Failed, size of data mismatch"; + return true; } vh.push_back(*reinterpret_cast(b.data())); } From bf6d1474c097ee0affe827fe2e3dac489b290f40 Mon Sep 17 00:00:00 2001 From: moneromooo-monero Date: Sat, 30 Jan 2016 13:28:26 +0000 Subject: [PATCH 5/5] new flush_txpool command, and associated RPC call It can flush a particular tx, or the whole pool (the RPC command can flush a list of transactions too) --- src/cryptonote_core/blockchain.cpp | 19 ++++++++ src/cryptonote_core/blockchain.h | 2 + src/cryptonote_core/blockchain_storage.cpp | 19 ++++++++ src/cryptonote_core/blockchain_storage.h | 1 + src/daemon/command_parser_executor.cpp | 18 ++++++++ src/daemon/command_parser_executor.h | 2 + src/daemon/command_server.cpp | 5 ++ src/daemon/rpc_command_executor.cpp | 30 ++++++++++++ src/daemon/rpc_command_executor.h | 2 + src/rpc/core_rpc_server.cpp | 54 ++++++++++++++++++++++ src/rpc/core_rpc_server.h | 2 + src/rpc/core_rpc_server_commands_defs.h | 21 +++++++++ 12 files changed, 175 insertions(+) diff --git a/src/cryptonote_core/blockchain.cpp b/src/cryptonote_core/blockchain.cpp index b27927c0a..bf17544fc 100644 --- a/src/cryptonote_core/blockchain.cpp +++ b/src/cryptonote_core/blockchain.cpp @@ -2386,6 +2386,25 @@ void Blockchain::return_tx_to_pool(const std::vector &txs) } } //------------------------------------------------------------------ +bool Blockchain::flush_txes_from_pool(const std::list &txids) +{ + bool res = true; + for (const auto &txid: txids) + { + cryptonote::transaction tx; + size_t blob_size; + uint64_t fee; + bool relayed; + LOG_PRINT_L1("Removing txid " << txid << " from the pool"); + if(!m_tx_pool.take_tx(txid, tx, blob_size, fee, relayed)) + { + LOG_PRINT_L0("Failed to remove txid " << txid << " from the pool"); + res = false; + } + } + return res; +} +//------------------------------------------------------------------ // Needs to validate the block and acquire each transaction from the // transaction mem_pool, then pass the block and transactions to // m_db->add_block() diff --git a/src/cryptonote_core/blockchain.h b/src/cryptonote_core/blockchain.h index 87c8a2454..ecabf5376 100644 --- a/src/cryptonote_core/blockchain.h +++ b/src/cryptonote_core/blockchain.h @@ -164,6 +164,8 @@ namespace cryptonote bool get_hard_fork_voting_info(uint8_t version, uint32_t &window, uint32_t &votes, uint32_t &threshold, uint64_t &earliest_height, uint8_t &voting) const; + bool flush_txes_from_pool(const std::list &txids); + bool for_all_key_images(std::function) const; bool for_all_blocks(std::function) const; bool for_all_transactions(std::function) const; diff --git a/src/cryptonote_core/blockchain_storage.cpp b/src/cryptonote_core/blockchain_storage.cpp index f656f938b..e1b89f887 100644 --- a/src/cryptonote_core/blockchain_storage.cpp +++ b/src/cryptonote_core/blockchain_storage.cpp @@ -1892,6 +1892,25 @@ void blockchain_storage::set_enforce_dns_checkpoints(bool enforce_checkpoints) m_enforce_dns_checkpoints = enforce_checkpoints; } //------------------------------------------------------------------ +bool blockchain_storage::flush_txes_from_pool(const std::list &txids) +{ + bool res = true; + for (const auto &txid: txids) + { + cryptonote::transaction tx; + size_t blob_size; + uint64_t fee; + bool relayed; + LOG_PRINT_L1("Removing txid " << txid << " from the pool"); + if(!m_tx_pool->take_tx(txid, tx, blob_size, fee, relayed)) + { + LOG_PRINT_L0("Failed to remove txid " << txid << " from the pool"); + res = false; + } + } + return res; +} +//------------------------------------------------------------------ bool blockchain_storage::for_all_key_images(std::function f) const { for (key_images_container::const_iterator i = m_spent_keys.begin(); i != m_spent_keys.end(); ++i) { diff --git a/src/cryptonote_core/blockchain_storage.h b/src/cryptonote_core/blockchain_storage.h index cb5e17cdb..878202cf1 100644 --- a/src/cryptonote_core/blockchain_storage.h +++ b/src/cryptonote_core/blockchain_storage.h @@ -130,6 +130,7 @@ namespace cryptonote bool is_storing_blockchain()const{return m_is_blockchain_storing;} uint64_t block_difficulty(size_t i) const; double get_avg_block_size( size_t count) const; + bool flush_txes_from_pool(const std::list &txids); template bool get_blocks(const t_ids_container& block_ids, t_blocks_container& blocks, t_missed_container& missed_bs) const diff --git a/src/daemon/command_parser_executor.cpp b/src/daemon/command_parser_executor.cpp index d1d48b6da..0b42257e7 100644 --- a/src/daemon/command_parser_executor.cpp +++ b/src/daemon/command_parser_executor.cpp @@ -421,5 +421,23 @@ bool t_command_parser_executor::unban(const std::vector& args) return m_executor.unban(ip); } +bool t_command_parser_executor::flush_txpool(const std::vector& args) +{ + if (args.size() > 1) return false; + + std::string txid; + if (args.size() == 1) + { + crypto::hash hash; + if (!parse_hash256(args[0], hash)) + { + std::cout << "failed to parse tx id" << std::endl; + return true; + } + txid = args[0]; + } + return m_executor.flush_txpool(txid); +} + } // namespace daemonize diff --git a/src/daemon/command_parser_executor.h b/src/daemon/command_parser_executor.h index 2d9315df8..51c55a8c0 100644 --- a/src/daemon/command_parser_executor.h +++ b/src/daemon/command_parser_executor.h @@ -112,6 +112,8 @@ public: bool ban(const std::vector& args); bool unban(const std::vector& args); + + bool flush_txpool(const std::vector& args); }; } // namespace daemonize diff --git a/src/daemon/command_server.cpp b/src/daemon/command_server.cpp index f99b0844a..206de9d4a 100644 --- a/src/daemon/command_server.cpp +++ b/src/daemon/command_server.cpp @@ -209,6 +209,11 @@ t_command_server::t_command_server( , std::bind(&t_command_parser_executor::unban, &m_parser, p::_1) , "Unban a given IP" ); + m_command_lookup.set_handler( + "flush_txpool" + , std::bind(&t_command_parser_executor::flush_txpool, &m_parser, p::_1) + , "Flush a transaction from the tx pool by its txid, or the whole tx pool" + ); } bool t_command_server::process_command_str(const std::string& cmd) diff --git a/src/daemon/rpc_command_executor.cpp b/src/daemon/rpc_command_executor.cpp index 6809f68b9..1ab1c8ed8 100644 --- a/src/daemon/rpc_command_executor.cpp +++ b/src/daemon/rpc_command_executor.cpp @@ -1161,4 +1161,34 @@ bool t_rpc_command_executor::unban(const std::string &ip) return true; } +bool t_rpc_command_executor::flush_txpool(const std::string &txid) +{ + cryptonote::COMMAND_RPC_FLUSH_TRANSACTION_POOL::request req; + cryptonote::COMMAND_RPC_FLUSH_TRANSACTION_POOL::response res; + std::string fail_message = "Unsuccessful"; + epee::json_rpc::error error_resp; + + if (!txid.empty()) + req.txids.push_back(txid); + + if (m_is_rpc) + { + if (!m_rpc_client->json_rpc_request(req, res, "flush_txpool", fail_message.c_str())) + { + return true; + } + } + else + { + if (!m_rpc_server->on_flush_txpool(req, res, error_resp)) + { + tools::fail_msg_writer() << fail_message.c_str(); + return true; + } + } + + return true; +} + + }// namespace daemonize diff --git a/src/daemon/rpc_command_executor.h b/src/daemon/rpc_command_executor.h index 9589dff64..bc3f2d5c5 100644 --- a/src/daemon/rpc_command_executor.h +++ b/src/daemon/rpc_command_executor.h @@ -130,6 +130,8 @@ public: bool ban(const std::string &ip, time_t seconds); bool unban(const std::string &ip); + + bool flush_txpool(const std::string &txid); }; } // namespace daemonize diff --git a/src/rpc/core_rpc_server.cpp b/src/rpc/core_rpc_server.cpp index 4a6f8e671..3ce4e6006 100644 --- a/src/rpc/core_rpc_server.cpp +++ b/src/rpc/core_rpc_server.cpp @@ -984,6 +984,60 @@ namespace cryptonote return true; } //------------------------------------------------------------------------------------------------------------------------------ + bool core_rpc_server::on_flush_txpool(const COMMAND_RPC_FLUSH_TRANSACTION_POOL::request& req, COMMAND_RPC_FLUSH_TRANSACTION_POOL::response& res, epee::json_rpc::error& error_resp) + { + if(!check_core_busy()) + { + error_resp.code = CORE_RPC_ERROR_CODE_CORE_BUSY; + error_resp.message = "Core is busy."; + return false; + } + + bool failed = false; + std::list txids; + if (req.txids.empty()) + { + std::list pool_txs; + bool r = m_core.get_pool_transactions(pool_txs); + if (!r) + { + res.status = "Failed to get txpool contents"; + return true; + } + for (const auto &tx: pool_txs) + { + txids.push_back(cryptonote::get_transaction_hash(tx)); + } + } + else + { + for (const auto &str: req.txids) + { + cryptonote::blobdata txid_data; + if(!epee::string_tools::parse_hexstr_to_binbuff(str, txid_data)) + { + failed = true; + } + crypto::hash txid = *reinterpret_cast(txid_data.data()); + txids.push_back(txid); + } + } + if (!m_core.get_blockchain_storage().flush_txes_from_pool(txids)) + { + res.status = "Failed to remove one more tx"; + return false; + } + + if (failed) + { + res.status = "Failed to parse txid"; + return false; + } + + res.status = CORE_RPC_STATUS_OK; + return true; + } + //------------------------------------------------------------------------------------------------------------------------------ bool core_rpc_server::on_fast_exit(const COMMAND_RPC_FAST_EXIT::request& req, COMMAND_RPC_FAST_EXIT::response& res) { cryptonote::core::set_fast_exit(); diff --git a/src/rpc/core_rpc_server.h b/src/rpc/core_rpc_server.h index 4ff6cc8ab..f79087030 100644 --- a/src/rpc/core_rpc_server.h +++ b/src/rpc/core_rpc_server.h @@ -108,6 +108,7 @@ namespace cryptonote MAP_JON_RPC_WE("hard_fork_info", on_hard_fork_info, COMMAND_RPC_HARD_FORK_INFO) MAP_JON_RPC_WE("setbans", on_set_bans, COMMAND_RPC_SETBANS) MAP_JON_RPC_WE("getbans", on_get_bans, COMMAND_RPC_GETBANS) + MAP_JON_RPC_WE("flush_txpool", on_flush_txpool, COMMAND_RPC_FLUSH_TRANSACTION_POOL) END_JSON_RPC_MAP() END_URI_MAP2() @@ -147,6 +148,7 @@ namespace cryptonote bool on_hard_fork_info(const COMMAND_RPC_HARD_FORK_INFO::request& req, COMMAND_RPC_HARD_FORK_INFO::response& res, epee::json_rpc::error& error_resp); bool on_set_bans(const COMMAND_RPC_SETBANS::request& req, COMMAND_RPC_SETBANS::response& res, epee::json_rpc::error& error_resp); bool on_get_bans(const COMMAND_RPC_GETBANS::request& req, COMMAND_RPC_GETBANS::response& res, epee::json_rpc::error& error_resp); + bool on_flush_txpool(const COMMAND_RPC_FLUSH_TRANSACTION_POOL::request& req, COMMAND_RPC_FLUSH_TRANSACTION_POOL::response& res, epee::json_rpc::error& error_resp); //----------------------- private: diff --git a/src/rpc/core_rpc_server_commands_defs.h b/src/rpc/core_rpc_server_commands_defs.h index 772d1d942..72e399ec4 100644 --- a/src/rpc/core_rpc_server_commands_defs.h +++ b/src/rpc/core_rpc_server_commands_defs.h @@ -965,5 +965,26 @@ namespace cryptonote END_KV_SERIALIZE_MAP() }; }; + + struct COMMAND_RPC_FLUSH_TRANSACTION_POOL + { + struct request + { + std::list txids; + + BEGIN_KV_SERIALIZE_MAP() + KV_SERIALIZE(txids) + END_KV_SERIALIZE_MAP() + }; + + struct response + { + std::string status; + + BEGIN_KV_SERIALIZE_MAP() + KV_SERIALIZE(status) + END_KV_SERIALIZE_MAP() + }; + }; }