[BACK]Return to fwsync.c CVS log [TXT] [DIR] Up to [ELWIX - Embedded LightWeight unIX -] / fwsync / driver

Diff for /fwsync/driver/fwsync.c between versions 1.6 and 1.7

version 1.6, 2022/07/15 09:19:25 version 1.7, 2022/08/04 00:24:39
Line 5 Line 5
 #include "fwsync.h"  #include "fwsync.h"
   
   
 static intptr_t fwsync_wchan;  
   
   
 static void  static void
 fwsync_edge_proc(void *arg)  fwsync_edge_proc(void *arg)
 {  {
Line 18  fwsync_edge_proc(void *arg) Line 15  fwsync_edge_proc(void *arg)
   
         DTRACE();          DTRACE();
   
           callout_schedule(&fws_co, hz);
   
         memset(&uio, 0, sizeof uio);          memset(&uio, 0, sizeof uio);
         uio.uio_resid = 1000000000;          uio.uio_resid = 1000000000;
         uio.uio_td = curthread;          uio.uio_td = curthread;
   
        fws_ctx.config |= CTX_EDGE_ONLINE;        if ((fws_cfg.cfg.on & CFG_SYNC_EDGE) && (fws_ctx.config & CTX_EDGE_READY)) {
        while ((fws_cfg.cfg.on & CFG_SYNC_EDGE) && (fws_ctx.config & CTX_EDGE_READY)) { 
                if (m) 
                        m_freem(m); 
                m = NULL; 
                 rcvflg = MSG_DONTWAIT;                  rcvflg = MSG_DONTWAIT;
                 e = soreceive(fws_ctx.sockz[CFG_SYNC_ADDR_EDGE], NULL, &uio, &m, NULL, &rcvflg);                  e = soreceive(fws_ctx.sockz[CFG_SYNC_ADDR_EDGE], NULL, &uio, &m, NULL, &rcvflg);
                 if (e) {                  if (e) {
                         if (e != EAGAIN)                          if (e != EAGAIN)
                                 printf("error in edge handler #%d\n", e);                                  printf("error in edge handler #%d\n", e);
                        tsleep(&fwsync_wchan, 0, "edge_handler", hz);                        return;
                        continue; 
                 }                  }
                 pkt = mtod(m, struct fws_proto*);                  pkt = mtod(m, struct fws_proto*);
                 if (m_length(m, NULL) != sizeof(struct fws_proto)) {                  if (m_length(m, NULL) != sizeof(struct fws_proto)) {
                         printf("FWSync packet length=%d isn't match expected %lu\n",                           printf("FWSync packet length=%d isn't match expected %lu\n", 
                                         m_length(m, NULL), sizeof(struct fws_proto));                                          m_length(m, NULL), sizeof(struct fws_proto));
                        continue;                        return;
                 }                  }
   
                   printf("%u...-> %s version=%c\n", m->m_len, m->m_data, pkt->fws_version);
   
                 switch (pkt->fws_version) {                  switch (pkt->fws_version) {
                         case FWS_PKTVER_STATE:                          case FWS_PKTVER_STATE:
                                 fwsync_add_state(pkt);                                  fwsync_add_state(pkt);
Line 51  fwsync_edge_proc(void *arg) Line 47  fwsync_edge_proc(void *arg)
                                 break;                                  break;
                         default:                          default:
                                 printf("FWSync packet was discarded due to wrong version\n");                                  printf("FWSync packet was discarded due to wrong version\n");
                                continue;                                return;
                 }                  }
   
                 printf("%u...-> %s version=%c\n", m->m_len, m->m_data, pkt->fws_version);  
         }          }
         fws_ctx.config &= ~CTX_EDGE_ONLINE;  
   
         kproc_exit(0);  
 }  }
   
 int  int
Line 175  fwsync_destroy(struct ip_fw_chain *ch, ip_fw3_opheader Line 166  fwsync_destroy(struct ip_fw_chain *ch, ip_fw3_opheader
                 fws_cfg.cfg.addrs = 0;                  fws_cfg.cfg.addrs = 0;
                 memset(fws_cfg.cfg_addr, 0, sizeof fws_cfg.cfg_addr[0]);                  memset(fws_cfg.cfg_addr, 0, sizeof fws_cfg.cfg_addr[0]);
   
                if (fws_ctx.config & CTX_EDGE_READY) {                if (fws_ctx.config & CTX_EDGE_ONLINE) {
                         callout_drain(&fws_co);
                         soshutdown(fws_ctx.sockz[CFG_SYNC_ADDR_EDGE], SHUT_RD);                          soshutdown(fws_ctx.sockz[CFG_SYNC_ADDR_EDGE], SHUT_RD);
                         tsleep(&fwsync_wchan, 0, "fwsedge_kill", 2 * hz);  
                         soclose(fws_ctx.sockz[CFG_SYNC_ADDR_EDGE]);                          soclose(fws_ctx.sockz[CFG_SYNC_ADDR_EDGE]);
                 }                  }
         }          }
Line 252  fwsync_list(struct ip_fw_chain *ch, ip_fw3_opheader *o Line 243  fwsync_list(struct ip_fw_chain *ch, ip_fw3_opheader *o
 int  int
 fwsync_start(struct ip_fw_chain *ch, ip_fw3_opheader *op3, struct sockopt_data *sd)  fwsync_start(struct ip_fw_chain *ch, ip_fw3_opheader *op3, struct sockopt_data *sd)
 {  {
        int *n, e;        int *n;
         ipfw_obj_header *oh;          ipfw_obj_header *oh;
         size_t sz;          size_t sz;
   
Line 273  fwsync_start(struct ip_fw_chain *ch, ip_fw3_opheader * Line 264  fwsync_start(struct ip_fw_chain *ch, ip_fw3_opheader *
   
         if ((*n & CFG_SYNC_EDGE) && (fws_ctx.config & CTX_EDGE_READY)) {          if ((*n & CFG_SYNC_EDGE) && (fws_ctx.config & CTX_EDGE_READY)) {
                 fws_cfg.cfg.on |= CFG_SYNC_EDGE;                  fws_cfg.cfg.on |= CFG_SYNC_EDGE;
                   fws_ctx.config |= CTX_EDGE_ONLINE;
   
                e = kproc_create(fwsync_edge_proc, NULL, &fws_ctx.procz[CFG_SYNC_ADDR_EDGE],                 callout_reset(&fws_co, hz, fwsync_edge_proc, NULL);
                                0, 0, "fwsync_edge"); 
                if (e) { 
                        printf("fwsync fwsync_edge failed #%d\n", e); 
                        return e; 
                } 
         }          }
   
         if ((*n & CFG_SYNC_COLLECTOR) && (fws_ctx.config & CTX_COLLECTOR_1_READY)) {          if ((*n & CFG_SYNC_COLLECTOR) && (fws_ctx.config & CTX_COLLECTOR_1_READY)) {
Line 329  fwsync_stop(struct ip_fw_chain *ch, ip_fw3_opheader *o Line 316  fwsync_stop(struct ip_fw_chain *ch, ip_fw3_opheader *o
   
         n = (int*) (oh + 1);          n = (int*) (oh + 1);
   
        if ((*n & CFG_SYNC_EDGE) && (fws_ctx.config & CTX_CFG_EDGE))        if ((*n & CFG_SYNC_EDGE) && (fws_ctx.config & CTX_CFG_EDGE)) {
                 fws_cfg.cfg.on &= ~CFG_SYNC_EDGE;                  fws_cfg.cfg.on &= ~CFG_SYNC_EDGE;
                   fws_ctx.config &= ~CTX_EDGE_ONLINE;
   
                   callout_drain(&fws_co);
           }
   
         if ((*n & CFG_SYNC_COLLECTOR) && (fws_ctx.config & CTX_COLLECTOR_2_ONLINE))          if ((*n & CFG_SYNC_COLLECTOR) && (fws_ctx.config & CTX_COLLECTOR_2_ONLINE))
                 fws_ctx.config &= ~CTX_COLLECTOR_2_ONLINE;                  fws_ctx.config &= ~CTX_COLLECTOR_2_ONLINE;
Removed from v.1.6  
changed lines
  Added in v.1.7

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>