+bad:
+ so->so_state &= ~SS_ISCONNECTING;
+ m_freem(nam);
+ if (error == ERESTART)
+ error = EINTR;
+ RETURN (error);
+}
+
+socketpair()
+{
+ register struct a {
+ int domain;
+ int type;
+ int protocol;
+ int *rsv;
+ } *uap = (struct a *)u.u_ap;
+ struct file *fp1, *fp2;
+ struct socket *so1, *so2;
+ int fd, error, sv[2];
+
+ if (error = socreate(uap->domain, &so1, uap->type, uap->protocol))
+ RETURN (error);
+ if (error = socreate(uap->domain, &so2, uap->type, uap->protocol))
+ goto free1;
+ if (error = falloc(&fp1, &fd))
+ goto free2;
+ sv[0] = fd;
+ fp1->f_flag = FREAD|FWRITE;
+ fp1->f_type = DTYPE_SOCKET;
+ fp1->f_ops = &socketops;
+ fp1->f_data = (caddr_t)so1;
+ if (error = falloc(&fp2, &fd))
+ goto free3;
+ fp2->f_flag = FREAD|FWRITE;
+ fp2->f_type = DTYPE_SOCKET;
+ fp2->f_ops = &socketops;
+ fp2->f_data = (caddr_t)so2;
+ sv[1] = fd;
+ if (error = soconnect2(so1, so2))
+ goto free4;
+ if (uap->type == SOCK_DGRAM) {
+ /*
+ * Datagram socket connection is asymmetric.
+ */
+ if (error = soconnect2(so2, so1))
+ goto free4;
+ }
+ error = copyout((caddr_t)sv, (caddr_t)uap->rsv, 2 * sizeof (int));
+ u.u_r.r_val1 = sv[0]; /* XXX ??? */
+ u.u_r.r_val2 = sv[1]; /* XXX ??? */
+ RETURN (error);
+free4:
+ crfree(fp2->f_cred);
+ fp2->f_count = 0;
+ u.u_ofile[sv[1]] = 0;
+free3:
+ crfree(fp1->f_cred);
+ fp1->f_count = 0;
+ u.u_ofile[sv[0]] = 0;
+free2:
+ (void)soclose(so2);
+free1:
+ (void)soclose(so1);
+ RETURN (error);
+}
+
+sendto()
+{
+ register struct a {
+ int s;
+ caddr_t buf;
+ int len;
+ int flags;
+ caddr_t to;
+ int tolen;
+ } *uap = (struct a *)u.u_ap;
+ struct msghdr msg;
+ struct iovec aiov;
+
+ msg.msg_name = uap->to;
+ msg.msg_namelen = uap->tolen;
+ msg.msg_iov = &aiov;
+ msg.msg_iovlen = 1;
+ msg.msg_control = 0;
+#ifdef COMPAT_43
+ msg.msg_flags = 0;
+#endif
+ aiov.iov_base = uap->buf;
+ aiov.iov_len = uap->len;
+ RETURN (sendit(uap->s, &msg, uap->flags));
+}
+
+#ifdef COMPAT_43
+osend()
+{
+ register struct a {
+ int s;
+ caddr_t buf;
+ int len;
+ int flags;
+ } *uap = (struct a *)u.u_ap;
+ struct msghdr msg;
+ struct iovec aiov;
+
+ msg.msg_name = 0;
+ msg.msg_namelen = 0;
+ msg.msg_iov = &aiov;
+ msg.msg_iovlen = 1;
+ aiov.iov_base = uap->buf;
+ aiov.iov_len = uap->len;
+ msg.msg_control = 0;
+ msg.msg_flags = 0;
+ RETURN (sendit(uap->s, &msg, uap->flags));
+}
+
+#define MSG_COMPAT 0x8000
+osendmsg()
+{
+ register struct a {
+ int s;
+ caddr_t msg;
+ int flags;
+ } *uap = (struct a *)u.u_ap;
+ struct msghdr msg;
+ struct iovec aiov[MSG_MAXIOVLEN];
+ int error;
+
+ if (error = copyin(uap->msg, (caddr_t)&msg, sizeof (struct omsghdr)))
+ RETURN (error);
+ if ((u_int)msg.msg_iovlen >= sizeof (aiov) / sizeof (aiov[0]))
+ RETURN (EMSGSIZE);
+ if (error = copyin((caddr_t)msg.msg_iov, (caddr_t)aiov,
+ (unsigned)(msg.msg_iovlen * sizeof (aiov[0]))))
+ RETURN (error);
+ msg.msg_flags = MSG_COMPAT;
+ RETURN (sendit(uap->s, &msg, uap->flags));
+}
+#endif
+
+sendmsg()
+{
+ register struct a {
+ int s;
+ caddr_t msg;
+ int flags;
+ } *uap = (struct a *)u.u_ap;
+ struct msghdr msg;
+ struct iovec aiov[MSG_MAXIOVLEN];
+ int error;
+
+ if (error = copyin(uap->msg, (caddr_t)&msg, sizeof (msg)))
+ RETURN (error);
+ if ((u_int)msg.msg_iovlen >= sizeof (aiov) / sizeof (aiov[0]))
+ RETURN (EMSGSIZE);
+ if (msg.msg_iovlen &&
+ (error = copyin((caddr_t)msg.msg_iov, (caddr_t)aiov,
+ (unsigned)(msg.msg_iovlen * sizeof (aiov[0])))))
+ RETURN (error);
+ msg.msg_iov = aiov;
+#ifdef COMPAT_43
+ msg.msg_flags = 0;
+#endif
+ RETURN (sendit(uap->s, &msg, uap->flags));
+}
+
+sendit(s, mp, flags)
+ int s;
+ register struct msghdr *mp;
+ int flags;
+{
+ register struct file *fp;
+ struct uio auio;
+ register struct iovec *iov;
+ register int i;
+ struct mbuf *to, *control;
+ int len, error;
+
+ fp = getsock(s, &error);
+ if (fp == 0)
+ return (error);
+ auio.uio_iov = mp->msg_iov;
+ auio.uio_iovcnt = mp->msg_iovlen;
+ auio.uio_segflg = UIO_USERSPACE;
+ auio.uio_rw = UIO_WRITE;
+ auio.uio_offset = 0; /* XXX */
+ auio.uio_resid = 0;
+ iov = mp->msg_iov;
+ for (i = 0; i < mp->msg_iovlen; i++, iov++) {
+ if (iov->iov_len < 0)
+ return (EINVAL);
+ if ((auio.uio_resid += iov->iov_len) < 0)
+ return (EINVAL);
+ }
+ if (mp->msg_name) {
+ if (error = sockargs(&to, mp->msg_name, mp->msg_namelen,
+ MT_SONAME))
+ return (error);
+ } else
+ to = 0;
+ if (mp->msg_control) {
+ if (mp->msg_controllen < sizeof(struct cmsghdr)
+#ifdef COMPAT_43
+ && mp->msg_flags != MSG_COMPAT)
+#endif
+ {
+ error = EINVAL;
+ goto bad;
+ }
+ if (error = sockargs(&control, mp->msg_control,
+ mp->msg_controllen, MT_CONTROL))
+ goto bad;
+#ifdef COMPAT_43
+ if (mp->msg_flags == MSG_COMPAT) {
+ register struct cmsghdr *cm;
+
+ M_PREPEND(control, sizeof(*cm), M_WAIT);
+ if (control == 0) {
+ error = ENOBUFS;
+ goto bad;
+ } else {
+ cm = mtod(control, struct cmsghdr *);
+ cm->cmsg_len = control->m_len;
+ cm->cmsg_level = SOL_SOCKET;
+ cm->cmsg_type = SCM_RIGHTS;
+ }
+ }
+#endif
+ } else
+ control = 0;
+ len = auio.uio_resid;
+ if (error = sosend((struct socket *)fp->f_data, to, &auio,
+ (struct mbuf *)0, control, flags)) {
+ if (auio.uio_resid != len && (error == ERESTART ||
+ error == EINTR || error == EWOULDBLOCK))
+ error = 0;
+ if (error == EPIPE)
+ psignal(u.u_procp, SIGPIPE);
+ } else
+ u.u_r.r_val1 = len - auio.uio_resid;
+bad:
+ if (to)
+ m_freem(to);
+ return (error);
+}
+
+#ifdef COMPAT_43
+orecvfrom()
+{
+ struct a {
+ int s;
+ caddr_t buf;
+ int len;
+ int flags;
+ caddr_t from;
+ int *fromlenaddr;
+ };
+
+ ((struct a *)u.u_ap)->flags |= MSG_COMPAT;
+ RETURN (recvfrom());
+}
+#endif
+
+recvfrom()
+{
+ register struct a {
+ int s;
+ caddr_t buf;
+ int len;
+ int flags;
+ caddr_t from;
+ int *fromlenaddr;
+ } *uap = (struct a *)u.u_ap;
+ struct msghdr msg;
+ struct iovec aiov;
+ int error;
+
+ if (uap->fromlenaddr) {
+ if (error = copyin((caddr_t)uap->fromlenaddr,
+ (caddr_t)&msg.msg_namelen, sizeof (msg.msg_namelen)))
+ return (error);
+ } else
+ msg.msg_namelen = 0;
+ msg.msg_name = uap->from;
+ msg.msg_iov = &aiov;
+ msg.msg_iovlen = 1;
+ aiov.iov_base = uap->buf;
+ aiov.iov_len = uap->len;
+ msg.msg_control = 0;
+ msg.msg_flags = uap->flags | MSG_COMPAT;
+ return (recvit(uap->s, &msg, (caddr_t)uap->fromlenaddr));
+}
+
+#ifdef COMPAT_43
+orecv()
+{
+ register struct a {
+ int s;
+ caddr_t buf;
+ int len;
+ int flags;
+ } *uap = (struct a *)u.u_ap;
+ struct msghdr msg;
+ struct iovec aiov;
+
+ msg.msg_name = 0;
+ msg.msg_namelen = 0;
+ msg.msg_iov = &aiov;
+ msg.msg_iovlen = 1;
+ aiov.iov_base = uap->buf;
+ aiov.iov_len = uap->len;
+ msg.msg_control = 0;
+ msg.msg_flags = uap->flags;
+ RETURN (recvit(uap->s, &msg, (caddr_t)0));
projects / unix-history / blobdiff