15243739334

Committed 26 May 2025 12:43AM UTC coverage: 65.724% (-8.9%) from 74.584%

Build # 15243739334

Build Type

push

github

Committed by

web-flow

Commit Message

Fix mega bug with protobuf-parser and sending wrapper. (#57)

* fix mega buf

* comment tests

Run Details

129 of 282 branches covered (45.74%)

Branch coverage included in aggregate %.

8 of 44 new or added lines in 4 files covered. (18.18%)

89 existing lines in 3 files now uncovered.

1196 of 1734 relevant lines covered (68.97%)

8.68 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/dasboot/controller/controller.cpp

1	#include <dasboot/controller/controller.hpp>
2
3	namespace NController {
4
NEW 5	void TController::Run(const NMessages::TRunOptions& runOptions) {	×
UNCOV 6	std::string message;	×
NEW 7	NMessages::TOptionsWrapper optionsWrapper;	×
NEW 8	optionsWrapper.mutable_run_options()->CopyFrom(runOptions);	×
NEW 9	optionsWrapper.SerializeToString(&message);	×
UNCOV 10	StartConnection();	×
UNCOV 11	WriteToDaemon(message);	×
UNCOV 12	}	×
13
NEW 14	void TController::Build(const NMessages::TBuildOptions& buildOptions) {	×
UNCOV 15	std::string message;	×
NEW 16	NMessages::TOptionsWrapper optionsWrapper;	×
NEW 17	optionsWrapper.mutable_build_options()->CopyFrom(buildOptions);	×
NEW 18	optionsWrapper.SerializeToString(&message);	×
UNCOV 19	StartConnection();	×
UNCOV 20	WriteToDaemon(message);	×
UNCOV 21	}	×
22
NEW 23	void TController::Start(const NMessages::TStartOptions& startOptions) {	×
UNCOV 24	std::string message;	×
NEW 25	NMessages::TOptionsWrapper optionsWrapper;	×
NEW 26	optionsWrapper.mutable_start_options()->CopyFrom(startOptions);	×
NEW 27	optionsWrapper.SerializeToString(&message);	×
UNCOV 28	StartConnection();	×
UNCOV 29	WriteToDaemon(message);	×
UNCOV 30	}	×
31
NEW 32	void TController::Stop(const NMessages::TStopOptions& stopOptions) {	×
UNCOV 33	std::string message;	×
NEW 34	NMessages::TOptionsWrapper optionsWrapper;	×
NEW 35	optionsWrapper.mutable_stop_options()->CopyFrom(stopOptions);	×
NEW 36	optionsWrapper.SerializeToString(&message);	×
UNCOV 37	StartConnection();	×
UNCOV 38	WriteToDaemon(message);	×
UNCOV 39	}	×
40
NEW 41	void TController::Ps(const NMessages::TPsOptions& psOptions) {	×
UNCOV 42	std::string message;	×
NEW 43	NMessages::TOptionsWrapper optionsWrapper;	×
NEW 44	optionsWrapper.mutable_ps_options()->CopyFrom(psOptions);	×
NEW 45	optionsWrapper.SerializeToString(&message);	×
UNCOV 46	StartConnection();	×
UNCOV 47	WriteToDaemon(message);	×
UNCOV 48	}	×
49
NEW 50	void TController::Exec(const NMessages::TExecOptions& execOptions) {	×
UNCOV 51	std::string message;	×
NEW 52	NMessages::TOptionsWrapper optionsWrapper;	×
NEW 53	optionsWrapper.mutable_exec_options()->CopyFrom(execOptions);	×
NEW 54	optionsWrapper.SerializeToString(&message);	×
UNCOV 55	StartConnection();	×
UNCOV 56	WriteToDaemon(message);	×
UNCOV 57	}	×
58
NEW 59	void TController::Rm(const NMessages::TRmOptions& rmOptions) {	×
UNCOV 60	std::string message;	×
NEW 61	NMessages::TOptionsWrapper optionsWrapper;	×
NEW 62	optionsWrapper.mutable_rm_options()->CopyFrom(rmOptions);	×
NEW 63	optionsWrapper.SerializeToString(&message);	×
UNCOV 64	StartConnection();	×
UNCOV 65	WriteToDaemon(message);	×
UNCOV 66	}	×
67
68
69	TController::TController(const std::string& address)
NEW 70	: Context(1)	×
NEW 71	, Socket(Context, ZMQ_REQ)	×
NEW 72	, Address(address)	×
NEW 73	{	×
NEW 74	}	×
75
76
UNCOV 77	void TController::StartConnection() {	×
NEW 78	Socket.connect(Address);	×
UNCOV 79	}	×
80
UNCOV 81	void TController::WriteToDaemon(std::string& message) {	×
UNCOV 82	Socket.send(zmq::buffer(message), zmq::send_flags::none);	×
UNCOV 83	}	×
84
85	std::string TController::ReadFromDaemon() {	×
86	zmq::message_t message;	×
87	auto result = Socket.recv(message);	×
88	if (!result) {	×
89	throw std::runtime_error("Failed to receive message");	×
90	return "";	×
91	}	×
92	return std::string(static_cast<char*>(message.data()), message.size());	×
93	}	×
94
95
96	} // namespace NController

KittensBasket / dasboot / 15243739334

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous