Initial commit for AGL cluster api library

This source code is AGL instrument cluster common API library.
Currently, this source code is missing author information, license and other.
Will be add by author.

Author: Nozomu Abe (nozo_abe@nippon-seiki.co.jp)

Committed by Naoto Yamaguchi.
Signed-off-by: Naoto Yamaguchi <naoto.yamaguchi@aisin.co.jp>

1 files changed, 176 insertions, 0 deletions

diff --git a/test/client_test/dummy_server.c b/test/client_test/dummy_server.c
new file mode 100644
index 0000000..987552a
--- /dev/null
+++ b/test/client_test/dummy_server.c
@@ -0,0 +1,176 @@
+#include "client_test_common.h"
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <unistd.h>
+#include <stdbool.h>
+#include <sys/socket.h>
+#include <sys/un.h>
+#include <sys/epoll.h>
+
+#include <ipc.h>
+
+#define CLUSTER_TEST_EPOLL_WAIT_NUM (2)
+
+int createEpoll(int waitNum)
+{
+    int fd = -1;
+
+    fd = epoll_create(waitNum);
+    if (fd < 0) {
+        ERRNO_LOG(epoll_create);
+        return -1;
+    }
+
+    return fd;
+}
+
+int createSocket(int epollFd, int *pOutTestFd)
+{
+    int rc;
+    int fd = -1;
+    int testFd = -1;
+    struct sockaddr_un unixAddr;
+    int len;
+    struct epoll_event epollEv;
+
+    fd = socket(AF_UNIX, SOCK_STREAM, 0);
+    if (fd < 0) {
+        ERRNO_LOG(socket);
+        return -1;
+    }
+
+    unixAddr.sun_family = AF_UNIX;
+    strcpy(unixAddr.sun_path, CLUSTER_TEST_DOMAIN_PATH);
+    len = sizeof(unixAddr.sun_family)+strlen(unixAddr.sun_path);
+    rc = bind(fd, (struct sockaddr *)&unixAddr, len);
+    if (rc < 0) {
+        ERRNO_LOG(bind);
+        goto err;
+    }
+
+    rc = listen(fd, 1);
+    if (rc < 0) {
+        ERRNO_LOG(listen);
+        goto err;
+    }
+
+    testFd = accept(fd, (struct sockaddr*)&unixAddr, (socklen_t *)&len);
+    if (testFd < 0) {
+        ERRNO_LOG(accept);
+        goto err;
+    }
+
+    memset(&epollEv, 0, sizeof(epollEv));
+    epollEv.events = EPOLLIN;
+    epollEv.data.fd = fd;
+    epoll_ctl(epollFd, EPOLL_CTL_ADD, epollEv.data.fd, &epollEv);
+
+    epollEv.events = EPOLLIN | EPOLLRDHUP;
+    epollEv.data.fd = testFd;
+    epoll_ctl(epollFd, EPOLL_CTL_ADD, epollEv.data.fd, &epollEv);
+
+    *pOutTestFd = testFd;
+
+    return fd;
+err:
+    shutdown(fd, SHUT_RDWR);
+    close(fd);
+    unlink(CLUSTER_TEST_DOMAIN_PATH);
+    return -1;
+}
+
+void sendMessageLoop(void)
+{
+    int epollFd = -1;
+    int socketFd = -1;
+    int testFd = -1;
+    int fdNum;
+    int i;
+    struct epoll_event epEvents[CLUSTER_TEST_EPOLL_WAIT_NUM];
+    bool isRunning = true;
+    int dummyData;
+    FILE *fp;
+    IPC_DATA_IC_SERVICE_S sendData;
+    IPC_RET_E rc;
+    int size;
+
+    epollFd = createEpoll(CLUSTER_TEST_EPOLL_WAIT_NUM);
+    if (epollFd < 0) {
+        goto end;
+    }
+
+    socketFd = createSocket(epollFd, &testFd);
+    if (socketFd < 0) {
+        goto end;
+    }
+
+    while(isRunning == true) {
+        fdNum = epoll_wait(epollFd, epEvents, CLUSTER_TEST_EPOLL_WAIT_NUM, -1);
+
+        for (i = 0; i < fdNum; i++) {
+            if (epEvents[i].events & EPOLLRDHUP) {
+                isRunning = false;
+                break;
+            }
+            else if (epEvents[i].events & EPOLLIN) {
+                size = read(epEvents[i].data.fd, &dummyData, sizeof(dummyData));
+                if (size < 0) {
+                    ERRNO_LOG(read);
+                }
+                fp = fopen(CLUSTER_TEST_SENDDATA_FILE, "rb");
+                if (fp != NULL) {
+                    size = fread(&sendData, 1, sizeof(sendData), fp);
+                    if (size < sizeof(sendData) && ferror(fp)) {
+                        ERRNO_LOG(fread);
+                    }
+                    fclose(fp);
+                    rc = ipcSendMessage(IPC_USAGE_TYPE_IC_SERVICE, &sendData, sizeof(sendData));
+                    if (rc != IPC_RET_OK) {
+                        fprintf(stderr, "dummy_server:%d Failed to ipcSendMessage() : %d\n", __LINE__, rc);
+                    }
+                }
+            }
+        }
+    }
+
+end:
+    if (testFd >= 0) {
+        shutdown(testFd, SHUT_RDWR);
+        close(testFd);
+    }
+
+    if (socketFd >= 0) {
+        shutdown(socketFd, SHUT_RDWR);
+        close(socketFd);
+        unlink(CLUSTER_TEST_DOMAIN_PATH);
+    }
+
+    if (epollFd >= 0) {
+        close(epollFd);
+    }
+}
+
+int main(void)
+{
+    IPC_RET_E ret;
+
+    setenv(IPC_ENV_DOMAIN_SOCKET_PATH, IPC_TEST_DOMAIN_PATH, 1);
+
+    ret = ipcServerStart(IPC_USAGE_TYPE_IC_SERVICE);
+    if (ret != IPC_RET_OK) {
+        fprintf(stderr, "dummy_server:%d Failed to ipcServerStart() : %d\n", __LINE__, ret);
+        exit(EXIT_FAILURE);
+    }
+
+    sendMessageLoop();
+
+    ret = ipcServerStop(IPC_USAGE_TYPE_IC_SERVICE);
+    if (ret != IPC_RET_OK) {
+        fprintf(stderr, "dummy_server:%d Failed to ipcServerStop() : %d\n", __LINE__, ret);
+        exit(EXIT_FAILURE);
+    }
+
+    return 0;
+}
+