mirror of
https://github.com/wassname/ray.git
synced 2026-07-08 10:39:03 +08:00
Make #include consistent (#8666)
Co-authored-by: Mehrdad <noreply@github.com>
This commit is contained in:
@@ -19,7 +19,6 @@
|
||||
#include <boost/bind.hpp>
|
||||
#include <thread>
|
||||
|
||||
#include "../../common/test_util.h"
|
||||
#include "absl/container/flat_hash_map.h"
|
||||
#include "absl/container/flat_hash_set.h"
|
||||
#include "gmock/gmock.h"
|
||||
@@ -32,10 +31,10 @@
|
||||
#include "ray/core_worker/context.h"
|
||||
#include "ray/core_worker/store_provider/memory_store/memory_store.h"
|
||||
#include "ray/core_worker/transport/direct_actor_transport.h"
|
||||
#include "ray/protobuf/core_worker.pb.h"
|
||||
#include "ray/protobuf/gcs.pb.h"
|
||||
#include "ray/raylet/raylet_client.h"
|
||||
#include "ray/util/filesystem.h"
|
||||
#include "src/ray/protobuf/core_worker.pb.h"
|
||||
#include "src/ray/protobuf/gcs.pb.h"
|
||||
|
||||
namespace {
|
||||
|
||||
|
||||
@@ -18,13 +18,13 @@
|
||||
#include <memory>
|
||||
#include <utility>
|
||||
|
||||
#include "src/ray/common/task/task.h"
|
||||
#include "src/ray/common/task/task_util.h"
|
||||
#include "src/ray/common/test_util.h"
|
||||
#include "src/ray/gcs/gcs_server/gcs_actor_manager.h"
|
||||
#include "src/ray/gcs/gcs_server/gcs_actor_scheduler.h"
|
||||
#include "src/ray/gcs/gcs_server/gcs_node_manager.h"
|
||||
#include "src/ray/util/asio_util.h"
|
||||
#include "ray/common/task/task.h"
|
||||
#include "ray/common/task/task_util.h"
|
||||
#include "ray/common/test_util.h"
|
||||
#include "ray/gcs/gcs_server/gcs_actor_manager.h"
|
||||
#include "ray/gcs/gcs_server/gcs_actor_scheduler.h"
|
||||
#include "ray/gcs/gcs_server/gcs_node_manager.h"
|
||||
#include "ray/util/asio_util.h"
|
||||
|
||||
namespace ray {
|
||||
|
||||
|
||||
@@ -19,11 +19,11 @@
|
||||
#include <utility>
|
||||
|
||||
#include "gmock/gmock.h"
|
||||
#include "src/ray/common/task/task.h"
|
||||
#include "src/ray/common/task/task_util.h"
|
||||
#include "src/ray/common/test_util.h"
|
||||
#include "src/ray/protobuf/gcs_service.grpc.pb.h"
|
||||
#include "src/ray/util/asio_util.h"
|
||||
#include "ray/common/task/task.h"
|
||||
#include "ray/common/task/task_util.h"
|
||||
#include "ray/common/test_util.h"
|
||||
#include "ray/protobuf/gcs_service.grpc.pb.h"
|
||||
#include "ray/util/asio_util.h"
|
||||
|
||||
namespace ray {
|
||||
|
||||
|
||||
@@ -16,10 +16,10 @@
|
||||
|
||||
#include <boost/bind.hpp>
|
||||
|
||||
#include "ray/protobuf/core_worker.grpc.pb.h"
|
||||
#include "ray/protobuf/core_worker.pb.h"
|
||||
#include "ray/raylet/format/node_manager_generated.h"
|
||||
#include "ray/raylet/raylet.h"
|
||||
#include "src/ray/protobuf/core_worker.grpc.pb.h"
|
||||
#include "src/ray/protobuf/core_worker.pb.h"
|
||||
|
||||
namespace ray {
|
||||
|
||||
|
||||
@@ -16,9 +16,10 @@
|
||||
#define RAY_RPC_GCS_RPC_CLIENT_H
|
||||
|
||||
#include <unistd.h>
|
||||
#include "src/ray/common/network_util.h"
|
||||
#include "src/ray/protobuf/gcs_service.grpc.pb.h"
|
||||
#include "src/ray/rpc/grpc_client.h"
|
||||
|
||||
#include "ray/common/network_util.h"
|
||||
#include "ray/protobuf/gcs_service.grpc.pb.h"
|
||||
#include "ray/rpc/grpc_client.h"
|
||||
|
||||
namespace ray {
|
||||
namespace rpc {
|
||||
|
||||
@@ -15,10 +15,9 @@
|
||||
#ifndef RAY_RPC_GCS_RPC_SERVER_H
|
||||
#define RAY_RPC_GCS_RPC_SERVER_H
|
||||
|
||||
#include "src/ray/rpc/grpc_server.h"
|
||||
#include "src/ray/rpc/server_call.h"
|
||||
|
||||
#include "src/ray/protobuf/gcs_service.grpc.pb.h"
|
||||
#include "ray/protobuf/gcs_service.grpc.pb.h"
|
||||
#include "ray/rpc/grpc_server.h"
|
||||
#include "ray/rpc/server_call.h"
|
||||
|
||||
namespace ray {
|
||||
namespace rpc {
|
||||
|
||||
@@ -12,9 +12,10 @@
|
||||
// See the License for the specific language governing permissions and
|
||||
// limitations under the License.
|
||||
|
||||
#include "src/ray/rpc/grpc_server.h"
|
||||
#include "ray/rpc/grpc_server.h"
|
||||
|
||||
#include <grpcpp/impl/service_type.h>
|
||||
|
||||
#include <boost/asio/detail/socket_holder.hpp>
|
||||
|
||||
#include "ray/common/ray_config.h"
|
||||
|
||||
@@ -20,10 +20,10 @@
|
||||
#include <thread>
|
||||
|
||||
#include "ray/common/status.h"
|
||||
#include "ray/protobuf/node_manager.grpc.pb.h"
|
||||
#include "ray/protobuf/node_manager.pb.h"
|
||||
#include "ray/rpc/grpc_client.h"
|
||||
#include "ray/util/logging.h"
|
||||
#include "src/ray/protobuf/node_manager.grpc.pb.h"
|
||||
#include "src/ray/protobuf/node_manager.pb.h"
|
||||
|
||||
namespace ray {
|
||||
namespace rpc {
|
||||
|
||||
@@ -15,10 +15,10 @@
|
||||
#ifndef RAY_RPC_NODE_MANAGER_SERVER_H
|
||||
#define RAY_RPC_NODE_MANAGER_SERVER_H
|
||||
|
||||
#include "ray/protobuf/node_manager.grpc.pb.h"
|
||||
#include "ray/protobuf/node_manager.pb.h"
|
||||
#include "ray/rpc/grpc_server.h"
|
||||
#include "ray/rpc/server_call.h"
|
||||
#include "src/ray/protobuf/node_manager.grpc.pb.h"
|
||||
#include "src/ray/protobuf/node_manager.pb.h"
|
||||
|
||||
namespace ray {
|
||||
namespace rpc {
|
||||
|
||||
@@ -15,17 +15,17 @@
|
||||
#ifndef RAY_RPC_OBJECT_MANAGER_CLIENT_H
|
||||
#define RAY_RPC_OBJECT_MANAGER_CLIENT_H
|
||||
|
||||
#include <thread>
|
||||
|
||||
#include <grpcpp/grpcpp.h>
|
||||
#include <grpcpp/resource_quota.h>
|
||||
#include <grpcpp/support/channel_arguments.h>
|
||||
|
||||
#include <thread>
|
||||
|
||||
#include "ray/common/status.h"
|
||||
#include "ray/protobuf/object_manager.grpc.pb.h"
|
||||
#include "ray/protobuf/object_manager.pb.h"
|
||||
#include "ray/rpc/grpc_client.h"
|
||||
#include "ray/util/logging.h"
|
||||
#include "src/ray/protobuf/object_manager.grpc.pb.h"
|
||||
#include "src/ray/protobuf/object_manager.pb.h"
|
||||
#include "src/ray/rpc/grpc_client.h"
|
||||
|
||||
namespace ray {
|
||||
namespace rpc {
|
||||
|
||||
@@ -15,11 +15,10 @@
|
||||
#ifndef RAY_RPC_OBJECT_MANAGER_SERVER_H
|
||||
#define RAY_RPC_OBJECT_MANAGER_SERVER_H
|
||||
|
||||
#include "src/ray/rpc/grpc_server.h"
|
||||
#include "src/ray/rpc/server_call.h"
|
||||
|
||||
#include "src/ray/protobuf/object_manager.grpc.pb.h"
|
||||
#include "src/ray/protobuf/object_manager.pb.h"
|
||||
#include "ray/protobuf/object_manager.grpc.pb.h"
|
||||
#include "ray/protobuf/object_manager.pb.h"
|
||||
#include "ray/rpc/grpc_server.h"
|
||||
#include "ray/rpc/server_call.h"
|
||||
|
||||
namespace ray {
|
||||
namespace rpc {
|
||||
|
||||
@@ -25,10 +25,10 @@
|
||||
#include "absl/base/thread_annotations.h"
|
||||
#include "absl/hash/hash.h"
|
||||
#include "ray/common/status.h"
|
||||
#include "ray/protobuf/core_worker.grpc.pb.h"
|
||||
#include "ray/protobuf/core_worker.pb.h"
|
||||
#include "ray/rpc/grpc_client.h"
|
||||
#include "ray/util/logging.h"
|
||||
#include "src/ray/protobuf/core_worker.grpc.pb.h"
|
||||
#include "src/ray/protobuf/core_worker.pb.h"
|
||||
|
||||
namespace ray {
|
||||
namespace rpc {
|
||||
|
||||
@@ -15,10 +15,10 @@
|
||||
#ifndef RAY_RPC_CORE_WORKER_SERVER_H
|
||||
#define RAY_RPC_CORE_WORKER_SERVER_H
|
||||
|
||||
#include "ray/protobuf/core_worker.grpc.pb.h"
|
||||
#include "ray/protobuf/core_worker.pb.h"
|
||||
#include "ray/rpc/grpc_server.h"
|
||||
#include "ray/rpc/server_call.h"
|
||||
#include "src/ray/protobuf/core_worker.grpc.pb.h"
|
||||
#include "src/ray/protobuf/core_worker.pb.h"
|
||||
|
||||
namespace ray {
|
||||
|
||||
|
||||
Reference in New Issue
Block a user