diff options
| author | Ludovic Pouzenc <ludovic@pouzenc.fr> | 2016-07-02 20:31:40 +0200 |
|---|---|---|
| committer | Ludovic Pouzenc <ludovic@pouzenc.fr> | 2016-07-02 20:31:40 +0200 |
| commit | 0545a7e105633763507c24cc45ac03942fb271b3 (patch) | |
| tree | 18b4f6b7cff70ed6700a7178bcefa2d7b0fbf008 /mcastseed/src/mcastseed.c | |
| parent | fb33e6b84719746d22938e2e79c57b5954f63fa4 (diff) | |
| download | eficast-0545a7e105633763507c24cc45ac03942fb271b3.tar.gz eficast-0545a7e105633763507c24cc45ac03942fb271b3.tar.bz2 eficast-0545a7e105633763507c24cc45ac03942fb271b3.zip | |
dgrambuf: full scatter/gather, no ringbuffer. Dummy data to check some code paths.
Diffstat (limited to 'mcastseed/src/mcastseed.c')
| -rw-r--r-- | mcastseed/src/mcastseed.c | 17 |
1 files changed, 12 insertions, 5 deletions
diff --git a/mcastseed/src/mcastseed.c b/mcastseed/src/mcastseed.c index da73353..f86af84 100644 --- a/mcastseed/src/mcastseed.c +++ b/mcastseed/src/mcastseed.c @@ -264,15 +264,22 @@ int start_job() { int send_data() { ssize_t nwrite; - char buf[] = "dataXXXXXXJe suis à la plage."; - int paylen = strlen(buf)-10; + char buf[] = "dataXXXXJe suis à la plage."; + int paylen = strlen(buf)-8; int seq = 1; - //FIXME use http://troydhanson.github.io/tpl/index.html + //XXX Dummy + *( (uint32_t *) buf+1 ) = htonl(3); + sendto(mcast_sock, buf, 8+paylen, 0, mcast_addr->ai_addr, mcast_addr->ai_addrlen); + *( (uint32_t *) buf+1 ) = htonl(4); + sendto(mcast_sock, buf, 8+paylen, 0, mcast_addr->ai_addr, mcast_addr->ai_addrlen); + *( (uint32_t *) buf+1 ) = htonl(2); + sendto(mcast_sock, buf, 8+paylen, 0, mcast_addr->ai_addr, mcast_addr->ai_addrlen); + + *( (uint32_t *) buf+1 ) = htonl(seq); - *( (uint16_t *) buf+4 ) = htons(paylen); - nwrite = sendto(mcast_sock, buf, 10+paylen, 0, mcast_addr->ai_addr, mcast_addr->ai_addrlen); + nwrite = sendto(mcast_sock, buf, 8+paylen, 0, mcast_addr->ai_addr, mcast_addr->ai_addrlen); if ( nwrite < 0 ) { perror("sendto() failed"); return -1; |