Function application_read_suspects

src/daemon/application.c:700–790

                                                     size_t *active_jobs_out);

static char **application_read_suspects(cbm_daemon_application_job_t *job, const char *path,
                                        int *count_out, bool *cancelled_out) {
    *count_out = 0;
    *cancelled_out = false;
    int64_t marker_size = cbm_file_size(path);
    if (marker_size < 0 || marker_size > APPLICATION_MARKER_MAX_BYTES) {
        return NULL;
    }
    FILE *file = cbm_fopen(path, "rb");
    if (!file) {
        return NULL;
    }
    char **open_paths = NULL;
    int open_count = 0;
    int open_capacity = 0;
    bool allocation_failed = false;
    size_t lines_read = 0;
    char line[APPLICATION_PATH_CAP];
    while (fgets(line, sizeof(line), file)) {
        if ((lines_read++ & 255U) == 0U && application_job_cancel_requested(job)) {
            *cancelled_out = true;
            allocation_failed = true;
            break;
        }
        size_t length = strlen(line);
        if (length == 0 || line[length - 1] != '\n') {
            break;
        }
        line[--length] = '\0';
        if (length > 0 && line[length - 1] == '\r') {
            line[--length] = '\0';
        }
        if (length < 3 || (line[0] != 'S' && line[0] != 'D') || line[1] != ' ') {
            continue;
        }
        const char *relative = line + 2;
        if (line[0] == 'S') {
            if (open_count >= APPLICATION_MAX_SUSPECTS) {
                allocation_failed = true;
                break;
            }
            bool already_open = false;
            for (int i = 0; i < open_count && !already_open; i++) {
                already_open = strcmp(open_paths[i], relative) == 0;
            }
            if (already_open) {
                continue;
            }
            if (open_count == open_capacity) {
                int next_capacity = open_capacity ? open_capacity * 2 : 16;
                char **next = realloc(open_paths, (size_t)next_capacity * sizeof(*next));
                if (!next) {
                    allocation_failed = true;
                    break;
                }
                open_paths = next;
                open_capacity = next_capacity;
            }