hiro/ray
1
0
Fork 0
mirror of https://github.com/vale981/ray synced 2025-03-05 10:01:43 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

LINT changes.

Browse source
This commit is contained in:
sven1977 2021-08-12 13:11:47 +02:00
parent 0090265e8a
commit 88666d39c2
9 changed files with 41 additions and 37 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/ray/gcs/gcs_server/gcs_placement_group_manager.cc
View file

@ -543,8 +543,9 @@ void GcsPlacementGroupManager::WaitPlacementGroup(
}
void GcsPlacementGroupManager::RetryCreatingPlacementGroup() {
execute_after(io_context_, [this] { SchedulePendingPlacementGroups(); },
RayConfig::instance().gcs_create_placement_group_retry_interval_ms());
execute_after(
io_context_, [this] { SchedulePendingPlacementGroups(); },
RayConfig::instance().gcs_create_placement_group_retry_interval_ms());
}
void GcsPlacementGroupManager::OnNodeDead(const NodeID &node_id) {
@ -616,7 +617,8 @@ void GcsPlacementGroupManager::CollectStats() const {
void GcsPlacementGroupManager::Tick() {
UpdatePlacementGroupLoad();
execute_after(io_context_, [this] { Tick(); }, 1000 /* milliseconds */);
execute_after(
io_context_, [this] { Tick(); }, 1000 /* milliseconds */);
}
void GcsPlacementGroupManager::UpdatePlacementGroupLoad() {

1
src/ray/object_manager/chunk_object_reader.cc
View file

@ -13,6 +13,7 @@
// limitations under the License.
#include "ray/object_manager/chunk_object_reader.h"
#include "ray/util/logging.h"
namespace ray {

1
src/ray/object_manager/memory_object_reader.cc
View file

@ -13,6 +13,7 @@
// limitations under the License.
#include "ray/object_manager/memory_object_reader.h"
#include <cstring>
namespace ray {

23
src/ray/object_manager/object_manager.cc
View file

@ -476,17 +476,18 @@ void ObjectManager::PushObjectInternal(const ObjectID &object_id, const NodeID &
[=]() {
// Post to the multithreaded RPC event loop so that data is copied
// off of the main thread.
SendObjectChunk(push_id, object_id, node_id, chunk_id, rpc_client,
[=](const Status &status) {
// Post back to the main event loop because the
// PushManager is thread-safe.
main_service_->post(
[this, node_id, object_id]() {
push_manager_->OnChunkComplete(node_id, object_id);
},
"ObjectManager.Push");
},
std::move(chunk_reader));
SendObjectChunk(
push_id, object_id, node_id, chunk_id, rpc_client,
[=](const Status &status) {
// Post back to the main event loop because the
// PushManager is thread-safe.
main_service_->post(
[this, node_id, object_id]() {
push_manager_->OnChunkComplete(node_id, object_id);
},
"ObjectManager.Push");
},
std::move(chunk_reader));
},
"ObjectManager.Push");
});

9
src/ray/object_manager/plasma/client.cc
View file

@ -19,9 +19,9 @@
#include "ray/object_manager/plasma/client.h"
#include <cstring>
#include <algorithm>
#include <boost/asio.hpp>
#include <cstring>
#include <deque>
#include <mutex>
#include <tuple>
@ -29,8 +29,7 @@
#include <unordered_set>
#include <vector>
#include <boost/asio.hpp>
#include "absl/container/flat_hash_map.h"
#include "ray/common/asio/instrumented_io_context.h"
#include "ray/common/ray_config.h"
#include "ray/object_manager/plasma/connection.h"
@ -38,8 +37,6 @@
#include "ray/object_manager/plasma/protocol.h"
#include "ray/object_manager/plasma/shared_memory.h"
#include "absl/container/flat_hash_map.h"
namespace fb = plasma::flatbuf;
namespace plasma {

8
src/ray/object_manager/plasma/plasma_allocator.cc
View file

@ -15,12 +15,12 @@
// specific language governing permissions and limitations
// under the License.
#include "ray/common/ray_config.h"
#include "ray/util/logging.h"
#include "ray/object_manager/plasma/malloc.h"
#include "ray/object_manager/plasma/plasma_allocator.h"
#include "ray/common/ray_config.h"
#include "ray/object_manager/plasma/malloc.h"
#include "ray/util/logging.h"
namespace plasma {
bool IsOutsideInitialAllocation(void *ptr);

18
src/ray/object_manager/plasma/store.cc
View file

@ -956,12 +956,13 @@ void PlasmaStore::ProcessCreateRequests() {
if (retry_after_ms > 0) {
// Try to process requests later, after space has been made.
create_timer_ = execute_after(io_context_,
[this]() {
create_timer_ = nullptr;
ProcessCreateRequests();
},
retry_after_ms);
create_timer_ = execute_after(
io_context_,
[this]() {
create_timer_ = nullptr;
ProcessCreateRequests();
},
retry_after_ms);
}
}
@ -997,8 +998,9 @@ bool PlasmaStore::IsObjectSpillable(const ObjectID &object_id) {
void PlasmaStore::PrintDebugDump() const {
RAY_LOG(INFO) << GetDebugDump();
stats_timer_ = execute_after(io_context_, [this]() { PrintDebugDump(); },
RayConfig::instance().event_stats_print_interval_ms());
stats_timer_ = execute_after(
io_context_, [this]() { PrintDebugDump(); },
RayConfig::instance().event_stats_print_interval_ms());
}
std::string PlasmaStore::GetDebugDump() const {

7
src/ray/object_manager/test/spilled_object_test.cc
View file

@ -12,16 +12,15 @@
// See the License for the specific language governing permissions and
// limitations under the License.
#include "ray/object_manager/chunk_object_reader.h"
#include "ray/object_manager/memory_object_reader.h"
#include "ray/object_manager/spilled_object_reader.h"
#include <boost/endian/conversion.hpp>
#include <fstream>
#include "absl/strings/str_format.h"
#include "gtest/gtest.h"
#include "ray/common/test_util.h"
#include "ray/object_manager/chunk_object_reader.h"
#include "ray/object_manager/memory_object_reader.h"
#include "ray/object_manager/spilled_object_reader.h"
#include "ray/util/filesystem.h"
namespace ray {

3
src/ray/raylet/scheduling/cluster_task_manager.cc
View file

@ -1,9 +1,10 @@
#include "ray/raylet/scheduling/cluster_task_manager.h"
#include <google/protobuf/map.h>
#include <boost/functional/hash.hpp>
#include <boost/range/join.hpp>
#include "ray/raylet/scheduling/cluster_task_manager.h"
#include "ray/stats/stats.h"
#include "ray/util/logging.h"