Normalize socket scheduler interface
authorHenning Rogge <hrogge@googlemail.com>
Fri, 25 Feb 2011 17:15:59 +0000 (18:15 +0100)
committerHenning Rogge <hrogge@googlemail.com>
Fri, 25 Feb 2011 17:15:59 +0000 (18:15 +0100)
src/main.c
src/olsr_socket.c
src/olsr_socket.h

index 507be63..6e39c0e 100644 (file)
@@ -460,7 +460,7 @@ main(int argc, char *argv[])
     olsr_process_changes();
 
     /* Read incoming data and handle it immediately */
-    handle_sockets(next_interval);
+    olsr_socket_handle(next_interval);
   }
 
   olsr_timer_stop(tc_gen_timer);
index e93d03d..4f9b772 100644 (file)
@@ -140,7 +140,7 @@ olsr_socket_remove(struct olsr_socket_entry *entry)
  * @param next_interval
  */
 void
-handle_sockets(uint32_t next_interval)
+olsr_socket_handle(uint32_t until_time)
 {
   struct olsr_socket_entry *entry, *iterator;
   struct timeval tvp;
@@ -149,7 +149,7 @@ handle_sockets(uint32_t next_interval)
   /* Update time since this is much used by the parsing functions */
   olsr_clock_update();
 
-  remaining = olsr_clock_getRelative(next_interval);
+  remaining = olsr_clock_getRelative(until_time);
   if (remaining <= 0) {
     /* we are already over the interval */
     if (list_is_empty(&socket_head)) {
@@ -229,7 +229,7 @@ handle_sockets(uint32_t next_interval)
     }
 
     /* calculate the next timeout */
-    remaining = olsr_clock_getRelative(next_interval);
+    remaining = olsr_clock_getRelative(until_time);
     if (remaining <= 0) {
       /* we are already over the interval */
       break;
index 8239ab8..b769eb6 100644 (file)
@@ -104,8 +104,7 @@ olsr_socket_disable(struct olsr_socket_entry *entry, unsigned int flags)
   entry->flags &= ~flags;
 }
 
-/* used by timer scheduler */
-void handle_sockets(uint32_t next_interval);
+void olsr_socket_handle(uint32_t until_time);
 
 #endif