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

MySQL数据库

开发平台:

Visual C++

  1. /*-
  2.  * See the file LICENSE for redistribution information.
  3.  *
  4.  * Copyright (c) 1999-2002
  5.  * Sleepycat Software.  All rights reserved.
  6.  */
  7. #include "db_config.h"
  8. #ifndef lint
  9. static const char revid[] = "$Id: qam_stat.c,v 11.32 2002/05/11 13:40:11 bostic Exp $";
  10. #endif /* not lint */
  11. #ifndef NO_SYSTEM_INCLUDES
  12. #include <sys/types.h>
  13. #include <string.h>
  14. #endif
  15. #include "db_int.h"
  16. #include "dbinc/db_page.h"
  17. #include "dbinc/db_shash.h"
  18. #include "dbinc/db_am.h"
  19. #include "dbinc/lock.h"
  20. #include "dbinc/log.h"
  21. #include "dbinc/qam.h"
  22. /*
  23.  * __qam_stat --
  24.  * Gather/print the qam statistics
  25.  *
  26.  * PUBLIC: int __qam_stat __P((DB *, void *, u_int32_t));
  27.  */
  28. int
  29. __qam_stat(dbp, spp, flags)
  30. DB *dbp;
  31. void *spp;
  32. u_int32_t flags;
  33. {
  34. DBC *dbc;
  35. DB_LOCK lock;
  36. DB_MPOOLFILE *mpf;
  37. DB_QUEUE_STAT *sp;
  38. PAGE *h;
  39. QAMDATA *qp, *ep;
  40. QMETA *meta;
  41. QUEUE *t;
  42. db_indx_t indx;
  43. db_pgno_t first, last, pgno, pg_ext, stop;
  44. u_int32_t re_len;
  45. int ret, t_ret;
  46. PANIC_CHECK(dbp->dbenv);
  47. DB_ILLEGAL_BEFORE_OPEN(dbp, "DB->stat");
  48. LOCK_INIT(lock);
  49. mpf = dbp->mpf;
  50. sp = NULL;
  51. t = dbp->q_internal;
  52. /* Check for invalid flags. */
  53. if ((ret = __db_statchk(dbp, flags)) != 0)
  54. return (ret);
  55. if (spp == NULL)
  56. return (0);
  57. /* Acquire a cursor. */
  58. if ((ret = dbp->cursor(dbp, NULL, &dbc, 0)) != 0)
  59. return (ret);
  60. DEBUG_LWRITE(dbc, NULL, "qam_stat", NULL, NULL, flags);
  61. /* Allocate and clear the structure. */
  62. if ((ret = __os_umalloc(dbp->dbenv, sizeof(*sp), &sp)) != 0)
  63. goto err;
  64. memset(sp, 0, sizeof(*sp));
  65. re_len = ((QUEUE *)dbp->q_internal)->re_len;
  66. /* Determine the last page of the database. */
  67. if ((ret = __db_lget(dbc,
  68.     0, t->q_meta, DB_LOCK_READ, 0, &lock)) != 0)
  69. goto err;
  70. if ((ret = mpf->get(mpf, &t->q_meta, 0, (PAGE **)&meta)) != 0)
  71. goto err;
  72. if (flags == DB_FAST_STAT || flags == DB_CACHED_COUNTS) {
  73. sp->qs_nkeys = meta->dbmeta.key_count;
  74. sp->qs_ndata = meta->dbmeta.record_count;
  75. goto meta_only;
  76. }
  77. first = QAM_RECNO_PAGE(dbp, meta->first_recno);
  78. last = QAM_RECNO_PAGE(dbp, meta->cur_recno);
  79. if ((ret = mpf->put(mpf, meta, 0)) != 0)
  80. goto err;
  81. (void)__LPUT(dbc, lock);
  82. pgno = first;
  83. if (first > last)
  84. stop = QAM_RECNO_PAGE(dbp, UINT32_T_MAX);
  85. else
  86. stop = last;
  87. /* Dump each page. */
  88. pg_ext = ((QUEUE *)dbp->q_internal)->page_ext;
  89. begin:
  90. /* Walk through the pages and count. */
  91. for (; pgno <= stop; ++pgno) {
  92. if ((ret =
  93.     __db_lget(dbc, 0, pgno, DB_LOCK_READ, 0, &lock)) != 0)
  94. goto err;
  95. ret = __qam_fget(dbp, &pgno, 0, &h);
  96. if (ret == ENOENT) {
  97. pgno += pg_ext - 1;
  98. continue;
  99. }
  100. if (ret == DB_PAGE_NOTFOUND) {
  101. if (pg_ext == 0) {
  102. if (pgno != stop && first != last)
  103. goto err;
  104. ret = 0;
  105. break;
  106. }
  107. pgno += pg_ext - ((pgno - 1) % pg_ext) - 1;
  108. continue;
  109. }
  110. if (ret != 0)
  111. goto err;
  112. ++sp->qs_pages;
  113. ep = (QAMDATA *)((u_int8_t *)h + dbp->pgsize - re_len);
  114. for (indx = 0, qp = QAM_GET_RECORD(dbp, h, indx);
  115.     qp <= ep;
  116.     ++indx,  qp = QAM_GET_RECORD(dbp, h, indx)) {
  117. if (F_ISSET(qp, QAM_VALID))
  118. sp->qs_ndata++;
  119. else
  120. sp->qs_pgfree += re_len;
  121. }
  122. if ((ret = __qam_fput(dbp, pgno, h, 0)) != 0)
  123. goto err;
  124. (void)__LPUT(dbc, lock);
  125. }
  126. (void)__LPUT(dbc, lock);
  127. if (first > last) {
  128. pgno = 1;
  129. stop = last;
  130. first = last;
  131. goto begin;
  132. }
  133. /* Get the meta-data page. */
  134. if ((ret = __db_lget(dbc,
  135.     0, t->q_meta, F_ISSET(dbp, DB_AM_RDONLY) ?
  136.     DB_LOCK_READ : DB_LOCK_WRITE, 0, &lock)) != 0)
  137. goto err;
  138. if ((ret = mpf->get(mpf, &t->q_meta, 0, (PAGE **)&meta)) != 0)
  139. goto err;
  140. if (!F_ISSET(dbp, DB_AM_RDONLY))
  141. meta->dbmeta.key_count =
  142.     meta->dbmeta.record_count = sp->qs_ndata;
  143. sp->qs_nkeys = sp->qs_ndata;
  144. meta_only:
  145. /* Get the metadata fields. */
  146. sp->qs_magic = meta->dbmeta.magic;
  147. sp->qs_version = meta->dbmeta.version;
  148. sp->qs_metaflags = meta->dbmeta.flags;
  149. sp->qs_pagesize = meta->dbmeta.pagesize;
  150. sp->qs_extentsize = meta->page_ext;
  151. sp->qs_re_len = meta->re_len;
  152. sp->qs_re_pad = meta->re_pad;
  153. sp->qs_first_recno = meta->first_recno;
  154. sp->qs_cur_recno = meta->cur_recno;
  155. /* Discard the meta-data page. */
  156. if ((ret = mpf->put(mpf,
  157.     meta, F_ISSET(dbp, DB_AM_RDONLY) ? 0 : DB_MPOOL_DIRTY)) != 0)
  158. goto err;
  159. (void)__LPUT(dbc, lock);
  160. *(DB_QUEUE_STAT **)spp = sp;
  161. ret = 0;
  162. if (0) {
  163. err: if (sp != NULL)
  164. __os_ufree(dbp->dbenv, sp);
  165. }
  166. (void)__LPUT(dbc, lock);
  167. if ((t_ret = dbc->c_close(dbc)) != 0 && ret == 0)
  168. ret = t_ret;
  169. return (ret);
  170. }