#include <stdio.h>#include <stdlib.h>#include <string.h>#include <unistd.h>#include <sys/types.h>#include <sys/socket.h>#include <sys/time.h>#include <sys/un.h>#include <errno.h> #include "ipcsocket.h"  int opensocket(int *sockfd, const char *name, int connecttype){	int ret, temp = 1; 	if (!name || strlen(name) > MAX_SOCK_NAME_LEN) {		fprintf(stderr, "<%s>: Invalid socket name.\n", __func__);		return -1;	} 	ret = socket(PF_LOCAL, SOCK_STREAM, 0);	if (ret < 0) {		fprintf(stderr, "<%s>: Failed socket: <%s>\n",			__func__, strerror(errno));		return ret;	} 	*sockfd = ret;	if (setsockopt(*sockfd, SOL_SOCKET, SO_REUSEADDR,		(char *)&temp, sizeof(int)) < 0) {		fprintf(stderr, "<%s>: Failed setsockopt: <%s>\n",		__func__, strerror(errno));		goto err;	} 	sprintf(sock_name, "/tmp/%s", name); 	if (connecttype == 1) {		/* This is for Server connection */		struct sockaddr_un skaddr;		int clientfd;		socklen_t sklen; 		unlink(sock_name);		memset(&skaddr, 0, sizeof(skaddr));		skaddr.sun_family = AF_LOCAL;		strcpy(skaddr.sun_path, sock_name); 		ret = bind(*sockfd, (struct sockaddr *)&skaddr,			SUN_LEN(&skaddr));		if (ret < 0) {			fprintf(stderr, "<%s>: Failed bind: <%s>\n",			__func__, strerror(errno));			goto err;		} 		ret = listen(*sockfd, 5);		if (ret < 0) {			fprintf(stderr, "<%s>: Failed listen: <%s>\n",			__func__, strerror(errno));			goto err;		} 		memset(&skaddr, 0, sizeof(skaddr));		sklen = sizeof(skaddr); 		ret = accept(*sockfd, (struct sockaddr *)&skaddr,			(socklen_t *)&sklen);		if (ret < 0) {			fprintf(stderr, "<%s>: Failed accept: <%s>\n",			__func__, strerror(errno));			goto err;		} 		clientfd = ret;		*sockfd = clientfd;	} else {		/* This is for client connection */		struct sockaddr_un skaddr; 		memset(&skaddr, 0, sizeof(skaddr));		skaddr.sun_family = AF_LOCAL;		strcpy(skaddr.sun_path, sock_name); 		ret = connect(*sockfd, (struct sockaddr *)&skaddr,			SUN_LEN(&skaddr));		if (ret < 0) {			fprintf(stderr, "<%s>: Failed connect: <%s>\n",			__func__, strerror(errno));			goto err;		}	} 	return 0; err:	if (*sockfd)		close(*sockfd); 	return ret;} int sendtosocket(int sockfd, struct socketdata *skdata){	int ret, buffd;	unsigned int len;	char cmsg_b[CMSG_SPACE(sizeof(int))];	struct cmsghdr *cmsg;	struct msghdr msgh;	struct iovec iov;	struct timeval timeout;	fd_set selFDs; 	if (!skdata) {		fprintf(stderr, "<%s>: socketdata is NULL\n", __func__);		return -1;	} 	FD_ZERO(&selFDs);	FD_SET(0, &selFDs);	FD_SET(sockfd, &selFDs);	timeout.tv_sec = 20;	timeout.tv_usec = 0; 	ret = select(sockfd+1, NULL, &selFDs, NULL, &timeout);	if (ret < 0) {		fprintf(stderr, "<%s>: Failed select: <%s>\n",		__func__, strerror(errno));		return -1;	} 	if (FD_ISSET(sockfd, &selFDs)) {		buffd = skdata->data;		len = skdata->len;		memset(&msgh, 0, sizeof(msgh));		msgh.msg_control = &cmsg_b;		msgh.msg_controllen = CMSG_LEN(len);		iov.iov_base = "OK";		iov.iov_len = 2;		msgh.msg_iov = &iov;		msgh.msg_iovlen = 1;		cmsg = CMSG_FIRSTHDR(&msgh);		cmsg->cmsg_level = SOL_SOCKET;		cmsg->cmsg_type = SCM_RIGHTS;		cmsg->cmsg_len = CMSG_LEN(len);		memcpy(CMSG_DATA(cmsg), &buffd, len); 		ret = sendmsg(sockfd, &msgh, MSG_DONTWAIT);		if (ret < 0) {			fprintf(stderr, "<%s>: Failed sendmsg: <%s>\n",			__func__, strerror(errno));			return -1;		}	} 	return 0;} int receivefromsocket(int sockfd, struct socketdata *skdata){	int ret, buffd;	unsigned int len = 0;	char cmsg_b[CMSG_SPACE(sizeof(int))];	struct cmsghdr *cmsg;	struct msghdr msgh;	struct iovec iov;	fd_set recvFDs;	char data[32]; 	if (!skdata) {		fprintf(stderr, "<%s>: socketdata is NULL\n", __func__);		return -1;	} 	FD_ZERO(&recvFDs);	FD_SET(0, &recvFDs);	FD_SET(sockfd, &recvFDs); 	ret = select(sockfd+1, &recvFDs, NULL, NULL, NULL);	if (ret < 0) {		fprintf(stderr, "<%s>: Failed select: <%s>\n",		__func__, strerror(errno));		return -1;	} 	if (FD_ISSET(sockfd, &recvFDs)) {		len = sizeof(buffd);		memset(&msgh, 0, sizeof(msgh));		msgh.msg_control = &cmsg_b;		msgh.msg_controllen = CMSG_LEN(len);		iov.iov_base = data;		iov.iov_len = sizeof(data)-1;		msgh.msg_iov = &iov;		msgh.msg_iovlen = 1;		cmsg = CMSG_FIRSTHDR(&msgh);		cmsg->cmsg_level = SOL_SOCKET;		cmsg->cmsg_type = SCM_RIGHTS;		cmsg->cmsg_len = CMSG_LEN(len); 		ret = recvmsg(sockfd, &msgh, MSG_DONTWAIT);		if (ret < 0) {			fprintf(stderr, "<%s>: Failed recvmsg: <%s>\n",			__func__, strerror(errno));			return -1;		} 		memcpy(&buffd, CMSG_DATA(cmsg), len);		skdata->data = buffd;		skdata->len = len;	}	return 0;} int closesocket(int sockfd, char *name){	char sockname[MAX_SOCK_NAME_LEN]; 	if (sockfd)		close(sockfd);	sprintf(sockname, "/tmp/%s", name);	unlink(sockname);	shutdown(sockfd, 2); 	return 0;}