[xiph-commits] r14773 - icecast/trunk/icecast/src

[karl at svn.xiph.org]

Author: karl
Date: 2008-04-17 18:12:45 -0700 (Thu, 17 Apr 2008)
New Revision: 14773

Modified:
   icecast/trunk/icecast/src/yp.c
Log:
small update for failure case. retry times changed and limited redirection allowed


Modified: icecast/trunk/icecast/src/yp.c
===================================================================
--- icecast/trunk/icecast/src/yp.c	2008-04-17 20:34:40 UTC (rev 14772)
+++ icecast/trunk/icecast/src/yp.c	2008-04-18 01:12:45 UTC (rev 14773)
@@ -255,6 +255,8 @@
             curl_easy_setopt (server->curl, CURLOPT_WRITEDATA, server->curl);
             curl_easy_setopt (server->curl, CURLOPT_TIMEOUT, server->url_timeout);
             curl_easy_setopt (server->curl, CURLOPT_NOSIGNAL, 1L);
+            curl_easy_setopt (server->curl, CURLOPT_FOLLOWLOCATION, 1L);
+            curl_easy_setopt (server->curl, CURLOPT_MAXREDIRS, 3L);
             curl_easy_setopt (server->curl, CURLOPT_ERRORBUFFER, &(server->curl_error[0]));
             server->next = (struct yp_server *)pending_yps;
             pending_yps = server;
@@ -285,7 +287,8 @@
 
 
 /* handler for curl, checks if successful handling occurred
- * return 0 for ok, -1 for this entry failed, -2 for server fail
+ * return 0 for ok, -1 for this entry failed, -2 for server fail.
+ * On failure case, update and process are modified
  */
 static int send_to_yp (const char *cmd, ypdata_t *yp, char *post)
 {
@@ -300,7 +303,7 @@
     if (curlcode)
     {
         yp->process = do_yp_add;
-        yp->next_update += 900;
+        yp->next_update += 1200;
         ERROR2 ("connection to %s failed with \"%s\"", server->url, server->curl_error);
         return -2;
     }
@@ -308,9 +311,19 @@
     {
         if (yp->error_msg == NULL)
             yp->error_msg = strdup ("no response from server");
+        if (yp->process == do_yp_add)
+        {
+            ERROR3 ("YP %s on %s failed: %s", cmd, server->url, yp->error_msg);
+            yp->next_update += 7200;
+        }
+        else
+        {
+            INFO3 ("YP %s on %s failed: %s", cmd, server->url, yp->error_msg);
+            yp->next_update += 1200;
+        }
         yp->process = do_yp_add;
-        yp->next_update += 300;
-        ERROR3 ("YP %s on %s failed: %s", cmd, server->url, yp->error_msg);
+        free (yp->sid);
+        yp->sid = NULL;
         return -1;
     }
     DEBUG2 ("YP %s at %s succeeded", cmd, server->url);
@@ -334,9 +347,9 @@
         free (yp->sid);
         yp->sid = NULL;
     }
-    yp_update = 1;
     yp->remove = 1;
     yp->process = do_yp_add;
+    yp_update = 1;
 
     return ret;
 }
@@ -455,7 +468,12 @@
     if (ret >= (signed)len)
         return ret+1; /* space required for above text and nul*/
 
-    return send_to_yp ("touch", yp, s);
+    if (send_to_yp ("touch", yp, s) == 0)
+    {
+        yp->next_update = now + yp->touch_interval;
+        return 0;
+    }
+    return -1;
 }
 
 
@@ -467,7 +485,6 @@
 
     if (now < yp->next_update)
         return 0;
-    yp->next_update = now + yp->touch_interval;
 
     /* loop just in case the memory area isn't big enough */
     while (1)