BlinkenLib

BlinkenLib/BlinkenRecv.c   1) /* BlinkenLib

BlinkenLib/BlinkenRecv.c   2)    Copyright 2004-2014 Stefan Schuermans <stefan@schuermans.info>

BlinkenLib/BlinkenRecv.c   3)    Copyleft GNU public license - http://www.gnu.org/copyleft/gpl.html
BlinkenLib/BlinkenRecv.c   4)    a blinkenarea.org project */

BlinkenRecv.c              5) 
BlinkenRecv.c              6) #include <stdio.h>
BlinkenRecv.c              7) #include <stdlib.h>
BlinkenRecv.c              8) #include <string.h>

BlinkenRecv.c              9) #ifdef WIN32
BlinkenRecv.c             10) #include <winsock2.h>

BlinkenLib/BlinkenRecv.c  11) #include <ws2tcpip.h>

BlinkenRecv.c             12) #define close closesocket
BlinkenRecv.c             13) #else

BlinkenRecv.c             14) #include <unistd.h>

BlinkenRecv.c             15) #include <sys/types.h>
BlinkenRecv.c             16) #include <sys/socket.h>
BlinkenRecv.c             17) #include <netinet/in.h>
BlinkenRecv.c             18) #include <arpa/inet.h>

BlinkenRecv.c             19) #endif

BlinkenRecv.c             20) 

BlinkenLib/BlinkenRecv.c  21) #include <BlinkenLib/BlinkenLib.h>

BlinkenLib/BlinkenRecv.c  22) #include "Tools2.h"

BlinkenRecv.c             23) 

BlinkenLib/BlinkenRecv.c  24) int main(int argCnt, char **args)

BlinkenRecv.c             25) {

BlinkenLib/BlinkenRecv.c  26)   int i, bound, val, timeout, ipv6;
BlinkenLib/BlinkenRecv.c  27)   SOCKET udpSocket, tmpSock;

BlinkenRecv.c             28)   struct sockaddr_in addr;

BlinkenLib/BlinkenRecv.c  29)   struct sockaddr_in6 addr6;

BlinkenLib/BlinkenRecv.c  30)   stBlinkenMovie *pMovie;
BlinkenLib/BlinkenRecv.c  31) 
BlinkenLib/BlinkenRecv.c  32)   // print info
BlinkenLib/BlinkenRecv.c  33)   printf("BlinkenLib - BlinkenRecv\n"
BlinkenLib/BlinkenRecv.c  34)          "version %d.%d.%d\n"
BlinkenLib/BlinkenRecv.c  35)          "config " BLINKENLIB_CONFIG "\n"

BlinkenLib/BlinkenRecv.c  36)          "Copyright 2004-2014 Stefan Schuermans <stefan@schuermans.info>\n"

BlinkenLib/BlinkenRecv.c  37)          "Copyleft GNU public license - http://www.gnu.org/copyleft/gpl.html\n"

BlinkenLib/BlinkenRecv.c  38)          "a blinkenarea.org project\n\n",
BlinkenLib/BlinkenRecv.c  39)          BLINKENLIB_VERSION_MAJOR, BLINKENLIB_VERSION_MINOR,
BlinkenLib/BlinkenRecv.c  40)          BLINKENLIB_VERSION_REVISION);
BlinkenLib/BlinkenRecv.c  41) 
BlinkenLib/BlinkenRecv.c  42)   // print syntax
BlinkenLib/BlinkenRecv.c  43)   if (argCnt <= 1) {

BlinkenLib/BlinkenRecv.c  44) #ifdef BLINKENLIB_CFG_MNG
BlinkenLib/BlinkenRecv.c  45) # define MNGEXT ", *.mng"
BlinkenLib/BlinkenRecv.c  46) #else
BlinkenLib/BlinkenRecv.c  47) # define MNGEXT

BlinkenLib/BlinkenRecv.c  48) #endif
BlinkenLib/BlinkenRecv.c  49) #ifdef BLINKENLIB_CFG_GIF
BlinkenLib/BlinkenRecv.c  50) # define GIFEXT ", *.gif"
BlinkenLib/BlinkenRecv.c  51) #else
BlinkenLib/BlinkenRecv.c  52) # define GIFEXT

BlinkenLib/BlinkenRecv.c  53) #endif

BlinkenLib/BlinkenRecv.c  54)     printf("syntax: %s <parameter> [...]\n\n"
BlinkenLib/BlinkenRecv.c  55)            "parameters:\n"

BlinkenLib/BlinkenRecv.c  56)            "  -4\n"
BlinkenLib/BlinkenRecv.c  57)            "     use IPv4 (default for now, subject to change)\n"
BlinkenLib/BlinkenRecv.c  58)            "  -6\n"
BlinkenLib/BlinkenRecv.c  59)            "     use IPv6\n"

BlinkenLib/BlinkenRecv.c  60)            "  -l [<ip>:]<port>\n"
BlinkenLib/BlinkenRecv.c  61)            "     local address (defaults to 0.0.0.0:2323)\n"
BlinkenLib/BlinkenRecv.c  62)            "     must occur before -r and -o, may only occur once\n"
BlinkenLib/BlinkenRecv.c  63)            "  -r <ip>[:<port>]\n"
BlinkenLib/BlinkenRecv.c  64)            "     remote addess (defaults to every remote address)\n"
BlinkenLib/BlinkenRecv.c  65)            "  -t <milliseconds>\n"
BlinkenLib/BlinkenRecv.c  66)            "     set timeout (to detect movie end, defaults to 5000)\n"
BlinkenLib/BlinkenRecv.c  67)            "  -o <file>\n"

BlinkenLib/BlinkenRecv.c  68)            "     receive movie and write it to file (*.blm, *.bmm, *.bml, *.bbm" MNGEXT GIFEXT ")\n\n",

BlinkenLib/BlinkenRecv.c  69)            args[0]);

BlinkenRecv.c             70)     return 0;
BlinkenRecv.c             71)   }

BlinkenRecv.c             72) #ifdef WIN32
BlinkenRecv.c             73)   {
BlinkenRecv.c             74)     WSADATA WsaData;

BlinkenLib/BlinkenRecv.c  75)     WSAStartup(0x0101, &WsaData);

BlinkenRecv.c             76)   }
BlinkenRecv.c             77) #endif
BlinkenRecv.c             78) 

BlinkenLib/BlinkenRecv.c  79)   // create UDP socket
BlinkenLib/BlinkenRecv.c  80)   ipv6 = 0;

BlinkenLib/BlinkenRecv.c  81)   udpSocket = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
BlinkenLib/BlinkenRecv.c  82)   if (udpSocket == INVALID_SOCKET) {

BlinkenLib/BlinkenRecv.c  83)     printf("cannot create IPv4 UDP socket\n");

BlinkenRecv.c             84) #ifdef WIN32

BlinkenLib/BlinkenRecv.c  85)     WSACleanup();

BlinkenRecv.c             86) #endif

BlinkenRecv.c             87)     return -1;
BlinkenRecv.c             88)   }
BlinkenRecv.c             89)   bound = 0;
BlinkenRecv.c             90) 

BlinkenLib/BlinkenRecv.c  91)   // process parameters

BlinkenRecv.c             92)   timeout = 5000;

BlinkenLib/BlinkenRecv.c  93)   for (i = 1; i < argCnt; i++) {

BlinkenRecv.c             94) 

BlinkenLib/BlinkenRecv.c  95)     // IPv4
BlinkenLib/BlinkenRecv.c  96)     if (strcmp(args[i], "-4") == 0) {
BlinkenLib/BlinkenRecv.c  97)       if (ipv6) {
BlinkenLib/BlinkenRecv.c  98)         // replace socket with new IPv4 UDP socket
BlinkenLib/BlinkenRecv.c  99)         tmpSock = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
BlinkenLib/BlinkenRecv.c 100)         if (tmpSock != INVALID_SOCKET) {
BlinkenLib/BlinkenRecv.c 101)           close(udpSocket);
BlinkenLib/BlinkenRecv.c 102)           udpSocket = tmpSock;
BlinkenLib/BlinkenRecv.c 103)           ipv6 = 0;
BlinkenLib/BlinkenRecv.c 104)         } else {
BlinkenLib/BlinkenRecv.c 105)           printf("cannot create IPv4 UDP socket\n");
BlinkenLib/BlinkenRecv.c 106)         }
BlinkenLib/BlinkenRecv.c 107)       }
BlinkenLib/BlinkenRecv.c 108)     }
BlinkenLib/BlinkenRecv.c 109)     // IPv6
BlinkenLib/BlinkenRecv.c 110)     else if (strcmp(args[i], "-6") == 0) {
BlinkenLib/BlinkenRecv.c 111)       if (!ipv6) {
BlinkenLib/BlinkenRecv.c 112)         // replace socket with new IPv6 UDP socket
BlinkenLib/BlinkenRecv.c 113)         tmpSock = socket(AF_INET6, SOCK_DGRAM, IPPROTO_UDP);
BlinkenLib/BlinkenRecv.c 114)         if (tmpSock != INVALID_SOCKET) {
BlinkenLib/BlinkenRecv.c 115)           close(udpSocket);
BlinkenLib/BlinkenRecv.c 116)           udpSocket = tmpSock;
BlinkenLib/BlinkenRecv.c 117)           ipv6 = 1;
BlinkenLib/BlinkenRecv.c 118)         } else {
BlinkenLib/BlinkenRecv.c 119)           printf("cannot create IPv6 UDP socket\n");
BlinkenLib/BlinkenRecv.c 120)         }
BlinkenLib/BlinkenRecv.c 121)       }
BlinkenLib/BlinkenRecv.c 122)     }

BlinkenLib/BlinkenRecv.c 123)     // local address

BlinkenLib/BlinkenRecv.c 124)     else if (strcmp(args[i], "-l") == 0) {

BlinkenLib/BlinkenRecv.c 125)       if (i + 1 < argCnt) {

BlinkenRecv.c            126)         i++;

BlinkenLib/BlinkenRecv.c 127)         if (!ipv6) {
BlinkenLib/BlinkenRecv.c 128)           if (!txt2addr(args[i], &addr) ||
BlinkenLib/BlinkenRecv.c 129)               bind(udpSocket, (struct sockaddr *)&addr, sizeof(addr)) != 0)

BlinkenLib/BlinkenRecv.c 130)             printf("could not set local address to \"%s\"\n", args[i]);

BlinkenRecv.c            131)           else
BlinkenRecv.c            132)             bound = 1;

BlinkenLib/BlinkenRecv.c 133)         } else {
BlinkenLib/BlinkenRecv.c 134)           if (!txt2addr6(args[i], &addr6) ||
BlinkenLib/BlinkenRecv.c 135)               bind(udpSocket, (struct sockaddr *)&addr6, sizeof(addr6)) != 0)

BlinkenLib/BlinkenRecv.c 136)             printf("could not set local address to \"%s\"\n", args[i]);

BlinkenRecv.c            137)           else
BlinkenRecv.c            138)             bound = 1;

BlinkenLib/BlinkenRecv.c 139)         }

BlinkenLib/BlinkenRecv.c 140)       } else
BlinkenLib/BlinkenRecv.c 141)         printf("missing local address for \"-l\"\n");

BlinkenRecv.c            142)     }

BlinkenLib/BlinkenRecv.c 143)     // remote address
BlinkenLib/BlinkenRecv.c 144)     else if (strcmp(args[i], "-r") == 0) {
BlinkenLib/BlinkenRecv.c 145)       if (i + 1 < argCnt) {

BlinkenRecv.c            146)         i++;

BlinkenLib/BlinkenRecv.c 147)         if (!ipv6) {
BlinkenLib/BlinkenRecv.c 148)           if (!txt2addr(args[i], &addr) ||
BlinkenLib/BlinkenRecv.c 149)               bind(udpSocket, (struct sockaddr *)&addr, sizeof(addr)) != 0)

BlinkenLib/BlinkenRecv.c 150)             printf("could not set remote address to \"%s\"\n", args[i]);

BlinkenLib/BlinkenRecv.c 151)         } else {
BlinkenLib/BlinkenRecv.c 152)           if (!txt2addr6(args[i], &addr6) ||
BlinkenLib/BlinkenRecv.c 153)               bind(udpSocket, (struct sockaddr *)&addr6, sizeof(addr6)) != 0)

BlinkenLib/BlinkenRecv.c 154)             printf("could not set remote address to \"%s\"\n", args[i]);

BlinkenLib/BlinkenRecv.c 155)         }

BlinkenLib/BlinkenRecv.c 156)       } else
BlinkenLib/BlinkenRecv.c 157)         printf("missing remote address for \"-r\"\n");

BlinkenRecv.c            158)     }

BlinkenLib/BlinkenRecv.c 159)     // timeout
BlinkenLib/BlinkenRecv.c 160)     else if (strcmp(args[i], "-t") == 0) {
BlinkenLib/BlinkenRecv.c 161)       if (i + 1 < argCnt) {

BlinkenRecv.c            162)         i++;

BlinkenLib/BlinkenRecv.c 163)         if (sscanf(args[i], "%u", &val) == 1)

BlinkenRecv.c            164)           timeout = val;
BlinkenRecv.c            165)         else

BlinkenLib/BlinkenRecv.c 166)           printf("invalid timeout value \"%s\"\n", args[i]);
BlinkenLib/BlinkenRecv.c 167)       } else
BlinkenLib/BlinkenRecv.c 168)         printf("missing timeout value for \"-t\"\n");

BlinkenRecv.c            169)     }

BlinkenLib/BlinkenRecv.c 170)     // receive movie and write it to file
BlinkenLib/BlinkenRecv.c 171)     else if (strcmp(args[i], "-o") == 0) {
BlinkenLib/BlinkenRecv.c 172)       if (i + 1 < argCnt) {

BlinkenRecv.c            173)         i++;

BlinkenLib/BlinkenRecv.c 174)         if (!bound)     // try to bind if not bound

BlinkenRecv.c            175)         {

BlinkenLib/BlinkenRecv.c 176)           if (!ipv6) {
BlinkenLib/BlinkenRecv.c 177)             printf("no local address to receive movie for file \"%s\" to,\n"
BlinkenLib/BlinkenRecv.c 178)                    "  using default local address \"0.0.0.0:2323\"\n",
BlinkenLib/BlinkenRecv.c 179)                    args[i]);
BlinkenLib/BlinkenRecv.c 180)             if (!txt2addr("127.0.0.1:2323", &addr) ||
BlinkenLib/BlinkenRecv.c 181)                 bind(udpSocket, (struct sockaddr *)&addr, sizeof(addr)) != 0)
BlinkenLib/BlinkenRecv.c 182)               printf("could not set local address to \"127.0.0.1:2323\"\n");
BlinkenLib/BlinkenRecv.c 183)             else
BlinkenLib/BlinkenRecv.c 184)               bound = 1;
BlinkenLib/BlinkenRecv.c 185)           } else {
BlinkenLib/BlinkenRecv.c 186)             printf("no local address to receive movie for file \"%s\" to,\n"
BlinkenLib/BlinkenRecv.c 187)                    "  using default local address \"[::1]:2323\"\n",
BlinkenLib/BlinkenRecv.c 188)                    args[i]);
BlinkenLib/BlinkenRecv.c 189)             if (!txt2addr6("[::1]:2323", &addr6) ||
BlinkenLib/BlinkenRecv.c 190)                 bind(udpSocket, (struct sockaddr *)&addr6, sizeof(addr6)) != 0)
BlinkenLib/BlinkenRecv.c 191)               printf("could not set local address to \"[::1]:2323\"\n");
BlinkenLib/BlinkenRecv.c 192)             else
BlinkenLib/BlinkenRecv.c 193)               bound = 1;
BlinkenLib/BlinkenRecv.c 194)           }

BlinkenRecv.c            195)         }

BlinkenLib/BlinkenRecv.c 196)         if (bound) {
BlinkenLib/BlinkenRecv.c 197)           printf("receiving movie for file \"%s\"...\n", args[i]);
BlinkenLib/BlinkenRecv.c 198)           pMovie = BlinkenMovieReceive(udpSocket, timeout, NULL);
BlinkenLib/BlinkenRecv.c 199)           if (pMovie == NULL)
BlinkenLib/BlinkenRecv.c 200)             printf("could not receive movie for file \"%s\"\n", args[i]);
BlinkenLib/BlinkenRecv.c 201)           else {
BlinkenLib/BlinkenRecv.c 202)             if (BlinkenMovieSave(pMovie, args[i]) < 0)
BlinkenLib/BlinkenRecv.c 203)               printf("could not write movie \"%s\"\n", args[i]);

BlinkenRecv.c            204)             else

BlinkenLib/BlinkenRecv.c 205)               printf("movie \"%s\" written\n", args[i]);
BlinkenLib/BlinkenRecv.c 206)             BlinkenMovieFree(pMovie);

BlinkenRecv.c            207)           }

BlinkenLib/BlinkenRecv.c 208)         } else
BlinkenLib/BlinkenRecv.c 209)           printf("no local address set to receive movie for file \"%s\" on\n",
BlinkenLib/BlinkenRecv.c 210)                  args[i]);
BlinkenLib/BlinkenRecv.c 211)       } else
BlinkenLib/BlinkenRecv.c 212)         printf("missing output filename for \"-o\"\n");

BlinkenRecv.c            213)     }

BlinkenLib/BlinkenRecv.c 214)     // unknown parameter

BlinkenRecv.c            215)     else

BlinkenLib/BlinkenRecv.c 216)       printf
BlinkenLib/BlinkenRecv.c 217)           ("unknown parameter \"%s\", call without parameters to get help\n",
BlinkenLib/BlinkenRecv.c 218)            args[i]);

BlinkenRecv.c            219) 

BlinkenLib/BlinkenRecv.c 220)   }     // for( i ...

BlinkenRecv.c            221) 

BlinkenLib/BlinkenRecv.c 222)   // close socket
BlinkenLib/BlinkenRecv.c 223)   close(udpSocket);

BlinkenRecv.c            224) 

BlinkenRecv.c            225) #ifdef WIN32

BlinkenLib/BlinkenRecv.c 226)   WSACleanup();

BlinkenRecv.c            227) #endif