summaryrefslogtreecommitdiffstats
path: root/pacredir.c
diff options
context:
space:
mode:
authorGravatar Christian Hesse <mail@eworm.de>2014-07-28 16:37:24 +0200
committerGravatar Christian Hesse <mail@eworm.de>2014-07-28 16:37:24 +0200
commitfca82e3c743743a82d9ed3153fe2ab44e5a3f7b7 (patch)
treec289468cb4a29f9bd03c07cc84ac2f16d21a815e /pacredir.c
parent5481cb92ee747b2820cece4f051f20e59a6d5c0c (diff)
downloadpacredir-fca82e3c743743a82d9ed3153fe2ab44e5a3f7b7.tar.gz
pacredir-fca82e3c743743a82d9ed3153fe2ab44e5a3f7b7.tar.zst
have port in struct services, allow to specify host:port in pacredir.conf
Diffstat (limited to 'pacredir.c')
-rw-r--r--pacredir.c41
1 files changed, 27 insertions, 14 deletions
diff --git a/pacredir.c b/pacredir.c
index 37f346d..50ba1d3 100644
--- a/pacredir.c
+++ b/pacredir.c
@@ -78,7 +78,7 @@ char * get_url(const char * hostname, const uint16_t port, const char * uri) {
}
/*** add_host ***/
-int add_host(const char * host, const char * type) {
+int add_host(const char * host, const uint16_t port, const char * type) {
struct hosts * tmphosts = hosts;
struct request request;
@@ -93,12 +93,17 @@ int add_host(const char * host, const char * type) {
/* host not found, adding a new one */
write_log(stdout, "Adding host %s with service %s\n", host, type);
tmphosts->host = strdup(host);
+
+ tmphosts->pacserve.port = 0;
tmphosts->pacserve.online = 0;
tmphosts->pacserve.badtime = 0;
tmphosts->pacserve.badcount = 0;
+
+ tmphosts->pacdbserve.port = 0;
tmphosts->pacdbserve.online = 0;
tmphosts->pacdbserve.badtime = 0;
tmphosts->pacdbserve.badcount = 0;
+
tmphosts->next = malloc(sizeof(struct hosts));
tmphosts->next->host = NULL;
tmphosts->next->next = NULL;
@@ -106,17 +111,17 @@ int add_host(const char * host, const char * type) {
update:
if (strcmp(type, PACSERVE) == 0) {
tmphosts->pacserve.online = 1;
- request.port = PORT_PACSERVE;
+ tmphosts->pacserve.port = (port > 0 ? port : PORT_PACSERVE);
request.service = &tmphosts->pacserve;
} else if (strcmp(type, PACDBSERVE) == 0) {
tmphosts->pacdbserve.online = 1;
- request.port = PORT_PACDBSERVE;
+ tmphosts->pacdbserve.port = (port > 0? port : PORT_PACDBSERVE);
request.service = &tmphosts->pacdbserve;
}
/* do a first request and let get_http_code() set the bad status */
request.host = tmphosts->host;
- request.url = get_url(request.host, request.port, "");
+ request.url = get_url(request.host, request.service->port, "");
request.http_code = 0;
request.last_modified = 0;
get_http_code(&request);
@@ -182,7 +187,7 @@ static void browse_callback(AvahiServiceBrowser *b, AvahiIfIndex interface, Avah
write_log(stdout, "NEW: service '%s' of type '%s' in domain '%s'\n", name, type, domain);
# endif
- add_host(host, type);
+ add_host(host, 0, type);
out:
free(host);
@@ -248,7 +253,7 @@ static void * get_http_code(void * data) {
/* perform the request */
if (curl_easy_perform(curl) != CURLE_OK) {
- write_log(stderr, "Could not connect to server %s on port %d.\n", request->host, request->port);
+ write_log(stderr, "Could not connect to server %s on port %d.\n", request->host, request->service->port);
request->http_code = 0;
request->last_modified = 0;
request->service->badtime = tv.tv_sec;
@@ -381,14 +386,11 @@ static int ahc_echo(void * cls, struct MHD_Connection * connection, const char *
/* prepare request struct */
request->host = tmphosts->host;
- if (dbfile == 1) {
- request->port = PORT_PACDBSERVE;
+ if (dbfile == 1)
request->service = &(tmphosts->pacdbserve);
- } else {
- request->port = PORT_PACSERVE;
+ else
request->service = &(tmphosts->pacserve);
- }
- request->url = get_url(tmphosts->host, dbfile == 1 ? PORT_PACDBSERVE : PORT_PACSERVE, basename);
+ request->url = get_url(tmphosts->host, request->service->port, basename);
request->http_code = 0;
request->last_modified = 0;
@@ -494,6 +496,7 @@ void sighup_callback(int signal) {
int main(int argc, char ** argv) {
dictionary * ini;
char * values, * value;
+ uint16_t port;
struct ignore_interfaces * tmp_ignore_interfaces;
AvahiClient *client = NULL;
AvahiServiceBrowser *pacserve = NULL, *pacdbserve = NULL;
@@ -548,7 +551,12 @@ int main(int argc, char ** argv) {
# endif
value = strtok(values, DELIMITER);
while (value != NULL) {
- add_host(value, PACSERVE);
+ if (strchr(value, ':') != NULL) {
+ port = atoi(strchr(value, ':') + 1);
+ *strchr(value, ':') = 0;
+ } else
+ port = PORT_PACSERVE;
+ add_host(value, port, PACSERVE);
value = strtok(NULL, DELIMITER);
}
}
@@ -560,7 +568,12 @@ int main(int argc, char ** argv) {
# endif
value = strtok(values, DELIMITER);
while (value != NULL) {
- add_host(value, PACDBSERVE);
+ if (strchr(value, ':') != NULL) {
+ port = atoi(strchr(value, ':') + 1);
+ *strchr(value, ':') = 0;
+ } else
+ port = PORT_PACDBSERVE;
+ add_host(value, port, PACDBSERVE);
value = strtok(NULL, DELIMITER);
}
}