/* -*- Mode: C; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */

/*  Chunk I/O

 *  =========

 *  Copyright 2019 Eduardo Silva <eduardo@monkey.io>

 *

 *  Licensed under the Apache License, Version 2.0 (the "License");

 *  you may not use this file except in compliance with the License.

 *  You may obtain a copy of the License at

 *

 *      http://www.apache.org/licenses/LICENSE-2.0

 *

 *  Unless required by applicable law or agreed to in writing, software

 *  distributed under the License is distributed on an "AS IS" BASIS,

 *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

 *  See the License for the specific language governing permissions and

 *  limitations under the License.

 */

#include <stdio.h>

#include <string.h>

#include <chunkio/chunkio_compat.h>

#include <chunkio/chunkio.h>

#include <chunkio/cio_chunk.h>

#include <chunkio/cio_stats.h>

void cio_stats_get(struct cio_ctx *ctx, struct cio_stats *stats)

{

    struct mk_list *head;

    struct mk_list *f_head;

    struct cio_chunk *ch;

    struct cio_stream *stream;

    memset(stats, 0, sizeof(struct cio_stats));

    /* Iterate each stream */

    mk_list_foreach(head, &ctx->streams) {

        stream = mk_list_entry(head, struct cio_stream, _head);

        stats->streams_total++;

        /* Iterate chunks */

        mk_list_foreach(f_head, &stream->chunks) {

            stats->chunks_total++;

            if (stream->type == CIO_STORE_MEM) {

                stats->chunks_mem++;

                continue;

            }

            /* Only applicable for 'file' type chunks */

            ch = mk_list_entry(f_head, struct cio_chunk, _head);

            stats->chunks_fs++;

            if (cio_chunk_is_up(ch) == CIO_TRUE) {

                stats->chunks_fs_up++;

            }

            else {

                stats->chunks_fs_down++;

            }

        }

    }

}

void cio_stats_print_summary(struct cio_ctx *ctx)

{

    struct cio_stats st;

    /* retrieve stats */

    cio_stats_get(ctx, &st);

    printf("======== Chunk I/O Stats ========\n");

    printf("- streams total     : %i\n", st.streams_total);

    printf("- chunks total      : %i\n", st.chunks_total);

    printf("- chunks memfs total: %i\n", st.chunks_mem);

    printf("- chunks file total : %i\n", st.chunks_fs);

    printf("  - files up        : %i\n", st.chunks_fs_up);

    printf("  - files down      : %i\n", st.chunks_fs_down);

}