task: added task map growth

Signed-off-by: Leonardo Alminana <[email protected]>

Author: Leonardo Alminana

src/flb_task.c

@@ -33,36 +33,42 @@
 
 /*
  * Every task created must have an unique ID, this function lookup the
- * lowest number available in the tasks_map.
+ * lowest number available in the task_map.
  *
  * This 'id' is used by the task interface to communicate with the engine event
  * loop about some action.
  */
 
 static inline int map_get_task_id(struct flb_config *config)
 {
+    int result;
     int i;
-    int map_size = (sizeof(config->tasks_map) / sizeof(struct flb_task_map));
 
-    for (i = 0; i < map_size; i++) {
-        if (config->tasks_map[i].task == NULL) {
+    for (i = 0; i < config->task_map_size ; i++) {
+        if (config->task_map[i].task == NULL) {
             return i;
         }
     }
 
+    result = flb_config_task_map_grow(config);
+
+    if (result == 0) {
+        return i;
+    }
+
     return -1;
 }
 
 static inline void map_set_task_id(int id, struct flb_task *task,
                                    struct flb_config *config)
 {
-    config->tasks_map[id].task = task;
+    config->task_map[id].task = task;
 
 }
 
 static inline void map_free_task_id(int id, struct flb_config *config)
 {
-    config->tasks_map[id].task = NULL;
+    config->task_map[id].task = NULL;
 }
 
 void flb_task_retry_destroy(struct flb_task_retry *retry)
@@ -250,6 +256,7 @@ static struct flb_task *task_alloc(struct flb_config *config)
         flb_free(task);
         return NULL;
     }
+
     map_set_task_id(task_id, task, config);
 
     flb_trace("[task %p] created (id=%i)", task, task_id);