File tree Expand file tree Collapse file tree 1 file changed +0
-14
lines changed
server/src/main/java/org/opensearch/cluster/coordination Expand file tree Collapse file tree 1 file changed +0
-14
lines changed Original file line number Diff line number Diff line change @@ -499,21 +499,7 @@ public void onFailure(Exception e) {
499
499
} else {
500
500
responseActionListener = listener ;
501
501
}
502
- <<<<<<< HEAD
503
502
sendClusterState (destination , responseActionListener );
504
- =======
505
- // TODO Decide to send remote state before starting publication by checking remote publication on all nodes
506
- if (sendRemoteState && destination .isRemoteStatePublicationEnabled ()) {
507
- logger .trace ("sending remote cluster state version [{}] to [{}]" , newState .version (), destination );
508
- sendRemoteClusterState (destination , publishRequest .getAcceptedState (), responseActionListener );
509
- } else if (sendFullVersion || previousState .nodes ().nodeExists (destination ) == false ) {
510
- logger .trace ("sending full cluster state version [{}] to [{}]" , newState .version (), destination );
511
- sendFullClusterState (destination , responseActionListener );
512
- } else {
513
- logger .trace ("sending cluster state diff for version [{}] to [{}]" , newState .version (), destination );
514
- sendClusterStateDiff (destination , responseActionListener );
515
- }
516
- >>>>>>> f0cf40ce03f (cleanup unused code and remove added log lines )
517
503
}
518
504
519
505
public void sendApplyCommit (
You can’t perform that action at this time.
0 commit comments