← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to storage/myisam/mi_log.c

  • Committer: Brian Aker
  • Date: 2008-08-11 05:13:09 UTC
  • Revision ID: brian@tangent.org-20080811051309-t4b3bce0zw74wi0z
Another pass of ulong removal.

Show diffs side-by-side

added added

removed removed

Lines of Context:
storage/myisam/mi_log.c
1
 
/* Copyright (C) 2000-2001, 2004 MySQL AB
2
 
 
3
 
   This program is free software; you can redistribute it and/or modify
4
 
   it under the terms of the GNU General Public License as published by
5
 
   the Free Software Foundation; version 2 of the License.
6
 
 
7
 
   This program is distributed in the hope that it will be useful,
8
 
   but WITHOUT ANY WARRANTY; without even the implied warranty of
9
 
   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
10
 
   GNU General Public License for more details.
11
 
 
12
 
   You should have received a copy of the GNU General Public License
13
 
   along with this program; if not, write to the Free Software
14
 
   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
15
 
 
16
 
/*
17
 
  Logging of MyISAM commands and records on logfile for debugging
18
 
  The log can be examined with help of the myisamlog command.
19
 
*/
20
 
 
21
 
#include "myisamdef.h"
22
 
 
23
 
#undef GETPID                                   /* For HPUX */
24
 
#define GETPID() (log_type == 1 ? (long) myisam_pid : (long) my_thread_dbug_id())
25
 
 
26
 
        /* Activate logging if flag is 1 and reset logging if flag is 0 */
27
 
 
28
 
static int log_type=0;
29
 
uint32_t myisam_pid=0;
30
 
 
31
 
int mi_log(int activate_log)
32
 
{
33
 
  int error=0;
34
 
  char buff[FN_REFLEN];
35
 
 
36
 
  log_type=activate_log;
37
 
  if (activate_log)
38
 
  {
39
 
    if (!myisam_pid)
40
 
      myisam_pid=(uint32_t) getpid();
41
 
    if (myisam_log_file < 0)
42
 
    {
43
 
      if ((myisam_log_file = my_create(fn_format(buff,myisam_log_filename,
44
 
                                                "",".log",4),
45
 
                                      0,(O_RDWR | O_BINARY | O_APPEND),MYF(0)))
46
 
          < 0)
47
 
        return(my_errno);
48
 
    }
49
 
  }
50
 
  else if (myisam_log_file >= 0)
51
 
  {
52
 
    error=my_close(myisam_log_file,MYF(0)) ? my_errno : 0 ;
53
 
    myisam_log_file= -1;
54
 
  }
55
 
  return(error);
56
 
}
57
 
 
58
 
 
59
 
        /* Logging of records and commands on logfile */
60
 
        /* All logs starts with command(1) dfile(2) process(4) result(2) */
61
 
 
62
 
void _myisam_log(enum myisam_log_commands command, MI_INFO *info,
63
 
                 const uchar *buffert, uint length)
64
 
{
65
 
  uchar buff[11];
66
 
  int old_errno;
67
 
  uint32_t pid=(uint32_t) GETPID();
68
 
  old_errno=my_errno;
69
 
  memset(buff, 0, sizeof(buff));
70
 
  buff[0]=(char) command;
71
 
  mi_int2store(buff+1,info->dfile);
72
 
  mi_int4store(buff+3,pid);
73
 
  mi_int2store(buff+9,length);
74
 
 
75
 
  pthread_mutex_lock(&THR_LOCK_myisam);
76
 
  VOID(my_write(myisam_log_file,buff,sizeof(buff),MYF(0)));
77
 
  VOID(my_write(myisam_log_file,buffert,length,MYF(0)));
78
 
  pthread_mutex_unlock(&THR_LOCK_myisam);
79
 
  my_errno=old_errno;
80
 
}
81
 
 
82
 
 
83
 
void _myisam_log_command(enum myisam_log_commands command, MI_INFO *info,
84
 
                         const uchar *buffert, uint length, int result)
85
 
{
86
 
  uchar buff[9];
87
 
  int old_errno;
88
 
  uint32_t pid=(uint32_t) GETPID();
89
 
 
90
 
  old_errno=my_errno;
91
 
  buff[0]=(char) command;
92
 
  mi_int2store(buff+1,info->dfile);
93
 
  mi_int4store(buff+3,pid);
94
 
  mi_int2store(buff+7,result);
95
 
  pthread_mutex_lock(&THR_LOCK_myisam);
96
 
  VOID(my_write(myisam_log_file,buff,sizeof(buff),MYF(0)));
97
 
  if (buffert)
98
 
    VOID(my_write(myisam_log_file,buffert,length,MYF(0)));
99
 
  pthread_mutex_unlock(&THR_LOCK_myisam);
100
 
  my_errno=old_errno;
101
 
}
102
 
 
103
 
 
104
 
void _myisam_log_record(enum myisam_log_commands command, MI_INFO *info,
105
 
                        const uchar *record, my_off_t filepos, int result)
106
 
{
107
 
  uchar buff[21],*pos;
108
 
  int old_errno;
109
 
  uint length;
110
 
  uint32_t pid=(uint32_t) GETPID();
111
 
 
112
 
  old_errno=my_errno;
113
 
  if (!info->s->base.blobs)
114
 
    length=info->s->base.reclength;
115
 
  else
116
 
    length=info->s->base.reclength+ _my_calc_total_blob_length(info,record);
117
 
  buff[0]=(uchar) command;
118
 
  mi_int2store(buff+1,info->dfile);
119
 
  mi_int4store(buff+3,pid);
120
 
  mi_int2store(buff+7,result);
121
 
  mi_sizestore(buff+9,filepos);
122
 
  mi_int4store(buff+17,length);
123
 
  pthread_mutex_lock(&THR_LOCK_myisam);
124
 
  VOID(my_write(myisam_log_file, buff,sizeof(buff),MYF(0)));
125
 
  VOID(my_write(myisam_log_file, record,info->s->base.reclength,MYF(0)));
126
 
  if (info->s->base.blobs)
127
 
  {
128
 
    MI_BLOB *blob,*end;
129
 
 
130
 
    for (end=info->blobs+info->s->base.blobs, blob= info->blobs;
131
 
         blob != end ;
132
 
         blob++)
133
 
    {
134
 
      memcpy(&pos, record+blob->offset+blob->pack_length, sizeof(char*));
135
 
      VOID(my_write(myisam_log_file,pos,blob->length,MYF(0)));
136
 
    }
137
 
  }
138
 
  pthread_mutex_unlock(&THR_LOCK_myisam);
139
 
  my_errno=old_errno;
140
 
}