diff --git a/common/cpp/include/common/networking.h b/common/cpp/include/common/networking.h
index cafe5f2cec883eddac6e888757d50ea43505aa21..3d740dc91e80e86166e3eaf61ee99072759d334b 100644
--- a/common/cpp/include/common/networking.h
+++ b/common/cpp/include/common/networking.h
@@ -36,11 +36,12 @@ struct GenericRequestHeader {
op_code{i_op_code}, data_id{i_data_id}, data_size{i_data_size} {
strncpy(message, i_message.c_str(), kMaxMessageSize);
}
- GenericRequestHeader(const GenericRequestHeader &header) {op_code = header.op_code, data_id = header.data_id,data_size = header.data_size,
- strncpy(message, header.message, kMaxMessageSize);
+ GenericRequestHeader(const GenericRequestHeader& header) {
+ op_code = header.op_code, data_id = header.data_id, data_size = header.data_size,
+ strncpy(message, header.message, kMaxMessageSize);
}
- Opcode op_code;
+ Opcode op_code;
uint64_t data_id;
uint64_t data_size;
char message[kMaxMessageSize];
diff --git a/common/cpp/include/request/request.h b/common/cpp/include/request/request.h
index d386a479d7cd0b16ba18fa485213144970095120..42f4ea0001373f5c4588ed7a68be3fba46d94bd6 100644
--- a/common/cpp/include/request/request.h
+++ b/common/cpp/include/request/request.h
@@ -8,9 +8,9 @@
namespace asapo {
class GenericRequest {
- public:
+ public:
GenericRequest() = delete;
- GenericRequest(GenericRequestHeader h): header{std::move(h)}{};
+ GenericRequest(GenericRequestHeader h): header{std::move(h)} {};
GenericRequestHeader header;
virtual ~GenericRequest() = default;
};
diff --git a/common/cpp/include/request/request_pool.h b/common/cpp/include/request/request_pool.h
index 4b344846e2c9b4244f2a29abd772161fb3e23e55..b1eb651570b4dbdb4dafb5a71eaf7db1d154977a 100644
--- a/common/cpp/include/request/request_pool.h
+++ b/common/cpp/include/request/request_pool.h
@@ -21,7 +21,7 @@ class RequestPool {
std::unique_lock<std::mutex> lock;
};
public:
- explicit RequestPool(uint8_t n_threads, RequestHandlerFactory* request_handler_factory,AbstractLogger* log);
+ explicit RequestPool(uint8_t n_threads, RequestHandlerFactory* request_handler_factory, AbstractLogger* log);
VIRTUAL Error AddRequest(std::unique_ptr<GenericRequest> request);
~RequestPool();
uint64_t NRequestsInQueue();
diff --git a/common/cpp/src/request/request_pool.cpp b/common/cpp/src/request/request_pool.cpp
index 63f484e6df15e71903bf4b0299c29b4941274199..a7b78c3c9a0cc1f705b50c0b5450f2a49d6c5fd8 100644
--- a/common/cpp/src/request/request_pool.cpp
+++ b/common/cpp/src/request/request_pool.cpp
@@ -4,7 +4,7 @@
namespace asapo {
RequestPool:: RequestPool(uint8_t n_threads,
- RequestHandlerFactory* request_handler_factory,AbstractLogger* log): log__{log},
+ RequestHandlerFactory* request_handler_factory, AbstractLogger* log): log__{log},
request_handler_factory__{request_handler_factory},
threads_{n_threads} {
for(size_t i = 0; i < n_threads; i++) {
diff --git a/common/cpp/unittests/request/test_request.cpp b/common/cpp/unittests/request/test_request.cpp
index c8ed393a803edd952b41c0a767ee07ab7bd96e1e..5e07bdabdba87017e53e26ecc5f81fa8b4a7fbf9 100644
--- a/common/cpp/unittests/request/test_request.cpp
+++ b/common/cpp/unittests/request/test_request.cpp
@@ -41,10 +41,10 @@ TEST(Request, Constructor) {
GenericRequestHeader header{asapo::kOpcodeTransferData, 1, 2, "hello"};
GenericRequest r{header};
- ASSERT_THAT(r.header.data_id,Eq(1));
- ASSERT_THAT(r.header.op_code,Eq(asapo::kOpcodeTransferData));
- ASSERT_THAT(r.header.data_size,Eq(2));
- ASSERT_THAT(r.header.message,testing::StrEq("hello"));
+ ASSERT_THAT(r.header.data_id, Eq(1));
+ ASSERT_THAT(r.header.op_code, Eq(asapo::kOpcodeTransferData));
+ ASSERT_THAT(r.header.data_size, Eq(2));
+ ASSERT_THAT(r.header.message, testing::StrEq("hello"));
}
}
diff --git a/common/cpp/unittests/request/test_request_pool.cpp b/common/cpp/unittests/request/test_request_pool.cpp
index bee5a58e611186187c9fb88d88e7383029e96c0b..8fd7bca7fdf3944b44aa1286f819508f182931ca 100644
--- a/common/cpp/unittests/request/test_request_pool.cpp
+++ b/common/cpp/unittests/request/test_request_pool.cpp
@@ -52,8 +52,8 @@ class MockRequestHandlerFactory : public asapo::RequestHandlerFactory {
};
class TestRequest : public GenericRequest {
- public:
- TestRequest(GenericRequestHeader header):GenericRequest(header){};
+ public:
+ TestRequest(GenericRequestHeader header): GenericRequest(header) {};
};
@@ -63,7 +63,7 @@ class RequestPoolTests : public testing::Test {
NiceMock<asapo::MockLogger> mock_logger;
MockRequestHandlerFactory request_handler_factory{mock_request_handler};
const uint8_t nthreads = 1;
- asapo::RequestPool pool {nthreads, &request_handler_factory,&mock_logger};
+ asapo::RequestPool pool {nthreads, &request_handler_factory, &mock_logger};
std::unique_ptr<GenericRequest> request{new TestRequest{GenericRequestHeader{}}};
void SetUp() override {
}
@@ -79,7 +79,7 @@ TEST(RequestPool, Constructor) {
EXPECT_CALL(mock_logger, Debug(HasSubstr("starting"))).Times(4);
EXPECT_CALL(mock_logger, Debug(HasSubstr("finishing thread"))).Times(4);
- asapo::RequestPool pool{4, &factory,&mock_logger};
+ asapo::RequestPool pool{4, &factory, &mock_logger};
}
TEST_F(RequestPoolTests, AddRequestDoesNotGoFurtherWhenNotReady) {
diff --git a/producer/api/src/producer_impl.cpp b/producer/api/src/producer_impl.cpp
index 20cefa78ef537b2eb98ea6b3e4a2d58defc0d0bf..54cdc409c7420cdbecf88405ab6b997a862324ba 100644
--- a/producer/api/src/producer_impl.cpp
+++ b/producer/api/src/producer_impl.cpp
@@ -26,7 +26,7 @@ ProducerImpl::ProducerImpl(std::string endpoint, uint8_t n_processing_threads, a
request_handler_factory_.reset(new ProducerRequestHandlerFactory{endpoint});
}
- request_pool__.reset(new RequestPool{n_processing_threads, request_handler_factory_.get(),log__});
+ request_pool__.reset(new RequestPool{n_processing_threads, request_handler_factory_.get(), log__});
}
GenericRequestHeader ProducerImpl::GenerateNextSendRequest(uint64_t file_id, uint64_t file_size,
diff --git a/producer/api/src/producer_request.cpp b/producer/api/src/producer_request.cpp
index fb1ea5dcaa638822ef95e049d795e656f9ce29af..3dde2696dd6596dc20bdf7389fb9734887e2d539 100644
--- a/producer/api/src/producer_request.cpp
+++ b/producer/api/src/producer_request.cpp
@@ -12,11 +12,11 @@ Error ProducerRequest::ReadDataFromFileIfNeeded(const IO* io) {
}
ProducerRequest::ProducerRequest(std::string beamtime_id,
- GenericRequestHeader h,
- FileData data,
- std::string original_filepath,
- RequestCallback callback) : GenericRequest(std::move(h)),beamtime_id{beamtime_id},data{std::move(data)},
- original_filepath{std::move(original_filepath)},callback{callback} {
+ GenericRequestHeader h,
+ FileData data,
+ std::string original_filepath,
+ RequestCallback callback) : GenericRequest(std::move(h)), beamtime_id{beamtime_id}, data{std::move(data)},
+ original_filepath{std::move(original_filepath)}, callback{callback} {
}
}
\ No newline at end of file
diff --git a/producer/api/src/producer_request.h b/producer/api/src/producer_request.h
index ac6ea2f21a0872b87ccfb0af0a9818cb3d177d83..d423d7b17ac5e27c60ccc6c2d012414d67a24edc 100644
--- a/producer/api/src/producer_request.h
+++ b/producer/api/src/producer_request.h
@@ -10,8 +10,9 @@
namespace asapo {
class ProducerRequest : public GenericRequest {
- public:
- ProducerRequest(std::string beamtime_id,GenericRequestHeader header,FileData data,std::string original_filepath,RequestCallback callback);
+ public:
+ ProducerRequest(std::string beamtime_id, GenericRequestHeader header, FileData data, std::string original_filepath,
+ RequestCallback callback);
std::string beamtime_id;
FileData data;
std::string original_filepath;
diff --git a/producer/api/src/producer_request_handler_factory.cpp b/producer/api/src/producer_request_handler_factory.cpp
index b920226c5fd69b09b00d38e737f2e788901fec2f..d5d58d498b5a3c0b3094d2dc0b2aec25e170aade 100644
--- a/producer/api/src/producer_request_handler_factory.cpp
+++ b/producer/api/src/producer_request_handler_factory.cpp
@@ -6,7 +6,8 @@
namespace asapo {
-std::unique_ptr<RequestHandler> ProducerRequestHandlerFactory::NewRequestHandler(uint64_t thread_id, uint64_t* shared_counter) {
+std::unique_ptr<RequestHandler> ProducerRequestHandlerFactory::NewRequestHandler(uint64_t thread_id,
+ uint64_t* shared_counter) {
switch (type_) {
case asapo::RequestHandlerType::kTcp:
return std::unique_ptr<RequestHandler> {new RequestHandlerTcp(discovery_service_, thread_id, shared_counter)};
diff --git a/producer/api/src/producer_request_handler_factory.h b/producer/api/src/producer_request_handler_factory.h
index b111143d31c1a5c5b42b7e738bdea7d1314a10ae..f1931b83b681263085b208393c6b5aaa583a0bbd 100644
--- a/producer/api/src/producer_request_handler_factory.h
+++ b/producer/api/src/producer_request_handler_factory.h
@@ -11,9 +11,9 @@ namespace asapo {
class ProducerRequestHandlerFactory : public RequestHandlerFactory {
public:
- ProducerRequestHandlerFactory(ReceiverDiscoveryService* discovery_service);
- ProducerRequestHandlerFactory(std::string destination_folder);
- VIRTUAL std::unique_ptr<RequestHandler> NewRequestHandler(uint64_t thread_id, uint64_t* shared_counter) override;
+ ProducerRequestHandlerFactory(ReceiverDiscoveryService* discovery_service);
+ ProducerRequestHandlerFactory(std::string destination_folder);
+ VIRTUAL std::unique_ptr<RequestHandler> NewRequestHandler(uint64_t thread_id, uint64_t* shared_counter) override;
private:
RequestHandlerType type_;
ReceiverDiscoveryService* discovery_service_{nullptr};
diff --git a/producer/api/unittests/mocking.h b/producer/api/unittests/mocking.h
index dc81bfe58ac832883f7e9d94296b71477c585e83..e009cd0945d6817f702f879a4bd3266778e90330 100644
--- a/producer/api/unittests/mocking.h
+++ b/producer/api/unittests/mocking.h
@@ -25,7 +25,7 @@ class MockDiscoveryService : public asapo::ReceiverDiscoveryService {
class MockRequestPull : public RequestPool {
public:
MockRequestPull(RequestHandlerFactory* request_handler_factory, AbstractLogger* log) :
- RequestPool{1, request_handler_factory,log} {};
+ RequestPool{1, request_handler_factory, log} {};
asapo::Error AddRequest(std::unique_ptr<asapo::GenericRequest> request) override {
if (request == nullptr) {
return asapo::Error{AddRequest_t(nullptr)};
diff --git a/producer/api/unittests/test_producer_impl.cpp b/producer/api/unittests/test_producer_impl.cpp
index 6152a5efd2395e2e7872a9216e07f0a98ffab21b..ee16aa05d34197d2ed7c05196bb950baddeb21de 100644
--- a/producer/api/unittests/test_producer_impl.cpp
+++ b/producer/api/unittests/test_producer_impl.cpp
@@ -51,7 +51,7 @@ class ProducerImplTests : public testing::Test {
testing::NiceMock<MockDiscoveryService> service;
asapo::ProducerRequestHandlerFactory factory{&service};
testing::NiceMock<asapo::MockLogger> mock_logger;
- testing::NiceMock<MockRequestPull> mock_pull{&factory,&mock_logger};
+ testing::NiceMock<MockRequestPull> mock_pull{&factory, &mock_logger};
asapo::ProducerImpl producer{"", 1, asapo::RequestHandlerType::kTcp};
void SetUp() override {
producer.log__ = &mock_logger;
@@ -94,7 +94,7 @@ TEST_F(ProducerImplTests, OKSendingSendDataRequest) {
producer.SetBeamtimeId(expected_beamtimeid);
ProducerRequest request{"", asapo::GenericRequestHeader{asapo::kOpcodeTransferData, expected_id, expected_size, expected_name},
- nullptr, "", nullptr};
+ nullptr, "", nullptr};
EXPECT_CALL(mock_pull, AddRequest_t(M_CheckSendDataRequest(asapo::kOpcodeTransferData,
expected_beamtimeid, expected_id, expected_size, expected_name))).WillOnce(Return(
@@ -114,7 +114,7 @@ TEST_F(ProducerImplTests, OKSendingSendFileRequest) {
producer.SetBeamtimeId(expected_beamtimeid);
ProducerRequest request{"", asapo::GenericRequestHeader{asapo::kOpcodeTransferData, expected_id, 0, expected_name},
- nullptr, "", nullptr};
+ nullptr, "", nullptr};
EXPECT_CALL(mock_pull, AddRequest_t(M_CheckSendDataRequest(asapo::kOpcodeTransferData,
expected_beamtimeid, expected_id, 0, expected_name))).WillOnce(Return(