[BACK]Return to netisr.c CVS log [TXT] [DIR] Up to [DragonFly] / src / sys / net

Diff for /src/sys/net/netisr.c between versions 1.8 and 1.9

version 1.8, 2004/03/06 01:58:54 version 1.9, 2004/03/06 19:40:30
Line 11 Line 11
 #include <sys/kernel.h>  #include <sys/kernel.h>
 #include <sys/malloc.h>  #include <sys/malloc.h>
 #include <sys/msgport.h>  #include <sys/msgport.h>
 #include <sys/msgport2.h>  
 #include <sys/proc.h>  #include <sys/proc.h>
 #include <sys/interrupt.h>  #include <sys/interrupt.h>
 #include <sys/socket.h>  #include <sys/socket.h>
Line 22 Line 21
 #include <machine/cpufunc.h>  #include <machine/cpufunc.h>
 #include <machine/ipl.h>  #include <machine/ipl.h>
   
   #include <sys/thread2.h>
   #include <sys/msgport2.h>
   
 static struct netisr netisrs[NETISR_MAX];  static struct netisr netisrs[NETISR_MAX];
   
 /* Per-CPU thread to handle any protocol.  */  /* Per-CPU thread to handle any protocol.  */
 struct thread netisr_cpu[MAXCPU];  struct thread netisr_cpu[MAXCPU];
   lwkt_port netisr_afree_rport;
   
   /*
    * netisr_afree_rport replymsg function, only used to handle async
    * messages which the sender has abandoned to their fate.
    */
   static void
   netisr_autofree_reply(lwkt_port_t port, lwkt_msg_t msg)
   {
       free(msg, M_LWKTMSG);
   }
   
 static void  static void
 netisr_init(void)  netisr_init(void)
Line 33  netisr_init(void) Line 46  netisr_init(void)
     int i;      int i;
   
     /* Create default per-cpu threads for generic protocol handling. */      /* Create default per-cpu threads for generic protocol handling. */
     for (i = 0; i < ncpus; ++i)      for (i = 0; i < ncpus; ++i) {
         lwkt_create(netmsg_service_loop, NULL, NULL, &netisr_cpu[i], 0, i,          lwkt_create(netmsg_service_loop, NULL, NULL, &netisr_cpu[i], 0, i,
             "netisr_cpu %d", i);              "netisr_cpu %d", i);
       }
       lwkt_initport(&netisr_afree_rport, NULL);
       netisr_afree_rport.mp_replyport = netisr_autofree_reply;
 }  }
   
 SYSINIT(netisr, SI_SUB_PROTO_BEGIN, SI_ORDER_FIRST, netisr_init, NULL);  SYSINIT(netisr, SI_SUB_PROTO_BEGIN, SI_ORDER_FIRST, netisr_init, NULL);
Line 44  void Line 60  void
 netmsg_service_loop(void *arg)  netmsg_service_loop(void *arg)
 {  {
     struct netmsg *msg;      struct netmsg *msg;
       int error;
   
     while ((msg = lwkt_waitport(&curthread->td_msgport, NULL))) {      while ((msg = lwkt_waitport(&curthread->td_msgport, NULL))) {
         msg->nm_handler(msg);          error = msg->nm_handler(msg);
         if (msg->nm_lmsg.ms_flags & MSGF_ASYNC)          lwkt_replymsg(&msg->nm_lmsg, error);
             free(msg, M_LWKTMSG);  
     }      }
 }  }
   
Line 91  netisr_queue(int num, struct mbuf *m) Line 107  netisr_queue(int num, struct mbuf *m)
     if (!(pmsg = malloc(sizeof(struct netmsg_packet), M_LWKTMSG, M_NOWAIT)))      if (!(pmsg = malloc(sizeof(struct netmsg_packet), M_LWKTMSG, M_NOWAIT)))
         return (ENOBUFS);          return (ENOBUFS);
   
     lwkt_initmsg(&pmsg->nm_lmsg, port, CMD_NETMSG_NEWPKT);      lwkt_initmsg_rp(&pmsg->nm_lmsg, &netisr_afree_rport, CMD_NETMSG_NEWPKT);
     pmsg->nm_packet = m;      pmsg->nm_packet = m;
     pmsg->nm_handler = ni->ni_handler;      pmsg->nm_handler = ni->ni_handler;
     lwkt_sendmsg(port, &pmsg->nm_lmsg);      lwkt_sendmsg(port, &pmsg->nm_lmsg);
Line 151  schednetisr(int num) Line 167  schednetisr(int num)
     if (!(pmsg = malloc(sizeof(struct netmsg), M_LWKTMSG, M_NOWAIT)))      if (!(pmsg = malloc(sizeof(struct netmsg), M_LWKTMSG, M_NOWAIT)))
         return;          return;
   
     lwkt_initmsg(&pmsg->nm_lmsg, port, CMD_NETMSG_POLL);      lwkt_initmsg_rp(&pmsg->nm_lmsg, &netisr_afree_rport, CMD_NETMSG_POLL);
     pmsg->nm_handler = ni->ni_handler;      pmsg->nm_handler = ni->ni_handler;
     lwkt_sendmsg(port, &pmsg->nm_lmsg);      lwkt_sendmsg(port, &pmsg->nm_lmsg);
 }  }
Removed from v.1.8  
changed lines
  Added in v.1.9