usr/src/sys/kern/uipc_pipe.c

/*      uipc_pipe.c     4.18    82/10/31        */

#include "../h/param.h"
#include "../h/mbuf.h"
#include "../h/protosw.h"
#include "../h/socket.h"
#include "../h/socketvar.h"
#include "../h/unpcb.h"

#define PIPSIZ  4096

/*
 * Sneakily connect a pipe from wso to rso.
 * This will get cleaned up when socketpair is added.
 */
piconnect(wso, rso)
        struct socket *wso, *rso;
{

        /* when we reserve memory this routine may fail */
        sotounpcb(wso)->unp_conn = sotounpcb(rso);
        sotounpcb(rso)->unp_conn = sotounpcb(wso);
        wso->so_snd.sb_hiwat = PIPSIZ;
        wso->so_snd.sb_mbmax = 2*PIPSIZ;
        wso->so_state |= SS_ISCONNECTED|SS_CANTRCVMORE;
        rso->so_rcv.sb_hiwat = 0;
        rso->so_rcv.sb_mbmax = 0;
        rso->so_state |= SS_ISCONNECTED|SS_CANTSENDMORE;
        return (1);
}