oem-ibm: Modified to write system dump data on unix domain socket.
Currently pldm writes dump data on nbd device.
This commit is to enable dump offload using UNIX socket
On dump offload request, pldm setup a UNIX socket and
write data on socket, webserver connects to this socket
and reads data to offload
Tested By:
1. Offloaded system dump
2. Ran below pldmtool commands for performance test
while offloading system dump, i don't see an delay
pldmtool bios GetBIOSTable -t 1
pldmtool bios GetBIOSTable -t 2
Signed-off-by: Ravi Teja <raviteja28031990@gmail.com>
Change-Id: Iad8863d87c3b04a8dd588f1f0239f65fcb59f38b
diff --git a/oem/ibm/libpldmresponder/utils.cpp b/oem/ibm/libpldmresponder/utils.cpp
new file mode 100644
index 0000000..b8bbdf0
--- /dev/null
+++ b/oem/ibm/libpldmresponder/utils.cpp
@@ -0,0 +1,146 @@
+#include "utils.hpp"
+
+#include "libpldm/base.h"
+
+#include <sys/socket.h>
+#include <sys/types.h>
+#include <sys/un.h>
+#include <unistd.h>
+
+#include <iostream>
+
+namespace pldm
+{
+namespace responder
+{
+namespace utils
+{
+
+int setupUnixSocket(const std::string& socketInterface)
+{
+ int sock;
+ struct sockaddr_un addr;
+ memset(&addr, 0, sizeof(addr));
+ addr.sun_family = AF_UNIX;
+ if (strnlen(socketInterface.c_str(), sizeof(addr.sun_path)) ==
+ sizeof(addr.sun_path))
+ {
+ std::cerr << "setupUnixSocket: UNIX socket path too long" << std::endl;
+ return -1;
+ }
+
+ strncpy(addr.sun_path, socketInterface.c_str(), sizeof(addr.sun_path) - 1);
+
+ if ((sock = socket(AF_UNIX, SOCK_STREAM | SOCK_NONBLOCK, 0)) == -1)
+ {
+ std::cerr << "setupUnixSocket: socket() call failed" << std::endl;
+ return -1;
+ }
+
+ if (bind(sock, (struct sockaddr*)&addr, sizeof(addr)) == -1)
+ {
+ std::cerr << "setupUnixSocket: bind() call failed" << std::endl;
+ close(sock);
+ return -1;
+ }
+
+ if (listen(sock, 1) == -1)
+ {
+ std::cerr << "setupUnixSocket: listen() call failed" << std::endl;
+ close(sock);
+ return -1;
+ }
+
+ fd_set rfd;
+ struct timeval tv;
+ tv.tv_sec = 1;
+ tv.tv_usec = 0;
+
+ FD_ZERO(&rfd);
+ FD_SET(sock, &rfd);
+ int nfd = sock + 1;
+ int fd;
+
+ int retval = select(nfd, &rfd, NULL, NULL, &tv);
+ if (retval < 0)
+ {
+ std::cerr << "setupUnixSocket: select call failed " << errno
+ << std::endl;
+ close(sock);
+ return -1;
+ }
+
+ if ((retval > 0) && (FD_ISSET(sock, &rfd)))
+ {
+ fd = accept(sock, NULL, NULL);
+ if (fd < 0)
+ {
+ std::cerr << "setupUnixSocket: accept() call failed " << errno
+ << std::endl;
+ close(sock);
+ return -1;
+ }
+ close(sock);
+ }
+ return fd;
+}
+
+int writeToUnixSocket(const int sock, const char* buf, const uint64_t blockSize)
+{
+ uint64_t i;
+ int nwrite = 0;
+
+ for (i = 0; i < blockSize; i = i + nwrite)
+ {
+
+ fd_set wfd;
+ struct timeval tv;
+ tv.tv_sec = 1;
+ tv.tv_usec = 0;
+
+ FD_ZERO(&wfd);
+ FD_SET(sock, &wfd);
+ int nfd = sock + 1;
+
+ int retval = select(nfd, NULL, &wfd, NULL, &tv);
+ if (retval < 0)
+ {
+ std::cerr << "writeToUnixSocket: select call failed " << errno
+ << std::endl;
+ close(sock);
+ return -1;
+ }
+ if (retval == 0)
+ {
+ nwrite = 0;
+ continue;
+ }
+ if ((retval > 0) && (FD_ISSET(sock, &wfd)))
+ {
+ nwrite = write(sock, buf + i, blockSize - i);
+ if (nwrite < 0)
+ {
+ if (errno == EAGAIN || errno == EWOULDBLOCK || errno == EINTR)
+ {
+ std::cerr << "writeToUnixSocket: Write call failed with "
+ "EAGAIN or EWOULDBLOCK or EINTR"
+ << std::endl;
+ nwrite = 0;
+ continue;
+ }
+ std::cerr << "writeToUnixSocket: Failed to write" << std::endl;
+ close(sock);
+ return -1;
+ }
+ }
+ else
+ {
+ nwrite = 0;
+ }
+ }
+ return 0;
+}
+
+} // namespace utils
+} // namespace responder
+} // namespace pldm