Diff for /embedaddon/mpd/src/ccp_pred1.c between versions 1.1 and 1.1.1.2

version 1.1, 2012/02/21 23:32:47 version 1.1.1.2, 2021/03/17 00:39:23
Line 152  Pred1Init(Bund b, int dir) Line 152  Pred1Init(Bund b, int dir)
   
     strlcat(path, ppphook, sizeof(path));      strlcat(path, ppphook, sizeof(path));
   
    id = NgGetNodeID(-1, path);    if ((id = NgGetNodeID(-1, path)) == 0) {
         Perror("[%s] Cannot get %s node id", b->name, NG_PRED1_NODE_TYPE);
         goto fail;
     }
 
     if (dir == COMP_DIR_XMIT) {      if (dir == COMP_DIR_XMIT) {
         b->ccp.comp_node_id = id;          b->ccp.comp_node_id = id;
     } else {      } else {
Line 165  Pred1Init(Bund b, int dir) Line 169  Pred1Init(Bund b, int dir)
             NGM_PRED1_COOKIE, NGM_PRED1_CONFIG, &conf, sizeof(conf)) < 0) {              NGM_PRED1_COOKIE, NGM_PRED1_CONFIG, &conf, sizeof(conf)) < 0) {
         Perror("[%s] can't config %s node at %s",          Perror("[%s] can't config %s node at %s",
             b->name, NG_PRED1_NODE_TYPE, path);              b->name, NG_PRED1_NODE_TYPE, path);
        NgFuncShutdownNode(gCcpCsock, b->name, path);        goto fail;
        return(-1); 
     }      }
 #endif  #endif
     return 0;      return 0;
   
   fail:
       NgFuncShutdownNode(gCcpCsock, b->name, path);
       return(-1);
 }  }
   
 /*  /*
Line 378  Pred1Decompress(Bund b, Mbuf mbcomp) Line 385  Pred1Decompress(Bund b, Mbuf mbcomp)
 static Mbuf  static Mbuf
 Pred1RecvResetReq(Bund b, int id, Mbuf bp, int *noAck)  Pred1RecvResetReq(Bund b, int id, Mbuf bp, int *noAck)
 {  {
     (void)id;
     (void)bp;
     (void)noAck;
 #ifndef USE_NG_PRED1  #ifndef USE_NG_PRED1
   Pred1Info     p = &b->ccp.pred1;    Pred1Info     p = &b->ccp.pred1;
   
     (void)id;
     (void)bp;
     (void)noAck;
   
   Pred1Init(b, COMP_DIR_XMIT);    Pred1Init(b, COMP_DIR_XMIT);
   p->xmit_stats.Errors++;    p->xmit_stats.Errors++;
 #else  #else
     char                path[NG_PATHSIZ];      char                path[NG_PATHSIZ];
   
       (void)id;
       (void)bp;
       (void)noAck;
   
     /* Forward ResetReq to the Predictor1 compression node */      /* Forward ResetReq to the Predictor1 compression node */
     snprintf(path, sizeof(path), "[%x]:", b->ccp.comp_node_id);      snprintf(path, sizeof(path), "[%x]:", b->ccp.comp_node_id);
     if (NgSendMsg(gCcpCsock, path,      if (NgSendMsg(gCcpCsock, path,
Line 391  Pred1RecvResetReq(Bund b, int id, Mbuf bp, int *noAck) Line 411  Pred1RecvResetReq(Bund b, int id, Mbuf bp, int *noAck)
         Perror("[%s] reset to %s node", b->name, NG_PRED1_NODE_TYPE);          Perror("[%s] reset to %s node", b->name, NG_PRED1_NODE_TYPE);
     }      }
 #endif  #endif
return(NULL);    return(NULL);
 }  }
   
 /*  /*
Line 403  Pred1SendResetReq(Bund b) Line 423  Pred1SendResetReq(Bund b)
 {  {
 #ifndef USE_NG_PRED1  #ifndef USE_NG_PRED1
     Pred1Init(b, COMP_DIR_RECV);      Pred1Init(b, COMP_DIR_RECV);
   #else
       (void)b;
 #endif  #endif
     return(NULL);      return(NULL);
 }  }
Line 415  static void Line 437  static void
 Pred1RecvResetAck(Bund b, int id, Mbuf bp)  Pred1RecvResetAck(Bund b, int id, Mbuf bp)
 {  {
 #ifndef USE_NG_PRED1  #ifndef USE_NG_PRED1
       (void)id;
       (void)bp;
     Pred1Init(b, COMP_DIR_RECV);      Pred1Init(b, COMP_DIR_RECV);
 #else  #else
     char                path[NG_PATHSIZ];      char                path[NG_PATHSIZ];
   
       (void)id;
       (void)bp;
   
     /* Forward ResetReq to the Predictor1 decompression node */      /* Forward ResetReq to the Predictor1 decompression node */
     snprintf(path, sizeof(path), "[%x]:", b->ccp.decomp_node_id);      snprintf(path, sizeof(path), "[%x]:", b->ccp.decomp_node_id);
     if (NgSendMsg(gCcpCsock, path,      if (NgSendMsg(gCcpCsock, path,
Line 434  Pred1RecvResetAck(Bund b, int id, Mbuf bp) Line 462  Pred1RecvResetAck(Bund b, int id, Mbuf bp)
 static u_char *  static u_char *
 Pred1BuildConfigReq(Bund b, u_char *cp, int *ok)  Pred1BuildConfigReq(Bund b, u_char *cp, int *ok)
 {  {
     (void)b;
   cp = FsmConfValue(cp, CCP_TY_PRED1, 0, NULL);    cp = FsmConfValue(cp, CCP_TY_PRED1, 0, NULL);
   *ok = 1;    *ok = 1;
   return (cp);    return (cp);
Line 464  Pred1DecodeConfigReq(Fsm fp, FsmOption opt, int mode) Line 493  Pred1DecodeConfigReq(Fsm fp, FsmOption opt, int mode)
 static int  static int
 Pred1Negotiated(Bund b, int dir)  Pred1Negotiated(Bund b, int dir)
 {  {
     (void)b;
     (void)dir;
   
   return 1;    return 1;
 }  }
   
Line 474  Pred1Negotiated(Bund b, int dir) Line 506  Pred1Negotiated(Bund b, int dir)
 static int  static int
 Pred1SubtractBloat(Bund b, int size)  Pred1SubtractBloat(Bund b, int size)
 {  {
     (void)b;
   return(size - 4);    return(size - 4);
 }  }
   

Removed from v.1.1  
changed lines
  Added in v.1.1.1.2


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