diff options
Diffstat (limited to 'isam/log.c')
| -rw-r--r-- | isam/log.c | 156 |
1 files changed, 156 insertions, 0 deletions
diff --git a/isam/log.c b/isam/log.c new file mode 100644 index 00000000000..a95b53b5110 --- /dev/null +++ b/isam/log.c @@ -0,0 +1,156 @@ +/* Copyright (C) 2000 MySQL AB & MySQL Finland AB & TCX DataKonsult AB + + This program is free software; you can redistribute it and/or modify + it under the terms of the GNU General Public License as published by + the Free Software Foundation; either version 2 of the License, or + (at your option) any later version. + + This program 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 General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program; if not, write to the Free Software + Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ + +/* Logging of isamcommands and records on logfile */ + +#include "isamdef.h" +#if defined(MSDOS) || defined(__WIN__) +#include <errno.h> +#include <fcntl.h> +#ifndef __WIN__ +#include <process.h> +#endif +#endif +#ifdef VMS +#include <processes.h> +#endif + +#ifdef THREAD +#undef GETPID +#define GETPID() (log_type == 1 ? getpid() : (long) my_thread_id()); +#else +#define GETPID() getpid() +#endif + + /* Activate logging if flag is 1 and reset logging if flag is 0 */ + +static int log_type=0; + +int nisam_log(int activate_log) +{ + int error=0; + char buff[FN_REFLEN]; + DBUG_ENTER("nisam_log"); + + log_type=activate_log; + if (activate_log) + { + if (nisam_log_file < 0) + { + if ((nisam_log_file = my_create(fn_format(buff,nisam_log_filename, + "",".log",4), + 0,(O_RDWR | O_BINARY | O_APPEND),MYF(0))) + < 0) + DBUG_RETURN(1); + } + } + else if (nisam_log_file >= 0) + { + error=my_close(nisam_log_file,MYF(0)); + nisam_log_file= -1; + } + DBUG_RETURN(error); +} + + + /* Logging of records and commands on logfile */ + /* All logs starts with command(1) dfile(2) process(4) result(2) */ + +void _nisam_log(enum nisam_log_commands command, N_INFO *info, const byte *buffert, uint length) +{ + char buff[11]; + int error,old_errno; + ulong pid=(ulong) GETPID(); + old_errno=my_errno; + bzero(buff,sizeof(buff)); + buff[0]=(char) command; + int2store(buff+1,info->dfile); + int4store(buff+3,pid); + int2store(buff+9,length); + + pthread_mutex_lock(&THR_LOCK_isam); + error=my_lock(nisam_log_file,F_WRLCK,0L,F_TO_EOF,MYF(MY_SEEK_NOT_DONE)); + VOID(my_write(nisam_log_file,buff,sizeof(buff),MYF(0))); + VOID(my_write(nisam_log_file,buffert,length,MYF(0))); + if (!error) + error=my_lock(nisam_log_file,F_UNLCK,0L,F_TO_EOF,MYF(MY_SEEK_NOT_DONE)); + pthread_mutex_unlock(&THR_LOCK_isam); + my_errno=old_errno; +} + + +void _nisam_log_command(enum nisam_log_commands command, N_INFO *info, const byte *buffert, uint length, int result) +{ + char buff[9]; + int error,old_errno; + ulong pid=(ulong) GETPID(); + + old_errno=my_errno; + buff[0]=(char) command; + int2store(buff+1,info->dfile); + int4store(buff+3,pid); + int2store(buff+7,result); + pthread_mutex_lock(&THR_LOCK_isam); + error=my_lock(nisam_log_file,F_WRLCK,0L,F_TO_EOF,MYF(MY_SEEK_NOT_DONE)); + VOID(my_write(nisam_log_file,buff,sizeof(buff),MYF(0))); + if (buffert) + VOID(my_write(nisam_log_file,buffert,length,MYF(0))); + if (!error) + error=my_lock(nisam_log_file,F_UNLCK,0L,F_TO_EOF,MYF(MY_SEEK_NOT_DONE)); + pthread_mutex_unlock(&THR_LOCK_isam); + my_errno=old_errno; +} + + +void _nisam_log_record(enum nisam_log_commands command, N_INFO *info, const byte *record, ulong filepos, int result) +{ + char buff[17],*pos; + int error,old_errno; + uint length; + ulong pid=(ulong) GETPID(); + + old_errno=my_errno; + if (!info->s->base.blobs) + length=info->s->base.reclength; + else + length=info->s->base.reclength+ _calc_total_blob_length(info,record); + buff[0]=(char) command; + int2store(buff+1,info->dfile); + int4store(buff+3,pid); + int2store(buff+7,result); + int4store(buff+9,filepos); + int4store(buff+13,length); + pthread_mutex_lock(&THR_LOCK_isam); + error=my_lock(nisam_log_file,F_WRLCK,0L,F_TO_EOF,MYF(MY_SEEK_NOT_DONE)); + VOID(my_write(nisam_log_file,buff,sizeof(buff),MYF(0))); + VOID(my_write(nisam_log_file,(byte*) record,info->s->base.reclength,MYF(0))); + if (info->s->base.blobs) + { + N_BLOB *blob,*end; + + for (end=info->blobs+info->s->base.blobs, blob= info->blobs; + blob != end ; + blob++) + { + bmove(&pos,record+blob->offset+blob->pack_length,sizeof(char*)); + VOID(my_write(nisam_log_file,pos,blob->length,MYF(0))); + } + } + if (!error) + error=my_lock(nisam_log_file,F_UNLCK,0L,F_TO_EOF,MYF(MY_SEEK_NOT_DONE)); + pthread_mutex_unlock(&THR_LOCK_isam); + my_errno=old_errno; +} |