linux进程fd,linux进程间传递fd备忘

linux进程间传递fd备忘

(2012-11-08 16:50:15)

int sfd,cfd,size;

struct sockaddr_un un;

un.sun_family &＃61; AF_UNIX;

strcpy(un.sun_path,"foo.socket");

sfd &＃61; socket(AF_UNIX,SOCK_STREAM,0);

size &＃61; offsetof(struct sockaddr_un,sun_path) &＃43;

strlen(un.sun_path);

remove("foo.socket");

bind(sfd,(struct sockaddr *)&un,size);

listen(sfd,5);

while(true){

cfd &＃61; accept(sfd,NULL,NULL);

int fd;

fd &＃61; open("test",O_RDWR,0600);

send_fd(cfd,fd);

close(fd);

close(cfd);

}

close(sfd);

}

#define CONTROLLEN CMSG_LEN(sizeof(int))

static struct cmsghdr   *cmptr &＃61;

NULL;

int send_fd(int fd,int fd_to_send)

{

struct iovec

iov[1];

struct msghdr   msg;

char

buf[0];

iov[0].iov_base &＃61; buf;

iov[0].iov_len &＃61; 1;

msg.msg_name

&＃61; NULL;

msg.msg_namelen &＃61; 0;

msg.msg_iov

&＃61; iov;

msg.msg_iovlen &＃61; 1;

if(cmptr &＃61;&＃61; NULL && (cmptr &＃61; malloc(CONTROLLEN)) &＃61;&＃61;

NULL)

return (-1);

cmptr->cmsg_len

&＃61; CONTROLLEN;

cmptr->cmsg_level

&＃61; SOL_SOCKET;

cmptr->cmsg_type

&＃61; SCM_RIGHTS;

*(int *)CMSG_DATA(cmptr)&＃61; fd_to_send;

msg.msg_control

&＃61; cmptr;

msg.msg_controllen

&＃61; CONTROLLEN;

sendmsg(fd,&msg,0);

return (0);

}

&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;

client.c

&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;

#include

#include

#include

#include

int recv_fd(int fd);

enum{false,true};

int main()

{

int fd,size;

char buf[512];

int testfd;

memset(buf,&＃39;\0&＃39;,sizeof(buf));

struct sockaddr_un un;

un.sun_family &＃61; AF_UNIX;

strcpy(un.sun_path,"foo.socket");

fd &＃61; socket(AF_UNIX,SOCK_STREAM,0);

size &＃61; offsetof(struct sockaddr_un,sun_path) &＃43;

strlen(un.sun_path);

connect(fd,(struct sockaddr *)&un,size);

testfd &＃61; recv_fd(fd);

read(testfd,buf,512);

printf("%s\n",buf);

close(fd);

}

#define CONTROLLEN CMSG_LEN(sizeof(int))

static struct cmsghdr   *cmptr &＃61;

NULL;

int recv_fd(int fd)

{

int

newfd;

char

buf[0];

struct iovec

iov[1];

struct msghdr   msg;

while(true){

iov[0].iov_base &＃61; buf;

iov[0].iov_len &＃61; 1;

msg.msg_iov

&＃61; iov;

msg.msg_iovlen &＃61; 1;

msg.msg_name

&＃61; NULL;

msg.msg_namelen &＃61; 0;

if(cmptr &＃61;&＃61; NULL && (cmptr &＃61; malloc(CONTROLLEN)) &＃61;&＃61;

NULL){

return (-1);

}

msg.msg_control

&＃61; cmptr;

msg.msg_controllen

&＃61; CONTROLLEN;

recvmsg(fd,&msg,0);

newfd &＃61; *(int *)CMSG_DATA(cmptr);

return(newfd);

}

}