未验证 提交 ab8b6297 编写于 作者: R RJ 提交者: GitHub

Merge branch 'master' into master

...@@ -26,7 +26,7 @@ extern "C" { ...@@ -26,7 +26,7 @@ extern "C" {
void set_privileged( account_name account, bool is_priv ); void set_privileged( account_name account, bool is_priv );
void set_blockchain_parameters_packed(char* data, uint32_t datalen); void set_blockchain_parameters_packed(char* data, uint32_t datalen);
/** /**
* Retrieve the blolckchain parameters * Retrieve the blolckchain parameters
......
...@@ -453,20 +453,19 @@ namespace eosio { ...@@ -453,20 +453,19 @@ namespace eosio {
}; };
deque<queued_write> write_queue; deque<queued_write> write_queue;
deque<queued_write> out_queue; deque<queued_write> out_queue;
fc::sha256 node_id; fc::sha256 node_id;
handshake_message last_handshake_recv; handshake_message last_handshake_recv;
handshake_message last_handshake_sent; handshake_message last_handshake_sent;
int16_t sent_handshake_count; int16_t sent_handshake_count = 0;
bool connecting; bool connecting = false;
bool syncing; bool syncing = false;
uint16_t protocol_version; uint16_t protocol_version = 0;
string peer_addr; string peer_addr;
unique_ptr<boost::asio::steady_timer> response_expected; unique_ptr<boost::asio::steady_timer> response_expected;
optional<request_message> pending_fetch; optional<request_message> pending_fetch;
go_away_reason no_retry; go_away_reason no_retry = no_reason;
block_id_type fork_head; block_id_type fork_head;
uint32_t fork_head_num; uint32_t fork_head_num = 0;
optional<request_message> last_req; optional<request_message> last_req;
connection_status get_status()const { connection_status get_status()const {
...@@ -947,12 +946,12 @@ namespace eosio { ...@@ -947,12 +946,12 @@ namespace eosio {
bool trigger_send, bool trigger_send,
std::function<void(boost::system::error_code, std::size_t)> callback) { std::function<void(boost::system::error_code, std::size_t)> callback) {
write_queue.push_back({buff, callback}); write_queue.push_back({buff, callback});
if(write_queue.size() == 1 && trigger_send) if(out_queue.empty() && trigger_send)
do_queue_write(); do_queue_write();
} }
void connection::do_queue_write() { void connection::do_queue_write() {
if(write_queue.empty()) if(write_queue.empty() || !out_queue.empty())
return; return;
connection_wptr c(shared_from_this()); connection_wptr c(shared_from_this());
if(!socket->is_open()) { if(!socket->is_open()) {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册