/*
 * CDDL HEADER START
 *
 * The contents of this file are subject to the terms of the
 * Common Development and Distribution License, Version 1.0 only
 * (the "License").  You may not use this file except in compliance
 * with the License.
 *
 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
 * or http://www.opensolaris.org/os/licensing.
 * See the License for the specific language governing permissions
 * and limitations under the License.
 *
 * When distributing Covered Code, include this CDDL HEADER in each
 * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
 * If applicable, add the following below this CDDL HEADER, with the
 * fields enclosed by brackets "[]" replaced with your own identifying
 * information: Portions Copyright [yyyy] [name of copyright owner]
 *
 * CDDL HEADER END
 */
/*
 * Copyright 2004 Sun Microsystems, Inc.  All rights reserved.
 * Use is subject to license terms.
 */

#include "streams_array.h"
#include "streams_common.h"

/*
 * Single-byte character memory map-based streams implementation
 */

static int
stream_array_prime(stream_t *str)
{
        ASSERT((str->s_status & STREAM_SOURCE_MASK) == STREAM_ARRAY);

        str->s_type.LA.s_cur_index = MIN(0, str->s_type.LA.s_array_size - 1);
        if (str->s_type.LA.s_cur_index >= 0)
                copy_line_rec(
                    str->s_type.LA.s_array[str->s_type.LA.s_cur_index],
                    &str->s_current);
        else {
                stream_set(str, STREAM_EOS_REACHED);
                stream_unset(str, STREAM_PRIMED);
                return (PRIME_FAILED_EMPTY_FILE);
        }

        stream_set(str, STREAM_PRIMED);

        return (PRIME_SUCCEEDED);
}

static ssize_t
stream_array_fetch(stream_t *str)
{
        ASSERT(str->s_status & STREAM_OPEN);
        ASSERT(str->s_type.LA.s_cur_index < str->s_type.LA.s_array_size);

        if (++str->s_type.LA.s_cur_index == str->s_type.LA.s_array_size - 1)
                stream_set(str, STREAM_EOS_REACHED);

        copy_line_rec(str->s_type.LA.s_array[str->s_type.LA.s_cur_index],
            &str->s_current);

        return (NEXT_LINE_COMPLETE);
}

/*ARGSUSED*/
static int
stream_array_is_closable(stream_t *str)
{
        /*
         * Array streams are not closable.  That is, there is no open file
         * descriptor directly associated with an array stream.
         */
        return (0);
}

static int
stream_array_close(stream_t *str)
{
        stream_unset(str, STREAM_OPEN | STREAM_PRIMED);

        return (1);
}

static int
stream_array_free(stream_t *str)
{
        /*
         * It's now safe for us to close the various streams backing the array
         * stream's data.
         */
        stream_unset(str, STREAM_PRIMED | STREAM_NOT_FREEABLE);

        return (1);
}

static int
stream_array_eos(stream_t *str)
{
        int retval = 0;

        if (str == NULL || str->s_status & STREAM_EOS_REACHED)
                return (1);

        if (str->s_type.LA.s_cur_index + 1 >= str->s_type.LA.s_array_size) {
                retval = 1;
                stream_set(str, STREAM_EOS_REACHED);
        }

        return (retval);
}

/*ARGSUSED*/
static void
stream_array_release_line(stream_t *str)
{
}

const stream_ops_t stream_array_ops = {
        stream_array_is_closable,
        stream_array_close,
        stream_array_eos,
        stream_array_fetch,
        NULL,
        stream_array_free,
        NULL,
        stream_array_prime,
        NULL,
        stream_array_release_line,
        NULL,
        NULL
};