diff --git a/src/server/JasmineGraphInstanceService.cpp b/src/server/JasmineGraphInstanceService.cpp index 80aff835e..390a380be 100644 --- a/src/server/JasmineGraphInstanceService.cpp +++ b/src/server/JasmineGraphInstanceService.cpp @@ -3363,8 +3363,9 @@ static void streaming_triangles_command(int connFd, int serverPort, if (mode == "0") { localCount = StreamingTriangles::countLocalStreamingTriangles(incrementalLocalStoreInstance); } else { - localCount = StreamingTriangles::countDynamicLocalTriangles(incrementalLocalStoreInstance, - std::stol(oldLocalRelationCount), std::stol(oldCentralRelationCount)); + localCount = StreamingTriangles::countDynamicLocalTriangles( + incrementalLocalStoreInstance, std::stol(oldLocalRelationCount), + std::stol(oldCentralRelationCount)); } long newLocalRelationCount, newCentralRelationCount, result; @@ -3693,8 +3694,8 @@ static void aggregate_centralstore_triangles_command(int connFd, bool *loop_exit } } -static void aggregate_streaming_centralstore_triangles_command(int connFd, std::map &incrementalLocalStoreMap, +static void aggregate_streaming_centralstore_triangles_command( + int connFd, std::map &incrementalLocalStoreMap, bool *loop_exit_p) { if (!Utils::send_str_wrapper(connFd, JasmineGraphInstanceProtocol::OK)) { *loop_exit_p = true;