diff options
Diffstat (limited to 'storage/maria/ma_log.c')
| -rw-r--r-- | storage/maria/ma_log.c | 164 |
1 files changed, 164 insertions, 0 deletions
diff --git a/storage/maria/ma_log.c b/storage/maria/ma_log.c new file mode 100644 index 00000000000..7c32c1068cb --- /dev/null +++ b/storage/maria/ma_log.c @@ -0,0 +1,164 @@ +/* Copyright (C) 2006 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 MARIA commands and records on logfile for debugging + The log can be examined with help of the marialog command. +*/ + +#include "maria_def.h" +#if defined(MSDOS) || defined(__WIN__) +#include <fcntl.h> +#ifndef __WIN__ +#include <process.h> +#endif +#endif +#ifdef VMS +#include <processes.h> +#endif + +#undef GETPID /* For HPUX */ +#ifdef THREAD +#define GETPID() (log_type == 1 ? (long) maria_pid : (long) my_thread_id()); +#else +#define GETPID() maria_pid +#endif + + /* Activate logging if flag is 1 and reset logging if flag is 0 */ + +static int log_type=0; +ulong maria_pid=0; + +int maria_logging(int activate_log) +{ + int error=0; + char buff[FN_REFLEN]; + DBUG_ENTER("maria_logging"); + + log_type=activate_log; + if (activate_log) + { + if (!maria_pid) + maria_pid=(ulong) getpid(); + if (maria_log_file < 0) + { + if ((maria_log_file = my_create(fn_format(buff,maria_log_filename, + "",".log",4), + 0,(O_RDWR | O_BINARY | O_APPEND),MYF(0))) + < 0) + DBUG_RETURN(my_errno); + } + } + else if (maria_log_file >= 0) + { + error=my_close(maria_log_file,MYF(0)) ? my_errno : 0 ; + maria_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 _ma_log(enum maria_log_commands command, MARIA_HA *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; + mi_int2store(buff+1,info->dfile); + mi_int4store(buff+3,pid); + mi_int2store(buff+9,length); + + pthread_mutex_lock(&THR_LOCK_maria); + error=my_lock(maria_log_file,F_WRLCK,0L,F_TO_EOF,MYF(MY_SEEK_NOT_DONE)); + VOID(my_write(maria_log_file,buff,sizeof(buff),MYF(0))); + VOID(my_write(maria_log_file,buffert,length,MYF(0))); + if (!error) + error=my_lock(maria_log_file,F_UNLCK,0L,F_TO_EOF,MYF(MY_SEEK_NOT_DONE)); + pthread_mutex_unlock(&THR_LOCK_maria); + my_errno=old_errno; +} + + +void _ma_log_command(enum maria_log_commands command, MARIA_HA *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; + mi_int2store(buff+1,info->dfile); + mi_int4store(buff+3,pid); + mi_int2store(buff+7,result); + pthread_mutex_lock(&THR_LOCK_maria); + error=my_lock(maria_log_file,F_WRLCK,0L,F_TO_EOF,MYF(MY_SEEK_NOT_DONE)); + VOID(my_write(maria_log_file,buff,sizeof(buff),MYF(0))); + if (buffert) + VOID(my_write(maria_log_file,buffert,length,MYF(0))); + if (!error) + error=my_lock(maria_log_file,F_UNLCK,0L,F_TO_EOF,MYF(MY_SEEK_NOT_DONE)); + pthread_mutex_unlock(&THR_LOCK_maria); + my_errno=old_errno; +} + + +void _ma_log_record(enum maria_log_commands command, MARIA_HA *info, + const byte *record, my_off_t filepos, int result) +{ + char buff[21],*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+ _ma_calc_total_blob_length(info,record); + buff[0]=(char) command; + mi_int2store(buff+1,info->dfile); + mi_int4store(buff+3,pid); + mi_int2store(buff+7,result); + mi_sizestore(buff+9,filepos); + mi_int4store(buff+17,length); + pthread_mutex_lock(&THR_LOCK_maria); + error=my_lock(maria_log_file,F_WRLCK,0L,F_TO_EOF,MYF(MY_SEEK_NOT_DONE)); + VOID(my_write(maria_log_file,buff,sizeof(buff),MYF(0))); + VOID(my_write(maria_log_file,(byte*) record,info->s->base.reclength,MYF(0))); + if (info->s->base.blobs) + { + MARIA_BLOB *blob,*end; + + for (end=info->blobs+info->s->base.blobs, blob= info->blobs; + blob != end ; + blob++) + { + memcpy_fixed(&pos,record+blob->offset+blob->pack_length,sizeof(char*)); + VOID(my_write(maria_log_file,pos,blob->length,MYF(0))); + } + } + if (!error) + error=my_lock(maria_log_file,F_UNLCK,0L,F_TO_EOF,MYF(MY_SEEK_NOT_DONE)); + pthread_mutex_unlock(&THR_LOCK_maria); + my_errno=old_errno; +} |