Changeset eb70703
- Timestamp:
- 11/14/17 11:31:09 (3 years ago)
- Branches:
- cachetimestamps, develop, dpdk-ndag, etsilive, master, ndag_format, rc-4.0.2, rc-4.0.3, rc-4.0.4, ringdecrementfix, ringperformance
- Children:
- 07de3c6
- Parents:
- 5d8280a
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
lib/format_ndag.c
r5d8280a reb70703 698 698 ssock->mmsgbufs[i].msg_hdr.msg_iov = (struct iovec *) 699 699 malloc(sizeof(struct iovec)); 700 ssock->mmsgbufs[i].msg_hdr.msg_name = ssock->srcaddr->ai_addr; 701 ssock->mmsgbufs[i].msg_hdr.msg_namelen = ssock->srcaddr->ai_addrlen; 702 ssock->mmsgbufs[i].msg_hdr.msg_control = NULL; 703 ssock->mmsgbufs[i].msg_hdr.msg_controllen = 0; 704 ssock->mmsgbufs[i].msg_hdr.msg_flags = 0; 705 ssock->mmsgbufs[i].msg_len = 1; 700 706 } 701 707 … … 761 767 } 762 768 763 static int init_receivers(streamsock_t *ssock) { 769 static void init_receivers(streamsock_t *ssock, int required) { 770 771 int wind = ssock->nextwriteind; 772 int i; 773 774 for (i = 0; i < required; i++) { 775 ssock->mmsgbufs[i].msg_len = 0; 776 ssock->mmsgbufs[i].msg_hdr.msg_iov->iov_base = ssock->saved[wind]; 777 ssock->mmsgbufs[i].msg_hdr.msg_iov->iov_len = ENCAP_BUFSIZE; 778 ssock->mmsgbufs[i].msg_hdr.msg_iovlen = 1; 779 780 wind ++; 781 } 782 } 783 784 static int count_receivers(streamsock_t *ssock) { 764 785 765 786 int wind = ssock->nextwriteind; … … 776 797 break; 777 798 } 778 779 ssock->mmsgbufs[i].msg_len = 0;780 ssock->mmsgbufs[i].msg_hdr.msg_name = ssock->srcaddr->ai_addr;781 ssock->mmsgbufs[i].msg_hdr.msg_namelen = ssock->srcaddr->ai_addrlen;782 ssock->mmsgbufs[i].msg_hdr.msg_iov->iov_base = ssock->saved[wind];783 ssock->mmsgbufs[i].msg_hdr.msg_iov->iov_len = ENCAP_BUFSIZE;784 ssock->mmsgbufs[i].msg_hdr.msg_iovlen = 1;785 ssock->mmsgbufs[i].msg_hdr.msg_control = NULL;786 ssock->mmsgbufs[i].msg_hdr.msg_controllen = 0;787 ssock->mmsgbufs[i].msg_hdr.msg_flags = 0;788 799 789 800 avail ++; … … 872 883 } 873 884 874 avail = init_receivers(ssock);885 avail = count_receivers(ssock); 875 886 876 887 if (avail == 0) { … … 883 894 return 1; 884 895 } 896 897 init_receivers(ssock, avail); 885 898 886 899 ret = recvmmsg(ssock->sock, ssock->mmsgbufs, avail,
Note: See TracChangeset
for help on using the changeset viewer.