src/ics.c

   1 /* vim:tw=78:ts=8:sw=4:set ft=c:  */
   2 /*
   3     Copyright (C) 2002-2006 Ben Kibbey <bjk@arbornet.org>
   4
   5     This program is free software; you can redistribute it and/or modify
   6     it under the terms of the GNU General Public License as published by
   7     the Free Software Foundation; either version 2 of the License, or
   8     (at your option) any later version.
   9
  10     This program is distributed in the hope that it will be useful,
  11     but WITHOUT ANY WARRANTY; without even the implied warranty of
  12     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  13     GNU General Public License for more details.
  14
  15     You should have received a copy of the GNU General Public License
  16     along with this program; if not, write to the Free Software
  17     Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  18 */
  19 #include <stdio.h>
  20 #include <stdlib.h>
  21 #include <unistd.h>
  22 #include <err.h>
  23 #include <errno.h>
  24 #include <sys/types.h>
  25 #include <sys/socket.h>
  26 #include <netinet/in.h>
  27 #include <arpa/inet.h>
  28 #include <netdb.h>
  29 #include <string.h>
  30 #include <sys/time.h>
  31 #include <fcntl.h>
  32
  33 #ifdef HAVE_CONFIG_H
  34 #include <config.h>
  35 #endif
  36
  37 #include "common.h"
  38 #include "ics.h"
  39
  40 int parse_ics_output(char *str)
  41 {
  42     return 0;
  43 }
  44
  45 int send_to_ics(int sockfd, const char *format, ...)
  46 {
  47     va_list ap;
  48     int len;
  49     char *line;
  50     int try = 0;
  51
  52     va_start(ap, format);
  53 #ifdef HAVE_VASPRINTF
  54     len = vasprintf(&line, format, ap);
  55 #else
  56     line = Malloc(LINE_MAX);
  57     len = vsnprintf(line, LINE_MAX, format, ap);
  58 #endif
  59     va_end(ap);
  60
  61     while (1) {
  62         int n;
  63         fd_set fds;
  64         struct timeval tv;
  65
  66         FD_ZERO(&fds);
  67         FD_SET(sockfd, &fds);
  68
  69         tv.tv_sec = 0;
  70         tv.tv_usec = 0;
  71
  72         if ((n = select(sockfd + 1, NULL, &fds, NULL, &tv)) > 0) {
  73             if (FD_ISSET(sockfd, &fds)) {
  74                 n = send(sockfd, line, len, 0);
  75
  76                 if (n == -1) {
  77                     if (errno == EAGAIN)
  78                         continue;
  79
  80                     message(ERROR, ANYKEY, "Attempt #%i. send(): %s", ++try,
  81                             strerror(errno));
  82                     continue;
  83                 }
  84
  85                 if (len != n) {
  86                     message(NULL, ANYKEY, "try #%i: send() error to socket. "
  87                             "Expected %i, got %i.", ++try, len, n);
  88                     continue;
  89                 }
  90
  91                 break;
  92             }
  93         }
  94         else {
  95             /* timeout */
  96         }
  97     }
  98
  99     free(line);
 100     return 0;
 101 }
 102
 103 int ics_connect(int *sockfd)
 104 {
 105     struct sockaddr_in sa;
 106     struct hostent *h;
 107
 108     memset(&sa, 0, sizeof(struct sockaddr_in));
 109
 110     if ((h = gethostbyname(config.ics_server)) == NULL) {
 111         message(ERROR, ANYKEY, "%s: %s", config.ics_server, hstrerror(h_errno));
 112         return 1;
 113     }
 114
 115     /*
 116     if (inet_aton(argv[1], &sa.sin_addr) == 0)
 117         errx(EXIT_FAILURE, "malformed address");
 118     */
 119
 120     sa.sin_addr.s_addr = inet_addr(h->h_addr);
 121     sa.sin_family = AF_INET;
 122     sa.sin_port = htons(config.ics_port);
 123
 124     if ((*sockfd = socket(PF_INET, SOCK_STREAM, 0)) == -1) {
 125         message(ERROR, ANYKEY, "socket(): %s", strerror(errno));
 126         return 1;
 127     }
 128
 129     fcntl(*sockfd, F_SETFL, O_NONBLOCK);
 130
 131     /*
 132     if (bind(*sockfd, (struct sockaddr *)&sa, sizeof(struct sockaddr)) == -1) {
 133         message(ERROR, ANYKEY, "bind(): %s", strerror(errno));
 134         return 1;
 135     }
 136     */
 137
 138     if (connect(*sockfd, (struct sockaddr *)&sa, sizeof(struct sockaddr))
 139             == -1) {
 140         message(ERROR, ANYKEY, "connect(): %s", strerror(errno));
 141         return 1;
 142     }
 143
 144     return 0;
 145 }