stream.h

/* FreeTDS - Library of routines accessing Sybase and Microsoft databases
 * Copyright (C) 2013  Frediano Ziglio
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Library General Public
 * License as published by the Free Software Foundation; either
 * version 2 of the License, or (at your option) any later version.
 *
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Library General Public License for more details.
 *
 * You should have received a copy of the GNU Library General Public
 * License along with this library; if not, write to the
 * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
 * Boston, MA 02111-1307, USA.
 */

#ifndef _tdsguard_a5iqP6Ed7kDGP9L1OvOL7W_
#define _tdsguard_a5iqP6Ed7kDGP9L1OvOL7W_

#ifndef _tdsguard_hfOrWb5znoUCWdBPoNQvqN_
#error Include tds.h first
#endif

#include <freetds/pushvis.h>

typedef struct tds_input_stream {
    int (*read)(struct tds_input_stream *stream, void *ptr, size_t len);
} TDSINSTREAM;

typedef struct tds_output_stream {
    int (*write)(struct tds_output_stream *stream, size_t len);
    char *buffer;
    size_t buf_len;
} TDSOUTSTREAM;

TDSRET tds_convert_stream(TDSSOCKET * tds, TDSICONV * char_conv, TDS_ICONV_DIRECTION direction,
    TDSINSTREAM * istream, TDSOUTSTREAM *ostream);
TDSRET tds_copy_stream(TDSINSTREAM * istream, TDSOUTSTREAM * ostream);

/* Additional streams */

typedef struct tds_datain_stream {
    TDSINSTREAM stream;
    size_t wire_size;   
    TDSSOCKET *tds;
} TDSDATAINSTREAM;

void tds_datain_stream_init(TDSDATAINSTREAM * stream, TDSSOCKET * tds, size_t wire_size);

typedef struct tds_dataout_stream {
    TDSOUTSTREAM stream;
    TDSSOCKET *tds;
    size_t written;
} TDSDATAOUTSTREAM;

void tds_dataout_stream_init(TDSDATAOUTSTREAM * stream, TDSSOCKET * tds);

typedef struct tds_staticin_stream {
    TDSINSTREAM stream;
    const char *buffer;
    size_t buf_left;
} TDSSTATICINSTREAM;

void tds_staticin_stream_init(TDSSTATICINSTREAM * stream, const void *ptr, size_t len);

typedef struct tds_staticout_stream {
    TDSOUTSTREAM stream;
} TDSSTATICOUTSTREAM;

void tds_staticout_stream_init(TDSSTATICOUTSTREAM * stream, void *ptr, size_t len);

typedef struct tds_dynamic_stream {
    TDSOUTSTREAM stream;
    void **buf;
    size_t allocated;
    size_t size;
} TDSDYNAMICSTREAM;

TDSRET tds_dynamic_stream_init(TDSDYNAMICSTREAM * stream, void **ptr, size_t allocated);

#include <freetds/popvis.h>

#endif