← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to mysys/my_open.cc

Merge of Jay

Show diffs side-by-side

added added

removed removed

Lines of Context:
mysys/my_open.cc
13
13
   along with this program; if not, write to the Free Software
14
14
   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
15
15
 
16
 
#include "mysys_priv.h"
17
 
#include "mysys_err.h"
18
 
#include <my_dir.h>
 
16
#include "mysys/mysys_priv.h"
 
17
#include "mysys/mysys_err.h"
 
18
#include "my_dir.h"
 
19
 
19
20
#include <errno.h>
 
21
#include <stdlib.h>
 
22
#include <string.h>
20
23
 
21
24
/*
22
25
  Open a file
24
27
  SYNOPSIS
25
28
    my_open()
26
29
      FileName  Fully qualified file name
27
 
      Flags     Read | write 
 
30
      Flags     Read | write
28
31
      MyFlags   Special flags
29
32
 
30
33
  RETURN VALUE
44
47
  fd = open((char *) FileName, Flags);
45
48
#endif
46
49
 
47
 
  return(my_register_filename(fd, FileName, FILE_BY_OPEN,
48
 
                                   EE_FILENOTFOUND, MyFlags));
 
50
  return(my_register_filename(fd, FileName, EE_FILENOTFOUND, MyFlags));
49
51
} /* my_open */
50
52
 
51
53
 
63
65
{
64
66
  int err;
65
67
 
66
 
  pthread_mutex_lock(&THR_LOCK_open);
67
68
  do
68
69
  {
69
70
    err= close(fd);
73
74
  {
74
75
    my_errno=errno;
75
76
    if (MyFlags & (MY_FAE | MY_WME))
76
 
      my_error(EE_BADCLOSE, MYF(ME_BELL+ME_WAITTANG),my_filename(fd),errno);
77
 
  }
78
 
  if ((uint) fd < my_file_limit && my_file_info[fd].type != UNOPEN)
79
 
  {
80
 
    my_free(my_file_info[fd].name, MYF(0));
81
 
#if !defined(HAVE_PREAD)
82
 
    pthread_mutex_destroy(&my_file_info[fd].mutex);
83
 
#endif
84
 
    my_file_info[fd].type = UNOPEN;
 
77
      my_error(EE_BADCLOSE, MYF(ME_BELL+ME_WAITTANG), "unknown", errno);
85
78
  }
86
79
  my_file_opened--;
87
 
  pthread_mutex_unlock(&THR_LOCK_open);
 
80
 
88
81
  return(err);
89
82
} /* my_close */
90
83
 
91
84
 
92
85
/*
93
 
  Register file in my_file_info[]
94
 
   
 
86
  TODO: Get rid of
 
87
 
95
88
  SYNOPSIS
96
89
    my_register_filename()
97
90
    fd                     File number opened, -1 if error on open
106
99
 
107
100
*/
108
101
 
109
 
File my_register_filename(File fd, const char *FileName, enum file_type
110
 
                          type_of_file, uint error_message_number, myf MyFlags)
 
102
File my_register_filename(File fd, const char *FileName, uint32_t error_message_number, myf MyFlags)
111
103
{
112
104
  if ((int) fd >= 0)
113
105
  {
114
 
    if ((uint) fd >= my_file_limit)
115
 
    {
116
 
#if !defined(HAVE_PREAD)
117
 
      my_errno= EMFILE;
118
 
#else
119
 
      thread_safe_increment(my_file_opened,&THR_LOCK_open);
120
 
      return(fd);                               /* safeguard */
121
 
#endif
122
 
    }
123
 
    else
124
 
    {
125
 
      pthread_mutex_lock(&THR_LOCK_open);
126
 
      if ((my_file_info[fd].name = (char*) my_strdup(FileName,MyFlags)))
127
 
      {
128
 
        my_file_opened++;
129
 
        my_file_total_opened++;
130
 
        my_file_info[fd].type = type_of_file;
131
 
#if !defined(HAVE_PREAD)
132
 
        pthread_mutex_init(&my_file_info[fd].mutex,MY_MUTEX_INIT_FAST);
133
 
#endif
134
 
        pthread_mutex_unlock(&THR_LOCK_open);
135
 
        return(fd);
136
 
      }
137
 
      pthread_mutex_unlock(&THR_LOCK_open);
138
 
      my_errno= ENOMEM;
139
 
    }
140
 
    (void) my_close(fd, MyFlags);
 
106
    my_file_opened++;
 
107
    my_file_total_opened++;
 
108
 
 
109
    return fd;
141
110
  }
142
111
  else
143
112
    my_errno= errno;
149
118
    my_error(error_message_number, MYF(ME_BELL+ME_WAITTANG),
150
119
             FileName, my_errno);
151
120
  }
152
 
  return(-1);
153
 
}
154
 
 
155
 
 
156
 
#ifdef EXTRA_DEBUG
157
 
 
158
 
void my_print_open_files(void)
159
 
{
160
 
  if (my_file_opened | my_stream_opened)
161
 
  {
162
 
    uint i;
163
 
    for (i= 0 ; i < my_file_limit ; i++)
164
 
    {
165
 
      if (my_file_info[i].type != UNOPEN)
166
 
      {
167
 
        fprintf(stderr, EE(EE_FILE_NOT_CLOSED), my_file_info[i].name, i);
168
 
        fputc('\n', stderr);
169
 
      }
170
 
    }
171
 
  }
172
 
}
173
 
 
174
 
#endif
 
121
  return -1;
 
122
}