Commit 8722d4b8 authored by Sergei Golubchik's avatar Sergei Golubchik

cleanup: remove 16-year-old "TODO"

parent c826ac9d
...@@ -2839,7 +2839,7 @@ int maria_repair(HA_CHECK *param, register MARIA_HA *info, ...@@ -2839,7 +2839,7 @@ int maria_repair(HA_CHECK *param, register MARIA_HA *info,
(param->testflag & T_BACKUP_DATA ? (param->testflag & T_BACKUP_DATA ?
MYF(MY_REDEL_MAKE_BACKUP): MYF(0)) | MYF(MY_REDEL_MAKE_BACKUP): MYF(0)) |
sync_dir) || sync_dir) ||
_ma_open_datafile(info, share, NullS, -1)) _ma_open_datafile(info, share, NullS))
{ {
goto err; goto err;
} }
...@@ -3990,7 +3990,7 @@ int maria_repair_by_sort(HA_CHECK *param, register MARIA_HA *info, ...@@ -3990,7 +3990,7 @@ int maria_repair_by_sort(HA_CHECK *param, register MARIA_HA *info,
(param->testflag & T_BACKUP_DATA ? (param->testflag & T_BACKUP_DATA ?
MYF(MY_REDEL_MAKE_BACKUP): MYF(0)) | MYF(MY_REDEL_MAKE_BACKUP): MYF(0)) |
sync_dir) || sync_dir) ||
_ma_open_datafile(info, share, NullS, -1)) _ma_open_datafile(info, share, NullS))
{ {
_ma_check_print_error(param, "Couldn't change to new data file"); _ma_check_print_error(param, "Couldn't change to new data file");
goto err; goto err;
...@@ -4622,7 +4622,7 @@ int maria_repair_parallel(HA_CHECK *param, register MARIA_HA *info, ...@@ -4622,7 +4622,7 @@ int maria_repair_parallel(HA_CHECK *param, register MARIA_HA *info,
MYF((param->testflag & T_BACKUP_DATA ? MYF((param->testflag & T_BACKUP_DATA ?
MY_REDEL_MAKE_BACKUP : 0) | MY_REDEL_MAKE_BACKUP : 0) |
sync_dir)) || sync_dir)) ||
_ma_open_datafile(info,share, NullS, -1)) _ma_open_datafile(info,share, NullS))
got_error=1; got_error=1;
} }
} }
......
...@@ -104,7 +104,7 @@ static MARIA_HA *maria_clone_internal(MARIA_SHARE *share, const char *name, ...@@ -104,7 +104,7 @@ static MARIA_HA *maria_clone_internal(MARIA_SHARE *share, const char *name,
} }
if (data_file >= 0) if (data_file >= 0)
info.dfile.file= data_file; info.dfile.file= data_file;
else if (_ma_open_datafile(&info, share, name, -1)) else if (_ma_open_datafile(&info, share, name))
goto err; goto err;
errpos= 5; errpos= 5;
...@@ -820,7 +820,7 @@ MARIA_HA *maria_open(const char *name, int mode, uint open_flags) ...@@ -820,7 +820,7 @@ MARIA_HA *maria_open(const char *name, int mode, uint open_flags)
if ((share->data_file_type == BLOCK_RECORD || if ((share->data_file_type == BLOCK_RECORD ||
share->data_file_type == COMPRESSED_RECORD)) share->data_file_type == COMPRESSED_RECORD))
{ {
if (_ma_open_datafile(&info, share, name, -1)) if (_ma_open_datafile(&info, share, name))
goto err; goto err;
data_file= info.dfile.file; data_file= info.dfile.file;
} }
...@@ -1863,13 +1863,9 @@ void _ma_set_index_pagecache_callbacks(PAGECACHE_FILE *file, ...@@ -1863,13 +1863,9 @@ void _ma_set_index_pagecache_callbacks(PAGECACHE_FILE *file,
Open data file Open data file
We can't use dup() here as the data file descriptors need to have different We can't use dup() here as the data file descriptors need to have different
active seek-positions. active seek-positions.
The argument file_to_dup is here for the future if there would on some OS
exist a dup()-like call that would give us two different file descriptors.
*************************************************************************/ *************************************************************************/
int _ma_open_datafile(MARIA_HA *info, MARIA_SHARE *share, const char *org_name, int _ma_open_datafile(MARIA_HA *info, MARIA_SHARE *share, const char *org_name)
File file_to_dup __attribute__((unused)))
{ {
char *data_name= share->data_file_name.str; char *data_name= share->data_file_name.str;
char real_data_name[FN_REFLEN]; char real_data_name[FN_REFLEN];
......
...@@ -1242,7 +1242,7 @@ static int maria_chk(HA_CHECK *param, char *filename) ...@@ -1242,7 +1242,7 @@ static int maria_chk(HA_CHECK *param, char *filename)
mysql_file_close(info->dfile.file, MYF(MY_WME)); /* Close new file */ mysql_file_close(info->dfile.file, MYF(MY_WME)); /* Close new file */
error|=maria_change_to_newfile(filename,MARIA_NAME_DEXT,DATA_TMP_EXT, error|=maria_change_to_newfile(filename,MARIA_NAME_DEXT,DATA_TMP_EXT,
0, MYF(0)); 0, MYF(0));
if (_ma_open_datafile(info,info->s, NullS, -1)) if (_ma_open_datafile(info,info->s, NullS))
error=1; error=1;
param->out_flag&= ~O_NEW_DATA; /* We are using new datafile */ param->out_flag&= ~O_NEW_DATA; /* We are using new datafile */
param->read_cache.file= info->dfile.file; param->read_cache.file= info->dfile.file;
......
...@@ -1302,8 +1302,7 @@ int _ma_def_scan_restore_pos(MARIA_HA *info, MARIA_RECORD_POS lastpos); ...@@ -1302,8 +1302,7 @@ int _ma_def_scan_restore_pos(MARIA_HA *info, MARIA_RECORD_POS lastpos);
extern MARIA_HA *_ma_test_if_reopen(const char *filename); extern MARIA_HA *_ma_test_if_reopen(const char *filename);
my_bool _ma_check_table_is_closed(const char *name, const char *where); my_bool _ma_check_table_is_closed(const char *name, const char *where);
int _ma_open_datafile(MARIA_HA *info, MARIA_SHARE *share, const char *org_name, int _ma_open_datafile(MARIA_HA *info, MARIA_SHARE *share, const char *org_name);
File file_to_dup);
int _ma_open_keyfile(MARIA_SHARE *share); int _ma_open_keyfile(MARIA_SHARE *share);
void _ma_setup_functions(register MARIA_SHARE *share); void _ma_setup_functions(register MARIA_SHARE *share);
my_bool _ma_dynmap_file(MARIA_HA *info, my_off_t size); my_bool _ma_dynmap_file(MARIA_HA *info, my_off_t size);
......
...@@ -2538,7 +2538,7 @@ int mi_repair_by_sort(HA_CHECK *param, register MI_INFO *info, ...@@ -2538,7 +2538,7 @@ int mi_repair_by_sort(HA_CHECK *param, register MI_INFO *info,
(void) mysql_file_delete(mi_key_file_datatmp, (void) mysql_file_delete(mi_key_file_datatmp,
param->temp_filename, MYF(MY_WME)); param->temp_filename, MYF(MY_WME));
if (info->dfile == new_file) /* Retry with key cache */ if (info->dfile == new_file) /* Retry with key cache */
if (unlikely(mi_open_datafile(info, share, name, -1))) if (unlikely(mi_open_datafile(info, share, name)))
param->retry_repair= 0; /* Safety */ param->retry_repair= 0; /* Safety */
} }
mi_mark_crashed_on_repair(info); mi_mark_crashed_on_repair(info);
...@@ -3072,7 +3072,7 @@ int mi_repair_parallel(HA_CHECK *param, register MI_INFO *info, ...@@ -3072,7 +3072,7 @@ int mi_repair_parallel(HA_CHECK *param, register MI_INFO *info,
(void) mysql_file_delete(mi_key_file_datatmp, (void) mysql_file_delete(mi_key_file_datatmp,
param->temp_filename, MYF(MY_WME)); param->temp_filename, MYF(MY_WME));
if (info->dfile == new_file) /* Retry with key cache */ if (info->dfile == new_file) /* Retry with key cache */
if (unlikely(mi_open_datafile(info, share, name, -1))) if (unlikely(mi_open_datafile(info, share, name)))
param->retry_repair= 0; /* Safety */ param->retry_repair= 0; /* Safety */
} }
mi_mark_crashed_on_repair(info); mi_mark_crashed_on_repair(info);
...@@ -4785,7 +4785,7 @@ static int replace_data_file(HA_CHECK *param, MI_INFO *info, ...@@ -4785,7 +4785,7 @@ static int replace_data_file(HA_CHECK *param, MI_INFO *info,
DATA_TMP_EXT, param->backup_time, DATA_TMP_EXT, param->backup_time,
(param->testflag & T_BACKUP_DATA ? (param->testflag & T_BACKUP_DATA ?
MYF(MY_REDEL_MAKE_BACKUP): MYF(0))) || MYF(MY_REDEL_MAKE_BACKUP): MYF(0))) ||
mi_open_datafile(info, share, name, -1)) mi_open_datafile(info, share, name))
return 1; return 1;
return 0; return 0;
} }
...@@ -480,7 +480,7 @@ MI_INFO *mi_open(const char *name, int mode, uint open_flags) ...@@ -480,7 +480,7 @@ MI_INFO *mi_open(const char *name, int mode, uint open_flags)
lock_error=1; /* Database unlocked */ lock_error=1; /* Database unlocked */
} }
if (mi_open_datafile(&info, share, name, -1)) if (mi_open_datafile(&info, share, name))
goto err; goto err;
errpos=5; errpos=5;
...@@ -561,7 +561,7 @@ MI_INFO *mi_open(const char *name, int mode, uint open_flags) ...@@ -561,7 +561,7 @@ MI_INFO *mi_open(const char *name, int mode, uint open_flags)
my_errno=EACCES; /* Can't open in write mode */ my_errno=EACCES; /* Can't open in write mode */
goto err; goto err;
} }
if (mi_open_datafile(&info, share, name, old_info->dfile)) if (mi_open_datafile(&info, share, name))
goto err; goto err;
errpos=5; errpos=5;
have_rtree= old_info->rtree_recursion_state != NULL; have_rtree= old_info->rtree_recursion_state != NULL;
...@@ -1229,13 +1229,9 @@ uchar *mi_recinfo_read(uchar *ptr, MI_COLUMNDEF *recinfo) ...@@ -1229,13 +1229,9 @@ uchar *mi_recinfo_read(uchar *ptr, MI_COLUMNDEF *recinfo)
Open data file. Open data file.
We can't use dup() here as the data file descriptors need to have different We can't use dup() here as the data file descriptors need to have different
active seek-positions. active seek-positions.
The argument file_to_dup is here for the future if there would on some OS
exist a dup()-like call that would give us two different file descriptors.
*************************************************************************/ *************************************************************************/
int mi_open_datafile(MI_INFO *info, MYISAM_SHARE *share, const char *org_name, int mi_open_datafile(MI_INFO *info, MYISAM_SHARE *share, const char *org_name)
File file_to_dup __attribute__((unused)))
{ {
char *data_name= share->data_file_name; char *data_name= share->data_file_name;
char real_data_name[FN_REFLEN]; char real_data_name[FN_REFLEN];
......
...@@ -1012,7 +1012,7 @@ static int myisamchk(HA_CHECK *param, char * filename) ...@@ -1012,7 +1012,7 @@ static int myisamchk(HA_CHECK *param, char * filename)
MYF(MY_WME)); /* Close new file */ MYF(MY_WME)); /* Close new file */
error|=change_to_newfile(filename, MI_NAME_DEXT, DATA_TMP_EXT, error|=change_to_newfile(filename, MI_NAME_DEXT, DATA_TMP_EXT,
0, MYF(0)); 0, MYF(0));
if (mi_open_datafile(info,info->s, NULL, -1)) if (mi_open_datafile(info,info->s, NULL))
error=1; error=1;
param->out_flag&= ~O_NEW_DATA; /* We are using new datafile */ param->out_flag&= ~O_NEW_DATA; /* We are using new datafile */
param->read_cache.file=info->dfile; param->read_cache.file=info->dfile;
......
...@@ -708,8 +708,7 @@ void mi_disable_non_unique_index(MI_INFO *info, ha_rows rows); ...@@ -708,8 +708,7 @@ void mi_disable_non_unique_index(MI_INFO *info, ha_rows rows);
extern MI_INFO *test_if_reopen(char *filename); extern MI_INFO *test_if_reopen(char *filename);
my_bool check_table_is_closed(const char *name, const char *where); my_bool check_table_is_closed(const char *name, const char *where);
int mi_open_datafile(MI_INFO *info, MYISAM_SHARE *share, const char *orn_name, int mi_open_datafile(MI_INFO *info, MYISAM_SHARE *share, const char *orn_name);
File file_to_dup);
int mi_open_keyfile(MYISAM_SHARE *share); int mi_open_keyfile(MYISAM_SHARE *share);
void mi_setup_functions(register MYISAM_SHARE *share); void mi_setup_functions(register MYISAM_SHARE *share);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment