diff options
Diffstat (limited to 'isam/log.c')
| -rw-r--r-- | isam/log.c | 156 |
1 files changed, 0 insertions, 156 deletions
diff --git a/isam/log.c b/isam/log.c deleted file mode 100644 index 78b56690401..00000000000 --- a/isam/log.c +++ /dev/null @@ -1,156 +0,0 @@ -/* 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; -} |