File tree Expand file tree Collapse file tree 1 file changed +10
-6
lines changed
src/meta/service/src/meta_service Expand file tree Collapse file tree 1 file changed +10
-6
lines changed Original file line number Diff line number Diff line change @@ -884,12 +884,16 @@ impl MetaNode {
884
884
let as_leader_res = self . as_leader ( ) . await ;
885
885
debug ! ( "as_leader: is_err: {}" , as_leader_res. is_err( ) ) ;
886
886
887
- let leader = as_leader_res?;
888
- let res = leader. handle_forwardable_req ( req. clone ( ) ) . await ;
889
-
890
- let op_err = match res {
891
- Ok ( x) => return Ok ( x) ,
892
- Err ( e) => e,
887
+ // Handle the request locally or return a ForwardToLeader error
888
+ let op_err = match as_leader_res {
889
+ Ok ( leader) => {
890
+ let res = leader. handle_forwardable_req ( req. clone ( ) ) . await ;
891
+ match res {
892
+ Ok ( x) => return Ok ( x) ,
893
+ Err ( e) => e,
894
+ }
895
+ }
896
+ Err ( e) => MetaOperationError :: ForwardToLeader ( e) ,
893
897
} ;
894
898
895
899
// If needs to forward, deal with it. Otherwise return the unhandlable error.
You can’t perform that action at this time.
0 commit comments