Skip to content

Prevent multiple StreamData RPC calls #43

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
kox13 merged 28 commits into from
Jun 22, 2026
Merged

Prevent multiple StreamData RPC calls #43

Changes from all commits
Commits
Show all changes
28 commits
Select commit Hold shift + click to select a range
4c6e2d3
chore(server): initial structure and grpc dependencies
kox13 Feb 3, 2026
e03f338
chore(server): makefile for generating proto for the server
kox13 Feb 3, 2026
4d7d9b1
chore: updated gitignore
kox13 Mar 16, 2026
2b29bba
chore(server): delete generated folder
kox13 Mar 16, 2026
af624db
feat(server): config file support for the server
kox13 Mar 20, 2026
6466546
feat: example grpc communication between agent and server
kox13 Mar 20, 2026
e6e8b03
feat: async grpc communication
kox13 Mar 22, 2026
bbbbdf5
feat: handling multiple agents
kox13 Mar 26, 2026
1884b97
Merge branch 'devel' into feat/grpc-communication
kox13 Apr 11, 2026
991df71
feat: server logger, corrected paths after project structure refactor
kox13 Apr 12, 2026
577950f
ci: hooks target to symlink pre-commit script to .git/hooks, server g…
kox13 Apr 13, 2026
363cd16
feat(server): grpc message handling
kox13 Apr 13, 2026
6074c23
feat: IMessageHandler interface for the client, queue based writing a…
kox13 May 2, 2026
7dfc639
feat: metric streaming from the client to the server
kox13 May 4, 2026
34c7b21
feat: uuid generation on the server and saving locally on the agent, …
kox13 May 5, 2026
9807576
feat: separate proto types from services, as not every service will n…
kox13 May 8, 2026
06a7621
feat: REST API gateway running on the server with one endpoint for li…
kox13 May 10, 2026
36eb2b9
feat: refactor server architecture
kox13 May 15, 2026
49dad7f
feat: http server, agent - server handshake, api endpoints
kox13 May 17, 2026
a9973fb
merge: merge devel branch
kox13 Jun 5, 2026
81152e7
feat: metrics streaming from agent to server, but not fully working
kox13 Jun 5, 2026
6455120
feat: working agent - server metrics streaming with rest and WS endpo…
kox13 Jun 9, 2026
897d0f7
ci: generate go files from proto before running go vet
kox13 Jun 9, 2026
e4f0506
fix: agent doesn't crash when server is not available, agent now call…
kox13 Jun 12, 2026
2a8413c
fix: mark all child classes as final, so that the cppcheck tools, doe…
kox13 Jun 12, 2026
f27bd31
merge: merge devel branch
kox13 Jun 22, 2026
fd1d222
format: correct format
kox13 Jun 22, 2026
d1e6225
Merge branch 'devel' into feat/grpc-communication
kox13 Jun 22, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 8 additions & 0 deletions sources/agent/src/client/volta_collector_client.cc
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -151,6 +151,14 @@ void Client::StreamData() {
return;
}

if (stream_data_reactor_ != nullptr) {
std::cerr << "StreamData RPC already active, refusing to start another"
<< std::endl;
connect_reactor_->EnqueueWrite(connect_reactor_->CreateMessage(
::volta::MessageType::MESSAGE_ERROR, "StreamData RPC already active"));
return;
}

stream_data_reactor_ = std::make_unique<StreamMetricsReactor>(
stub_.get(), id_, buffer_, [this](const grpc::Status& status) {
if (!status.ok()) {
Expand Down
Loading