mirror of
https://github.com/wassname/ray.git
synced 2026-06-29 03:04:28 +08:00
Initialize some variables in constructor instead of header file. (#3617)
* Initialize some variables in constructor instead of header file
This commit is contained in:
committed by
Alexey Tumanov
parent
bada42c334
commit
ddd4c842f1
@@ -14,7 +14,11 @@ namespace ray {
|
||||
|
||||
ObjectStoreNotificationManager::ObjectStoreNotificationManager(
|
||||
boost::asio::io_service &io_service, const std::string &store_socket_name)
|
||||
: store_client_(), socket_(io_service) {
|
||||
: store_client_(),
|
||||
length_(0),
|
||||
num_adds_processed_(0),
|
||||
num_removes_processed_(0),
|
||||
socket_(io_service) {
|
||||
ARROW_CHECK_OK(store_client_.Connect(store_socket_name.c_str()));
|
||||
|
||||
ARROW_CHECK_OK(store_client_.Subscribe(&c_socket_));
|
||||
|
||||
@@ -67,9 +67,9 @@ class ObjectStoreNotificationManager {
|
||||
|
||||
plasma::PlasmaClient store_client_;
|
||||
int c_socket_;
|
||||
int64_t length_ = 0;
|
||||
int64_t num_adds_processed_ = 0;
|
||||
int64_t num_removes_processed_ = 0;
|
||||
int64_t length_;
|
||||
int64_t num_adds_processed_;
|
||||
int64_t num_removes_processed_;
|
||||
std::vector<uint8_t> notification_;
|
||||
boost::asio::local::stream_protocol::socket socket_;
|
||||
};
|
||||
|
||||
Reference in New Issue
Block a user