/* d4pack.c   (c)Copyright Sequiter Software Inc., 1990-1994.  All rights reserved. */

#include "d4all.h"
#ifndef S4UNIX
#ifdef __TURBOC__
#pragma hdrstop
#endif
#endif

#ifndef S4OFF_WRITE
int S4FUNCTION d4pack( DATA4 *data )
{
  int rc ;
#ifndef S4OPTIMIZE_OFF
  int has_opt ;
#endif

#ifdef S4VBASIC
  if ( c4parm_check( data, 2, E4_D4PACK ) )
    return 0 ;
#endif

  if ( data == 0 )
#ifdef S4DEBUG
    e4severe( e4parm, E4_D4PACK ) ;
#else
  return -1 ;
#endif

#ifndef S4SINGLE
  rc = d4lock_all( data ) ;   /* returns -1 if code_base->error_code < 0 */
  if ( rc )
    return rc ;
#endif

#ifndef S4OPTIMIZE_OFF
  has_opt = data->code_base->has_opt && data->code_base->opt.num_buffers ;
  d4opt_suspend( data->code_base ) ;
#endif

  rc = d4pack_data( data ) ;   /* returns -1 if code_base->error_code < 0 */
  if ( rc == 0 )
  {
    if ( d4reccount( data ) == 0 )
      data->bof_flag = data->eof_flag = 1 ;
    else
      data->bof_flag = data->eof_flag = 0 ;
#ifndef S4INDEX_OFF
    rc = d4reindex( data ) ;
#endif
    d4update_header( data, 1, 1 ) ;
  }

#ifndef S4OPTIMIZE_OFF
  if ( has_opt )
    d4opt_restart( data->code_base ) ;
#endif
  return rc ;
}

int S4FUNCTION d4pack_data( DATA4 *data )
{
  char *rd_buf, *wr_buf ;
  FILE4SEQ_READ   rd ;
  FILE4SEQ_WRITE  wr ;
  long new_count, cur_count, i_rec ;
  int  rc ;
  unsigned buf_size ;
#ifndef S4OPTIMIZE_OFF
  int has_opt ;
#endif

  if ( data == 0 )
#ifdef S4DEBUG
    e4severe( e4parm, E4_D4PACK_DATA ) ;
#else
  return -1 ;
#endif

#ifndef S4SINGLE
  rc = d4lock_file( data ) ;   /* returns -1 if code_base->error_code < 0 */
  if ( rc )
    return rc ;
#endif

  rc = d4update( data ) ;   /* returns -1 if code_base->error_code < 0 */
  if ( rc )
    return rc ;

  data->file_changed = 1 ;

  rd_buf = wr_buf = 0 ;
  buf_size = data->code_base->mem_size_buffer ;

#ifndef S4OPTIMIZE_OFF
  has_opt = data->code_base->has_opt && data->code_base->opt.num_buffers ;
  d4opt_suspend( data->code_base ) ;
#endif

  for ( ; buf_size > data->record_width; buf_size -= 0x800 )
  {
    rd_buf = (char *)u4alloc( buf_size ) ;
    if ( rd_buf == 0 )
      continue ;

    wr_buf = (char *)u4alloc( buf_size ) ;
    if ( wr_buf )
      break ;

    u4free( rd_buf ) ;
    rd_buf = 0 ;
  }

  file4seq_read_init( &rd, &data->file, d4record_position( data, 1L ), rd_buf, ( rd_buf == 0 ) ? 0 : buf_size ) ;
  file4seq_write_init( &wr, &data->file, d4record_position( data, 1L ), wr_buf, ( wr_buf == 0 ) ? 0 : buf_size) ;

  new_count = 0L ;
  cur_count = d4reccount( data ) ;

  for ( i_rec= 1L; i_rec <= cur_count; i_rec++ )
  {
    file4seq_read_all( &rd, data->record, data->record_width ) ;
    if ( !d4deleted( data ) )
    {
      file4seq_write( &wr, data->record, data->record_width ) ;
      new_count++ ;
    }
  }

  file4seq_write( &wr, "\032", 1 ) ;
  rc = file4seq_write_flush( &wr ) ;
  u4free( rd_buf ) ;
  u4free( wr_buf ) ;
#ifndef S4OPTIMIZE_OFF
  if ( has_opt )
    d4opt_restart( data->code_base ) ;
#endif
  if ( rc < 0 )
    return -1 ;

  data->num_recs = new_count ;
  data->rec_num = -1 ;
  data->rec_num_old = -1 ;
  memset( data->record, ' ', data->record_width ) ;

  return file4len_set( &data->file, d4record_position( data, new_count + 1L ) + 1L ) ;
}
#endif  /* S4OFF_WRITE */