socketpair：建立一对匿名的已经连接的套接字
#include <sys/types.h> #include <sys/socket.h> int socketpair(int d, int type, int protocol, int sv[2]);1）UNIX域
2）SOCK_STREAM SOCK_DGRAM
3）对于socketpair函数，protocol参数必须提供为0。
4）参数sv[2]是接收代表两个套接口的整数数组。每一个文件描述符代表一个套接口，并且与另一个并没有区别。
5）返回值：成功时，返回零。 出错时，返回-1，并适当地设置errno。
在ProxyManager的分派连接中，调用ProxyWorker中的send函数
// 分派连接 for (size_t i = 0; i < _workers.size(); ++i) { int ret = _workers[_idx]->send(&fds[0], (int)fds.size()); _idx = (_idx + 1) % (int)_workers.size(); if (ret == 0) { break; } } 在ProxyWorker中，start函数，父进程send，子进程读
void ProxyWorker::start() { if (_fd != -1) { ::close(_fd); _fd = -1; } int fd[2]; ::socketpair(AF_UNIX, SOCK_STREAM, 0, fd); // 未命名的全双工管道 可以在fd[0] 与 fd[1]间 (父子进程间)完成通讯 if ((_pid = fork()) == 0) { // 子进程 Comm::LogErr("worker %u running", _startId); ::close(fd[0]); _pid = getpid(); { int cpu_num = sysconf(_SC_NPROCESSORS_ONLN) - 1; if (cpu_num > 2){ int cpuidx = (_startId + 1 ) % cpu_num + 1; cpu_set_t mask; CPU_ZERO(&mask); CPU_SET(cpuidx, &mask); sched_setaffinity(_pid, sizeof(mask), &mask); } } _mgr.init(fd[1], _startId, _step); _mgr.run(); Comm::LogErr("worker exit"); _exit(0); } else if (_pid > 0) { // 父进程 ::close(fd[1]); _fd = fd[0]; } else { //Comm::LogErr } } ProxyWorker中的send函数
int ProxyWorker::send(int* fd, int n) { char c = '\0'; struct iovec iov; iov.iov_base = &c; iov.iov_len = 1; char buf[CMSG_SPACE(sizeof(int) * n)]; struct msghdr msg = { 0 }; msg.msg_iov = &iov; msg.msg_iovlen = 1; msg.msg_control = buf; msg.msg_controllen = sizeof(buf); msg.msg_name = NULL; msg.msg_namelen = 0; struct cmsghdr* cmsg = CMSG_FIRSTHDR(&msg); cmsg->cmsg_level = SOL_SOCKET; cmsg->cmsg_type = SCM_RIGHTS; cmsg->cmsg_len = CMSG_LEN(sizeof(int) * n); memcpy(CMSG_DATA(cmsg), fd, sizeof(int) * n); ssize_t s = ::sendmsg(_fd, &msg, 0); if (s < 0) { Comm::LogErr("sendmsg %ld %s", s, strerror(errno)); return -1; } return 0; }
