Method createSocket

libapp2sys/src/main/cpp/localsocket.h:248–355

server: remotePath is null or "" client: remotePath is valid

    //server: remotePath is null or ""
    //client: remotePath is valid
    int createSocket(const char *localPath, const char *remotePath) {
        pdbg("createSocket, localPath: %s, remotePath: %s", localPath, remotePath);
        if (m_fd > 0) {
            return m_fd;
        }

        int ret = pipe(m_pipefd);
        if (ret < 0) {
            perr("createSocket, create pipe error, ret:%d", ret);
            return -1;
        }
        const int fd = socket(AF_UNIX, SOCK_STREAM, 0);
        if (fd < 0) {
            perr("createSocket, socket error, fd:%d", fd);
            return -1;
        }

        struct sockaddr_un un;
        socklen_t len;
        if (remotePath == NULL || strlen(remotePath) == 0) { //server
            unlink(localPath);

            memset(&un, 0, sizeof(un));
            un.sun_family = AF_UNIX;
            un.sun_path[0] = '\0';
            memcpy(un.sun_path + 1, localPath, strlen(localPath));
            len = offsetof(struct sockaddr_un, sun_path) + strlen(localPath) + 1;
            ret = ::bind(fd, (struct sockaddr *) &un, len);
            if (ret < 0) {
                close(fd);
                perr("createSocket, bind error, ret:%d, fd:%d, localPath:%s", ret, fd, localPath);
                return -2;
            }

            ret = listen(fd, 5);
            if (ret < 0) {
                close(fd);
                perr("createSocket, listen error, ret:%d, fd:%d, localPath:%s", ret, fd, localPath);
                return -3;
            }
            m_fd = fd;
            pwrn("createSocket, create Server socket:%d, localPath:%s", m_fd, localPath);
            return fd;
        }

        memset(&un, 0, sizeof(un));
        un.sun_family = AF_UNIX;
        un.sun_path[0] = '\0';
        memcpy(un.sun_path + 1, remotePath, strlen(remotePath));
        len = offsetof(struct sockaddr_un, sun_path) + strlen(remotePath) + 1;



//      non-blocking connect implementation
        int opt = 1;
        //set non-blocking
        if (ioctl(fd, FIONBIO, &opt) < 0) {
            close(fd);