log0log.h
上传用户:romrleung
上传日期:2022-05-23
资源大小:18897k
文件大小:30k
源码类别:

MySQL数据库

开发平台:

Visual C++

  1. /******************************************************
  2. Database log
  3. (c) 1995 Innobase Oy
  4. Created 12/9/1995 Heikki Tuuri
  5. *******************************************************/
  6. #ifndef log0log_h
  7. #define log0log_h
  8. #include "univ.i"
  9. #include "ut0byte.h"
  10. #include "sync0sync.h"
  11. #include "sync0rw.h"
  12. typedef struct log_struct log_t;
  13. typedef struct log_group_struct log_group_t;
  14. extern ibool log_do_write;
  15. extern  ibool log_debug_writes;
  16. /* Wait modes for log_write_up_to */
  17. #define LOG_NO_WAIT 91
  18. #define LOG_WAIT_ONE_GROUP 92
  19. #define LOG_WAIT_ALL_GROUPS 93
  20. #define LOG_MAX_N_GROUPS 32
  21. /********************************************************************
  22. Sets the global variable log_fsp_current_free_limit. Also makes a checkpoint,
  23. so that we know that the limit has been written to a log checkpoint field
  24. on disk. */
  25. void
  26. log_fsp_current_free_limit_set_and_checkpoint(
  27. /*==========================================*/
  28. ulint limit); /* in: limit to set */
  29. /***********************************************************************
  30. Calculates where in log files we find a specified lsn. */
  31. ulint
  32. log_calc_where_lsn_is(
  33. /*==================*/
  34. /* out: log file number */
  35. ib_longlong* log_file_offset, /* out: offset in that file
  36. (including the header) */
  37. dulint first_header_lsn, /* in: first log file start
  38. lsn */
  39. dulint lsn, /* in: lsn whose position to
  40. determine */
  41. ulint n_log_files, /* in: total number of log
  42. files */
  43. ib_longlong log_file_size); /* in: log file size
  44. (including the header) */
  45. /****************************************************************
  46. Writes to the log the string given. The log must be released with
  47. log_release. */
  48. UNIV_INLINE
  49. dulint
  50. log_reserve_and_write_fast(
  51. /*=======================*/
  52. /* out: end lsn of the log record, ut_dulint_zero if
  53. did not succeed */
  54. byte* str, /* in: string */
  55. ulint len, /* in: string length */
  56. dulint* start_lsn,/* out: start lsn of the log record */
  57. ibool* success);/* out: TRUE if success */
  58. /***************************************************************************
  59. Releases the log mutex. */
  60. UNIV_INLINE
  61. void
  62. log_release(void);
  63. /*=============*/
  64. /***************************************************************************
  65. Checks if there is need for a log buffer flush or a new checkpoint, and does
  66. this if yes. Any database operation should call this when it has modified
  67. more than about 4 pages. NOTE that this function may only be called when the
  68. OS thread owns no synchronization objects except the dictionary mutex. */
  69. UNIV_INLINE
  70. void
  71. log_free_check(void);
  72. /*================*/
  73. /****************************************************************
  74. Opens the log for log_write_low. The log must be closed with log_close and
  75. released with log_release. */
  76. dulint
  77. log_reserve_and_open(
  78. /*=================*/
  79. /* out: start lsn of the log record */
  80. ulint len); /* in: length of data to be catenated */
  81. /****************************************************************
  82. Writes to the log the string given. It is assumed that the caller holds the
  83. log mutex. */
  84. void
  85. log_write_low(
  86. /*==========*/
  87. byte* str, /* in: string */
  88. ulint str_len); /* in: string length */
  89. /****************************************************************
  90. Closes the log. */
  91. dulint
  92. log_close(void);
  93. /*===========*/
  94. /* out: lsn */
  95. /****************************************************************
  96. Gets the current lsn. */
  97. UNIV_INLINE
  98. dulint
  99. log_get_lsn(void);
  100. /*=============*/
  101. /* out: current lsn */
  102. /**********************************************************
  103. Initializes the log. */
  104. void
  105. log_init(void);
  106. /*==========*/
  107. /**********************************************************************
  108. Inits a log group to the log system. */
  109. void
  110. log_group_init(
  111. /*===========*/
  112. ulint id, /* in: group id */
  113. ulint n_files, /* in: number of log files */
  114. ulint file_size, /* in: log file size in bytes */
  115. ulint space_id, /* in: space id of the file space
  116. which contains the log files of this
  117. group */
  118. ulint archive_space_id); /* in: space id of the file space
  119. which contains some archived log
  120. files for this group; currently, only
  121. for the first log group this is
  122. used */
  123. /**********************************************************
  124. Completes an i/o to a log file. */
  125. void
  126. log_io_complete(
  127. /*============*/
  128. log_group_t* group); /* in: log group */
  129. /**********************************************************
  130. This function is called, e.g., when a transaction wants to commit. It checks
  131. that the log has been written to the log file up to the last log entry written
  132. by the transaction. If there is a flush running, it waits and checks if the
  133. flush flushed enough. If not, starts a new flush. */
  134. void
  135. log_write_up_to(
  136. /*============*/
  137. dulint lsn, /* in: log sequence number up to which the log should
  138. be written, ut_dulint_max if not specified */
  139. ulint wait, /* in: LOG_NO_WAIT, LOG_WAIT_ONE_GROUP,
  140. or LOG_WAIT_ALL_GROUPS */
  141. ibool flush_to_disk);
  142. /* in: TRUE if we want the written log also to be
  143. flushed to disk */
  144. /********************************************************************
  145. Does a syncronous flush of the log buffer to disk. */
  146. void
  147. log_buffer_flush_to_disk(void);
  148. /*==========================*/
  149. /********************************************************************
  150. Advances the smallest lsn for which there are unflushed dirty blocks in the
  151. buffer pool and also may make a new checkpoint. NOTE: this function may only
  152. be called if the calling thread owns no synchronization objects! */
  153. ibool
  154. log_preflush_pool_modified_pages(
  155. /*=============================*/
  156. /* out: FALSE if there was a flush batch of
  157. the same type running, which means that we
  158. could not start this flush batch */
  159. dulint new_oldest, /* in: try to advance oldest_modified_lsn
  160. at least to this lsn */
  161. ibool sync); /* in: TRUE if synchronous operation is
  162. desired */
  163. /**********************************************************
  164. Makes a checkpoint. Note that this function does not flush dirty
  165. blocks from the buffer pool: it only checks what is lsn of the oldest
  166. modification in the pool, and writes information about the lsn in
  167. log files. Use log_make_checkpoint_at to flush also the pool. */
  168. ibool
  169. log_checkpoint(
  170. /*===========*/
  171. /* out: TRUE if success, FALSE if a checkpoint
  172. write was already running */
  173. ibool sync, /* in: TRUE if synchronous operation is
  174. desired */
  175. ibool write_always); /* in: the function normally checks if the
  176. the new checkpoint would have a greater
  177. lsn than the previous one: if not, then no
  178. physical write is done; by setting this
  179. parameter TRUE, a physical write will always be
  180. made to log files */
  181. /********************************************************************
  182. Makes a checkpoint at a given lsn or later. */
  183. void
  184. log_make_checkpoint_at(
  185. /*===================*/
  186. dulint lsn, /* in: make a checkpoint at this or a later
  187. lsn, if ut_dulint_max, makes a checkpoint at
  188. the latest lsn */
  189. ibool write_always); /* in: the function normally checks if the
  190. the new checkpoint would have a greater
  191. lsn than the previous one: if not, then no
  192. physical write is done; by setting this
  193. parameter TRUE, a physical write will always be
  194. made to log files */
  195. /********************************************************************
  196. Makes a checkpoint at the latest lsn and writes it to first page of each
  197. data file in the database, so that we know that the file spaces contain
  198. all modifications up to that lsn. This can only be called at database
  199. shutdown. This function also writes all log in log files to the log archive. */
  200. void
  201. logs_empty_and_mark_files_at_shutdown(void);
  202. /*=======================================*/
  203. /**********************************************************
  204. Reads a checkpoint info from a log group header to log_sys->checkpoint_buf. */
  205. void
  206. log_group_read_checkpoint_info(
  207. /*===========================*/
  208. log_group_t* group, /* in: log group */
  209. ulint field); /* in: LOG_CHECKPOINT_1 or LOG_CHECKPOINT_2 */
  210. /***********************************************************************
  211. Gets info from a checkpoint about a log group. */
  212. void
  213. log_checkpoint_get_nth_group_info(
  214. /*==============================*/
  215. byte* buf, /* in: buffer containing checkpoint info */
  216. ulint n, /* in: nth slot */
  217. ulint* file_no,/* out: archived file number */
  218. ulint* offset);/* out: archived file offset */
  219. /**********************************************************
  220. Writes checkpoint info to groups. */
  221. void
  222. log_groups_write_checkpoint_info(void);
  223. /*==================================*/
  224. /**********************************************************
  225. Writes info to a buffer of a log group when log files are created in
  226. backup restoration. */
  227. void
  228. log_reset_first_header_and_checkpoint(
  229. /*==================================*/
  230. byte* hdr_buf,/* in: buffer which will be written to the start
  231. of the first log file */
  232. dulint start); /* in: lsn of the start of the first log file;
  233. we pretend that there is a checkpoint at
  234. start + LOG_BLOCK_HDR_SIZE */
  235. /************************************************************************
  236. Starts an archiving operation. */
  237. ibool
  238. log_archive_do(
  239. /*===========*/
  240. /* out: TRUE if succeed, FALSE if an archiving
  241. operation was already running */
  242. ibool sync, /* in: TRUE if synchronous operation is desired */
  243. ulint* n_bytes);/* out: archive log buffer size, 0 if nothing to
  244. archive */
  245. /********************************************************************
  246. Writes the log contents to the archive up to the lsn when this function was
  247. called, and stops the archiving. When archiving is started again, the archived
  248. log file numbers start from a number one higher, so that the archiving will
  249. not write again to the archived log files which exist when this function
  250. returns. */
  251. ulint
  252. log_archive_stop(void);
  253. /*==================*/
  254. /* out: DB_SUCCESS or DB_ERROR */
  255. /********************************************************************
  256. Starts again archiving which has been stopped. */
  257. ulint
  258. log_archive_start(void);
  259. /*===================*/
  260. /* out: DB_SUCCESS or DB_ERROR */
  261. /********************************************************************
  262. Stop archiving the log so that a gap may occur in the archived log files. */
  263. ulint
  264. log_archive_noarchivelog(void);
  265. /*==========================*/
  266. /* out: DB_SUCCESS or DB_ERROR */
  267. /********************************************************************
  268. Start archiving the log so that a gap may occur in the archived log files. */
  269. ulint
  270. log_archive_archivelog(void);
  271. /*========================*/
  272. /* out: DB_SUCCESS or DB_ERROR */
  273. /**********************************************************
  274. Generates an archived log file name. */
  275. void
  276. log_archived_file_name_gen(
  277. /*=======================*/
  278. char* buf, /* in: buffer where to write */
  279. ulint id, /* in: group id */
  280. ulint file_no);/* in: file number */
  281. /************************************************************************
  282. Checks that there is enough free space in the log to start a new query step.
  283. Flushes the log buffer or makes a new checkpoint if necessary. NOTE: this
  284. function may only be called if the calling thread owns no synchronization
  285. objects! */
  286. void
  287. log_check_margins(void);
  288. /*===================*/
  289. /**********************************************************
  290. Reads a specified log segment to a buffer. */
  291. void
  292. log_group_read_log_seg(
  293. /*===================*/
  294. ulint type, /* in: LOG_ARCHIVE or LOG_RECOVER */
  295. byte* buf, /* in: buffer where to read */
  296. log_group_t* group, /* in: log group */
  297. dulint start_lsn, /* in: read area start */
  298. dulint end_lsn); /* in: read area end */
  299. /**********************************************************
  300. Writes a buffer to a log file group. */
  301. void
  302. log_group_write_buf(
  303. /*================*/
  304. log_group_t* group, /* in: log group */
  305. byte* buf, /* in: buffer */
  306. ulint len, /* in: buffer len; must be divisible
  307. by OS_FILE_LOG_BLOCK_SIZE */
  308. dulint start_lsn, /* in: start lsn of the buffer; must
  309. be divisible by
  310. OS_FILE_LOG_BLOCK_SIZE */
  311. ulint new_data_offset);/* in: start offset of new data in
  312. buf: this parameter is used to decide
  313. if we have to write a new log file
  314. header */
  315. /************************************************************
  316. Sets the field values in group to correspond to a given lsn. For this function
  317. to work, the values must already be correctly initialized to correspond to
  318. some lsn, for instance, a checkpoint lsn. */
  319. void
  320. log_group_set_fields(
  321. /*=================*/
  322. log_group_t* group, /* in: group */
  323. dulint lsn); /* in: lsn for which the values should be
  324. set */
  325. /**********************************************************
  326. Calculates the data capacity of a log group, when the log file headers are not
  327. included. */
  328. ulint
  329. log_group_get_capacity(
  330. /*===================*/
  331. /* out: capacity in bytes */
  332. log_group_t* group); /* in: log group */
  333. /****************************************************************
  334. Gets a log block flush bit. */
  335. UNIV_INLINE
  336. ibool
  337. log_block_get_flush_bit(
  338. /*====================*/
  339. /* out: TRUE if this block was the first
  340. to be written in a log flush */
  341. byte* log_block); /* in: log block */
  342. /****************************************************************
  343. Gets a log block number stored in the header. */
  344. UNIV_INLINE
  345. ulint
  346. log_block_get_hdr_no(
  347. /*=================*/
  348. /* out: log block number stored in the block
  349. header */
  350. byte* log_block); /* in: log block */
  351. /****************************************************************
  352. Gets a log block data length. */
  353. UNIV_INLINE
  354. ulint
  355. log_block_get_data_len(
  356. /*===================*/
  357. /* out: log block data length measured as a
  358. byte offset from the block start */
  359. byte* log_block); /* in: log block */
  360. /****************************************************************
  361. Sets the log block data length. */
  362. UNIV_INLINE
  363. void
  364. log_block_set_data_len(
  365. /*===================*/
  366. byte* log_block, /* in: log block */
  367. ulint len); /* in: data length */
  368. /****************************************************************
  369. Calculates the checksum for a log block. */
  370. UNIV_INLINE
  371. ulint
  372. log_block_calc_checksum(
  373. /*====================*/
  374. /* out: checksum */
  375. byte* block); /* in: log block */
  376. /****************************************************************
  377. Gets a log block checksum field value. */
  378. UNIV_INLINE
  379. ulint
  380. log_block_get_checksum(
  381. /*===================*/
  382. /* out: checksum */
  383. byte* log_block); /* in: log block */
  384. /****************************************************************
  385. Sets a log block checksum field value. */
  386. UNIV_INLINE
  387. void
  388. log_block_set_checksum(
  389. /*===================*/
  390. byte* log_block, /* in: log block */
  391. ulint checksum); /* in: checksum */
  392. /****************************************************************
  393. Gets a log block first mtr log record group offset. */
  394. UNIV_INLINE
  395. ulint
  396. log_block_get_first_rec_group(
  397. /*==========================*/
  398. /* out: first mtr log record group byte offset
  399. from the block start, 0 if none */
  400. byte* log_block); /* in: log block */
  401. /****************************************************************
  402. Sets the log block first mtr log record group offset. */
  403. UNIV_INLINE
  404. void
  405. log_block_set_first_rec_group(
  406. /*==========================*/
  407. byte* log_block, /* in: log block */
  408. ulint offset); /* in: offset, 0 if none */
  409. /****************************************************************
  410. Gets a log block checkpoint number field (4 lowest bytes). */
  411. UNIV_INLINE
  412. ulint
  413. log_block_get_checkpoint_no(
  414. /*========================*/
  415. /* out: checkpoint no (4 lowest bytes) */
  416. byte* log_block); /* in: log block */
  417. /****************************************************************
  418. Initializes a log block in the log buffer. */
  419. UNIV_INLINE
  420. void
  421. log_block_init(
  422. /*===========*/
  423. byte* log_block, /* in: pointer to the log buffer */
  424. dulint lsn); /* in: lsn within the log block */
  425. /****************************************************************
  426. Initializes a log block in the log buffer in the old, < 3.23.52 format, where
  427. there was no checksum yet. */
  428. UNIV_INLINE
  429. void
  430. log_block_init_in_old_format(
  431. /*=========================*/
  432. byte* log_block, /* in: pointer to the log buffer */
  433. dulint lsn); /* in: lsn within the log block */
  434. /****************************************************************
  435. Converts a lsn to a log block number. */
  436. UNIV_INLINE
  437. ulint
  438. log_block_convert_lsn_to_no(
  439. /*========================*/
  440. /* out: log block number, it is > 0 and <= 1G */
  441. dulint lsn); /* in: lsn of a byte within the block */
  442. /**********************************************************
  443. Prints info of the log. */
  444. void
  445. log_print(
  446. /*======*/
  447. FILE* file); /* in: file where to print */
  448. /**********************************************************
  449. Peeks the current lsn. */
  450. ibool
  451. log_peek_lsn(
  452. /*=========*/
  453.                        /* out: TRUE if success, FALSE if could not get the
  454.                        log system mutex */
  455.        dulint* lsn);   /* out: if returns TRUE, current lsn is here */
  456. /**************************************************************************
  457. Refreshes the statistics used to print per-second averages. */
  458. void
  459. log_refresh_stats(void);
  460. /*===================*/
  461. extern log_t* log_sys;
  462. /* Values used as flags */
  463. #define LOG_FLUSH 7652559
  464. #define LOG_CHECKPOINT 78656949
  465. #define LOG_ARCHIVE 11122331
  466. #define LOG_RECOVER 98887331
  467. /* The counting of lsn's starts from this value: this must be non-zero */
  468. #define LOG_START_LSN ut_dulint_create(0, 16 * OS_FILE_LOG_BLOCK_SIZE)
  469. #define LOG_BUFFER_SIZE  (srv_log_buffer_size * UNIV_PAGE_SIZE)
  470. #define LOG_ARCHIVE_BUF_SIZE (srv_log_buffer_size * UNIV_PAGE_SIZE / 4)
  471. /* Offsets of a log block header */
  472. #define LOG_BLOCK_HDR_NO 0 /* block number which must be > 0 and
  473. is allowed to wrap around at 2G; the
  474. highest bit is set to 1 if this is the
  475. first log block in a log flush write
  476. segment */
  477. #define LOG_BLOCK_FLUSH_BIT_MASK 0x80000000UL
  478. /* mask used to get the highest bit in
  479. the preceding field */
  480. #define LOG_BLOCK_HDR_DATA_LEN 4 /* number of bytes of log written to
  481. this block */
  482. #define LOG_BLOCK_FIRST_REC_GROUP 6 /* offset of the first start of an
  483. mtr log record group in this log block,
  484. 0 if none; if the value is the same
  485. as LOG_BLOCK_HDR_DATA_LEN, it means
  486. that the first rec group has not yet
  487. been catenated to this log block, but
  488. if it will, it will start at this
  489. offset; an archive recovery can
  490. start parsing the log records starting
  491. from this offset in this log block,
  492. if value not 0 */
  493. #define LOG_BLOCK_CHECKPOINT_NO 8 /* 4 lower bytes of the value of
  494. log_sys->next_checkpoint_no when the
  495. log block was last written to: if the
  496. block has not yet been written full,
  497. this value is only updated before a
  498. log buffer flush */
  499. #define LOG_BLOCK_HDR_SIZE 12 /* size of the log block header in
  500. bytes */
  501. /* Offsets of a log block trailer from the end of the block */
  502. #define LOG_BLOCK_CHECKSUM 4 /* 4 byte checksum of the log block
  503. contents; in InnoDB versions
  504. < 3.23.52 this did not contain the
  505. checksum but the same value as
  506. .._HDR_NO */
  507. #define LOG_BLOCK_TRL_SIZE 4 /* trailer size in bytes */
  508. /* Offsets for a checkpoint field */
  509. #define LOG_CHECKPOINT_NO 0
  510. #define LOG_CHECKPOINT_LSN 8
  511. #define LOG_CHECKPOINT_OFFSET 16
  512. #define LOG_CHECKPOINT_LOG_BUF_SIZE 20
  513. #define LOG_CHECKPOINT_ARCHIVED_LSN 24
  514. #define LOG_CHECKPOINT_GROUP_ARRAY 32
  515. /* For each value < LOG_MAX_N_GROUPS the following 8 bytes: */
  516. #define LOG_CHECKPOINT_ARCHIVED_FILE_NO 0
  517. #define LOG_CHECKPOINT_ARCHIVED_OFFSET 4
  518. #define LOG_CHECKPOINT_ARRAY_END (LOG_CHECKPOINT_GROUP_ARRAY
  519. + LOG_MAX_N_GROUPS * 8)
  520. #define LOG_CHECKPOINT_CHECKSUM_1  LOG_CHECKPOINT_ARRAY_END
  521. #define LOG_CHECKPOINT_CHECKSUM_2  (4 + LOG_CHECKPOINT_ARRAY_END)
  522. #define LOG_CHECKPOINT_FSP_FREE_LIMIT (8 + LOG_CHECKPOINT_ARRAY_END)
  523. /* current fsp free limit in
  524. tablespace 0, in units of one
  525. megabyte; this information is only used
  526. by ibbackup to decide if it can
  527. truncate unused ends of
  528. non-auto-extending data files in space
  529. 0 */
  530. #define LOG_CHECKPOINT_FSP_MAGIC_N (12 + LOG_CHECKPOINT_ARRAY_END)
  531. /* this magic number tells if the
  532. checkpoint contains the above field:
  533. the field was added to
  534. InnoDB-3.23.50 */
  535. #define LOG_CHECKPOINT_SIZE (16 + LOG_CHECKPOINT_ARRAY_END)
  536. #define LOG_CHECKPOINT_FSP_MAGIC_N_VAL 1441231243
  537. /* Offsets of a log file header */
  538. #define LOG_GROUP_ID 0 /* log group number */
  539. #define LOG_FILE_START_LSN 4 /* lsn of the start of data in this
  540. log file */
  541. #define LOG_FILE_NO 12 /* 4-byte archived log file number;
  542. this field is only defined in an
  543. archived log file */
  544. #define LOG_FILE_WAS_CREATED_BY_HOT_BACKUP 16
  545. /* a 32-byte field which contains
  546. the string 'ibbackup' and the
  547. creation time if the log file was
  548. created by ibbackup --restore;
  549. when mysqld is first time started
  550. on the restored database, it can
  551. print helpful info for the user */
  552. #define LOG_FILE_ARCH_COMPLETED OS_FILE_LOG_BLOCK_SIZE
  553. /* this 4-byte field is TRUE when
  554. the writing of an archived log file
  555. has been completed; this field is
  556. only defined in an archived log file */
  557. #define LOG_FILE_END_LSN (OS_FILE_LOG_BLOCK_SIZE + 4)
  558. /* lsn where the archived log file
  559. at least extends: actually the
  560. archived log file may extend to a
  561. later lsn, as long as it is within the
  562. same log block as this lsn; this field
  563. is defined only when an archived log
  564. file has been completely written */
  565. #define LOG_CHECKPOINT_1 OS_FILE_LOG_BLOCK_SIZE
  566. /* first checkpoint field in the log
  567. header; we write alternately to the
  568. checkpoint fields when we make new
  569. checkpoints; this field is only defined
  570. in the first log file of a log group */
  571. #define LOG_CHECKPOINT_2 (3 * OS_FILE_LOG_BLOCK_SIZE)
  572. /* second checkpoint field in the log
  573. header */
  574. #define LOG_FILE_HDR_SIZE (4 * OS_FILE_LOG_BLOCK_SIZE)
  575. #define LOG_GROUP_OK 301
  576. #define LOG_GROUP_CORRUPTED 302
  577. /* Log group consists of a number of log files, each of the same size; a log
  578. group is implemented as a space in the sense of the module fil0fil. */
  579. struct log_group_struct{
  580. /* The following fields are protected by log_sys->mutex */
  581. ulint id; /* log group id */
  582. ulint n_files; /* number of files in the group */
  583. ulint file_size; /* individual log file size in bytes,
  584. including the log file header */
  585. ulint space_id; /* file space which implements the log
  586. group */
  587. ulint state; /* LOG_GROUP_OK or
  588. LOG_GROUP_CORRUPTED */
  589. dulint lsn; /* lsn used to fix coordinates within
  590. the log group */
  591. ulint lsn_offset; /* the offset of the above lsn */
  592. ulint n_pending_writes;/* number of currently pending flush
  593. writes for this log group */
  594. byte** file_header_bufs;/* buffers for each file header in the
  595. group */
  596. /*-----------------------------*/
  597. byte** archive_file_header_bufs;/* buffers for each file
  598. header in the group */
  599. ulint archive_space_id;/* file space which implements the log
  600. group archive */
  601. ulint archived_file_no;/* file number corresponding to
  602. log_sys->archived_lsn */
  603. ulint archived_offset;/* file offset corresponding to
  604. log_sys->archived_lsn, 0 if we have
  605. not yet written to the archive file
  606. number archived_file_no */
  607. ulint next_archived_file_no;/* during an archive write,
  608. until the write is completed, we
  609. store the next value for
  610. archived_file_no here: the write
  611. completion function then sets the new
  612. value to ..._file_no */
  613. ulint next_archived_offset; /* like the preceding field */
  614. /*-----------------------------*/
  615. dulint scanned_lsn; /* used only in recovery: recovery scan
  616. succeeded up to this lsn in this log
  617. group */
  618. byte* checkpoint_buf; /* checkpoint header is written from
  619. this buffer to the group */
  620. UT_LIST_NODE_T(log_group_t)
  621. log_groups; /* list of log groups */
  622. };
  623. struct log_struct{
  624. byte pad[64]; /* padding to prevent other memory
  625. update hotspots from residing on the
  626. same memory cache line */
  627. dulint lsn; /* log sequence number */
  628. ulint buf_free; /* first free offset within the log
  629. buffer */
  630. mutex_t mutex; /* mutex protecting the log */
  631. byte* buf; /* log buffer */
  632. ulint buf_size; /* log buffer size in bytes */
  633. ulint max_buf_free; /* recommended maximum value of
  634. buf_free, after which the buffer is
  635. flushed */
  636. ulint old_buf_free; /* value of buf free when log was
  637. last time opened; only in the debug
  638. version */
  639. dulint old_lsn; /* value of lsn when log was last time
  640. opened; only in the debug version */
  641. ibool check_flush_or_checkpoint;
  642. /* this is set to TRUE when there may
  643. be need to flush the log buffer, or
  644. preflush buffer pool pages, or make
  645. a checkpoint; this MUST be TRUE when
  646. lsn - last_checkpoint_lsn >
  647. max_checkpoint_age; this flag is
  648. peeked at by log_free_check(), which
  649. does not reserve the log mutex */
  650. UT_LIST_BASE_NODE_T(log_group_t)
  651. log_groups; /* log groups */
  652. /* The fields involved in the log buffer flush */
  653. ulint buf_next_to_write;/* first offset in the log buffer
  654. where the byte content may not exist
  655. written to file, e.g., the start
  656. offset of a log record catenated
  657. later; this is advanced when a flush
  658. operation is completed to all the log
  659. groups */
  660. dulint written_to_some_lsn;
  661. /* first log sequence number not yet
  662. written to any log group; for this to
  663. be advanced, it is enough that the
  664. write i/o has been completed for any
  665. one log group */
  666. dulint written_to_all_lsn;
  667. /* first log sequence number not yet
  668. written to some log group; for this to
  669. be advanced, it is enough that the
  670. write i/o has been completed for all
  671. log groups */
  672. dulint write_lsn; /* end lsn for the current running 
  673. write */
  674. ulint write_end_offset;/* the data in buffer has been written
  675. up to this offset when the current
  676. write ends: this field will then
  677. be copied to buf_next_to_write */
  678. dulint current_flush_lsn;/* end lsn for the current running 
  679. write + flush operation */
  680. dulint flushed_to_disk_lsn;
  681. /* how far we have written the log
  682. AND flushed to disk */
  683. ulint n_pending_writes;/* number of currently pending flushes
  684. or writes */
  685. /* NOTE on the 'flush' in names of the fields below: starting from
  686. 4.0.14, we separate the write of the log file and the actual fsync()
  687. or other method to flush it to disk. The names below shhould really
  688. be 'flush_or_write'! */
  689. os_event_t no_flush_event; /* this event is in the reset state
  690. when a flush or a write is running;
  691. a thread should wait for this without
  692. owning the log mutex, but NOTE that
  693. to set or reset this event, the
  694. thread MUST own the log mutex! */
  695. ibool one_flushed; /* during a flush, this is first FALSE
  696. and becomes TRUE when one log group
  697. has been written or flushed */
  698. os_event_t one_flushed_event;/* this event is reset when the
  699. flush or write has not yet completed
  700. for any log group; e.g., this means
  701. that a transaction has been committed
  702. when this is set; a thread should wait
  703. for this without owning the log mutex,
  704. but NOTE that to set or reset this
  705. event, the thread MUST own the log
  706. mutex! */
  707. ulint n_log_ios; /* number of log i/os initiated thus
  708. far */
  709. ulint n_log_ios_old; /* number of log i/o's at the
  710. previous printout */
  711. time_t last_printout_time;/* when log_print was last time
  712. called */
  713. /* Fields involved in checkpoints */
  714.         ulint           log_group_capacity; /* capacity of the log group; if
  715.                                         the checkpoint age exceeds this, it is
  716.                                         a serious error because it is possible
  717.                                         we will then overwrite log and spoil
  718.                                         crash recovery */
  719. ulint max_modified_age_async;
  720. /* when this recommended value for lsn
  721. - buf_pool_get_oldest_modification()
  722. is exceeded, we start an asynchronous
  723. preflush of pool pages */
  724. ulint max_modified_age_sync;
  725. /* when this recommended value for lsn
  726. - buf_pool_get_oldest_modification()
  727. is exceeded, we start a synchronous
  728. preflush of pool pages */
  729. ulint adm_checkpoint_interval;
  730. /* administrator-specified checkpoint
  731. interval in terms of log growth in
  732. bytes; the interval actually used by
  733. the database can be smaller */
  734. ulint max_checkpoint_age_async;
  735. /* when this checkpoint age is exceeded
  736. we start an asynchronous writing of a
  737. new checkpoint */
  738. ulint max_checkpoint_age;
  739. /* this is the maximum allowed value
  740. for lsn - last_checkpoint_lsn when a
  741. new query step is started */
  742. dulint next_checkpoint_no;
  743. /* next checkpoint number */
  744. dulint last_checkpoint_lsn;
  745. /* latest checkpoint lsn */
  746. dulint next_checkpoint_lsn;
  747. /* next checkpoint lsn */
  748. ulint n_pending_checkpoint_writes;
  749. /* number of currently pending
  750. checkpoint writes */
  751. rw_lock_t checkpoint_lock;/* this latch is x-locked when a
  752. checkpoint write is running; a thread
  753. should wait for this without owning
  754. the log mutex */
  755. byte* checkpoint_buf; /* checkpoint header is read to this
  756. buffer */
  757. /* Fields involved in archiving */
  758. ulint archiving_state;/* LOG_ARCH_ON, LOG_ARCH_STOPPING
  759. LOG_ARCH_STOPPED, LOG_ARCH_OFF */
  760. dulint archived_lsn; /* archiving has advanced to this
  761. lsn */
  762. ulint max_archived_lsn_age_async;
  763. /* recommended maximum age of
  764. archived_lsn, before we start
  765. asynchronous copying to the archive */
  766. ulint max_archived_lsn_age;
  767. /* maximum allowed age for
  768. archived_lsn */
  769. dulint next_archived_lsn;/* during an archive write,
  770. until the write is completed, we
  771. store the next value for
  772. archived_lsn here: the write
  773. completion function then sets the new
  774. value to archived_lsn */
  775. ulint archiving_phase;/* LOG_ARCHIVE_READ or
  776. LOG_ARCHIVE_WRITE */
  777. ulint n_pending_archive_ios;
  778. /* number of currently pending reads
  779. or writes in archiving */
  780. rw_lock_t archive_lock; /* this latch is x-locked when an
  781. archive write is running; a thread
  782. should wait for this without owning
  783. the log mutex */
  784. ulint archive_buf_size;/* size of archive_buf */
  785. byte* archive_buf; /* log segment is written to the
  786. archive from this buffer */
  787. os_event_t archiving_on; /* if archiving has been stopped,
  788. a thread can wait for this event to
  789. become signaled */
  790. };
  791. #define LOG_ARCH_ON 71
  792. #define LOG_ARCH_STOPPING 72
  793. #define LOG_ARCH_STOPPING2 73
  794. #define LOG_ARCH_STOPPED 74
  795. #define LOG_ARCH_OFF 75
  796. #ifndef UNIV_NONINL
  797. #include "log0log.ic"
  798. #endif
  799. #endif