libsnapuserd: Handle error message
Bug: 400723109
Test: snapshotctl pause-merge
snapshotctl resume-merge
Change-Id: Ifbcbc14c9be69f849ad9680414614ca4851cfec2
Signed-off-by: Akilesh Kailash <akailash@google.com>
diff --git a/fs_mgr/libsnapshot/snapuserd/snapuserd_client.cpp b/fs_mgr/libsnapshot/snapuserd/snapuserd_client.cpp
index d0ff7f7..693fe39 100644
--- a/fs_mgr/libsnapshot/snapuserd/snapuserd_client.cpp
+++ b/fs_mgr/libsnapshot/snapuserd/snapuserd_client.cpp
@@ -395,7 +395,8 @@
LOG(ERROR) << "Failed to pause snapshot merge.";
return false;
}
- return true;
+ std::string response = Receivemsg();
+ return response == "success";
}
bool SnapuserdClient::ResumeMerge() {
@@ -403,7 +404,8 @@
LOG(ERROR) << "Failed to resume snapshot merge.";
return false;
}
- return true;
+ std::string response = Receivemsg();
+ return response == "success";
}
} // namespace snapshot
diff --git a/fs_mgr/libsnapshot/snapuserd/user-space-merge/snapuserd_server.cpp b/fs_mgr/libsnapshot/snapuserd/user-space-merge/snapuserd_server.cpp
index a2813bf..372b2f2 100644
--- a/fs_mgr/libsnapshot/snapuserd/user-space-merge/snapuserd_server.cpp
+++ b/fs_mgr/libsnapshot/snapuserd/user-space-merge/snapuserd_server.cpp
@@ -229,10 +229,10 @@
return Sendmsg(fd, "success");
} else if (cmd == "pause_merge") {
handlers_->PauseMerge();
- return true;
+ return Sendmsg(fd, "success");
} else if (cmd == "resume_merge") {
handlers_->ResumeMerge();
- return true;
+ return Sendmsg(fd, "success");
} else {
LOG(ERROR) << "Received unknown message type from client";
Sendmsg(fd, "fail");