sctpserv07.lc 2.7 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849
  1. int## 1 ##src/sctp/sctpserv07.c##
  2. main(int argc, char **argv)## 2 ##src/sctp/sctpserv07.c##
  3. {## 3 ##src/sctp/sctpserv07.c##
  4. int sock_fd, msg_flags;## 4 ##src/sctp/sctpserv07.c##
  5. char readbuf[BUFFSIZE];## 5 ##src/sctp/sctpserv07.c##
  6. struct sockaddr_in cliaddr;## 6 ##src/sctp/sctpserv07.c##
  7. struct sctp_sndrcvinfo sri;## 7 ##src/sctp/sctpserv07.c##
  8. struct sctp_event_subscribe evnts;## 8 ##src/sctp/sctpserv07.c##
  9. socklen_t len;## 9 ##src/sctp/sctpserv07.c##
  10. size_t rd_sz;## 10 ##src/sctp/sctpserv07.c##
  11. /* include mod_serv07 */## 11 ##src/sctp/sctpserv07.c##
  12. if (argc < 2)## 12 ##src/sctp/sctpserv07.c##
  13. err_quit("Error, use %s [list of addresses to bind]\n", argv[0]);## 13 ##src/sctp/sctpserv07.c##
  14. sock_fd = Socket(AF_INET6, SOCK_SEQPACKET, IPPROTO_SCTP);## 14 ##src/sctp/sctpserv07.c##
  15. if (sctp_bind_arg_list(sock_fd, argv + 1, argc - 1))## 15 ##src/sctp/sctpserv07.c##
  16. err_sys("Can't bind the address set");## 16 ##src/sctp/sctpserv07.c##
  17. bzero(&evnts, sizeof(evnts));## 17 ##src/sctp/sctpserv07.c##
  18. evnts.sctp_data_io_event = 1;## 18 ##src/sctp/sctpserv07.c##
  19. /* end mod_serv07 */## 19 ##src/sctp/sctpserv07.c##
  20. evnts.sctp_association_event = 1;## 20 ##src/sctp/sctpserv07.c##
  21. evnts.sctp_address_event = 1;## 21 ##src/sctp/sctpserv07.c##
  22. evnts.sctp_send_failure_event = 1;## 22 ##src/sctp/sctpserv07.c##
  23. evnts.sctp_peer_error_event = 1;## 23 ##src/sctp/sctpserv07.c##
  24. evnts.sctp_shutdown_event = 1;## 24 ##src/sctp/sctpserv07.c##
  25. evnts.sctp_partial_delivery_event = 1;## 25 ##src/sctp/sctpserv07.c##
  26. evnts.sctp_adaption_layer_event = 1;## 26 ##src/sctp/sctpserv07.c##
  27. Setsockopt(sock_fd, IPPROTO_SCTP, SCTP_EVENTS, &evnts, sizeof(evnts));## 27 ##src/sctp/sctpserv07.c##
  28. Listen(sock_fd, LISTENQ);## 28 ##src/sctp/sctpserv07.c##
  29. for (;;) {## 29 ##src/sctp/sctpserv07.c##
  30. len = sizeof(struct sockaddr_in);## 30 ##src/sctp/sctpserv07.c##
  31. rd_sz = Sctp_recvmsg(sock_fd, readbuf, sizeof(readbuf),## 31 ##src/sctp/sctpserv07.c##
  32. (SA *) &cliaddr, &len, &sri, &msg_flags);## 32 ##src/sctp/sctpserv07.c##
  33. if (msg_flags & MSG_NOTIFICATION) {## 33 ##src/sctp/sctpserv07.c##
  34. print_notification(readbuf);## 34 ##src/sctp/sctpserv07.c##
  35. continue;## 35 ##src/sctp/sctpserv07.c##
  36. }## 36 ##src/sctp/sctpserv07.c##
  37. Sctp_sendmsg(sock_fd, readbuf, rd_sz,## 37 ##src/sctp/sctpserv07.c##
  38. (SA *) &cliaddr, len,## 38 ##src/sctp/sctpserv07.c##
  39. sri.sinfo_ppid,## 39 ##src/sctp/sctpserv07.c##
  40. sri.sinfo_flags, sri.sinfo_stream, 0, 0);## 40 ##src/sctp/sctpserv07.c##
  41. }## 41 ##src/sctp/sctpserv07.c##
  42. }## 42 ##src/sctp/sctpserv07.c##