← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to plugin/myisam/myisam_priv.h

  • Committer: Brian Aker
  • Date: 2010-11-22 00:16:44 UTC
  • mto: (1945.2.1 quick)
  • mto: This revision was merged to the branch mainline in revision 1947.
  • Revision ID: brian@tangent.org-20101122001644-pi6jv0d65e82xn38
Merge in lock refactor, this just encapsulates.

Show diffs side-by-side

added added

removed removed

Lines of Context:
plugin/myisam/myisam_priv.h
11
11
 
12
12
   You should have received a copy of the GNU General Public License
13
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 */
 
14
   Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA */
15
15
 
16
16
/* This file is included by all internal myisam files */
17
17
 
31
31
#include <string.h>
32
32
#include <list>
33
33
 
 
34
#include <boost/thread/mutex.hpp>
 
35
 
34
36
#if defined(my_write)
35
37
#undef my_write                         /* undef map from my_nosys; We need test-if-disk full */
36
38
#endif
37
39
 
 
40
/* Typical key cash */
 
41
static const uint32_t KEY_CACHE_SIZE= 8*1024*1024;
 
42
 
 
43
/* Default size of a key cache block  */
 
44
static const uint32_t KEY_CACHE_BLOCK_SIZE= 1024;
 
45
 
38
46
typedef struct st_mi_status_info
39
47
{
40
48
  drizzled::ha_rows records;                    /* Rows in table */
177
185
  char  *data_file_name,                /* Resolved path names from symlinks */
178
186
        *index_file_name;
179
187
  unsigned char *file_map;                      /* mem-map of file if possible */
180
 
  drizzled::KEY_CACHE *key_cache;                       /* ref to the current key cache */
 
188
private:
 
189
  drizzled::KEY_CACHE key_cache;                        /* ref to the current key cache */
 
190
public:
 
191
  drizzled::KEY_CACHE *getKeyCache()
 
192
  {
 
193
    return &key_cache;
 
194
  }
 
195
 
 
196
  void setKeyCache();
 
197
 
181
198
  MI_DECODE_TREE *decode_trees;
182
199
  uint16_t *decode_tables;
183
200
  int (*read_record)(struct st_myisam_info*, drizzled::internal::my_off_t, unsigned char*);
195
212
  ulong this_process;                   /* processid */
196
213
  ulong last_process;                   /* For table-change-check */
197
214
  ulong last_version;                   /* Version on start */
198
 
  ulong options;                        /* Options used */
 
215
  uint64_t options;                     /* Options used */
199
216
  ulong min_pack_length;                /* Theese are used by packed data */
200
217
  ulong max_pack_length;
201
218
  ulong state_diff_length;
217
234
    not_flushed,
218
235
    temporary,delay_key_write,
219
236
    concurrent_insert;
220
 
  drizzled::THR_LOCK lock;
221
 
  pthread_mutex_t intern_lock;          /* Locking for use with _locking */
222
 
  pthread_rwlock_t *key_root_lock;
223
237
  drizzled::internal::my_off_t mmaped_length;
224
238
  uint32_t     nonmmaped_inserts;           /* counter of writing in non-mmaped
225
239
                                           area */
226
 
  pthread_rwlock_t mmap_lock;
227
240
} MYISAM_SHARE;
228
241
 
229
242
 
459
472
#define MI_UNIQUE_HASH_TYPE     HA_KEYTYPE_ULONG_INT
460
473
#define mi_unique_store(A,B)    mi_int4store((A),(B))
461
474
 
462
 
extern pthread_mutex_t THR_LOCK_myisam;
 
475
extern boost::mutex THR_LOCK_myisam;
463
476
 
464
477
        /* Some extern variables */
465
478
 
704
717
                           const unsigned char *record, drizzled::internal::my_off_t pos);
705
718
int mi_unique_comp(MI_UNIQUEDEF *def, const unsigned char *a, const unsigned char *b,
706
719
                   bool null_are_equal);
707
 
void mi_get_status(void* param, int concurrent_insert);
708
 
void mi_update_status(void* param);
709
 
void mi_restore_status(void* param);
710
 
void mi_copy_status(void* to,void *from);
711
 
bool mi_check_status(void* param);
712
720
 
713
721
extern MI_INFO *test_if_reopen(char *filename);
714
722
bool check_table_is_closed(const char *name, const char *where);
727
735
void mi_check_print_info(MI_CHECK *param, const char *fmt,...);
728
736
int flush_pending_blocks(MI_SORT_PARAM *param);
729
737
int thr_write_keys(MI_SORT_PARAM *sort_param);
730
 
/* needs extern "C" because we pass it to pthread_create */
731
 
extern "C" pthread_handler_t thr_find_all_keys(void *arg);
732
738
int flush_blocks(MI_CHECK *param, drizzled::KEY_CACHE *key_cache, int file);
733
739
 
734
740
int sort_write_record(MI_SORT_PARAM *sort_param);