usrsctp数据收到回调参数值变成废话

Question

我最近正在基于usrsctp的项目工作。

当创建一个新的SCTP套接字时，可以指定一个回调函数，当新数据可用时将会调用该函数，如下面的代码所示。

创建一个新的SCTP套接字：

struct socket *s = usrsctp_socket(AF_CONN, SOCK_STREAM, IPPROTO_SCTP, 
            sctp_data_received_cb, NULL, 0, sctp); 

回调函数：

static int 
sctp_data_received_cb(struct socket *sock, union sctp_sockstore addr, void *data, 
        size_t len, struct sctp_rcvinfo recv_info, int flags, void *user_data) 
{ 
    struct sctp_transport *sctp = (struct sctp_transport *)user_data; 
    if (sctp == NULL || len == 0) 
    return -1; 

    fprintf(stdout, "Data of length %u received on stream %u with SSN %u, TSN %u, PPID %u\n", 
      (uint32_t)len, 
      recv_info.rcv_sid, 
      recv_info.rcv_ssn, 
      recv_info.rcv_tsn, 
      ntohl(recv_info.rcv_ppid)); 

    if (flags & MSG_NOTIFICATION) 
    handle_notification_message(sctp, (union sctp_notification *)data, len); 
    else 
    handle_rtcdc_message(sctp, data, len, ntohl(recv_info.rcv_ppid), recv_info.rcv_sid); 

    free(data); 
    return 0; 
} 

这个回调函数将被正常调用，但是它的参数值都只是无稽之谈。上面的代码的输出是等

Data of length 675381504 received on stream 31504 with SSN 34835, TSN 32651, PPID 8470824

应该一直喜欢

Data of length 18 received on stream 0 with SSN 0, TSN 4117987333, PPID 50

我读usrsctp的源代码，并发现其中的回调被调用：

if (control->spec_flags & M_NOTIFICATION) { 
    flags |= MSG_NOTIFICATION; 
} 
inp->recv_callback(so, addr, buffer, control->length, rcv, flags, inp->ulp_info); 
SCTP_TCB_LOCK(stcb); 

将其更改为以下代码并重新编译库

if (control->spec_flags & M_NOTIFICATION) { 
    flags |= MSG_NOTIFICATION; 
} 
fprintf(stdout, "[LIB] Data of length %u received on stream %u with SSN %u, TSN %u, PPID %u\n", 
     control->length, 
     rcv.rcv_sid, 
     rcv.rcv_ssn, 
     rcv.rcv_tsn, 
     ntohl(rcv.rcv_ppid)); 
inp->recv_callback(so, addr, buffer, control->length, rcv, flags, inp->ulp_info); 
SCTP_TCB_LOCK(stcb); 

我能得到预期的输出：

[LIB] Data of length 18 received on stream 0 with SSN 0, TSN 4117987333, PPID 50

为什么参数值成为回调函数废话？

我发现了一个类似的问题here，但无法理解它的答案。我很肯定这是同一个问题。

[UPDATE1]

usrsctp_socket的usrsctp.h原型：

struct socket * 
usrsctp_socket(int domain, int type, int protocol, 
      int (*receive_cb)(struct socket *sock, union sctp_sockstore addr, void *data, 
          size_t datalen, struct sctp_rcvinfo, int flags, void *ulp_info), 
      int (*send_cb)(struct socket *sock, uint32_t sb_free), 
      uint32_t sb_threshold, 
      void *ulp_info); 

[UPDATE2]

我敢肯定，需要在the old similar thread提示没有额外的技巧，因为我在official examples中看到没有奇怪的铸件，他们只是运作良好。

例如echo_server.c：

static int 
receive_cb(struct socket *sock, union sctp_sockstore addr, void *data, 
      size_t datalen, struct sctp_rcvinfo rcv, int flags, void *ulp_info) 
{ 
    char namebuf[INET6_ADDRSTRLEN]; 
    const char *name; 
    uint16_t port; 

    if (data) { 
    if (flags & MSG_NOTIFICATION) { 
     printf("Notification of length %d received.\n", (int)datalen); 
    } else { 
     switch (addr.sa.sa_family) { 
#ifdef INET 
     case AF_INET: 
     name = inet_ntop(AF_INET, &addr.sin.sin_addr, namebuf, INET_ADDRSTRLEN); 
     port = ntohs(addr.sin.sin_port); 
     break; 
#endif 
#ifdef INET6 
     case AF_INET6: 
     name = inet_ntop(AF_INET6, &addr.sin6.sin6_addr, namebuf, INET6_ADDRSTRLEN), 
     port = ntohs(addr.sin6.sin6_port); 
     break; 
#endif 
     case AF_CONN: 
#ifdef _WIN32 
     _snprintf(namebuf, INET6_ADDRSTRLEN, "%p", addr.sconn.sconn_addr); 
#else 
     snprintf(namebuf, INET6_ADDRSTRLEN, "%p", addr.sconn.sconn_addr); 
#endif 
     name = namebuf; 
     port = ntohs(addr.sconn.sconn_port); 
     break; 
     default: 
     name = NULL; 
     port = 0; 
     break; 
     } 
     printf("Msg of length %d received from %s:%u on stream %d with SSN %u and TSN %u, PPID %d, context %u.\n", 
      (int)datalen, 
      name, 
      port, 
      rcv.rcv_sid, 
      rcv.rcv_ssn, 
      rcv.rcv_tsn, 
      ntohl(rcv.rcv_ppid), 
      rcv.rcv_context); 
     if (flags & MSG_EOR) { 
     struct sctp_sndinfo snd_info; 

     snd_info.snd_sid = rcv.rcv_sid; 
     snd_info.snd_flags = 0; 
     if (rcv.rcv_flags & SCTP_UNORDERED) { 
      snd_info.snd_flags |= SCTP_UNORDERED; 
     } 
     snd_info.snd_ppid = rcv.rcv_ppid; 
     snd_info.snd_context = 0; 
     snd_info.snd_assoc_id = rcv.rcv_assoc_id; 
     if (usrsctp_sendv(sock, data, datalen, NULL, 0, &snd_info, sizeof(struct sctp_sndinfo), SCTP_SENDV_SNDINFO, 0) < 0) { 
      perror("sctp_sendv"); 
     } 
     } 
    } 
    free(data); 
    } 
    return (1); 
} 

Answer 1

OK，我想通了，为什么我自己。这很愚蠢，但我会在这里发布解决方案，以防有人需要它。

联合sctp_sockstore（回调函数的第二个参数的类型）的定义如下所示。

union sctp_sockstore { 
#if defined(INET) 
    struct sockaddr_in sin; 
#endif 
#if defined(INET6) 
    struct sockaddr_in6 sin6; 
#endif 
    struct sockaddr_conn sconn; 
    struct sockaddr sa; 
}; 

INET和INET6在usrsctp库，但不是在我的代码中定义的，因为我手工制作的Makefile文件和省略它们。由于工会的规模不同，参数发生了偏移（如16位），因此变得无稽之谈。

当您编译自己的代码时，定义INET和INET6（特别是INET6）可以解决问题。