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"
@@ -104,7 +103,7 @@ SignalHandler::Result CollectorOutput::SendMsg(const MessageType& msg) {
104
103
void CollectorOutput::EstablishGrpcStream () {
105
104
while (EstablishGrpcStreamSingle ()) {
106
105
}
107
- CLOG (INFO) << " Signal service client terminating." ;
106
+ CLOG (INFO) << " Service client terminating." ;
108
107
}
109
108
110
109
bool CollectorOutput::EstablishGrpcStreamSingle () {
@@ -135,7 +134,10 @@ bool CollectorOutput::EstablishGrpcStreamSingle() {
135
134
}
136
135
137
136
if (success) {
137
+ CLOG (INFO) << " Successfully established GRPC stream." ;
138
138
stream_active_.store (true , std::memory_order_release);
139
+ } else {
140
+ CLOG (WARNING) << " Failed to establish GRPC stream, retrying..." ;
139
141
}
140
142
return true ;
141
143
}
You can’t perform that action at this time.
0 commit comments