开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > MySQL数据库 > 查看源码
qam_method.c
资源名称：mysql-3.23.35.tar.gz　[点击查看]
上传用户：tsgydb
上传日期：2007-04-14
资源大小：10674k
文件大小：10k
源码类别：

MySQL数据库

开发平台：

Visual C++

qam_method.c：源码内容
  1. /*-
  2.  * See the file LICENSE for redistribution information.
  3.  *
  4.  * Copyright (c) 1999, 2000
  5.  * Sleepycat Software.  All rights reserved.
  6.  */
  8. #include "db_config.h"
  10. #ifndef lint
  11. static const char revid[] = "$Id: qam_method.c,v 11.17 2001/01/10 04:50:54 ubell Exp $";
  12. #endif /* not lint */
  14. #ifndef NO_SYSTEM_INCLUDES
  15. #include <sys/types.h>
  16. #include <string.h>
  17. #endif
  19. #include "db_int.h"
  20. #include "db_page.h"
  21. #include "db_int.h"
  22. #include "db_shash.h"
  23. #include "db_am.h"
  24. #include "qam.h"
  25. #include "db.h"
  26. #include "mp.h"
  27. #include "lock.h"
  28. #include "log.h"
  30. static int __qam_set_extentsize __P((DB *, u_int32_t));
  31. static int __qam_remove_callback __P((DB *, void *));
  33. struct __qam_cookie {
  34. DB_LSN lsn;
  35. QUEUE_FILELIST *filelist;
  36. };
  38. /*
  39.  * __qam_db_create --
  40.  * Queue specific initialization of the DB structure.
  41.  *
  42.  * PUBLIC: int __qam_db_create __P((DB *));
  43.  */
  44. int
  45. __qam_db_create(dbp)
  46. DB *dbp;
  47. {
  48. QUEUE *t;
  49. int ret;
  51. /* Allocate and initialize the private queue structure. */
  52. if ((ret = __os_calloc(dbp->dbenv, 1, sizeof(QUEUE), &t)) != 0)
  53. return (ret);
  54. dbp->q_internal = t;
  55. dbp->set_q_extentsize = __qam_set_extentsize;
  57. t->re_pad = ' ';
  59. return (0);
  60. }
  62. /*
  63.  * __qam_db_close --
  64.  * Queue specific discard of the DB structure.
  65.  *
  66.  * PUBLIC: int __qam_db_close __P((DB *));
  67.  */
  68. int
  69. __qam_db_close(dbp)
  70. DB *dbp;
  71. {
  72. DB_MPOOLFILE *mpf;
  73. MPFARRAY *array;
  74. QUEUE *t;
  75. struct __qmpf *mpfp;
  76. u_int32_t i;
  77. int ret, t_ret;
  79. ret = 0;
  80. t = dbp->q_internal;
  82. array = &t->array1;
  83. again:
  84. mpfp = array->mpfarray;
  85. if (mpfp != NULL) {
  86. for (i = array->low_extent;
  87.     i <= array->hi_extent; i++, mpfp++) {
  88. mpf = mpfp->mpf;
  89. mpfp->mpf = NULL;
  90. if (mpf != NULL &&
  91.     (t_ret = memp_fclose(mpf)) != 0 && ret == 0)
  92. ret = t_ret;
  93. }
  94. __os_free(array->mpfarray, 0);
  95. }
  96. if (t->array2.n_extent != 0) {
  97. array = &t->array2;
  98. array->n_extent = 0;
  99. goto again;
  100. }
  102. if (t->path != NULL)
  103. __os_free(t->path, 0);
  104. __os_free(t, sizeof(QUEUE));
  105. dbp->q_internal = NULL;
  107. return (ret);
  108. }
  110. static int
  111. __qam_set_extentsize(dbp, extentsize)
  112. DB *dbp;
  113. u_int32_t extentsize;
  114. {
  115. DB_ILLEGAL_AFTER_OPEN(dbp, "set_extentsize");
  117. if (extentsize < 1) {
  118. __db_err(dbp->dbenv, "Extent size must be at least 1.");
  119. return (EINVAL);
  120. }
  122. ((QUEUE*)dbp->q_internal)->page_ext = extentsize;
  124. return (0);
  125. }
  127. /*
  128.  * __db_prqueue --
  129.  * Print out a queue
  130.  *
  131.  * PUBLIC: int __db_prqueue __P((DB *, u_int32_t));
  132.  */
  133. int
  134. __db_prqueue(dbp, flags)
  135. DB *dbp;
  136. u_int32_t flags;
  137. {
  138. PAGE *h;
  139. QMETA *meta;
  140. db_pgno_t first, i, last, pg_ext, stop;
  141. int ret;
  143. /* Find out the page number of the last page in the database. */
  144. i = PGNO_BASE_MD;
  145. if ((ret = memp_fget(dbp->mpf, &i, 0, &meta)) != 0)
  146. return (ret);
  148. first = QAM_RECNO_PAGE(dbp, meta->first_recno);
  149. last = QAM_RECNO_PAGE(dbp, meta->cur_recno);
  151. if ((ret = __db_prpage(dbp, (PAGE *)meta, flags)) != 0)
  152. return (ret);
  153. if ((ret = memp_fput(dbp->mpf, meta, 0)) != 0)
  154. return (ret);
  156. i = first;
  157. if (first > last)
  158. stop = QAM_RECNO_PAGE(dbp, UINT32_T_MAX);
  159. else
  160. stop = last;
  162. /* Dump each page. */
  163. begin:
  164. for (; i <= stop; ++i) {
  165. if ((ret = __qam_fget(dbp, &i, DB_MPOOL_EXTENT, &h)) != 0) {
  166. pg_ext = ((QUEUE *)dbp->q_internal)->page_ext;
  167. if (pg_ext == 0) {
  168. if (ret == EINVAL && first == last)
  169. return (0);
  170. return (ret);
  171. }
  172. if (ret == ENOENT || ret == EINVAL) {
  173. i += pg_ext - ((i - 1) % pg_ext) - 1;
  174. continue;
  175. }
  176. return (ret);
  177. }
  178. (void)__db_prpage(dbp, h, flags);
  179. if ((ret = __qam_fput(dbp, i, h, 0)) != 0)
  180. return (ret);
  181. }
  183. if (first > last) {
  184. i = 1;
  185. stop = last;
  186. first = last;
  187. goto begin;
  188. }
  189. return (0);
  190. }
  192. /*
  193.  * __qam_remove
  194.  * Remove method for a Queue.
  195.  *
  196.  * PUBLIC: int __qam_remove __P((DB *, const char *,
  197.  * PUBLIC:      const char *, DB_LSN *, int (**)(DB *, void*), void **));
  198.  */
  199. int
  200. __qam_remove(dbp, name, subdb, lsnp, callbackp, cookiep)
  201. DB *dbp;
  202. const char *name, *subdb;
  203. DB_LSN *lsnp;
  204. int (**callbackp) __P((DB *, void *));
  205. void **cookiep;
  206. {
  207. DBT namedbt;
  208. DB_ENV *dbenv;
  209. DB_LSN lsn;
  210. MPFARRAY *ap;
  211. QUEUE *qp;
  212. int ret;
  213. char *backup, buf[256], *real_back, *real_name;
  214. QUEUE_FILELIST *filelist, *fp;
  215. struct __qam_cookie *qam_cookie;
  217. dbenv = dbp->dbenv;
  218. ret = 0;
  219. backup = real_back = real_name = NULL;
  220. filelist = NULL;
  222. PANIC_CHECK(dbenv);
  224. /*
  225.  * Subdatabases.
  226.  */
  227. if (subdb != NULL) {
  228. __db_err(dbenv,
  229.     "Queue does not support multiple databases per file.");
  230. ret = EINVAL;
  231. goto done;
  232. }
  234. qp = (QUEUE *)dbp->q_internal;
  236. if (qp->page_ext != 0 &&
  237.     (ret = __qam_gen_filelist(dbp, &filelist)) != 0)
  238. goto done;
  240. if (filelist == NULL)
  241. goto done;
  243. for (fp = filelist; fp->mpf != NULL; fp++) {
  244. snprintf(buf,
  245.     sizeof(buf), QUEUE_EXTENT, qp->dir, qp->name, fp->id);
  246. if ((ret = __db_appname(dbenv,
  247.     DB_APP_DATA, NULL, buf, 0, NULL, &real_name)) != 0)
  248. goto done;
  249. if (LOGGING_ON(dbenv)) {
  250. memset(&namedbt, 0, sizeof(namedbt));
  251. namedbt.data = (char *)buf;
  252. namedbt.size = strlen(buf) + 1;
  254. if ((ret =
  255.     __qam_delete_log(dbenv, dbp->open_txn,
  256.     &lsn, DB_FLUSH, &namedbt, lsnp)) != 0) {
  257. __db_err(dbenv,
  258.     "%s: %s", name, db_strerror(ret));
  259. goto done;
  260. }
  261. }
  262. (void)__memp_fremove(fp->mpf);
  263. if ((ret = memp_fclose(fp->mpf)) != 0)
  264. goto done;
  265. if (qp->array2.n_extent == 0 || qp->array2.low_extent > fp->id)
  266. ap = &qp->array1;
  267. else
  268. ap = &qp->array2;
  269. ap->mpfarray[fp->id - ap->low_extent].mpf = NULL;
  271. /* Create name for backup file. */
  272. if (TXN_ON(dbenv)) {
  273. if ((ret = __db_backup_name(dbenv,
  274.     buf, &backup, lsnp)) != 0)
  275. goto done;
  276. if ((ret = __db_appname(dbenv, DB_APP_DATA,
  277.      NULL, backup, 0, NULL, &real_back)) != 0)
  278. goto done;
  279. if ((ret = __os_rename(dbenv,
  280.      real_name, real_back)) != 0)
  281. goto done;
  282. __os_freestr(real_back);
  283. real_back = NULL;
  284. }
  285. else
  286. if ((ret = __os_unlink(dbenv, real_name)) != 0)
  287. goto done;
  288. __os_freestr(real_name);
  289. real_name = NULL;
  290. }
  291. if ((ret= __os_malloc(dbenv,
  292.     sizeof(struct __qam_cookie), NULL, &qam_cookie)) != 0)
  293. goto done;
  294. qam_cookie->lsn = *lsnp;
  295. qam_cookie->filelist = filelist;
  296. *cookiep = qam_cookie;
  297. *callbackp = __qam_remove_callback;
  299. done:
  300. if (ret != 0 && filelist != NULL)
  301. __os_free(filelist, 0);
  302. if (real_back != NULL)
  303. __os_freestr(real_back);
  304. if (real_name != NULL)
  305. __os_freestr(real_name);
  306. if (backup != NULL)
  307. __os_freestr(backup);
  309. return (ret);
  310. }
  312. static int
  313. __qam_remove_callback(dbp, cookie)
  314. DB *dbp;
  315. void *cookie;
  316. {
  317. DB_ENV *dbenv;
  318. DB_LSN *lsnp;
  319. QUEUE *qp;
  320. QUEUE_FILELIST *filelist, *fp;
  321. char *backup, buf[256], *real_back;
  322. int ret;
  324. qp = (QUEUE *)dbp->q_internal;
  325. if (qp->page_ext == 0)
  326. return (__os_unlink(dbp->dbenv, cookie));
  328. dbenv = dbp->dbenv;
  329. lsnp = &((struct __qam_cookie *)cookie)->lsn;
  330. filelist = fp = ((struct __qam_cookie *)cookie)->filelist;
  331. real_back = backup = NULL;
  332. if ((ret =
  333.     __db_backup_name(dbenv, qp->name, &backup, lsnp)) != 0)
  334. goto err;
  335. if ((ret = __db_appname(dbenv,
  336.     DB_APP_DATA, NULL, backup, 0, NULL, &real_back)) != 0)
  337. goto err;
  338. if ((ret = __os_unlink(dbp->dbenv, real_back)) != 0)
  339. goto err;
  341. __os_freestr(backup);
  342. __os_freestr(real_back);
  344. if (fp == NULL)
  345. return (0);
  347. for (; fp->mpf != NULL; fp++) {
  348. snprintf(buf,
  349.     sizeof(buf), QUEUE_EXTENT, qp->dir, qp->name, fp->id);
  350. real_back = backup = NULL;
  351. if ((ret = __db_backup_name(dbenv, buf, &backup, lsnp)) != 0)
  352. goto err;
  353. if ((ret = __db_appname(dbenv,
  354.     DB_APP_DATA, NULL, backup, 0, NULL, &real_back)) != 0)
  355. goto err;
  356. ret = __os_unlink(dbenv, real_back);
  357. __os_freestr(real_back);
  358. __os_freestr(backup);
  359. }
  360. __os_free(filelist, 0);
  361. __os_free(cookie, sizeof (struct __qam_cookie));
  363. return (0);
  365. err:
  366. if (backup != NULL)
  367. __os_freestr(backup);
  369. if (real_back != NULL)
  370. __os_freestr(real_back);
  372. return (ret);
  373. }
  375. /*
  376.  * __qam_rename
  377.  * Rename method for Queue.
  378.  *
  379.  * PUBLIC: int __qam_rename __P((DB *,
  380.  * PUBLIC:     const char *, const char *, const char *));
  381.  */
  382. int
  383. __qam_rename(dbp, filename, subdb, newname)
  384. DB *dbp;
  385. const char *filename, *subdb, *newname;
  386. {
  387. DBT namedbt, newnamedbt;
  388. DB_ENV *dbenv;
  389. DB_LSN newlsn;
  390. MPFARRAY *ap;
  391. QUEUE *qp;
  392. QUEUE_FILELIST *fp, *filelist;
  393. char buf[256], nbuf[256], *namep, *real_name, *real_newname;
  394. int ret;
  396. dbenv = dbp->dbenv;
  397. ret = 0;
  398. real_name = real_newname = NULL;
  399. filelist = NULL;
  401. qp = (QUEUE *)dbp->q_internal;
  403. if (subdb != NULL) {
  404. __db_err(dbenv,
  405.     "Queue does not support multiple databases per file.");
  406. ret = EINVAL;
  407. goto err;
  408. }
  409. if (qp->page_ext != 0 &&
  410.     (ret = __qam_gen_filelist(dbp, &filelist)) != 0)
  411. goto err;
  412. if ((namep = __db_rpath(newname)) != NULL)
  413. newname = namep + 1;
  415. for (fp = filelist; fp != NULL && fp->mpf != NULL; fp++) {
  416. if ((ret = __memp_fremove(fp->mpf)) != 0)
  417. goto err;
  418. if ((ret = memp_fclose(fp->mpf)) != 0)
  419. goto err;
  420. if (qp->array2.n_extent == 0 || qp->array2.low_extent > fp->id)
  421. ap = &qp->array1;
  422. else
  423. ap = &qp->array2;
  424. ap->mpfarray[fp->id - ap->low_extent].mpf = NULL;
  425. snprintf(buf,
  426.     sizeof(buf), QUEUE_EXTENT, qp->dir, qp->name, fp->id);
  427. if ((ret = __db_appname(dbenv,
  428.     DB_APP_DATA, NULL, buf, 0, NULL, &real_name)) != 0)
  429. goto err;
  430. snprintf(nbuf,
  431.      sizeof(nbuf), QUEUE_EXTENT, qp->dir, newname, fp->id);
  432. if ((ret = __db_appname(dbenv,
  433.     DB_APP_DATA, NULL, nbuf, 0, NULL, &real_newname)) != 0)
  434. goto err;
  435. if (LOGGING_ON(dbenv)) {
  436. memset(&namedbt, 0, sizeof(namedbt));
  437. namedbt.data = (char *)buf;
  438. namedbt.size = strlen(buf) + 1;
  440. memset(&newnamedbt, 0, sizeof(namedbt));
  441. newnamedbt.data = (char *)nbuf;
  442. newnamedbt.size = strlen(nbuf) + 1;
  444. if ((ret =
  445.     __qam_rename_log(dbenv,
  446.     dbp->open_txn, &newlsn, 0,
  447.     &namedbt, &newnamedbt)) != 0) {
  448. __db_err(dbenv, "%s: %s", filename, db_strerror(ret));
  449. goto err;
  450. }
  452. if ((ret = __log_filelist_update(dbenv, dbp,
  453.     dbp->log_fileid, newname, NULL)) != 0)
  454. goto err;
  455. }
  456. if ((ret = __os_rename(dbenv, real_name, real_newname)) != 0)
  457. goto err;
  458. __os_freestr(real_name);
  459. __os_freestr(real_newname);
  460. real_name = real_newname = NULL;
  461. }
  463. err:
  464. if (real_name != NULL)
  465. __os_freestr(real_name);
  466. if (real_newname != NULL)
  467. __os_freestr(real_newname);
  468. if (filelist != NULL)
  469. __os_free(filelist, 0);
  471. return (ret);
  472. }