---

BufferedInputStream

/*
 * NOTE: "zlib/libpng" style License
 *
 *                 ----=== s t d n e t ===----
 *
 * Copyright (c) 2002 Warwick Molloy   w-molloy@users.sf.net
 *
 * Copyright (c) 2002 Stdnet Community
 * HTTP://Sourceforge.net/projects/stdnet
 *
 * All references to "software" refer to the stdnet.
 *
 * This software is provided 'as-is', without any express or
 * implied warranty. In no event will the authors be held liable
 * for any damages arising from the use of this software.
 *
 * Permission is granted to anyone to use this software for any
 * purpose, including commercial applications, and to alter it
 * and redistribute it freely, subject to the following
 * restrictions:
 *
 * 1.  The origin of this software must not be misrepresented;
 *     you must not claim that you wrote the original software.
 *     If you use this software in a product, an acknowledgment
 *     in the product documentation would be appreciated but
 *     is not required.
 *
 * 2.  Altered source versions must be plainly marked as such,
 *     and must not be misrepresented as being the original
 *     software.
 *
 * 3.  This notice may not be removed or altered from any source
 *     distribution.
 */

#ifndef __io_BufferedInputStream__
#define __io_BufferedInputStream__

#include <stdnet/system/Abstract>
#include <stdnet/io/IOException>
#include <stdnet/io/FilterInputStream>
#include <stdnet/config.h>

namespace stdbase {
    namespace io {

class BufferedInputStream
    : public FilterInputStream
{
protected:
    BufferedInputStream( InputStreamRef input);
    virtual ~BufferedInputStream() {};

public:
    static system::reference< BufferedInputStream >
        create( InputStreamRef r);

    virtual int
        available() throw (IOException);
    
    //virtual void
    //    close() throw (IOException);

    virtual void
        mark( int readlimit);

    virtual void
        reset() throw (IOException);

    virtual bool
        markSupported();

    virtual int
        read( byte buffer[], int len) throw (IOException);
        
    virtual int
        read() throw (IOException);

    //virtual long
    //    skip( long n ) throw (IOException);

private:
    void    prepare_buffer() throw (IOException);

    void    advance_start_pos( int count) throw (IOException);

private:
    enum {  
        BUFFER_MAX = 2048,
        BUFF_CHUNK = 512
    };

    char    buffer[ BUFFER_MAX ];
    int     start_pos;
    int     end_pos;
    int     mark_pos;
    int     mark_read_limit;
    int     mark_read_count;

    enum {
        MARK_READ_LIMIT_NULL = 0,
        MARK_READ_LIMIT_EXCEEDED = -1,
        MARK_POS_UNSET = -1,
        MARK_POS_OVERWRITTEN = -2
    };
};

typedef system::reference< BufferedInputStream >
            BufferedInputStreamRef;


    } // -- end io --
} // -- end stdbase --

#endif  //  __io_BufferedInputStream__

---