a0f5e0898b
which included commits to RCS files with non-trunk default branches. git-svn-id: svn://10.65.10.50/trunk@976 c028cbd2-c16b-5b4b-a496-9718f37d4682
149 lines
3.2 KiB
C
Executable File
149 lines
3.2 KiB
C
Executable File
/* 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 */
|