Skip to content

Commit

Permalink
chore: Rename abort_udf to abort_late_udf
Browse files Browse the repository at this point in the history
Bug: N/A
Change-Id: I461bdbbcf7edcb9dfd9212cffcb99c8d39b97ec3
GitOrigin-RevId: d7909912f27a826003a656756fabfa7136c10f4e
  • Loading branch information
Privacy Sandbox Team authored and copybara-github committed Nov 8, 2024
1 parent 343a303 commit 464a78f
Show file tree
Hide file tree
Showing 4 changed files with 11 additions and 11 deletions.
2 changes: 1 addition & 1 deletion src/roma/byob/dispatcher/BUILD.bazel
Original file line number Diff line number Diff line change
Expand Up @@ -76,7 +76,7 @@ cc_test(
data = [
":run_workers_without_sandbox",
"//src/roma/byob/sample_udf",
"//src/roma/byob/sample_udf:abort_udf",
"//src/roma/byob/sample_udf:abort_late_udf",
"//src/roma/byob/sample_udf:new_udf",
"//src/roma/byob/sample_udf:nonzero_return_udf",
"//src/roma/byob/sample_udf:pause_udf",
Expand Down
2 changes: 1 addition & 1 deletion src/roma/byob/dispatcher/dispatcher_udf_test.cc
Original file line number Diff line number Diff line change
Expand Up @@ -369,7 +369,7 @@ TEST(DispatcherUdfTest, LoadAndExecuteAbortUdf) {
Dispatcher dispatcher;
ASSERT_TRUE(dispatcher.Init(fd, /*logdir=*/"").ok());
const absl::StatusOr<std::string> code_token =
dispatcher.LoadBinary("src/roma/byob/sample_udf/abort_udf",
dispatcher.LoadBinary("src/roma/byob/sample_udf/abort_late_udf",
/*num_workers=*/10);
ASSERT_TRUE(code_token.ok());
SampleRequest bin_request;
Expand Down
5 changes: 3 additions & 2 deletions src/roma/byob/sample_udf/BUILD.bazel
Original file line number Diff line number Diff line change
Expand Up @@ -166,8 +166,8 @@ cc_binary(
)

cc_binary(
name = "abort_udf",
srcs = ["abort_udf.cc"],
name = "abort_late_udf",
srcs = ["abort_late_udf.cc"],
visibility = ["//visibility:public"],
deps = [
":sample_byob_sdk_cc_proto",
Expand Down Expand Up @@ -343,6 +343,7 @@ native_image(
filegroup(
name = "udf_binaries",
srcs = [
":abort_late_udf",
":callback_payload_read_udf",
":callback_payload_write_udf",
":log_benchmark_udf",
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -12,18 +12,17 @@
// See the License for the specific language governing permissions and
// limitations under the License.

#include <stdlib.h>

#include <cstdlib>
#include <iostream>

#include "google/protobuf/any.pb.h"
#include "google/protobuf/util/delimited_message_util.h"
#include "src/roma/byob/sample_udf/sample_udf_interface.pb.h"

using ::google::protobuf::io::FileInputStream;
using ::google::protobuf::util::ParseDelimitedFromZeroCopyStream;
using ::google::protobuf::util::SerializeDelimitedToFileDescriptor;
using ::privacy_sandbox::roma_byob::example::SampleResponse;
using google::protobuf::io::FileInputStream;
using google::protobuf::util::ParseDelimitedFromZeroCopyStream;
using google::protobuf::util::SerializeDelimitedToFileDescriptor;
using privacy_sandbox::roma_byob::example::SampleResponse;

void ReadRequestFromFd(int fd) {
google::protobuf::Any bin_request;
Expand All @@ -47,5 +46,5 @@ int main(int argc, char* argv[]) {
SampleResponse bin_response;
bin_response.set_greeting("I am a crashing UDF!");
WriteResponseToFd(fd, std::move(bin_response));
::abort();
std::abort();
}

0 comments on commit 464a78f

Please sign in to comment.