[BACK]Return to uipc_socket.c CVS log [TXT][DIR] Up to [cvs.NetBSD.org] / src / sys / kern

Please note that diffs are not public domain; they are subject to the copyright notices on the relevant files.

Diff for /src/sys/kern/uipc_socket.c between version 1.10 and 1.11

version 1.10, 1994/01/23 06:06:27 version 1.11, 1994/04/25 08:22:07
Line 42 
Line 42 
 #include <sys/mbuf.h>  #include <sys/mbuf.h>
 #include <sys/domain.h>  #include <sys/domain.h>
 #include <sys/kernel.h>  #include <sys/kernel.h>
 #include <sys/select.h>  
 #include <sys/protosw.h>  #include <sys/protosw.h>
 #include <sys/socket.h>  #include <sys/socket.h>
 #include <sys/socketvar.h>  #include <sys/socketvar.h>
Line 58 
Line 57 
 /*ARGSUSED*/  /*ARGSUSED*/
 int  int
 socreate(dom, aso, type, proto)  socreate(dom, aso, type, proto)
           int dom;
         struct socket **aso;          struct socket **aso;
         register int type;          register int type;
         int proto;          int proto;
Line 325  sosend(so, addr, uio, top, control, flag
Line 325  sosend(so, addr, uio, top, control, flag
         struct mbuf *control;          struct mbuf *control;
         int flags;          int flags;
 {  {
         struct proc *p = curproc;               /* XXX */  
         struct mbuf **mp;          struct mbuf **mp;
         register struct mbuf *m;          register struct mbuf *m;
         register long space, len, resid;          register long space, len, resid;
Line 348  sosend(so, addr, uio, top, control, flag
Line 347  sosend(so, addr, uio, top, control, flag
         dontroute =          dontroute =
             (flags & MSG_DONTROUTE) && (so->so_options & SO_DONTROUTE) == 0 &&              (flags & MSG_DONTROUTE) && (so->so_options & SO_DONTROUTE) == 0 &&
             (so->so_proto->pr_flags & PR_ATOMIC);              (so->so_proto->pr_flags & PR_ATOMIC);
         p->p_stats->p_ru.ru_msgsnd++;          if (uio->uio_procp)
                   uio->uio_procp->p_stats->p_ru.ru_msgsnd++;
         if (control)          if (control)
                 clen = control->m_len;                  clen = control->m_len;
 #define snderr(errno)   { error = errno; splx(s); goto release; }  #define snderr(errno)   { error = errno; splx(s); goto release; }
Line 373  restart:
Line 373  restart:
                 space = sbspace(&so->so_snd);                  space = sbspace(&so->so_snd);
                 if (flags & MSG_OOB)                  if (flags & MSG_OOB)
                         space += 1024;                          space += 1024;
                 if (space < resid + clen &&                  if (atomic && resid > so->so_snd.sb_hiwat ||
                       clen > so->so_snd.sb_hiwat)
                           snderr(EMSGSIZE);
                   if (space < resid + clen && uio &&
                     (atomic || space < so->so_snd.sb_lowat || space < clen)) {                      (atomic || space < so->so_snd.sb_lowat || space < clen)) {
                         if (atomic && resid > so->so_snd.sb_hiwat ||  
                             clen > so->so_snd.sb_hiwat)  
                                 snderr(EMSGSIZE);  
                         if (so->so_state & SS_NBIO)                          if (so->so_state & SS_NBIO)
                                 snderr(EWOULDBLOCK);                                  snderr(EWOULDBLOCK);
                         sbunlock(&so->so_snd);                          sbunlock(&so->so_snd);
Line 492  soreceive(so, paddr, uio, mp0, controlp,
Line 492  soreceive(so, paddr, uio, mp0, controlp,
         struct mbuf **controlp;          struct mbuf **controlp;
         int *flagsp;          int *flagsp;
 {  {
         struct proc *p = curproc;               /* XXX */  
         register struct mbuf *m, **mp;          register struct mbuf *m, **mp;
         register int flags, len, error, s, offset;          register int flags, len, error, s, offset;
         struct protosw *pr = so->so_proto;          struct protosw *pr = so->so_proto;
Line 593  restart:
Line 592  restart:
                 goto restart;                  goto restart;
         }          }
 dontblock:  dontblock:
         p->p_stats->p_ru.ru_msgrcv++;          if (uio->uio_procp)
                   uio->uio_procp->p_stats->p_ru.ru_msgrcv++;
         nextrecord = m->m_nextpkt;          nextrecord = m->m_nextpkt;
         if (pr->pr_flags & PR_ADDR) {          if (pr->pr_flags & PR_ADDR) {
 #ifdef DIAGNOSTIC  #ifdef DIAGNOSTIC

Legend:
Removed from v.1.10  
changed lines
  Added in v.1.11

CVSweb <webmaster@jp.NetBSD.org>