task: validate retry_limit if is set (non false)

Signed-off-by: Eduardo Silva <[email protected]>
fluent · Apr 5, 2017 · cee904d · cee904d
1 parent edd403b
commit cee904d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/flb_task.c b/src/flb_task.c
@@ -101,7 +101,7 @@ struct flb_task_retry *flb_task_retry_create(struct flb_task *task,
     mk_list_foreach_safe(head, tmp, &task->retries) {
         retry = mk_list_entry(head, struct flb_task_retry, _head);
         if (retry->o_ins == o_ins) {
-            if (retry->attemps > o_ins->retry_limit) {
+            if (retry->attemps > o_ins->retry_limit && o_ins->retry_limit >= 0) {
                 flb_debug("[task] task_id=%i reached retry-attemps limit %i/%i",
                           task->id, retry->attemps, o_ins->retry_limit);
                 flb_task_retry_destroy(retry);