| 3299 | } |
| 3300 | |
| 3301 | void node_impl::process_block_during_sync( peer_connection* originating_peer, |
| 3302 | const graphene::net::block_message& block_message_to_process, const message_hash_type& message_hash ) |
| 3303 | { |
| 3304 | VERIFY_CORRECT_THREAD(); |
| 3305 | dlog( "received a sync block from peer ${endpoint}", ("endpoint", originating_peer->get_remote_endpoint() ) ); |
| 3306 | |
| 3307 | // add it to the front of _received_sync_items, then process _received_sync_items to try to |
| 3308 | // pass as many messages as possible to the client. |
| 3309 | _new_received_sync_items.push_front( block_message_to_process ); |
| 3310 | trigger_process_backlog_of_sync_blocks(); |
| 3311 | } |
| 3312 | |
| 3313 | void node_impl::process_block_during_normal_operation( peer_connection* originating_peer, |
| 3314 | const graphene::net::block_message& block_message_to_process, |
nothing calls this directly
no test coverage detected