#include <sys/socket.h>
#include <sys/types.h>
#include <sys/stat.h>
+#include <sys/select.h>
#include <fcntl.h>
#include <unistd.h>
#include <strings.h>
+#include <netdb.h>
#include "http.h"
#include "mcast.h"
+#include "sap.h"
+#include "common.h"
#define CHUNKSIZE 3000
#define GTOD_INTERVAL 100
int error_sleep = 0;
char buffer[CHUNKSIZE];
int in, out;
+ fd_set rfds;
+ struct timeval tv;
+ int retval;
if ((in = (*open_fn)(url)) < 0) {
fprintf(stderr,"Can't open url %s!\n",url);
}
}
+ FD_ZERO(&rfds);
+ FD_SET(in, &rfds);
+
+ tv.tv_sec = 1;
+ tv.tv_usec = 0;
+
+ if ((retval = select(in + 1, &rfds, NULL, NULL, &tv)) == -1) {
+ error_sleep = 1;
+ continue;
+ }
+
+ if (!retval) {
+ gettimeofday(&curr, NULL);
+ continue;
+ }
+
if ((recvd = recv(in, buffer, CHUNKSIZE, 0)) < 1) {
error_sleep = 1;
continue;
duration = atoi(argv[2])*60;
outfile = argv[3];
} else {
- fprintf(stderr,"Syntax: %s URL duration_in_minutes outfile\n", argv[0]);
+ fprintf(stderr,"Syntax: %s URL|SAPServiceName duration_in_minutes outfile\n", argv[0]);
exit(EXIT_FAILURE);
}
+ if (!is_url(url)) {
+ char *service_url;
+ if ((service_url = get_url_from_sap(url))) {
+ printf("SAP says: '%s' -> %s\n", url, service_url);
+ url = service_url;
+ }
+ }
+
if (is_http(url)) {
open_fn = &open_http;
} else if (is_mcast(url)) {
open_fn = &open_mcast;
} else {
- printf("URL %s not supported!\n", url);
+ printf("URL '%s' not supported!\n", url);
exit(EXIT_FAILURE);
}