319 lines
6.9 KiB
C
319 lines
6.9 KiB
C
|
/* m4memo.c (c)Copyright Sequiter Software Inc., 1990-1994. All rights reserved. */
|
||
|
|
|
||
|
|
#include "d4all.h"
|
||
|
|
#ifndef S4UNIX
|
||
|
|
#ifdef __TURBOC__
|
||
|
|
#pragma hdrstop
|
||
|
|
#endif
|
||
|
|
#endif
|
||
|
|
|
||
|
|
#ifndef S4MEMO_OFF
|
||
|
|
|
||
|
|
#ifdef S4MFOX
|
||
|
|
long S4FUNCTION memo4len_part( MEMO4FILE *f4memo, long memo_id )
|
||
|
|
{
|
||
|
|
long pos ;
|
||
|
|
MEMO4BLOCK memo_block ;
|
||
|
|
|
||
|
|
if ( memo_id <= 0L )
|
||
|
|
return 0 ;
|
||
|
|
|
||
|
|
pos = memo_id * f4memo->block_size ;
|
||
|
|
if ( file4read_all( &f4memo->file, pos, &memo_block, sizeof( MEMO4BLOCK ) ) < 0)
|
||
|
|
return -1 ;
|
||
|
|
#ifdef S4BYTE_SWAP
|
||
|
|
memo_block.type = x4reverse_long( (void *)&memo_block.type ) ;
|
||
|
|
memo_block.num_chars = x4reverse_long( (void *)&memo_block.num_chars ) ;
|
||
|
|
#endif
|
||
|
|
|
||
|
|
return x4reverse_long( (void *)&memo_block.num_chars ) ;
|
||
|
|
}
|
||
|
|
#endif
|
||
|
|
|
||
|
|
#ifndef S4OFF_WRITE
|
||
|
|
int S4FUNCTION d4memo_compress( DATA4 *data )
|
||
|
|
{
|
||
|
|
char *rd_buf, *wr_buf, *ptr ;
|
||
|
|
FILE4SEQ_READ rd ;
|
||
|
|
FILE4SEQ_WRITE wr ;
|
||
|
|
MEMO4FILE new_file ;
|
||
|
|
CODE4 *code_base ;
|
||
|
|
unsigned buf_size, ptr_len, ptr_max ;
|
||
|
|
long cur_count, i_rec, new_id ;
|
||
|
|
int rc, i, save_flag ;
|
||
|
|
FIELD4 *field ;
|
||
|
|
#ifndef S4OPTIMIZE_OFF
|
||
|
|
int has_opt ;
|
||
|
|
#endif
|
||
|
|
#ifdef S4FOX
|
||
|
|
long memo_len, pos ;
|
||
|
|
#endif
|
||
|
|
|
||
|
|
#ifdef S4VBASIC
|
||
|
|
if ( c4parm_check( data, 2, E4_D4MEMO_COMP ) )
|
||
|
|
return -1 ;
|
||
|
|
#endif
|
||
|
|
|
||
|
|
if ( data == 0 )
|
||
|
|
#ifdef S4DEBUG
|
||
|
|
e4severe( e4parm, E4_D4MEMO_COMP ) ;
|
||
|
|
#else
|
||
|
|
return -1 ;
|
||
|
|
#endif
|
||
|
|
|
||
|
|
code_base = data->code_base ;
|
||
|
|
if ( code_base->error_code < 0 )
|
||
|
|
return -1 ;
|
||
|
|
|
||
|
|
if ( data->n_fields_memo == 0 )
|
||
|
|
return 0 ;
|
||
|
|
|
||
|
|
rc = d4update( data ) ;
|
||
|
|
if ( rc )
|
||
|
|
return rc ;
|
||
|
|
|
||
|
|
#ifndef S4SINGLE
|
||
|
|
rc = d4lock_file( data ) ;
|
||
|
|
if ( rc )
|
||
|
|
return rc ;
|
||
|
|
#ifndef N4OTHER
|
||
|
|
if ( !rc )
|
||
|
|
if ( data->n_fields_memo > 0 && data->memo_file.file.hand != -1 )
|
||
|
|
rc = memo4file_lock( &data->memo_file ) ;
|
||
|
|
#endif
|
||
|
|
if ( rc )
|
||
|
|
return rc ;
|
||
|
|
#endif
|
||
|
|
|
||
|
|
save_flag = code_base->mem_size_memo ;
|
||
|
|
code_base->mem_size_memo = data->memo_file.block_size ;
|
||
|
|
|
||
|
|
if ( memo4file_create( &new_file, code_base, data, 0 ) < 0 )
|
||
|
|
return -1 ;
|
||
|
|
|
||
|
|
code_base->mem_size_memo = save_flag ;
|
||
|
|
new_file.block_size = data->memo_file.block_size ;
|
||
|
|
|
||
|
|
rd_buf = wr_buf = 0 ;
|
||
|
|
buf_size = code_base->mem_size_buffer ;
|
||
|
|
|
||
|
|
#ifndef S4OPTIMIZE_OFF
|
||
|
|
has_opt = code_base->has_opt && code_base->opt.num_buffers ;
|
||
|
|
d4opt_suspend( 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, buf_size ) ;
|
||
|
|
file4seq_write_init( &wr, &data->file, d4record_position( data, 1L ), wr_buf, buf_size ) ;
|
||
|
|
|
||
|
|
cur_count = d4reccount( data ) ;
|
||
|
|
|
||
|
|
ptr = 0 ;
|
||
|
|
ptr_len = ptr_max = 0 ;
|
||
|
|
|
||
|
|
for ( i_rec= 1L ; i_rec <= cur_count ; i_rec++ )
|
||
|
|
{
|
||
|
|
if ( file4seq_read_all( &rd, data->record, data->record_width ) < 0 )
|
||
|
|
break ;
|
||
|
|
|
||
|
|
for ( i = 0 ; i < data->n_fields_memo ; i++ )
|
||
|
|
{
|
||
|
|
field = data->fields_memo[i].field ;
|
||
|
|
|
||
|
|
#ifdef S4FOX
|
||
|
|
pos = 0L ;
|
||
|
|
memo_len = memo4len_part( &data->memo_file, f4long( field ) ) ;
|
||
|
|
|
||
|
|
if ( memo_len > 0L )
|
||
|
|
{
|
||
|
|
do
|
||
|
|
{
|
||
|
|
#ifdef S4DEBUG
|
||
|
|
if ( pos > memo_len )
|
||
|
|
e4severe( e4info, E4_D4MEMO_COMP ) ;
|
||
|
|
#endif
|
||
|
|
|
||
|
|
ptr_len = ptr_max ;
|
||
|
|
|
||
|
|
if ( memo4file_read_part( &data->memo_file, f4long( field ), &ptr, &ptr_len, pos, UINT_MAX ) < 0 )
|
||
|
|
{
|
||
|
|
rc = -1 ;
|
||
|
|
break ;
|
||
|
|
}
|
||
|
|
|
||
|
|
if ( ptr_len > ptr_max )
|
||
|
|
ptr_max = ptr_len ;
|
||
|
|
|
||
|
|
new_id = 0L ;
|
||
|
|
if ( memo4file_write_part( &new_file, &new_id, ptr, memo_len, pos, ptr_len ) < 0 )
|
||
|
|
{
|
||
|
|
rc = -1 ;
|
||
|
|
break ;
|
||
|
|
}
|
||
|
|
pos += ptr_len ;
|
||
|
|
} while( pos != memo_len ) ;
|
||
|
|
c4ltoa45( new_id, f4ptr(field), -( (int)field->len ) ) ;
|
||
|
|
}
|
||
|
|
else
|
||
|
|
c4ltoa45( 0L, f4ptr(field), -( (int)field->len) ) ;
|
||
|
|
#else
|
||
|
|
ptr_len = ptr_max ;
|
||
|
|
if ( memo4file_read( &data->memo_file, f4long(field), &ptr, &ptr_len ) < 0 )
|
||
|
|
{
|
||
|
|
rc = -1 ;
|
||
|
|
break ;
|
||
|
|
}
|
||
|
|
|
||
|
|
#ifndef N4OTHER
|
||
|
|
if ( ptr_len > ptr_max )
|
||
|
|
#endif
|
||
|
|
ptr_max = ptr_len ;
|
||
|
|
|
||
|
|
new_id = 0L ;
|
||
|
|
if ( memo4file_write( &new_file, &new_id, ptr, ptr_len ) < 0 )
|
||
|
|
{
|
||
|
|
rc = -1 ;
|
||
|
|
break ;
|
||
|
|
}
|
||
|
|
|
||
|
|
c4ltoa45( new_id, f4ptr(field), - ((int) field->len) ) ;
|
||
|
|
#endif
|
||
|
|
}
|
||
|
|
file4seq_write( &wr, data->record, data->record_width ) ;
|
||
|
|
}
|
||
|
|
|
||
|
|
if ( rc < 0 )
|
||
|
|
file4close( &new_file.file ) ; /* error occurred */
|
||
|
|
else
|
||
|
|
file4seq_write_flush(&wr) ;
|
||
|
|
|
||
|
|
u4free( ptr ) ;
|
||
|
|
u4free( rd_buf ) ;
|
||
|
|
u4free( wr_buf ) ;
|
||
|
|
|
||
|
|
if ( rc == 0 )
|
||
|
|
rc = file4replace( &data->memo_file.file, &new_file.file ) ;
|
||
|
|
|
||
|
|
#ifndef S4OPTIMIZE_OFF
|
||
|
|
if ( has_opt )
|
||
|
|
d4opt_restart( code_base ) ;
|
||
|
|
#endif
|
||
|
|
|
||
|
|
return rc ;
|
||
|
|
}
|
||
|
|
#endif /* S4OFF_WRITE */
|
||
|
|
|
||
|
|
#ifndef S4MFOX
|
||
|
|
#ifndef S4MNDX
|
||
|
|
|
||
|
|
int memo4file_chain_flush( MEMO4FILE *f4memo, MEMO4CHAIN_ENTRY *chain )
|
||
|
|
{
|
||
|
|
#ifdef S4BYTE_SWAP
|
||
|
|
MEMO4CHAIN_ENTRY swap ;
|
||
|
|
#endif
|
||
|
|
|
||
|
|
if ( chain->to_disk )
|
||
|
|
{
|
||
|
|
chain->to_disk = 0 ;
|
||
|
|
#ifdef S4BYTE_SWAP
|
||
|
|
memcpy( (void *)&swap, (void *)chain, sizeof( MEMO4CHAIN_ENTRY ) ) ;
|
||
|
|
swap.next = x4reverse_long( (void *)&swap.next ) ;
|
||
|
|
swap.num = x4reverse_long( (void *)&swap.num ) ;
|
||
|
|
|
||
|
|
return file4write( &f4memo->file, chain->block_no * f4memo->block_size, &swap, 2*sizeof(S4LONG) ) ;
|
||
|
|
#else
|
||
|
|
return file4write( &f4memo->file, chain->block_no * f4memo->block_size, chain, 2*sizeof(S4LONG) ) ;
|
||
|
|
#endif
|
||
|
|
}
|
||
|
|
return 0 ;
|
||
|
|
}
|
||
|
|
|
||
|
|
int memo4file_chain_skip( MEMO4FILE *f4memo, MEMO4CHAIN_ENTRY *chain )
|
||
|
|
{
|
||
|
|
unsigned len_read ;
|
||
|
|
|
||
|
|
chain->to_disk = 0 ;
|
||
|
|
chain->block_no = chain->next ;
|
||
|
|
|
||
|
|
if ( chain->next < 0 )
|
||
|
|
len_read = 0 ;
|
||
|
|
else
|
||
|
|
{
|
||
|
|
len_read = file4read( &f4memo->file, chain->next * f4memo->block_size, chain, sizeof(chain->next)+sizeof(chain->num) ) ;
|
||
|
|
#ifdef S4BYTE_SWAP
|
||
|
|
chain->next = x4reverse_long( (void *)&chain->next ) ;
|
||
|
|
chain->num = x4reverse_long( (void *)&chain->num ) ;
|
||
|
|
#endif
|
||
|
|
}
|
||
|
|
|
||
|
|
if ( f4memo->data->code_base->error_code < 0 )
|
||
|
|
return -1 ;
|
||
|
|
if ( len_read == 0 )
|
||
|
|
{
|
||
|
|
chain->num = -1 ;
|
||
|
|
chain->next = -1 ;
|
||
|
|
return 0 ;
|
||
|
|
}
|
||
|
|
if ( len_read != sizeof(chain->next)+sizeof(chain->num) )
|
||
|
|
return file4read_error( &f4memo->file ) ;
|
||
|
|
return 0 ;
|
||
|
|
}
|
||
|
|
#endif
|
||
|
|
#endif
|
||
|
|
|
||
|
|
#endif /* S4MEMO_OFF */
|
||
|
|
|
||
|
|
/* Make the memo file entries current */
|
||
|
|
int S4FUNCTION d4validate_memo_ids( DATA4 *data )
|
||
|
|
{
|
||
|
|
#ifdef S4MEMO_OFF
|
||
|
|
return 0 ;
|
||
|
|
#else
|
||
|
|
int rc, i ;
|
||
|
|
char *from_ptr ;
|
||
|
|
|
||
|
|
if ( data == 0 )
|
||
|
|
#ifdef S4DEBUG
|
||
|
|
e4severe( e4parm, E4_D4VALID_MID ) ;
|
||
|
|
#else
|
||
|
|
return -1 ;
|
||
|
|
#endif
|
||
|
|
|
||
|
|
if ( data->memo_validated )
|
||
|
|
return 0 ;
|
||
|
|
|
||
|
|
#ifndef S4SINGLE
|
||
|
|
if ( data->rec_num > 0 )
|
||
|
|
{
|
||
|
|
rc = d4lock( data, data->rec_num ) ;
|
||
|
|
if ( rc )
|
||
|
|
return rc ;
|
||
|
|
}
|
||
|
|
#endif
|
||
|
|
|
||
|
|
if ( d4read_old( data, data->rec_num ) < 0 )
|
||
|
|
return -1 ;
|
||
|
|
|
||
|
|
for ( i = 0 ; i < data->n_fields_memo ; i++ )
|
||
|
|
{
|
||
|
|
from_ptr = data->record_old + data->fields_memo[i].field->offset ;
|
||
|
|
memcpy( f4ptr( data->fields_memo[i].field), from_ptr, 10 ) ;
|
||
|
|
}
|
||
|
|
data->memo_validated = 1 ;
|
||
|
|
return 0 ;
|
||
|
|
#endif /* S4MEMO_OFF */
|
||
|
|
}
|