[lib] fix generating DM messages to peers
ClosedPublic
Actions

	#pragma once			#pragma once

	#include <grpcpp/grpcpp.h>			#include <grpcpp/grpcpp.h>

				#include <mutex>

	namespace comm {			namespace comm {
	namespace network {			namespace network {
	namespace reactor {			namespace reactor {

	enum class ReactorState {			enum class ReactorState {
	NONE = 0,			NONE = 0,
	RUNNING = 1,			RUNNING = 1,
	TERMINATED = 2,			TERMINATED = 2,
	DONE = 3,			DONE = 3,
	};			};

	class BaseReactor {			class BaseReactor {
				private:
				grpc::Status status = grpc::Status::OK;
				std::mutex statusAccessMutex;

	protected:			protected:
	ReactorState state = ReactorState::NONE;			ReactorState state = ReactorState::NONE;

	public:			public:
				grpc::Status getStatus() {
				const std::unique_lock<std::mutex> lock(this->statusAccessMutex);
				return this->status;
				}
				void setStatus(const grpc::Status &status) {
				const std::unique_lock<std::mutex> lock(this->statusAccessMutex);
				this->status = status;
				}

	ReactorState getState() const {			ReactorState getState() const {
	return this->state;			return this->state;
	}			}

	virtual void terminate(const grpc::Status &status){};			virtual void terminate(const grpc::Status &status){};
	virtual void validate(){};			virtual void validate(){};
	virtual void doneCallback(){};			virtual void doneCallback(){};
	virtual void terminateCallback(){};			virtual void terminateCallback(){};
	};			};

	} // namespace reactor			} // namespace reactor
	} // namespace network			} // namespace network
	} // namespace comm			} // namespace comm

[lib] fix generating DM messages to peersClosedPublicActions