IOBuffer.h

Go to the documentation of this file.

/*
  Copyright (c) 2009 Yahoo! Inc.  All rights reserved.  The copyrights
  embodied in the content of this file are licensed under the BSD
  (revised) open source license.

  Copyright (c) 2011 Berlin Institute of Technology and Max-Planck-Society.

  This program is free software; you can redistribute it and/or modify
  it under the terms of the GNU General Public License as published by
  the Free Software Foundation; either version 3 of the License, or
  (at your option) any later version.

  Shogun adjustments (w) 2011 Shashwat Lal Das
*/

#ifndef IOBUFFER_H__
#define IOBUFFER_H__

#include <shogun/lib/config.h>

#include <shogun/lib/v_array.h>
#include <shogun/lib/common.h>
#include <shogun/base/SGObject.h>

#ifndef O_LARGEFILE //for OSX
#define O_LARGEFILE 0
#endif

namespace shogun
{
 class CIOBuffer : public CSGObject
 {

 public:

    CIOBuffer();

    CIOBuffer(int fd);

    ~CIOBuffer();

    void init();

    virtual void use_file(int fd);

    virtual int open_file(const char* name, char flag='r');

    virtual void reset_file();

    void set(char *p);

    virtual ssize_t read_file(void* buf, size_t nbytes);

    size_t fill();

    virtual ssize_t write_file(const void* buf, size_t nbytes);

    virtual void flush();

    virtual bool close_file();

    ssize_t readto(char* &pointer, char terminal);

    inline ssize_t read_line(char* &pointer)
    {
        return readto(pointer, '\n');
    }

    void buf_write(char* &pointer, int n);

    unsigned int buf_read(char* &pointer, int n);

    virtual const char* get_name() const
    {
        return "IOBuffer";
    }

public:

    v_array<char> space;
    /* space.begin = beginning of loaded values
     * space.end   = end of read or written values */

    char* endloaded;

    int working_file;
};
}
#endif  /* IOBUFFER_H__ */