summaryrefslogtreecommitdiff
path: root/src/buildtool/execution_api/execution_service
diff options
context:
space:
mode:
Diffstat (limited to 'src/buildtool/execution_api/execution_service')
-rw-r--r--src/buildtool/execution_api/execution_service/TARGETS2
-rw-r--r--src/buildtool/execution_api/execution_service/bytestream_server.cpp6
2 files changed, 4 insertions, 4 deletions
diff --git a/src/buildtool/execution_api/execution_service/TARGETS b/src/buildtool/execution_api/execution_service/TARGETS
index 7f8e0e0d..26be0be8 100644
--- a/src/buildtool/execution_api/execution_service/TARGETS
+++ b/src/buildtool/execution_api/execution_service/TARGETS
@@ -118,7 +118,7 @@
, ["src/buildtool/storage", "config"]
]
, "private-deps":
- [ ["src/buildtool/execution_api/common", "bytestream-common"]
+ [ ["src/buildtool/execution_api/common", "bytestream_utils"]
, ["src/buildtool/file_system", "file_system_manager"]
, ["src/buildtool/common", "artifact_digest_factory"]
, ["src/buildtool/common", "common"]
diff --git a/src/buildtool/execution_api/execution_service/bytestream_server.cpp b/src/buildtool/execution_api/execution_service/bytestream_server.cpp
index fb54ea2b..985f41a9 100644
--- a/src/buildtool/execution_api/execution_service/bytestream_server.cpp
+++ b/src/buildtool/execution_api/execution_service/bytestream_server.cpp
@@ -23,7 +23,7 @@
#include "src/buildtool/common/artifact_digest.hpp"
#include "src/buildtool/common/artifact_digest_factory.hpp"
#include "src/buildtool/common/bazel_types.hpp"
-#include "src/buildtool/execution_api/common/bytestream_common.hpp"
+#include "src/buildtool/execution_api/common/bytestream_utils.hpp"
#include "src/buildtool/execution_api/execution_service/cas_utils.hpp"
#include "src/buildtool/file_system/file_system_manager.hpp"
#include "src/buildtool/logging/log_level.hpp"
@@ -104,10 +104,10 @@ auto BytestreamServiceImpl::Read(
::google::bytestream::ReadResponse response;
std::string& buffer = *response.mutable_data();
- buffer.resize(kChunkSize);
+ buffer.resize(ByteStreamUtils::kChunkSize);
while (not stream.eof()) {
- stream.read(buffer.data(), kChunkSize);
+ stream.read(buffer.data(), ByteStreamUtils::kChunkSize);
if (stream.bad()) {
auto const str =
fmt::format("Failed to read data for {}", read_digest->hash());