D4590.1767366498.diff
No OneTemporary
Actions

Size

1 KB

Referenced Files

None

Subscribers

None

D4590.1767366498.diff
View Options

	diff --git a/services/blob/src/BlobServiceImpl.cpp b/services/blob/src/BlobServiceImpl.cpp
	--- a/services/blob/src/BlobServiceImpl.cpp
	+++ b/services/blob/src/BlobServiceImpl.cpp
	@@ -9,6 +9,8 @@
	#include "GetReactor.h"
	#include "PutReactor.h"

	+#include <glog/logging.h>
	+
	#include <iostream>
	#include <memory>

	@@ -90,7 +92,7 @@
	database::DatabaseManager::getInstance().removeBlobItem(blobHash);
	}
	} catch (std::runtime_error &e) {
	- std::cout << "error: " << e.what() << std::endl;
	+ LOG(ERROR) << e.what();
	status = grpc::Status(grpc::StatusCode::INTERNAL, e.what());
	}
	auto *reactor = context->DefaultReactor();
	diff --git a/services/blob/src/server.cpp b/services/blob/src/server.cpp
	--- a/services/blob/src/server.cpp
	+++ b/services/blob/src/server.cpp
	@@ -1,6 +1,9 @@
	#include "BlobServiceImpl.h"

	+#include "GlobalTools.h"
	+
	#include <grpcpp/grpcpp.h>
	+#include <glog/logging.h>

	#include <iostream>
	#include <memory>
	@@ -18,7 +21,7 @@
	builder.AddListeningPort(server_address, grpc::InsecureServerCredentials());
	builder.RegisterService(&blobService);
	std::unique_ptr<grpc::Server> server(builder.BuildAndStart());
	- std::cout << "Server listening" << std::endl;
	+ LOG(INFO) << "Server listening";

	server->Wait();
	}
	@@ -27,6 +30,7 @@
	} // namespace comm

	int main(int argc, char **argv) {
	+ comm::network::tools::InitLogging("blob");
	comm::network::RunServer();

	return 0;