in_blob: fixed already registered file log message

Signed-off-by: Leonardo Alminana <[email protected]>
fluent · Oct 21, 2024 · aadaf1c · aadaf1c
1 parent 8f1fd00
commit aadaf1c
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/plugins/in_blob/blob.c b/plugins/in_blob/blob.c
@@ -561,6 +561,11 @@ static ssize_t recursive_file_search(struct blob_ctx *ctx,
                                 (uint64_t) fs_entry_metadata.st_ino);
                 }
                 else {
+                    /* Result codes :
+                     *  0 - Success
+                     * -1 - Generic failure
+                     *  1 - The file was alrady present in our records
+                     */
                     flb_plg_debug(ctx->ins,
                                 "blob scan skip: %s",
                                 glob_context.gl_pathv[index]);

diff --git a/plugins/in_blob/blob_file.c b/plugins/in_blob/blob_file.c
@@ -40,15 +40,15 @@ int blob_file_append(struct blob_ctx *ctx, char *path, struct stat *st)
         bfile = cfl_list_entry(head, struct blob_file, _head);
         if (strcmp(bfile->path, path) == 0) {
             /* file already exists */
-            return -1;
+            return 1;
         }
     }
 
 #ifdef FLB_HAVE_SQLDB
     if (ctx->database_file) {
         /* the file was already registered, just skipt it */
         if (blob_db_file_exists(ctx, path, &id_found) == FLB_TRUE) {
-            return 0;
+            return 1;
         }
     }
 #endif