File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change 1
1
#include " CollectorOutput.h"
2
2
3
- #include " internalapi/sensor/collector.pb.h"
4
3
#include " internalapi/sensor/collector_iservice.pb.h"
5
4
6
5
#include " GRPCUtil.h"
@@ -105,7 +104,7 @@ SignalHandler::Result CollectorOutput::SendMsg(const MessageType& msg) {
105
104
void CollectorOutput::EstablishGrpcStream () {
106
105
while (EstablishGrpcStreamSingle ()) {
107
106
}
108
- CLOG (INFO) << " Signal service client terminating." ;
107
+ CLOG (INFO) << " Service client terminating." ;
109
108
}
110
109
111
110
bool CollectorOutput::EstablishGrpcStreamSingle () {
@@ -136,7 +135,10 @@ bool CollectorOutput::EstablishGrpcStreamSingle() {
136
135
}
137
136
138
137
if (success) {
138
+ CLOG (INFO) << " Successfully established GRPC stream." ;
139
139
stream_active_.store (true , std::memory_order_release);
140
+ } else {
141
+ CLOG (WARNING) << " Failed to establish GRPC stream, retrying..." ;
140
142
}
141
143
return true ;
142
144
}
You can’t perform that action at this time.
0 commit comments