Skip to content

Commit

Permalink
Remove deprecated comms functions
Browse files Browse the repository at this point in the history
PiperOrigin-RevId: 568510723
Change-Id: I517d739e44cb61eec8b0fd9fe6aa473e1bb8ec06
  • Loading branch information
happyCoder92 authored and copybara-github committed Sep 26, 2023
1 parent fadfa79 commit 37a7432
Show file tree
Hide file tree
Showing 3 changed files with 0 additions and 82 deletions.
54 changes: 0 additions & 54 deletions sandboxed_api/sandbox2/comms.cc
Original file line number Diff line number Diff line change
Expand Up @@ -109,9 +109,6 @@ socklen_t CreateSockaddrUn(const std::string& socket_name, bool abstract_uds,
}
} // namespace

Comms::Comms(const std::string& socket_name, bool abstract_uds)
: name_(socket_name), abstract_uds_(abstract_uds) {}

Comms::Comms(int fd, absl::string_view name) : connection_fd_(fd) {
// Generate a unique and meaningful socket name for this FD.
// Note: getpid()/gettid() are non-blocking syscalls.
Expand Down Expand Up @@ -163,23 +160,6 @@ absl::Status ListeningComms::Listen() {
return absl::OkStatus();
}

bool Comms::Listen() {
if (IsConnected()) {
return true;
}

absl::StatusOr<ListeningComms> listening_comms =
ListeningComms::Create(name_, abstract_uds_);
if (!listening_comms.ok()) {
SAPI_RAW_LOG(ERROR, "Listening failed: %s",
std::string(listening_comms.status().message()).c_str());
return false;
}
listening_comms_ =
std::make_unique<ListeningComms>(*std::move(listening_comms));
return true;
}

absl::StatusOr<Comms> ListeningComms::Accept() {
sockaddr_un suc;
socklen_t len = sizeof(suc);
Expand All @@ -197,25 +177,6 @@ absl::StatusOr<Comms> ListeningComms::Accept() {
return Comms(connection_fd, socket_name_);
}

bool Comms::Accept() {
if (IsConnected()) {
return true;
}

if (listening_comms_ == nullptr) {
SAPI_RAW_LOG(ERROR, "Comms::Listen needs to be called first");
return false;
}

absl::StatusOr<Comms> comms = listening_comms_->Accept();
if (!comms.ok()) {
SAPI_RAW_LOG(ERROR, "%s", std::string(comms.status().message()).c_str());
return false;
}
*this = *std::move(comms);
return true;
}

absl::StatusOr<Comms> Comms::Connect(const std::string& socket_name,
bool abstract_uds) {
FDCloser connection_fd(socket(AF_UNIX, SOCK_STREAM, 0)); // Non-blocking
Expand All @@ -240,21 +201,6 @@ absl::StatusOr<Comms> Comms::Connect(const std::string& socket_name,
return Comms(connection_fd.Release(), socket_name);
}

bool Comms::Connect() {
if (IsConnected()) {
return true;
}

absl::StatusOr<Comms> connected = Connect(name_, abstract_uds_);
if (!connected.ok()) {
SAPI_RAW_LOG(ERROR, "%s",
std::string(connected.status().message()).c_str());
return false;
}
*this = *std::move(connected);
return true;
}

void Comms::Terminate() {
state_ = State::kTerminated;

Expand Down
20 changes: 0 additions & 20 deletions sandboxed_api/sandbox2/comms.h
Original file line number Diff line number Diff line change
Expand Up @@ -98,12 +98,6 @@ class Comms {
static absl::StatusOr<Comms> Connect(const std::string& socket_name,
bool abstract_uds = true);

// This object will have to be connected later on.
// When not specified the constructor uses abstract unix domain sockets.
ABSL_DEPRECATED(
"Use ListeningComms or absl::StatusOr<Comms> Connect() instead")
explicit Comms(const std::string& socket_name, bool abstract_uds = true);

Comms(Comms&& other) { *this = std::move(other); }
Comms& operator=(Comms&& other) {
if (this != &other) {
Expand All @@ -126,20 +120,6 @@ class Comms {

~Comms();

// Binds to an address and make it listen to connections.
ABSL_DEPRECATED("Use ListeningComms::Create() instead")
bool Listen();

// Accepts the connection.
ABSL_DEPRECATED("Use ListeningComms::Accept() instead")
bool Accept();

// Connects to a remote socket.
ABSL_DEPRECATED(
"Use absl::StatusOr<Comms> Comms::Connect(std::string& socket_name, bool "
"abstract_uds) instead")
bool Connect();

// Terminates all underlying file descriptors, and sets the status of the
// Comms object to TERMINATED.
void Terminate();
Expand Down
8 changes: 0 additions & 8 deletions sandboxed_api/sandbox2/comms_test.cc
Original file line number Diff line number Diff line change
Expand Up @@ -371,12 +371,4 @@ TEST(CommsTest, TestSendRecvBytes) {
HandleCommunication(a, b);
}

// We cannot test this in the Client or Server tests, as the endpoint needs to
// be unconnected.
TEST(CommsTest, TestMsgSize) {
// There will be no actual connection to this socket.
const std::string socket_name = "sandbox2_comms_msg_size_test";
Comms c(socket_name);
}

} // namespace sandbox2

0 comments on commit 37a7432

Please sign in to comment.