/*
 * $Id: put_row.c,v 2.0.2.1 2006/01/25 14:15:05 markus Exp $
 */
/**********************************************************************
 *
 *   G_zeros_r_nulls(zeros_r_nulls)
 *      int zeros_r_nulls	the last argument of put_data()
 *
 *   zeros_r_nulls > 0		zero values of buf to be written into files
 *   				are null values by default.
 *
 *   zeros_r_nulls == 0		zero values are just zero itself.
 *
 *   zeros_r_nulls < 0		do not set. return current setting.
 *   				1: set
 *   				0: not set
 *
 *   Return setting values in all cases.
 *
 *   *** NOTE *** 
 *   Use only to change a default behavior for zero of G_put_map_row[_random].
 *
 ********************************************************************** 
 *
 *   G_put_[c/f/d]_raster_row(fd, buf)
 *      int fd           file descriptor of the opened map
 *      [F/D]CELL *buf   buffer holding row info to be written
 *
 *   Writes the next row for the cell file opened on 'fd' from 'buf'
 *   All writes go into NEW files that exactly match the current window.
 *   The file must have been opened with G_open_cell_new()
 *   and be written sequentially, ie no skipping rows
 *
 *   when the null values are embeded into the data, corresponding cells are 
 *   changed to 0's and the corresponding null value row is written into null 
 *   file.
 *
 *   *** NOTE *** 
 *   A map cannot be copied using G_get_raster_row() and G_put_raster_row().
 *   The former resamples the data of the original map into a row buffer
 *   that matches the current window.  The later writes out rows associated
 *   with the window.
 *
 *   returns:    1  if successful
 *              -1  on fail
 *
 *  Keeps track of the minimum and maximum cell value  for use in updating
 *  the range file upon close of the cell file.
 *  HOWEVER when nulls are not embeded, the cells are considered 0's as far
 *  as updating range is concerned, even if the corresponding cell is null
 *  in the resulting null file, so programmer should be carefult to set all 
 *  the null values using G_set_null_value() or G_insert_[d/f_]null_values()
 *
 ********************************************************************** 
 *
 *   G_put_map_row(fd, buf)
 *      int fd           file descriptor of the opened map
 *      CELL *buf        buffer holding row info to be written
 *
 *   Writes the next row for the cell file opened on 'fd' from 'buf'
 *   All writes go into NEW files that exactly match the current window.
 *   The file must have been opened with G_open_cell_new()
 *   and be written sequentially, ie no skipping rows
 *
 *   NULLS are written into null bitmap file for all cells which are zero,
 *   and cells which have null value (these cells are converted to 0's before
 *   writing) 
 *
 *   *** NOTE *** 
 *   A map cannot be copied using G_get_map_row() and G_put_map_row().
 *   The former resamples the data of the original map into a row buffer
 *   that matches the current window.  The later writes out rows associated
 *   with the window.
 *
 *   returns:    1  if successful
 *              -1  on fail
 *
 *  Keeps track of the minimum and maximum cell value  for use in updating
 *  the range file upon close of the cell file.
 *
 ********************************************************************** 
 *
 *  G_put_map_row_random(fd, buf, row, col, ncells)
 *      int fd                  File descriptor where data is to be written
 *      CELL *buf               Buffer holding data
 *      int row                 Map row where data is to be written
 *      int col                 Column where data begins
 *      int ncells              Number of columns of data to be written
 *
 *   Writes parts of rows into open cell file.
 *
 *   Cell file must have been opened with G_open_cell_new_random()
 *   except it can't write null file.
 *
 *   returns:    0  if successful
 *              -1  on fail
 *
 *   behaves the same as G_put_map_row()
 *
 **********************************************************************
 *
 *  Note: there is no G_put_[c/f/d]_raster_row_random() because even though
 *  it is possible to randomly write floating and integer rows, it is not
 *  possible to rand. write null data, so the null file can't
 *  be updated correctly.
 *
 ***********************************************************************
 *
 *  G__put_null_value_row(fd, buf, row, col, ncells)
 *      int fd                  File descriptor where data is to be written
 *      char *buf               Buffer holding null data
 *      int row                 Map row where data is to be written
 *      int col                 Column where data begins
 *      int ncells              Number of columns of data to be written
 *
 *   converts a buffer of zero's and ones to bitstream and stores this 
 *   bitstream in memory. (the null rows from memory are written into null
 *   file after the limit is reached, and the place for new null rows
 *   to be kept in memory is freed. Should not be used by application
 *   programs.
 *
 *   returns:    0  if successful
 *              -1  on fail
 **********************************************************************/

#include <string.h>

#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include <fcntl.h>

#include "config.h"

#include "G.h"
#include "glocale.h"

static int _zeros_r_nulls = 1;

static int put_raster_data(int,void *,int,int,int,int,RASTER_MAP_TYPE);
static int put_data(int,CELL *,int, int,int,int);
static int check_open(const char *,int,int);
static int adjust(int, int *, int *);
static void write_error(int,int);
static int same(const unsigned char *, const unsigned char *, int);
static int seek_random(int, int, int);
static void set_file_pointer(int,int);
static int put_fp_data(int,void *,int,int,int,RASTER_MAP_TYPE);
static int put_null_data(int,char *, int);
static int convert_and_write_if(int, CELL *);
static int convert_and_write_id(int, CELL *);
static int convert_and_write_df(int, DCELL *);
static int convert_and_write_fd(int, FCELL *);
static int put_raster_row(int fd, void *buf, RASTER_MAP_TYPE data_type, int zeros_r_nulls);

/*--------------------------------------------------------------------------*/
/*--------------------------------------------------------------------------*/
/*--------------------------------------------------------------------------*/

int G_zeros_r_nulls(int zeros_r_nulls)
{
    if (zeros_r_nulls >= 0)
	_zeros_r_nulls = zeros_r_nulls > 0;

    return _zeros_r_nulls;
}

int G_put_map_row_random(int fd, CELL *buf, int row, int col, int n)
{
    struct fileinfo *fcb = &G__.fileinfo[fd];

    if (!check_open("G_put_map_row_random", fd, 1))
        return -1;

    buf += adjust(fd, &col, &n);
    switch (put_data(fd, buf, row, col, n, _zeros_r_nulls))
    {
    case -1: return -1;
    case  0: return  1;
    }

    /* only for integer maps */
    if (fcb->want_histogram)
	G_update_cell_stats (buf, n, &fcb->statf);

    G_row_update_range (buf, n, &fcb->range);

    return 1;
}

int G__put_null_value_row(int fd, char *buf)
{
    struct fileinfo *fcb = &G__.fileinfo[fd];

    switch (put_null_data(fd, buf, fcb->null_cur_row))
    {
    case -1: return -1;
    case  0: return  1;
    }

    fcb->null_cur_row++;
    return 1;
}

int G_put_map_row(int fd, CELL *buf)
{
    struct fileinfo *fcb = &G__.fileinfo[fd];

    if (fcb->map_type != CELL_TYPE)
    {
	G_fatal_error("G_put_map_row: %s is not integer! Use G_put_[f/d]_raster_row()!",
		      fcb->name);
        return -1;
    }

    return put_raster_row(fd, buf, CELL_TYPE, _zeros_r_nulls);
}

int G_put_raster_row(int fd, void *buf, RASTER_MAP_TYPE data_type)
{
    return put_raster_row(fd, buf, data_type, 0);
}

int G_put_c_raster_row(int fd, CELL *buf)
{
    return G_put_raster_row(fd, buf, CELL_TYPE);
}

int G_put_f_raster_row(int fd, FCELL *buf)
{
    return G_put_raster_row(fd, buf, FCELL_TYPE);
}

int G_put_d_raster_row(int fd, DCELL *buf)
{
    return G_put_raster_row(fd, buf, DCELL_TYPE);
}

/*--------------------------------------------------------------------------*/

static int check_open(const char *me, int fd, int random)
{
    struct fileinfo *fcb = &G__.fileinfo[fd];

    switch (fcb->open_mode)
    {
    case OPEN_OLD:
	G_warning(
	    "%s: map [%s] not open for write - request ignored",
	    me, fcb->name);
	break;
    case OPEN_NEW_COMPRESSED:
    case OPEN_NEW_UNCOMPRESSED:
	if (!random)
	    return 1;
	G_warning(
	    "%s: map [%s] not open for random write - request ignored",
	    me, fcb->name);
	break;
    case OPEN_NEW_RANDOM:
	if (random)
	    return 1;
	G_warning(
	    "%s: map [%s] not open for sequential write - request ignored",
	    me, fcb->name);
	break;
    default:
	G_warning( 
	    "%s: unopened file descriptor - request ignored",
	    me);
	break;
    }

    return 0;
}

/*******************************************************
*  adjust the column,n so that it is within the window
*  returns the adjustment to buffer that must be made
*  if col,n is adjusted
*
*  if n comes back <= zero, do not write
*******************************************************/
static int adjust(int fd, int *col, int *n)
{
    struct fileinfo *fcb = &G__.fileinfo[fd];
    int adj = 0;
    int last = *col + *n;

    if (*col < 0)
    {
        adj = -(*col);
        *col = 0;
    }

    if (last > fcb->cellhd.cols)
        last = fcb->cellhd.cols;

    *n = last - *col;

    return adj;
}

static void write_error(int fd,int row)
{
    struct fileinfo *fcb = &G__.fileinfo[fd];

    if (fcb->io_error)
	return;

    G_warning(_("map [%s] - unable to write row %d"), fcb->name, row);

    fcb->io_error = 1;

    return;
}

/*--------------------------------------------------------------------------*/

int G__write_data(int fd, int row, int n)

{
    struct fileinfo *fcb = &G__.fileinfo[fd];
    int nwrite = fcb->nbytes * n;

    if (write(fd, G__.work_buf, nwrite) != nwrite)
    {
	write_error(fd, row);
	return -1;
    }

    return 0;
}

int G__write_data_compressed(int fd, int row, int n)
{
    struct fileinfo *fcb = &G__.fileinfo[fd];
    int nwrite = fcb->nbytes * n;

    if (G_zlib_write(fd, G__.work_buf, nwrite) < 0)
    {
	write_error(fd, row);
	return -1;
    }
  
    return 0;
}

/*--------------------------------------------------------------------------*/

static int seek_random(int fd, int row, int col)
{
    struct fileinfo *fcb = &G__.fileinfo[fd];
    off_t offset = ((off_t) fcb->cellhd.cols * row + col) * fcb->nbytes;

    if (lseek(fd, offset, 0) < 0)
    {
	write_error(fd, row);
	return -1;
    }

    return 0;
}

/*--------------------------------------------------------------------------*/

static void set_file_pointer(int fd, int row)
{
    struct fileinfo *fcb = &G__.fileinfo[fd];

    fcb->row_ptr[row] = lseek(fd, (off_t) 0, 1);
}

/*--------------------------------------------------------------------------*/
/*--------------------------------------------------------------------------*/
/*--------------------------------------------------------------------------*/

static int convert_float(
	XDR *xdrs, const FCELL *rast, int row, int col, int n, int random)
{
    int i;

    for (i = 0; i < n; i++) 
    {
	FCELL f;

	/* substitute embeded null vals by 0's */
	if (G_is_f_null_value(&rast[i]))
	{
	    f = 0.;
	    if (!random)
		G__.null_buf[col + i] = 1;
	}
	else 
	    f = rast[i];

	if (!xdr_float(xdrs, &f)) 
	{
	    G_warning("xdr_float failed for index %d of row %d.",  i, row);
	    return -1;
	}
    }

    return 0;
}

static int convert_double(
	XDR *xdrs, const DCELL *rast, int row, int col, int n, int random)
{
    int i;

    for (i = 0; i < n; i++) 
    {
	DCELL d;

	/* substitute embeded null vals by 0's */
	if (G_is_d_null_value(&rast[i]))
	{
	    d = 0.;
	    if (!random)
		G__.null_buf[col + i] = 1;
	}
	else
	    d = rast[i];

	if (!xdr_double(xdrs, &d)) 
	{
	    G_warning("xdr_double failed for index %d of row %d.", i, row);
	    return -1;
	}
    }

    return 0;
}

/*--------------------------------------------------------------------------*/

/* writes data to fcell file for either full or partial rows */

static int put_fp_data(int fd, void *rast, int row, int col, int n, RASTER_MAP_TYPE data_type)
{
    struct fileinfo *fcb = &G__.fileinfo[fd];
    int random     = (fcb->open_mode == OPEN_NEW_RANDOM);
    int compressed = (fcb->open_mode == OPEN_NEW_COMPRESSED);
    XDR *xdrs = &fcb->xdrstream;

    if (row < 0 || row >= fcb->cellhd.rows)
	return 0;
  
    if (n <= 0)
	return 0;
  
    if (random)
    {
	if (seek_random(fd, row, col) == -1)
	    return -1;
    }
    else if (compressed)
	set_file_pointer(fd, row);
  
    xdrmem_create(xdrs, (caddr_t) G__.work_buf,
		  (u_int) (fcb->nbytes * fcb->cellhd.cols), XDR_ENCODE);
    xdr_setpos (xdrs, 0);
  
    if (data_type == FCELL_TYPE)
    {
	if (convert_float(xdrs, rast, row, col, n, random) < 0)
	    return -1;
    }
    else
    {
	if (convert_double(xdrs, rast, row, col, n, random) < 0)
	    return -1;
    }

    xdr_destroy(&fcb->xdrstream);
  
    if (compressed)
    {
	if (G__write_data_compressed(fd, row, n) == -1)
	    return -1;
    }
    else
	if (G__write_data(fd, row, n) == -1)
	    return -1;
  
    return 1;
}

/*--------------------------------------------------------------------------*/
/*--------------------------------------------------------------------------*/
/*--------------------------------------------------------------------------*/

static void convert_int(
    unsigned char *wk, const CELL *rast, int col, int n,
    int random, int len, int zeros_r_nulls)
{
    int i;

    /* transform CELL data into non-machine dependent multi-byte format */

    for (i = 0; i < n; i++)
    {
	CELL v = rast[i];
	int neg;
	int k;

	/* substitute embeded null vals by 0's */
	if (G_is_c_null_value(&v))
	{
	    v = 0;
	    if (!random)
		G__.null_buf[col + i] = 1;
	}
	else if (!random && zeros_r_nulls && !v)
	    G__.null_buf[col + i] = 1;

	/* negatives */
	if (v < 0)
	{
	    neg = 1;
	    v = -v;
	}
	else
	    neg = 0;

	/* copy byte by byte */
	for (k = len - 1; k >= 0; k--)
	{
	    wk[k] = v & 0xff;
	    v >>= 8;
	}

	/* set negative bit in first byte */
	if (neg)
	    wk[0] |= 0x80 ;

	wk += len;
    }
}

static int count_bytes(const unsigned char *wk, int n, int len)
{
    int i, j;

    for (i = 0; i < len - 1; i++)
	for (j = 0; j < n; j++)
	    if (wk[j * len + i] != 0)
		return len - i;

    return 1;
}

static void trim_bytes(unsigned char *wk, int n, int slen, int trim)
{
    unsigned char *wk2 = wk;
    int i, j;

    for (i = 0; i < n; i++)
    {
	for (j = 0; j < trim; j++)
	    wk++;
	for ( ; j < slen; j++)
	    *wk2++ = *wk++;
    }
}

static int same(const unsigned char *x, const unsigned char *y, int n)
{
    return memcmp(x, y, n) == 0;
}

static int count_run(const unsigned char *src, int n, int nbytes)
{
    const unsigned char *cur = src + nbytes;
    int i;

    for (i = 1; i < n; i++)
    {
	if (i == 255 || !same(cur, src, nbytes))
	    return i;

	cur += nbytes;
    }

    return n;
}

static int rle_compress(unsigned char *dst, unsigned char *src, int n, int nbytes)
{
    int nwrite = 0;
    int total = nbytes * n;

    while (n > 0)
    {
	int count;

	nwrite += nbytes + 1;
	if (nwrite >= total)
	    return 0;

	count = count_run(src, n, nbytes);

	*dst++ = count;
	memcpy(dst, src, nbytes);
	dst += nbytes;

	src += count * nbytes;
	n -= count;
    }

    return nwrite;
}

static int zlib_compress(unsigned char *dst, unsigned char *src, int n, int nbytes)
{
    int total = nbytes * n;
    int nwrite = G_zlib_compress(G__.work_buf + 1, total,
				 G__.compressed_buf + 1, G__.compressed_buf_size - 1);

    return (nwrite >= total) ? 0 : nwrite;
}

/*--------------------------------------------------------------------------*/

static int put_data(int fd, CELL *cell, int row, int col, int n, int zeros_r_nulls)
{
    struct fileinfo *fcb = &G__.fileinfo[fd];
    int random     = (fcb->open_mode == OPEN_NEW_RANDOM);
    int compressed = fcb->cellhd.compressed;
    int len = compressed ? sizeof(CELL) : fcb->nbytes;
    unsigned char *wk = G__.work_buf;
    int nwrite;

    if (row < 0 || row >= fcb->cellhd.rows)
        return 0;

    if (n <= 0)
        return 0;

    if (random)
    {
	if (seek_random(fd, row, col) == -1)
	    return -1;
    }
    else if (compressed)
	set_file_pointer(fd, row);

    if (compressed)
	wk++;

    convert_int(wk, cell, col, n, random, len, zeros_r_nulls);

    if (compressed)
    {
	unsigned char *wk = G__.work_buf + 1;
	int nbytes = count_bytes(wk, n, len);

	if (fcb->nbytes < nbytes)
	    fcb->nbytes = nbytes;

	/* first trim away zero high bytes */
	if (nbytes < len)
	    trim_bytes(wk, n, len, len - nbytes);

	G__.compressed_buf[0] = G__.work_buf[0] = nbytes;

	/* then compress the data */
	nwrite = compressed == 1
	    ? rle_compress(G__.compressed_buf + 1, G__.work_buf + 1, n, nbytes)
	    : zlib_compress(G__.compressed_buf + 1, G__.work_buf + 1, n, nbytes);

	if (nwrite > 0)
	{
	    nwrite++;

	    if (write(fd, G__.compressed_buf, nwrite) != nwrite)
	    {
		write_error(fd, row);
		return -1;
	    }
	}
	else
	{
	    nwrite = nbytes * n + 1;
	    if (write(fd, G__.work_buf, nwrite) != nwrite)
	    {
		write_error(fd, row);
		return -1;
	    }
	}
    }
    else
    {
	nwrite = fcb->nbytes * n;

	if (write(fd, G__.work_buf, nwrite) != nwrite)
	{
	    write_error(fd, row);
	    return -1;
	}
    }

    return 1;
}

/*--------------------------------------------------------------------------*/
/*--------------------------------------------------------------------------*/
/*--------------------------------------------------------------------------*/

static int put_raster_data(int fd, void *rast, int row, int col, int n, int zeros_r_nulls, RASTER_MAP_TYPE map_type)
{
    return (map_type == CELL_TYPE)
	? put_data(fd, rast, row, col, n, zeros_r_nulls)
	: put_fp_data(fd, rast, row, col, n, map_type);
}

/*--------------------------------------------------------------------------*/
/*--------------------------------------------------------------------------*/
/*--------------------------------------------------------------------------*/

static int put_null_data(int fd, char *flags, int row)
{
    struct fileinfo *fcb = &G__.fileinfo[fd];
    int null_fd, i;

    if (fcb->min_null_row + NULL_ROWS_INMEM <= row)
    {
	/* the row is out of the range of rows stored in memory */
	/* write out all the rows kept in memory, and initialize memory
	   for keeping new NULL_ROWS_INMEM rows */

	if (fcb->min_null_row >= 0)
	{
	    null_fd = G__open_null_write(fd);
	    if (null_fd < 0)
		return -1;

	    for (i = 0; i < NULL_ROWS_INMEM; i++)
	    {
		/* fcb->cellhd.rows doesn't have to be a miultiple of NULL_ROWS_INMEM */
		if (i + fcb->min_null_row >= fcb->cellhd.rows)
		    break;

		if (G__write_null_bits(null_fd, fcb->NULL_ROWS[i], 
				       i+fcb->min_null_row, fcb->cellhd.cols, fd) < 0)
		    return -1;

	    } /* done writing out memory rows */
	    if (null_fd >= 0)
		close(null_fd);
	}

	/* now initialize memory to store new NULL_ROWS_INMEM rows */
	fcb->min_null_row = fcb->min_null_row + NULL_ROWS_INMEM;
	/* init memory to store next NULL_ROWS_INMEM rows */
    }

    /* remember the null row for i for the future writing */
    G__convert_01_flags(flags, fcb->NULL_ROWS[row - fcb->min_null_row], fcb->cellhd.cols);
    return 1;
}

int G__open_null_write(int fd)
{
    struct fileinfo *fcb = &G__.fileinfo[fd];
    int null_fd;

    if (access(fcb->null_temp_name, 0) != 0) 
    {
	G_warning("unable to find a temporary null file %s", 
		  fcb->null_temp_name);
	return -1;
    }

    null_fd = open(fcb->null_temp_name, O_WRONLY);
    if (null_fd < 0)
	return -1;

    return null_fd;
}

int G__write_null_bits(int null_fd, unsigned char *flags, int row, int cols, int fd)
{
    off_t offset;
    int size;

    size = G__null_bitstream_size(cols);
    offset = (off_t) size * row;

    if (lseek(null_fd, offset, 0) < 0)
    {
	G_warning(_("error writing null row %d"),row);
	return -1;
    }

    if (write(null_fd, flags, size) != size)
    {
	G_warning(_("error writing null row %d"),row);
	return -1;
    }
    return 1;
}

/*--------------------------------------------------------------------------*/
/*--------------------------------------------------------------------------*/
/*--------------------------------------------------------------------------*/

static int convert_and_write_if(int fd, CELL *buf)
{
    struct fileinfo *fcb = &G__.fileinfo[fd];
    FCELL *p = (FCELL *) fcb->data;
    int i;

    for (i = 0; i < fcb->cellhd.cols; i++)
	if (G_is_c_null_value(&buf[i]))
	    G_set_f_null_value(&p[i], 1);
	else
	    p[i] = (FCELL) buf[i];

    return G_put_f_raster_row(fd, p);
}

static int convert_and_write_df(int fd, DCELL *buf)
{
    struct fileinfo *fcb = &G__.fileinfo[fd];
    FCELL *p = (FCELL *) fcb->data;
    int i;

    for (i = 0; i < fcb->cellhd.cols; i++)
	if (G_is_d_null_value(&buf[i]))
	    G_set_f_null_value(&p[i], 1);
	else
	    p[i] = (FCELL) buf[i];

    return G_put_f_raster_row(fd, p);
}

static int convert_and_write_id(int fd, CELL *buf)
{
    struct fileinfo *fcb = &G__.fileinfo[fd];
    DCELL *p = (DCELL *) fcb->data;
    int i;

    for (i = 0; i < fcb->cellhd.cols; i++)
	if (G_is_c_null_value(&buf[i]))
	    G_set_d_null_value(&p[i], 1);
	else
	    p[i] = (DCELL) buf[i];

    return G_put_d_raster_row(fd, p);
}

static int convert_and_write_fd(int fd, FCELL *buf)
{
    struct fileinfo *fcb = &G__.fileinfo[fd];
    DCELL *p = (DCELL *) fcb->data;
    int i;

    for (i = 0; i < fcb->cellhd.cols; i++)
	if (G_is_f_null_value(&buf[i]))
	    G_set_d_null_value(&p[i], 1);
	else
	    p[i] = (DCELL) buf[i];

    return G_put_d_raster_row(fd, p);
}

static int convert_and_write_fi(int fd, FCELL *buf)
{
    struct fileinfo *fcb = &G__.fileinfo[fd];
    CELL *p = (CELL *) fcb->data;
    int i;

    for (i = 0; i < fcb->cellhd.cols; i++)
	if (G_is_f_null_value(&buf[i]))
	    G_set_c_null_value(&p[i], 1);
	else
	    p[i] = (CELL) buf[i];

    return G_put_c_raster_row(fd, p);
}

static int convert_and_write_di(int fd, DCELL *buf)
{
    struct fileinfo *fcb = &G__.fileinfo[fd];
    CELL *p = (CELL *) fcb->data;
    int i;

    for (i = 0; i < fcb->cellhd.cols; i++)
	if (G_is_d_null_value(&buf[i]))
	    G_set_c_null_value(&p[i], 1);
	else
	    p[i] = (CELL) buf[i];

    return G_put_c_raster_row(fd, p);
}

/*--------------------------------------------------------------------------*/

static int put_raster_row(
    int fd, void *buf, RASTER_MAP_TYPE data_type, int zeros_r_nulls)
{
    struct fileinfo *fcb = &G__.fileinfo[fd];

    static int (*convert_and_write_FtypeOtype[3][3])() = {
	{NULL                , convert_and_write_if, convert_and_write_id},
	{convert_and_write_fi, NULL                , convert_and_write_fd},
	{convert_and_write_di, convert_and_write_df, NULL                }
    };

    if (!check_open("put_raster_row", fd, 0))
        return -1;

    if (fcb->map_type != data_type)
        return convert_and_write_FtypeOtype[data_type][fcb->map_type](fd, buf);

    G_zero(G__.null_buf, fcb->cellhd.cols * sizeof(char));

    switch (put_raster_data(fd, buf, fcb->cur_row, 0, fcb->cellhd.cols, zeros_r_nulls, data_type))
    {
    case -1: return -1;
    case  0: return  1;
    }

    /* only for integer maps */
    if (data_type == CELL_TYPE)
    {
	if (fcb->want_histogram)
 	    G_update_cell_stats(buf, fcb->cellhd.cols, &fcb->statf);
	G__row_update_range(buf, fcb->cellhd.cols, &fcb->range, zeros_r_nulls);
    }
    else
        G_row_update_fp_range (buf, fcb->cellhd.cols, &fcb->fp_range, data_type);

    fcb->cur_row++;

    /* write the null row for the data row */
    return G__put_null_value_row(fd, G__.null_buf);
}

/*--------------------------------------------------------------------------*/
/*--------------------------------------------------------------------------*/
/*--------------------------------------------------------------------------*/