File tree 2 files changed +3
-3
lines changed
2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -144,6 +144,7 @@ void AddEdgesProcessor::doProcess(const cpp2::AddEdgesRequest& req) {
144
144
if (code != nebula::cpp2::ErrorCode::SUCCEEDED) {
145
145
handleAsync (spaceId_, partId, code);
146
146
} else {
147
+ stats::StatsManager::addValue (kNumEdgesInserted , data.size ());
147
148
if (consistOp_) {
148
149
auto batchHolder = std::make_unique<kvstore::BatchHolder>();
149
150
(*consistOp_)(*batchHolder, &data);
@@ -155,7 +156,6 @@ void AddEdgesProcessor::doProcess(const cpp2::AddEdgesRequest& req) {
155
156
});
156
157
} else {
157
158
doPut (spaceId_, partId, std::move (data));
158
- stats::StatsManager::addValue (kNumEdgesInserted , data.size ());
159
159
}
160
160
}
161
161
}
Original file line number Diff line number Diff line change @@ -143,8 +143,8 @@ void AddVerticesProcessor::doProcess(const cpp2::AddVerticesRequest& req) {
143
143
if (code != nebula::cpp2::ErrorCode::SUCCEEDED) {
144
144
handleAsync (spaceId_, partId, code);
145
145
} else {
146
- doPut (spaceId_, partId, std::move (data));
147
146
stats::StatsManager::addValue (kNumVerticesInserted , data.size ());
147
+ doPut (spaceId_, partId, std::move (data));
148
148
}
149
149
}
150
150
}
@@ -213,7 +213,7 @@ void AddVerticesProcessor::doProcessWithIndex(const cpp2::AddVerticesRequest& re
213
213
if (code != nebula::cpp2::ErrorCode::SUCCEEDED) {
214
214
handleAsync (spaceId_, partId, code);
215
215
} else {
216
- stats::StatsManager::addValue (kNumVerticesInserted , verticeData .size ());
216
+ stats::StatsManager::addValue (kNumVerticesInserted , tags .size ());
217
217
auto atomicOp = [=, tags = std::move (tags), vertices = std::move (verticeData)]() mutable {
218
218
return addVerticesWithIndex (partId, tags, vertices);
219
219
};
You can’t perform that action at this time.
0 commit comments