收到回调的usrsctp数据的c参数值变得毫无意义

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 %un",
          (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 %un",
        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

为什么参数值在回调函数中变得毫无意义？

我在这里找到了一个类似的问题，但无法理解它的答案。我确信这是同一个问题。

[更新1]

usrsctp.h:中usrsctp_socket的原型

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);

[更新2]

我非常确信，不需要像旧的类似线程中建议的那样使用额外的技巧，因为我在官方示例中没有看到奇怪的铸件，它们只是工作得很好。

例如在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

好吧，我自己也弄清楚了原因。这很傻，但我会在这里张贴解决方案，以防有人需要。

union 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）可以解决问题。