fix peer rpc compatibility issue (#548)

every rpc packet should contains descriptor if sent to old version et.
This commit is contained in:
Sijie.Sun
2025-01-06 10:30:56 -05:00
committed by GitHub
parent 34e4e907a9
commit a4419a31fd

View File

@@ -159,7 +159,10 @@ pub fn build_rpc_packet(
let cur_packet = RpcPacket { let cur_packet = RpcPacket {
from_peer, from_peer,
to_peer, to_peer,
descriptor: if cur_offset == 0 { descriptor: if cur_offset == 0
|| compression_info.algo == CompressionAlgoPb::None as i32
{
// old version must have descriptor on every piece
Some(rpc_desc.clone()) Some(rpc_desc.clone())
} else { } else {
None None