mirror of
https://github.com/cubefs/cubefs.git
synced 2026-08-02 02:00:56 +00:00
fix(raft): should check header of snapshot request
with: #1000100262 Signed-off-by: JasonHu520 <huzongchao@oppo.com>
This commit is contained in:
parent
6506cab835
commit
f2bd5dc417
@ -177,7 +177,7 @@ func (t *Transport) RaftSnapshot(resp rpc2.ResponseWriter, req *rpc2.Request) er
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
if rs == nil {
|
||||
if rs.Header == nil {
|
||||
return stream.Send(&RaftSnapshotResponse{
|
||||
Status: RaftSnapshotResponse_ERROR,
|
||||
Message: "snapshot sender error: no header in the first snapshot request",
|
||||
|
||||
Loading…
Reference in New Issue
Block a user