From 36b6a67ea52919727202e91384a6dd0eabb04d1a Mon Sep 17 00:00:00 2001
From: alegrand <alegrand@48e7efb5-ca39-0410-a469-dd3cf9ba447f>
Date: Thu, 18 May 2006 23:10:12 +0000
Subject: [PATCH] Bug fix raised by Fabien Janvier. Returns a sensible value
 when asking whether there remains some tasks to handle on the timer
 resource...

git-svn-id: svn+ssh://scm.gforge.inria.fr/svn/simgrid/simgrid/trunk@2241 48e7efb5-ca39-0410-a469-dd3cf9ba447f
---
 src/surf/surf_timer.c | 19 ++++++++++++++++++-
 1 file changed, 18 insertions(+), 1 deletion(-)

diff --git a/src/surf/surf_timer.c b/src/surf/surf_timer.c
index 9f4d72dc4d..c86ddfe2bd 100644
--- a/src/surf/surf_timer.c
+++ b/src/surf/surf_timer.c
@@ -8,10 +8,14 @@
 #include "xbt/ex.h"
 #include "surf_timer_private.h"
 
+XBT_LOG_NEW_DEFAULT_SUBCATEGORY(surf_timer, surf,
+				"Logging specific to SURF (timer)");
+
 surf_timer_resource_t surf_timer_resource = NULL;
 static tmgr_trace_t empty_trace = NULL;
 static xbt_swag_t command_pending = NULL;
 static xbt_swag_t command_to_run = NULL;
+static xbt_heap_t timer_heap = NULL;
 
 static void timer_free(void *timer)
 {
@@ -93,11 +97,19 @@ static void action_change_state(surf_action_t action,
 
 static double share_resources(double now)
 {
-  return -1.0;
+  if (xbt_heap_size(timer_heap))
+    return (xbt_heap_maxkey(timer_heap));
+  else
+    return -1.0;
 }
 
 static void update_actions_state(double now, double delta)
 {
+  if(xbt_heap_size(timer_heap)) {
+    if(xbt_heap_maxkey(timer_heap)<=now+delta) {
+      xbt_heap_pop(timer_heap);
+    }
+  }
   return;
 }
 
@@ -121,6 +133,7 @@ static void set(double date, void *function, void *arg)
   command = command_new(function, arg);
 
   tmgr_history_add_trace(history, empty_trace, date, 0, command);  
+  xbt_heap_push(timer_heap, NULL , date);
 }
 
 
@@ -156,6 +169,9 @@ static int action_is_suspended(surf_action_t action)
 
 static void finalize(void)
 {
+  xbt_heap_free(timer_heap);
+  timer_heap = NULL;
+
   tmgr_trace_free(empty_trace);
   empty_trace = NULL;
 
@@ -232,6 +248,7 @@ static void surf_timer_resource_init_internal(void)
   }
 
   empty_trace = tmgr_empty_trace_new();
+  timer_heap = xbt_heap_new(8, NULL);
 
   xbt_assert0(maxmin_system, "surf_init has to be called first!");
 }
-- 
2.20.1