@@ -98,8 +98,10 @@ func (bc *broadcastClient) try(action func() (interface{}, error)) (interface{},
98
98
if err != nil {
99
99
backoffDuration , retry = bc .shouldRetry (attempt , time .Since (start ))
100
100
if ! retry {
101
+ logger .Warning ("Got error:" , err , "at" , attempt , "attempt. Ceasing to retry" )
101
102
break
102
103
}
104
+ logger .Warning ("Got error:" , err , ",at" , attempt , "attempt. Retrying in" , backoffDuration )
103
105
bc .sleep (backoffDuration )
104
106
continue
105
107
}
@@ -135,11 +137,13 @@ func (bc *broadcastClient) sleep(duration time.Duration) {
135
137
136
138
func (bc * broadcastClient ) connect () error {
137
139
conn , endpoint , err := bc .prod .NewConnection ()
140
+ logger .Debug ("Connected to" , endpoint )
138
141
if err != nil {
139
142
logger .Error ("Failed obtaining connection:" , err )
140
143
return err
141
144
}
142
145
ctx , cf := context .WithCancel (context .Background ())
146
+ logger .Debug ("Establishing gRPC stream with" , endpoint , "..." )
143
147
abc , err := bc .createClient (conn ).Deliver (ctx )
144
148
if err != nil {
145
149
logger .Error ("Connection to " , endpoint , "established but was unable to create gRPC stream:" , err )
@@ -150,13 +154,16 @@ func (bc *broadcastClient) connect() error {
150
154
if err == nil {
151
155
return nil
152
156
}
157
+ logger .Warning ("Failed running post-connection procedures:" , err )
153
158
// If we reached here, lets make sure connection is closed
154
159
// and nullified before we return
155
160
bc .Disconnect ()
156
161
return err
157
162
}
158
163
159
164
func (bc * broadcastClient ) afterConnect (conn * grpc.ClientConn , abc orderer.AtomicBroadcast_DeliverClient , cf context.CancelFunc ) error {
165
+ logger .Debug ("Entering" )
166
+ defer logger .Debug ("Exiting" )
160
167
bc .Lock ()
161
168
bc .conn = & connection {ClientConn : conn , cancel : cf }
162
169
bc .BlocksDeliverer = abc
@@ -194,6 +201,8 @@ func (bc *broadcastClient) shouldStop() bool {
194
201
195
202
// Close makes the client close its connection and shut down
196
203
func (bc * broadcastClient ) Close () {
204
+ logger .Debug ("Entering" )
205
+ defer logger .Debug ("Exiting" )
197
206
bc .Lock ()
198
207
defer bc .Unlock ()
199
208
if bc .shouldStop () {
@@ -209,6 +218,8 @@ func (bc *broadcastClient) Close() {
209
218
210
219
// Disconnect makes the client close the existing connection
211
220
func (bc * broadcastClient ) Disconnect () {
221
+ logger .Debug ("Entering" )
222
+ defer logger .Debug ("Exiting" )
212
223
bc .Lock ()
213
224
defer bc .Unlock ()
214
225
if bc .conn == nil {
0 commit comments