fix bad merge - missing support for header msg type (#690)
This commit is contained in:
+13
-1
@@ -88,7 +88,7 @@ impl MessageHandler for Protocol {
|
||||
adapter.block_received(b, self.addr);
|
||||
Ok(None)
|
||||
}
|
||||
|
||||
|
||||
|
||||
Type::GetCompactBlock => {
|
||||
let h: Hash = msg.body()?;
|
||||
@@ -141,6 +141,18 @@ impl MessageHandler for Protocol {
|
||||
return Ok(Some((header_bytes, Type::Headers)));
|
||||
}
|
||||
|
||||
// "header first" block propagation - if we have not yet seen this block
|
||||
// we can go request it from some of our peers
|
||||
Type::Header => {
|
||||
let header: core::BlockHeader = msg.body()?;
|
||||
|
||||
adapter.header_received(header, self.addr);
|
||||
|
||||
// we do not return a hash here as we never request a single header
|
||||
// a header will always arrive unsolicited
|
||||
Ok(None)
|
||||
}
|
||||
|
||||
Type::Headers => {
|
||||
let headers: Headers = msg.body()?;
|
||||
adapter.headers_received(headers.headers, self.addr);
|
||||
|
||||
Reference in New Issue
Block a user