This repository was archived by the owner on Feb 18, 2021. It is now read-only.
File tree Expand file tree Collapse file tree 1 file changed +29
-0
lines changed Expand file tree Collapse file tree 1 file changed +29
-0
lines changed Original file line number Diff line number Diff line change @@ -732,24 +732,53 @@ function connectSinglePeer(hostPort, connectInfo) {
732
732
var self = this ;
733
733
734
734
if ( self . peersToPrune [ hostPort ] ) {
735
+
736
+ self . logger . info ( 'SKIPPING PEER CONNECTION: PRUNED' , self . extendLogInfo ( {
737
+ hostPort : hostPort ,
738
+ connectInfo : connectInfo
739
+ } ) ) ;
740
+
735
741
return ;
736
742
}
737
743
738
744
var serviceName = connectInfo . serviceName ;
739
745
var serviceChannel = self . getServiceChannel ( serviceName ) ;
740
746
if ( ! serviceChannel ) {
747
+
748
+ self . logger . info ( 'SKIPPING PEER CONNECTION: NO SERVICE CHANNEL' , self . extendLogInfo ( {
749
+ hostPort : hostPort ,
750
+ connectInfo : connectInfo
751
+ } ) ) ;
752
+
741
753
return ;
742
754
}
743
755
744
756
var peer = serviceChannel . peers . get ( hostPort ) ;
745
757
if ( ! peer ) {
758
+
759
+ self . logger . info ( 'SKIPPING PEER CONNECTION: NO PEER' , self . extendLogInfo ( {
760
+ hostPort : hostPort ,
761
+ connectInfo : connectInfo
762
+ } ) ) ;
763
+
746
764
return ;
747
765
}
748
766
749
767
if ( peer . draining ) {
768
+
769
+ self . logger . info ( 'SKIPPING PEER CONNECTION: PEER DRAINING' , self . extendLogInfo ( {
770
+ hostPort : hostPort ,
771
+ connectInfo : connectInfo
772
+ } ) ) ;
773
+
750
774
return ;
751
775
}
752
776
777
+ self . logger . info ( 'CONNECTING TO PEER' , self . extendLogInfo ( {
778
+ hostPort : hostPort ,
779
+ connectInfo : connectInfo
780
+ } ) ) ;
781
+
753
782
peer . connectTo ( ) ;
754
783
} ;
755
784
You can’t perform that action at this time.
0 commit comments