1- From 0a45b262883da74db4f411478b175240a0cc1b92 Mon Sep 17 00:00:00 2001
1+ From f77554e0a65b7ef7573c65c562796f6661e4f40c Mon Sep 17 00:00:00 2001
22From: Austin Morton <austin.morton@aquatic.com>
3- Date: Fri, 29 Aug 2025 00 :12:05 +0300
4- Subject: [PATCH 05/11 ] Vendor grpc 1.67.1
3+ Date: Wed, 15 Oct 2025 16 :12:56 +0000
4+ Subject: [PATCH 4/8 ] Vendor grpc 1.67.1
55
6+ Co-authored-by: Lonnie Liu <lonnie@anyscale.com>
67---
78 bazel/ray_deps_setup.bzl | 28 ++++++++-----------
89 .../task_event_buffer_export_event_test.cc | 2 +-
9- .../tests/gcs_actor_manager_test.cc | 14 +++++-----
10- src/ray/raylet_client/raylet_client.cc | 2 +-
10+ src/ray/gcs/tests/gcs_actor_manager_test.cc | 14 +++++-----
1111 src/ray/rpc/server_call.h | 2 +-
1212 src/ray/util/event.cc | 2 +-
13+ .../grpc-configurable-thread-count.patch | 11 ++++----
1314 thirdparty/patches/grpc-zlib-fdopen.patch | 4 +--
14- 7 files changed, 25 insertions(+), 29 deletions(-)
15+ 7 files changed, 29 insertions(+), 34 deletions(-)
1516
1617diff --git a/bazel/ray_deps_setup.bzl b/bazel/ray_deps_setup.bzl
17- index 5ece022cdb..ce365f9a34 100644
18+ index b10370d052..5b8d351a97 100644
1819--- a/bazel/ray_deps_setup.bzl
1920+++ b/bazel/ray_deps_setup.bzl
2021@@ -91,15 +91,11 @@ def ray_deps_setup():
@@ -48,9 +49,9 @@ index 5ece022cdb..ce365f9a34 100644
4849- "https://github.com/abseil/abseil-cpp/archive/refs/tags/20230802.1.tar.gz",
4950+ "https://github.com/abseil/abseil-cpp/archive/refs/tags/20240722.0.tar.gz",
5051 ],
51- )
52-
53- @@ -274 ,8 +270 ,8 @@ def ray_deps_setup():
52+ patches = [
53+ # TODO (israbbani): #55430 Separate the compiler flags and remove this patch
54+ @@ -278 ,8 +274 ,8 @@ def ray_deps_setup():
5455 auto_http_archive(
5556 name = "com_github_grpc_grpc",
5657 # NOTE: If you update this, also update @boringssl's hash.
@@ -61,7 +62,7 @@ index 5ece022cdb..ce365f9a34 100644
6162 patches = [
6263 "@io_ray//thirdparty/patches:grpc-cython-copts.patch",
6364 "@io_ray//thirdparty/patches:grpc-zlib-fdopen.patch",
64- @@ -319 ,13 +315 ,13 @@ def ray_deps_setup():
65+ @@ -323 ,13 +319 ,13 @@ def ray_deps_setup():
6566 http_archive(
6667 # This rule is used by @com_github_grpc_grpc, and using a GitHub mirror
6768 # provides a deterministic archive hash for caching. Explanation here:
@@ -80,10 +81,10 @@ index 5ece022cdb..ce365f9a34 100644
8081 )
8182
8283diff --git a/src/ray/core_worker/tests/task_event_buffer_export_event_test.cc b/src/ray/core_worker/tests/task_event_buffer_export_event_test.cc
83- index 9e6345bd95..99f6f0cafb 100644
84+ index cf2e6e7203..aa1c53e9f0 100644
8485--- a/src/ray/core_worker/tests/task_event_buffer_export_event_test.cc
8586+++ b/src/ray/core_worker/tests/task_event_buffer_export_event_test.cc
86- @@ -153 ,7 +153 ,7 @@ TEST_F(TaskEventTestWriteExport, TestWriteTaskExportEvents) {
87+ @@ -150 ,7 +150 ,7 @@ TEST_F(TaskEventTestWriteExport, TestWriteTaskExportEvents) {
8788 auto task_ids = GenTaskIDs(num_events);
8889 google::protobuf::util::JsonPrintOptions options;
8990 options.preserve_proto_field_names = true;
@@ -92,11 +93,11 @@ index 9e6345bd95..99f6f0cafb 100644
9293
9394 std::vector<SourceTypeVariant> source_types = {
9495 rpc::ExportEvent_SourceType::ExportEvent_SourceType_EXPORT_TASK};
95- diff --git a/src/ray/gcs/gcs_server/ tests/gcs_actor_manager_test.cc b/src/ray/gcs/gcs_server /tests/gcs_actor_manager_test.cc
96- index 3030856998..2b11a89296 100644
97- --- a/src/ray/gcs/gcs_server/ tests/gcs_actor_manager_test.cc
98- +++ b/src/ray/gcs/gcs_server/ tests/gcs_actor_manager_test.cc
99- @@ -1199 ,7 +1199 ,7 @@ TEST_F(GcsActorManagerTest, TestGetAllActorInfoFilters) {
96+ diff --git a/src/ray/gcs/tests/gcs_actor_manager_test.cc b/src/ray/gcs/tests/gcs_actor_manager_test.cc
97+ index fe38880f7c..1c488d18a7 100644
98+ --- a/src/ray/gcs/tests/gcs_actor_manager_test.cc
99+ +++ b/src/ray/gcs/tests/gcs_actor_manager_test.cc
100+ @@ -1230 ,7 +1230 ,7 @@ TEST_F(GcsActorManagerTest, TestGetAllActorInfoFilters) {
100101 request.mutable_filters()->set_actor_id(actor->GetActorID().Binary());
101102
102103 auto &reply =
@@ -105,7 +106,7 @@ index 3030856998..2b11a89296 100644
105106 gcs_actor_manager_->HandleGetAllActorInfo(request, &reply, callback);
106107 ASSERT_EQ(reply.actor_table_data().size(), 1);
107108 ASSERT_EQ(reply.total(), 1 + num_other_actors);
108- @@ -1212 ,7 +1212 ,7 @@ TEST_F(GcsActorManagerTest, TestGetAllActorInfoFilters) {
109+ @@ -1243 ,7 +1243 ,7 @@ TEST_F(GcsActorManagerTest, TestGetAllActorInfoFilters) {
109110 request.mutable_filters()->set_job_id(job_id.Binary());
110111
111112 auto &reply =
@@ -114,7 +115,7 @@ index 3030856998..2b11a89296 100644
114115 gcs_actor_manager_->HandleGetAllActorInfo(request, &reply, callback);
115116 ASSERT_EQ(reply.actor_table_data().size(), 1);
116117 ASSERT_EQ(reply.num_filtered(), num_other_actors);
117- @@ -1224 ,7 +1224 ,7 @@ TEST_F(GcsActorManagerTest, TestGetAllActorInfoFilters) {
118+ @@ -1255 ,7 +1255 ,7 @@ TEST_F(GcsActorManagerTest, TestGetAllActorInfoFilters) {
118119 request.mutable_filters()->set_state(rpc::ActorTableData::ALIVE);
119120
120121 auto &reply =
@@ -123,7 +124,7 @@ index 3030856998..2b11a89296 100644
123124 gcs_actor_manager_->HandleGetAllActorInfo(request, &reply, callback);
124125 ASSERT_EQ(reply.actor_table_data().size(), 1);
125126 ASSERT_EQ(reply.num_filtered(), num_other_actors);
126- @@ -1237 ,7 +1237 ,7 @@ TEST_F(GcsActorManagerTest, TestGetAllActorInfoFilters) {
127+ @@ -1268 ,7 +1268 ,7 @@ TEST_F(GcsActorManagerTest, TestGetAllActorInfoFilters) {
127128 request.mutable_filters()->set_job_id(job_id.Binary());
128129
129130 auto &reply =
@@ -132,7 +133,7 @@ index 3030856998..2b11a89296 100644
132133 gcs_actor_manager_->HandleGetAllActorInfo(request, &reply, callback);
133134 ASSERT_EQ(reply.actor_table_data().size(), 1);
134135 ASSERT_EQ(reply.num_filtered(), num_other_actors);
135- @@ -1248 ,7 +1248 ,7 @@ TEST_F(GcsActorManagerTest, TestGetAllActorInfoFilters) {
136+ @@ -1279 ,7 +1279 ,7 @@ TEST_F(GcsActorManagerTest, TestGetAllActorInfoFilters) {
136137 request.mutable_filters()->set_job_id(job_id.Binary());
137138
138139 auto &reply =
@@ -141,16 +142,15 @@ index 3030856998..2b11a89296 100644
141142 gcs_actor_manager_->HandleGetAllActorInfo(request, &reply, callback);
142143 ASSERT_EQ(reply.num_filtered(), num_other_actors + 1);
143144 ASSERT_EQ(reply.actor_table_data().size(), 0);
144- @@ -1272,7 +1272,7 @@ TEST_F(GcsActorManagerTest, TestGetAllActorInfoLimit) {
145+ @@ -1302,14 +1302,14 @@ TEST_F(GcsActorManagerTest, TestGetAllActorInfoLimit) {
145146 {
146147 rpc::GetAllActorInfoRequest request;
147148 auto &reply =
148149- *google::protobuf::Arena::CreateMessage<rpc::GetAllActorInfoReply>(&arena);
149150+ *google::protobuf::Arena::Create<rpc::GetAllActorInfoReply>(&arena);
150- auto callback = [](Status status,
151- std::function<void()> success,
152- std::function<void()> failure) {};
153- @@ -1281,7 +1281,7 @@ TEST_F(GcsActorManagerTest, TestGetAllActorInfoLimit) {
151+ auto callback = [](Status, std::function<void()>, std::function<void()>) {};
152+ gcs_actor_manager_->HandleGetAllActorInfo(request, &reply, callback);
153+ ASSERT_EQ(reply.actor_table_data().size(), 3);
154154
155155 request.set_limit(2);
156156 auto &reply_2 =
@@ -159,24 +159,11 @@ index 3030856998..2b11a89296 100644
159159 gcs_actor_manager_->HandleGetAllActorInfo(request, &reply_2, callback);
160160 ASSERT_EQ(reply_2.actor_table_data().size(), 2);
161161 ASSERT_EQ(reply_2.total(), 3);
162- diff --git a/src/ray/raylet_client/raylet_client.cc b/src/ray/raylet_client/raylet_client.cc
163- index bfb8b0665d..f377bfec23 100644
164- --- a/src/ray/raylet_client/raylet_client.cc
165- +++ b/src/ray/raylet_client/raylet_client.cc
166- @@ -44,7 +44,7 @@ void RayletClient::RequestWorkerLease(
167- const bool is_selected_based_on_locality) {
168- google::protobuf::Arena arena;
169- auto request =
170- - google::protobuf::Arena::CreateMessage<rpc::RequestWorkerLeaseRequest>(&arena);
171- + google::protobuf::Arena::Create<rpc::RequestWorkerLeaseRequest>(&arena);
172- // The unsafe allocating here is actually safe because the life-cycle of
173- // task_spec is longer than request.
174- // Request will be sent before the end of this call, and after that, it won't be
175162diff --git a/src/ray/rpc/server_call.h b/src/ray/rpc/server_call.h
176- index a2e7cd2cee..f3dea61850 100644
163+ index 0d0779525e..c5dc59b21f 100644
177164--- a/src/ray/rpc/server_call.h
178165+++ b/src/ray/rpc/server_call.h
179- @@ -193 ,7 +193 ,7 @@ class ServerCallImpl : public ServerCall {
166+ @@ -181 ,7 +181 ,7 @@ class ServerCallImpl : public ServerCall {
180167 cluster_id_(cluster_id),
181168 start_time_(0),
182169 record_metrics_(record_metrics) {
@@ -186,7 +173,7 @@ index a2e7cd2cee..f3dea61850 100644
186173 RAY_CHECK(!call_name_.empty()) << "Call name is empty";
187174 if (record_metrics_) {
188175diff --git a/src/ray/util/event.cc b/src/ray/util/event.cc
189- index e704c86847..08a79db77f 100644
176+ index efdd53ff8d..8dd4c30fb5 100644
190177--- a/src/ray/util/event.cc
191178+++ b/src/ray/util/event.cc
192179@@ -138,7 +138,7 @@ std::string LogEventReporter::ExportEventToString(const rpc::ExportEvent &export
@@ -198,23 +185,8 @@ index e704c86847..08a79db77f 100644
198185 if (export_event.has_task_event_data()) {
199186 RAY_CHECK(google::protobuf::util::MessageToJsonString(
200187 export_event.task_event_data(), &event_data_as_string, options)
201- diff --git a/thirdparty/patches/grpc-zlib-fdopen.patch b/thirdparty/patches/grpc-zlib-fdopen.patch
202- index 83dfba2b95..95d59c2279 100644
203- --- a/thirdparty/patches/grpc-zlib-fdopen.patch
204- +++ b/thirdparty/patches/grpc-zlib-fdopen.patch
205- @@ -2,8 +2,8 @@ diff -u bazel/grpc_deps.bzl
206- --- bazel/grpc_deps.bzl
207- +++ bazel/grpc_deps.bzl
208- @@ -238,6 +238,9 @@
209- - "https://storage.googleapis.com/grpc-bazel-mirror/github.com/madler/zlib/archive/04f42ceca40f73e2978b50e93806c2a18c1281fc.tar.gz",
210- - "https://github.com/madler/zlib/archive/04f42ceca40f73e2978b50e93806c2a18c1281fc.tar.gz",
211- + "https://storage.googleapis.com/grpc-bazel-mirror/github.com/madler/zlib/archive/09155eaa2f9270dc4ed1fa13e2b4b2613e6e4851.tar.gz",
212- + "https://github.com/madler/zlib/archive/09155eaa2f9270dc4ed1fa13e2b4b2613e6e4851.tar.gz",
213- ],
214- + patches = [
215- + "@io_ray//thirdparty/patches:zlib-fdopen.patch",
216188diff --git a/thirdparty/patches/grpc-configurable-thread-count.patch b/thirdparty/patches/grpc-configurable-thread-count.patch
217- index 26387f51a5..f1ae73ec4a 100644
189+ index e17e111f85..9db71c5275 100644
218190--- a/thirdparty/patches/grpc-configurable-thread-count.patch
219191+++ b/thirdparty/patches/grpc-configurable-thread-count.patch
220192@@ -1,7 +1,6 @@
@@ -244,6 +216,21 @@ index 26387f51a5..f1ae73ec4a 100644
244216- gpr_log(GPR_ERROR, "Cannot determine number of CPUs: assuming 1");
245217+ LOG(ERROR) << "Cannot determine number of CPUs: assuming 1";
246218 ncpus = 1;
219+ diff --git a/thirdparty/patches/grpc-zlib-fdopen.patch b/thirdparty/patches/grpc-zlib-fdopen.patch
220+ index 83dfba2b95..95d59c2279 100644
221+ --- a/thirdparty/patches/grpc-zlib-fdopen.patch
222+ +++ b/thirdparty/patches/grpc-zlib-fdopen.patch
223+ @@ -2,8 +2,8 @@ diff -u bazel/grpc_deps.bzl
224+ --- bazel/grpc_deps.bzl
225+ +++ bazel/grpc_deps.bzl
226+ @@ -238,6 +238,9 @@
227+ - "https://storage.googleapis.com/grpc-bazel-mirror/github.com/madler/zlib/archive/04f42ceca40f73e2978b50e93806c2a18c1281fc.tar.gz",
228+ - "https://github.com/madler/zlib/archive/04f42ceca40f73e2978b50e93806c2a18c1281fc.tar.gz",
229+ + "https://storage.googleapis.com/grpc-bazel-mirror/github.com/madler/zlib/archive/09155eaa2f9270dc4ed1fa13e2b4b2613e6e4851.tar.gz",
230+ + "https://github.com/madler/zlib/archive/09155eaa2f9270dc4ed1fa13e2b4b2613e6e4851.tar.gz",
231+ ],
232+ + patches = [
233+ + "@io_ray//thirdparty/patches:zlib-fdopen.patch",
247234- -
248- 2.39.5 (Apple Git-154)
235+ 2.25.1
249236
0 commit comments