开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 嵌入式/单片机编程 > VxWorks > 查看源码
raw_ip.c
资源名称：vxwork_src.rar　[点击查看]
上传用户：nvosite88
上传日期：2007-01-17
资源大小：4983k
文件大小：18k
源码类别：

VxWorks

开发平台：

C/C++

raw_ip.c：源码内容
  1. /* raw_ip.c - raw interface to IP protocol */
  3. /* Copyright 1984 - 2002 Wind River Systems, Inc. */
  4. #include "copyright_wrs.h"
  6. /*
  7.  * Copyright (c) 1982, 1986, 1988, 1993, 1995
  8.  * The Regents of the University of California.  All rights reserved.
  9.  *
  10.  * Redistribution and use in source and binary forms, with or without
  11.  * modification, are permitted provided that the following conditions
  12.  * are met:
  13.  * 1. Redistributions of source code must retain the above copyright
  14.  *    notice, this list of conditions and the following disclaimer.
  15.  * 2. Redistributions in binary form must reproduce the above copyright
  16.  *    notice, this list of conditions and the following disclaimer in the
  17.  *    documentation and/or other materials provided with the distribution.
  18.  * 3. All advertising materials mentioning features or use of this software
  19.  *    must display the following acknowledgement:
  20.  * This product includes software developed by the University of
  21.  * California, Berkeley and its contributors.
  22.  * 4. Neither the name of the University nor the names of its contributors
  23.  *    may be used to endorse or promote products derived from this software
  24.  *    without specific prior written permission.
  25.  *
  26.  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
  27.  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  28.  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  29.  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
  30.  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
  31.  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
  32.  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
  33.  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
  34.  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
  35.  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
  36.  * SUCH DAMAGE.
  37.  *
  38.  * @(#)raw_ip.c 8.7 (Berkeley) 5/15/95
  39.  */
  41. /*
  42. modification history
  43. --------------------
  44. 01j,20may02,vvv  fixed rip_input to send ICMP protocol unreachable errors 
  45.  only when called directly from ip_input (SPR #75405)
  46. 01i,21mar02,rae  Allow ICMP to be excluded (SPR #73703)
  47. 01h,12oct01,rae  merge from truestack ver 01o, base 01g (SPRs 69657,
  48.                  35258, etc)
  49. 01g,26aug98,n_s  corrected rip_output for IP_HDRINCL case. spr #22246
  50. 01f,26aug98,n_s  added return val check for M_PREPEND in rip_output and
  51.                  mBufClGet in rip_ctloutput. spr # 22238.
  52. 01e,16apr97,vin  added PRU_CONTROL support to rip_usrreq().
  53. 01d,08apr97,vin  include pcb hashing changes from FREEBSD2.2.1, removed
  54.  ip_mrouter, added mCastRouteCmdHook. removed all MROUTING
  55. 01c,31jan97,vin  changed declaration according to prototype decl in protosw.h
  56. 01b,22nov96,vin  added cluster support replaced m_get(..) with mBufClGet(..).
  57. 01a,03mar96,vin  created from BSD4.4 stuff,integrated with 02i of raw_usrreq.c
  58. */
  60. /*
  61. DESCRIPTION
  62. */
  64. #include "vxWorks.h"
  65. #include "net/mbuf.h"
  66. #include "sys/socket.h"
  67. #include "net/protosw.h"
  68. #include "net/socketvar.h"
  69. #include "errno.h"
  71. #include "net/if.h"
  72. #include "net/route.h"
  73. #include "net/raw_cb.h"
  75. #include "netinet/in.h"
  76. #include "netinet/in_systm.h"
  77. #include "netinet/in_var.h"
  78. #include "netinet/ip.h"
  79. #include "netinet/ip_icmp.h"
  80. #include "netinet/ip_var.h"
  81. #include "netinet/ip_mroute.h"
  82. #include "netinet/in_pcb.h"
  84. #ifdef WV_INSTRUMENTATION
  85. #ifdef INCLUDE_WVNET
  86. #include "wvNetLib.h"
  87. #endif
  88. #endif
  90. /* externs */
  91. extern FUNCPTR _mCastRouteCmdHook; /* WRS mcast route command hook */
  92. extern VOIDFUNCPTR _icmpErrorHook;
  93. extern int icmp_ctloutput (int, struct socket *, int, int, struct mbuf **);
  94. extern struct protosw inetsw[];
  95. extern u_char ip_protox[IPPROTO_MAX];
  97. /* globals */
  99. #ifndef VIRTUAL_STACK
  100. static struct inpcbhead ripcb;
  101. static struct inpcbinfo ripcbinfo;
  102. static struct sockaddr_in ripsrc = { sizeof(ripsrc), AF_INET };
  103. #endif /* VIRTUAL_STACK */
  105. #ifdef VIRTUAL_STACK
  106. #include "netinet/vsLib.h"
  107. #endif
  109. /*
  110.  * Nominal space allocated to a raw ip socket.
  111.  */
  112. #define RIPSNDQ 8192
  113. #define RIPRCVQ 8192
  115. /* locals */
  116. static int _mCastCtlOutput (int option, int optName, struct socket * sockPtr,
  117.                             struct mbuf ** pPtrMbuf); 
  119. #ifdef WV_INSTRUMENTATION
  120. #ifdef INCLUDE_WVNET
  121.     /* Set common fields of event identifiers for this module. */
  123. LOCAL UCHAR wvNetModuleId = WV_NET_RAWIP_MODULE;   /* Value for raw_ip.c */
  124. LOCAL UCHAR wvNetLocalFilter = WV_NET_NONE;     /* Available event filter */
  126. LOCAL ULONG wvNetEventId;       /* Event identifier: see wvNetLib.h */
  127. #endif    /* INCLUDE_WVNET */
  128. #endif
  130. /*
  131.  * Raw interface to IP protocol.
  132.  */
  134. /*
  135.  * Initialize raw connection block q.
  136.  */
  137. void
  138. rip_init()
  139. {
  140. #ifdef WV_INSTRUMENTATION
  141. #ifdef INCLUDE_WVNET    /* WV_NET_VERBOSE event */
  142.     WV_NET_MARKER_0 (NET_AUX_EVENT, WV_NET_VERBOSE, 31, 11,
  143.                      WV_NETEVENT_RAWIPINIT_START)
  144. #endif  /* INCLUDE_WVNET */
  145. #endif
  147. LIST_INIT(&ripcb);
  148.         ripcbinfo.listhead = &ripcb;
  149.         /*
  150.          * XXX We don't use the hash list for raw IP, but it's easier
  151.          * to allocate a one entry hash list than it is to check all
  152.          * over the place for hashbase == NULL.
  153.          */
  154.         ripcbinfo.hashbase = hashinit(1, MT_PCB, &ripcbinfo.hashmask);
  156. #ifdef VIRTUAL_STACK
  157.         rip_sendspace = RIPSNDQ;
  158.         rip_recvspace = RIPRCVQ;
  159.         ripsrc.sin_len = sizeof(struct sockaddr_in);
  160.         ripsrc.sin_family = AF_INET;
  161. #endif /* VIRTUAL_STACK */
  162. }
  164. /*
  165.  * Setup generic address and protocol structures
  166.  * for raw_input routine, then pass them along with
  167.  * mbuf chain.
  168.  */
  169. void
  170. rip_input(m)
  171. struct mbuf *m;
  172. {
  173. register struct ip *ip = mtod(m, struct ip *);
  174. register struct inpcb *inp;
  175. struct socket *last = 0;
  177. #ifdef WV_INSTRUMENTATION
  178. #ifdef INCLUDE_WVNET    /* WV_NET_NOTICE event */
  179.     WV_NET_EVENT_0 (NET_CORE_EVENT, WV_NET_NOTICE, 14, 7,
  180.                      WV_NETEVENT_RAWIPIN_START, WV_NET_RECV)
  181. #endif  /* INCLUDE_WVNET */
  182. #endif
  184. ripsrc.sin_addr = ip->ip_src;
  185.         * (int *)ripsrc.sin_zero = m->m_pkthdr.rcvif->if_index;
  186.         for (inp = ripcb.lh_first; inp != NULL; inp = inp->inp_list.le_next) {
  187. if (inp->inp_ip.ip_p && inp->inp_ip.ip_p != ip->ip_p)
  188. continue;
  189. if (inp->inp_laddr.s_addr &&
  190.     inp->inp_laddr.s_addr != ip->ip_dst.s_addr)
  191. continue;
  192. if (inp->inp_faddr.s_addr &&
  193.     inp->inp_faddr.s_addr != ip->ip_src.s_addr)
  194. continue;
  195. if (last) {
  196. struct mbuf *n;
  197. if ((n = m_copy(m, 0, (int)M_COPYALL))) {
  198. if (sbappendaddr(&last->so_rcv,
  199.     (struct sockaddr *)&ripsrc, n,
  200.     (struct mbuf *)0) == 0)
  201.                                     {
  202. #ifdef WV_INSTRUMENTATION
  203. #ifdef INCLUDE_WVNET    /* WV_NET_WARNING event */
  204.                 WV_NET_ADDRIN_EVENT_3 (NET_CORE_EVENT, WV_NET_WARNING, 9, 6,
  205.                                        ip->ip_src.s_addr, ip->ip_dst.s_addr,
  206.                                        WV_NETEVENT_RAWIPIN_LOST, WV_NET_RECV,
  207.                                        last->so_fd, ip->ip_src.s_addr,
  208.                                        ip->ip_dst.s_addr)
  209. #endif  /* INCLUDE_WVNET */
  210. #endif
  212. /* should notify about lost packet */
  213. m_freem(n);
  214.                                     }
  215. else
  216. sorwakeup(last);
  217. }
  218. }
  219. last = inp->inp_socket;
  220. }
  221. if (last) {
  222. if (sbappendaddr(&last->so_rcv, (struct sockaddr *)&ripsrc,
  223.     m, (struct mbuf *)0) == 0)
  224.                     {
  225. #ifdef WV_INSTRUMENTATION
  226. #ifdef INCLUDE_WVNET    /* WV_NET_WARNING event */
  227.                 WV_NET_ADDRIN_EVENT_3 (NET_CORE_EVENT, WV_NET_WARNING, 9, 6,
  228.                                        ip->ip_src.s_addr, ip->ip_dst.s_addr,
  229.                                        WV_NETEVENT_RAWIPIN_LOST, WV_NET_RECV,
  230.                                        last->so_fd, ip->ip_src.s_addr,
  231.                                        ip->ip_dst.s_addr)
  232. #endif  /* INCLUDE_WVNET */
  233. #endif
  235. m_freem(m);
  236.                     }
  237. else
  238. sorwakeup(last);
  239. } else {
  240. #ifdef WV_INSTRUMENTATION
  241. #ifdef INCLUDE_WVNET    /* WV_NET_ERROR event */
  242.             WV_NET_ADDRIN_EVENT_2 (NET_CORE_EVENT, WV_NET_ERROR, 35, 5,
  243.                                    ip->ip_src.s_addr, ip->ip_dst.s_addr,
  244.                                    WV_NETEVENT_RAWIPIN_NOSOCK, WV_NET_RECV,
  245.                                    ip->ip_src.s_addr, ip->ip_dst.s_addr)
  246. #endif  /* INCLUDE_WVNET */
  247. #endif
  249.                 if ((_icmpErrorHook) && 
  250.     (inetsw[ip_protox[ip->ip_p]].pr_protocol == IPPROTO_RAW))
  251.                     _icmpErrorHook (m, ICMP_UNREACH, ICMP_UNREACH_PROTOCOL, 
  252.                                     ip->ip_src.s_addr, 0);
  253. m_freem(m);
  255. #ifdef VIRTUAL_STACK
  256. _ipstat.ips_noproto++;
  257. _ipstat.ips_delivered--;
  258. #else
  259. ipstat.ips_noproto++;
  260. ipstat.ips_delivered--;
  261. #endif /* VIRTUAL_STACK */
  262. }
  263. return;
  264. }
  266. /*
  267.  * Generate IP header and pass packet to ip_output.
  268.  * Tack on options user may have setup with control call.
  269.  */
  270. int
  271. rip_output(m, so, dst)
  272. register struct mbuf *m;
  273. struct socket *so;
  274. u_long dst;
  275. {
  276. register struct ip *ip;
  277. register struct inpcb *inp = sotoinpcb(so);
  278. struct mbuf *opts;
  279. int flags = (so->so_options & SO_DONTROUTE) | IP_ALLOWBROADCAST;
  280.         int result;
  282. /*
  283.  * If the user handed us a complete IP packet, use it.
  284.  * Otherwise, allocate an mbuf for a header and fill it in.
  285.  */
  286. if ((inp->inp_flags & INP_HDRINCL) == 0) {
  287. M_PREPEND(m, sizeof(struct ip), M_WAIT);
  288. if (m == (struct mbuf *) NULL)
  289.     {
  290.     return (ENOBUFS);
  291.     }
  292.     
  293. ip = mtod(m, struct ip *);
  294. ip->ip_tos = 0;
  295. ip->ip_off = 0;
  296. ip->ip_p = inp->inp_ip.ip_p;
  297. ip->ip_len = m->m_pkthdr.len;
  298. ip->ip_src = inp->inp_laddr;
  299. ip->ip_dst.s_addr = dst;
  300. ip->ip_ttl = inp->inp_ip.ip_ttl;
  302. opts = inp->inp_options;
  303. } else {
  304.         if (m->m_len < sizeof (struct ip) &&
  305.     (m = m_pullup (m, sizeof (struct ip))) == NULL)
  306.     {
  307.     return (ENOBUFS);
  308.     }
  310. ip = mtod(m, struct ip *);
  311. if (ip->ip_id == 0)
  312. #ifdef VIRTUAL_STACK
  313. ip->ip_id = htons(_ip_id++);
  314. #else
  315. ip->ip_id = htons(ip_id++);
  316. #endif /* VIRTUAL_STACK */
  317. opts = NULL;
  318. /* XXX prevent ip_output from overwriting header fields */
  319. flags |= IP_RAWOUTPUT;
  320. #ifdef VIRTUAL_STACK
  321. _ipstat.ips_rawout++;
  322. #else
  323. ipstat.ips_rawout++;
  324. #endif /* VIRTUAL_STACK */
  325. }
  326.     result = ip_output(m, opts, &inp->inp_route, flags, inp->inp_moptions);
  328. #ifdef WV_INSTRUMENTATION
  329. #ifdef INCLUDE_WVNET    /* WV_NET_NOTICE event */
  330.     WV_NET_ADDROUT_EVENT_3 (NET_CORE_EVENT, WV_NET_NOTICE, 15, 8,
  331.                             inp->inp_laddr.s_addr, dst,
  332.                             WV_NETEVENT_RAWIPOUT_FINISH, WV_NET_SEND,
  333.                             result, inp->inp_laddr.s_addr, dst)
  334. #endif  /* INCLUDE_WVNET */
  335. #endif
  337.     return (result);
  338. }
  340. /*
  341.  * Raw IP socket option processing.
  342.  */
  343. int
  344. rip_ctloutput(op, so, level, optname, m)
  345. int op;
  346. struct socket *so;
  347. int level, optname;
  348. struct mbuf **m;
  349. {
  350. register struct inpcb *inp = sotoinpcb(so);
  351. register int error;
  353. #ifdef WV_INSTRUMENTATION
  354. #ifdef INCLUDE_WVNET    /* WV_NET_INFO event */
  355.     WV_NET_MARKER_4 (NET_AUX_EVENT, WV_NET_INFO, 13, 9,
  356.                      WV_NETEVENT_RAWCTLOUT_START,
  357.                      so->so_fd, op, level, optname)
  358. #endif  /* INCLUDE_WVNET */
  359. #endif
  361.         if (level == IPPROTO_ICMP)
  362.             return (icmp_ctloutput (op, so, level, optname, m));
  364. if (level != IPPROTO_IP) {
  365. if (op == PRCO_SETOPT && *m)
  366. (void) m_free(*m);
  367. #ifdef WV_INSTRUMENTATION
  368. #ifdef INCLUDE_WVNET    /* WV_NET_ERROR event */
  369.                 WV_NET_MARKER_4 (NET_AUX_EVENT, WV_NET_ERROR, 32, 2,
  370.                                  WV_NETEVENT_RAWCTLOUT_BADLEVEL,
  371.                                  so->so_fd, op, level, optname)
  372. #endif  /* INCLUDE_WVNET */
  373. #endif
  375. return (EINVAL);
  376. }
  378. switch (optname) {
  380. case IP_HDRINCL:
  381. error = 0;
  382. if (op == PRCO_SETOPT) {
  383. if (*m == 0 || (*m)->m_len < sizeof (int))
  384.                             {
  385. #ifdef WV_INSTRUMENTATION
  386. #ifdef INCLUDE_WVNET    /* WV_NET_ERROR event */
  387.                     WV_NET_MARKER_4 (NET_AUX_EVENT, WV_NET_ERROR, 33, 3,
  388.                                      WV_NETEVENT_RAWCTLOUT_BADMEM,
  389.                                      so->so_fd, op, level, optname)
  390. #endif  /* INCLUDE_WVNET */
  391. #endif
  393. error = EINVAL;
  394.                             }
  395. else if (*mtod(*m, int *))
  396. inp->inp_flags |= INP_HDRINCL;
  397. else
  398. inp->inp_flags &= ~INP_HDRINCL;
  399. if (*m)
  400. (void)m_free(*m);
  401. } else {
  402. *m = mBufClGet(M_WAIT, MT_SOOPTS, CL_SIZE_128, TRUE);
  403. if (*m == (struct mbuf *) NULL)
  404.     {
  405.     error = ENOBUFS;
  406.     }
  407. else
  408.     {
  409.     (*m)->m_len = sizeof (int);
  410.     *mtod(*m, int *) = inp->inp_flags & INP_HDRINCL;
  411.     }
  412. }
  413. return (error);
  415. case MRT_INIT:
  416. case MRT_DONE:
  417. case MRT_ADD_VIF:
  418. case MRT_DEL_VIF:
  419. case MRT_ADD_MFC:
  420. case MRT_DEL_MFC:
  421. case MRT_VERSION:
  422. case MRT_ASSERT:
  424.              return (_mCastCtlOutput (op, optname, so, m));
  426. default:
  427. if (optname >= MRT_INIT)
  428.              return (_mCastCtlOutput (op, optname, so, m));
  429. }
  430. return (ip_ctloutput(op, so, level, optname, m));
  431. }
  433. #ifndef VIRTUAL_STACK
  434. u_long rip_sendspace = RIPSNDQ;
  435. u_long rip_recvspace = RIPRCVQ;
  436. #endif /* VIRTUAL_STACK */
  438. /*ARGSUSED*/
  439. int
  440. rip_usrreq(so, req, m, nam, control)
  441. register struct socket *so;
  442. int req;
  443. struct mbuf *m, *nam, *control;
  444. {
  445. register int error = 0;
  446. register struct inpcb *inp = sotoinpcb(so);
  448. #ifdef WV_INSTRUMENTATION
  449. #ifdef INCLUDE_WVNET    /* WV_NET_INFO event */
  450.     WV_NET_MARKER_2 (NET_CORE_EVENT, WV_NET_INFO, 14, 10,
  451.                      WV_NETEVENT_RAWIPREQ_START, so->so_fd, req)
  452. #endif  /* INCLUDE_WVNET */
  453. #endif
  455.         if (req == PRU_CONTROL)
  456.             return (in_control(so, (u_long)m, (caddr_t)nam,
  457.                     (struct ifnet *)control));
  459. switch (req) {
  461. case PRU_ATTACH:
  462. if (inp)
  463.                     {
  464. #ifdef WV_INSTRUMENTATION
  465. #ifdef INCLUDE_WVNET    /* WV_NET_EMERGENCY event */
  466.                 WV_NET_MARKER_2 (NET_CORE_EVENT, WV_NET_EMERGENCY, 19, 1,
  467.                                  WV_NETEVENT_RAWIPREQ_PANIC, so->so_fd, req)
  468. #endif  /* INCLUDE_WVNET */
  469. #endif
  471. panic("rip_attach");
  472.                     }
  473. if ((so->so_state & SS_PRIV) == 0) {
  474. error = EACCES;
  475. break;
  476. }
  477. if ((error = soreserve(so, rip_sendspace, rip_recvspace)) ||
  478.     (error = in_pcballoc(so, &ripcbinfo)))
  479. break;
  480. inp = (struct inpcb *)so->so_pcb;
  481. inp->inp_ip.ip_p = (int)nam;
  482. inp->inp_ip.ip_ttl = ip_defttl;
  483. break;
  485. case PRU_DISCONNECT:
  486. if ((so->so_state & SS_ISCONNECTED) == 0) {
  487. error = ENOTCONN;
  488. break;
  489. }
  490. /* FALLTHROUGH */
  491. case PRU_ABORT:
  492. soisdisconnected(so);
  493. /* FALLTHROUGH */
  494. case PRU_DETACH:
  495. if (inp == 0)
  496.                     {
  497. #ifdef WV_INSTRUMENTATION
  498. #ifdef INCLUDE_WVNET    /* WV_NET_EMERGENCY event */
  499.                 WV_NET_MARKER_2 (NET_CORE_EVENT, WV_NET_EMERGENCY, 19, 1,
  500.                                  WV_NETEVENT_RAWIPREQ_PANIC, so->so_fd, req)
  501. #endif  /* INCLUDE_WVNET */
  502. #endif
  504. panic("rip_detach");
  505.                     }
  507. in_pcbdetach(inp);
  508. break;
  510. case PRU_BIND:
  511.     {
  512. struct sockaddr_in *addr = mtod(nam, struct sockaddr_in *);
  514. if (nam->m_len != sizeof(*addr)) {
  515. error = EINVAL;
  516. break;
  517. }
  518. #ifdef VIRTUAL_STACK
  519. if ((_ifnet == 0) ||
  520. #else
  521. if ((ifnet == 0) ||
  522. #endif /* VIRTUAL_STACK */
  523.     ((addr->sin_family != AF_INET) &&
  524.      (addr->sin_family != AF_IMPLINK)) ||
  525.     (addr->sin_addr.s_addr &&
  526.      ifa_ifwithaddr((struct sockaddr *)addr) == 0)) {
  527. error = EADDRNOTAVAIL;
  528. break;
  529. }
  530. inp->inp_laddr = addr->sin_addr;
  531. break;
  532.     }
  533. case PRU_CONNECT:
  534.     {
  535. struct sockaddr_in *addr = mtod(nam, struct sockaddr_in *);
  537. if (nam->m_len != sizeof(*addr)) {
  538. error = EINVAL;
  539. break;
  540. }
  541. #ifdef VIRTUAL_STACK
  542. if (_ifnet == 0) {
  543. #else
  544. if (ifnet == 0) {
  545. #endif /* VIRTUAL_STACK */
  546. error = EADDRNOTAVAIL;
  547. break;
  548. }
  549. if ((addr->sin_family != AF_INET) &&
  550.      (addr->sin_family != AF_IMPLINK)) {
  551. error = EAFNOSUPPORT;
  552. break;
  553. }
  554. inp->inp_faddr = addr->sin_addr;
  555. soisconnected(so);
  556. break;
  557.     }
  559. case PRU_CONNECT2:
  560. error = EOPNOTSUPP;
  561. break;
  563. /*
  564.  * Mark the connection as being incapable of further input.
  565.  */
  566. case PRU_SHUTDOWN:
  567. socantsendmore(so);
  568. break;
  570. /*
  571.  * Ship a packet out.  The appropriate raw output
  572.  * routine handles any massaging necessary.
  573.  */
  574. case PRU_SEND:
  575.     {
  576. register u_long dst;
  578. if (so->so_state & SS_ISCONNECTED) {
  579. if (nam) {
  580. error = EISCONN;
  581. break;
  582. }
  583. dst = inp->inp_faddr.s_addr;
  584. } else {
  585. if (nam == NULL) {
  586. error = ENOTCONN;
  587. break;
  588. }
  589. dst = mtod(nam, struct sockaddr_in *)->sin_addr.s_addr;
  590. }
  591. error = rip_output(m, so, dst);
  592. m = NULL;
  593. break;
  594.     }
  596. case PRU_SENSE:
  597. /*
  598.  * stat: don't bother with a blocksize.
  599.  */
  600. return (0);
  602. /*
  603.  * Not supported.
  604.  */
  605. case PRU_RCVOOB:
  606. case PRU_RCVD:
  607. case PRU_LISTEN:
  608. case PRU_ACCEPT:
  609. case PRU_SENDOOB:
  610. error = EOPNOTSUPP;
  611. break;
  613. case PRU_SOCKADDR:
  614. in_setsockaddr(inp, nam);
  615. break;
  617. case PRU_PEERADDR:
  618. in_setpeeraddr(inp, nam);
  619. break;
  621. default:
  622. #ifdef WV_INSTRUMENTATION
  623. #ifdef INCLUDE_WVNET    /* WV_NET_EMERGENCY event */
  624.             WV_NET_MARKER_2 (NET_CORE_EVENT, WV_NET_EMERGENCY, 19, 1,
  625.                              WV_NETEVENT_RAWIPREQ_PANIC, so->so_fd, req)
  626. #endif  /* INCLUDE_WVNET */
  627. #endif
  629. panic("rip_usrreq");
  630. }
  631. if (m != NULL)
  632. m_freem(m);
  634. #ifdef WV_INSTRUMENTATION
  635. #ifdef INCLUDE_WVNET    /* WV_NET_ERROR event */
  636.     if (error)
  637.         {
  638.         WV_NET_MARKER_3 (NET_CORE_EVENT, WV_NET_ERROR, 34, 4,
  639.                          WV_NETEVENT_RAWIPREQ_FAIL, so->so_fd, req, error)
  640.         }
  641. #endif  /* INCLUDE_WVNET */
  642. #endif
  644. return (error);
  645. }
  647. /*******************************************************************************
  648. * mCastCtlOutput - send commands to multicast routing engine.
  649. *
  650. * This function sends commands to multicast routing engine.
  651. *
  652. * INTERNAL
  653. * This function can be further expanded to receive multicast options also.
  654. * That is the reason for passing a pointer to a pointer to an mbuf as one of
  655. * the argument.
  656. *
  657. * RETURNS: OK/ERROR
  658. *
  659. * NOMANUAL
  660. */
  662. static int _mCastCtlOutput
  663.     (
  664.     int  option, /* type of option */
  665.     int  optName, /* name of the option */
  666.     struct socket *  sockPtr, /* pointer to the socket */
  667.     struct mbuf ** pPtrMbuf /* pointer to pointer to an mbuf */
  668.     )
  669.     {
  670.     register int error = EINVAL; /* default error value */
  672.     if (pPtrMbuf == NULL)
  673.         return (error);
  674.     
  675.     if (option == PRCO_SETOPT)
  676.         {
  677.         if (_mCastRouteCmdHook != NULL)
  678.             error = (*_mCastRouteCmdHook)(optName, sockPtr, *pPtrMbuf);
  679.         else
  680.             error = EOPNOTSUPP; 
  681.         }
  683.     if (*pPtrMbuf != NULL)
  684.         (void) m_free (*pPtrMbuf);
  686.     return (error);
  687.     }