1 /*-
2  * See the file LICENSE for redistribution information.
3  *
4  * Copyright (c) 1999, 2013 Oracle and/or its affiliates.  All rights reserved.
5  *
6  * $Id$
7  */
8 
9 #include "db_config.h"
10 
11 #include "db_int.h"
12 #include "dbinc/db_page.h"
13 #include "dbinc/db_am.h"
14 #include "dbinc/lock.h"
15 #include "dbinc/mp.h"
16 #include "dbinc/qam.h"
17 
18 #ifdef HAVE_STATISTICS
19 /*
20  * __qam_stat --
21  *	Gather/print the qam statistics
22  *
23  * PUBLIC: int __qam_stat __P((DBC *, void *, u_int32_t));
24  */
25 int
__qam_stat(dbc,spp,flags)26 __qam_stat(dbc, spp, flags)
27 	DBC *dbc;
28 	void *spp;
29 	u_int32_t flags;
30 {
31 	DB *dbp;
32 	DB_LOCK lock;
33 	DB_MPOOLFILE *mpf;
34 	DB_QUEUE_STAT *sp;
35 	PAGE *h;
36 	QAMDATA *qp, *ep;
37 	QMETA *meta;
38 	QUEUE *t;
39 	db_indx_t indx;
40 	db_pgno_t first, last, pgno, pg_ext, stop;
41 	u_int32_t re_len;
42 	int ret, t_ret;
43 
44 	dbp = dbc->dbp;
45 
46 	LOCK_INIT(lock);
47 	mpf = dbp->mpf;
48 	sp = NULL;
49 	t = dbp->q_internal;
50 
51 	if (spp == NULL)
52 		return (0);
53 
54 	/* Allocate and clear the structure. */
55 	if ((ret = __os_umalloc(dbp->env, sizeof(*sp), &sp)) != 0)
56 		goto err;
57 	memset(sp, 0, sizeof(*sp));
58 
59 	re_len = ((QUEUE *)dbp->q_internal)->re_len;
60 
61 	/* Determine the last page of the database. */
62 	if ((ret = __db_lget(dbc, 0, t->q_meta, DB_LOCK_READ, 0, &lock)) != 0)
63 		goto err;
64 	if ((ret = __memp_fget(mpf, &t->q_meta,
65 	    dbc->thread_info, dbc->txn, 0, &meta)) != 0)
66 		goto err;
67 
68 	if (flags == DB_FAST_STAT) {
69 		sp->qs_nkeys = meta->dbmeta.key_count;
70 		sp->qs_ndata = meta->dbmeta.record_count;
71 		goto meta_only;
72 	}
73 
74 	first = QAM_RECNO_PAGE(dbp, meta->first_recno);
75 	last = QAM_RECNO_PAGE(dbp, meta->cur_recno);
76 
77 	ret = __memp_fput(mpf, dbc->thread_info, meta, dbc->priority);
78 	if ((t_ret = __LPUT(dbc, lock)) != 0 && ret == 0)
79 		ret = t_ret;
80 	if (ret != 0)
81 		goto err;
82 
83 	pgno = first;
84 	if (first > last)
85 		stop = QAM_RECNO_PAGE(dbp, UINT32_MAX);
86 	else
87 		stop = last;
88 
89 	/* Dump each page. */
90 	pg_ext = ((QUEUE *)dbp->q_internal)->page_ext;
91 begin:
92 	/* Walk through the pages and count. */
93 	for (; pgno <= stop; ++pgno) {
94 		if ((ret =
95 		    __db_lget(dbc, 0, pgno, DB_LOCK_READ, 0, &lock)) != 0)
96 			goto err;
97 		ret = __qam_fget(dbc, &pgno, 0, &h);
98 		if (ret == ENOENT) {
99 			pgno += pg_ext - 1;
100 			continue;
101 		}
102 		if (ret == DB_PAGE_NOTFOUND) {
103 			if (pg_ext == 0) {
104 				if (pgno != stop && first != last)
105 					goto err;
106 				ret = 0;
107 				break;
108 			}
109 			pgno += (pg_ext - ((pgno - 1) % pg_ext)) - 1;
110 			continue;
111 		}
112 		if (ret != 0)
113 			goto err;
114 
115 		++sp->qs_pages;
116 
117 		ep = (QAMDATA *)((u_int8_t *)h + dbp->pgsize - re_len);
118 		for (indx = 0, qp = QAM_GET_RECORD(dbp, h, indx);
119 		    qp <= ep;
120 		    ++indx,  qp = QAM_GET_RECORD(dbp, h, indx)) {
121 			if (F_ISSET(qp, QAM_VALID))
122 				sp->qs_ndata++;
123 			else
124 				sp->qs_pgfree += re_len;
125 		}
126 
127 		ret = __qam_fput(dbc, pgno, h, dbc->priority);
128 		if ((t_ret = __LPUT(dbc, lock)) != 0 && ret == 0)
129 			ret = t_ret;
130 		if (ret != 0)
131 			goto err;
132 	}
133 
134 	if ((ret = __LPUT(dbc, lock)) != 0)
135 		goto err;
136 	if (first > last) {
137 		pgno = 1;
138 		stop = last;
139 		first = last;
140 		goto begin;
141 	}
142 
143 	/* Get the meta-data page. */
144 	if ((ret = __db_lget(dbc,
145 	    0, t->q_meta, F_ISSET(dbp, DB_AM_RDONLY) ?
146 	    DB_LOCK_READ : DB_LOCK_WRITE, 0, &lock)) != 0)
147 		goto err;
148 	if ((ret = __memp_fget(mpf, &t->q_meta, dbc->thread_info, dbc->txn,
149 	    F_ISSET(dbp, DB_AM_RDONLY) ? 0 : DB_MPOOL_DIRTY, &meta)) != 0)
150 		goto err;
151 
152 	if (!F_ISSET(dbp, DB_AM_RDONLY))
153 		meta->dbmeta.key_count =
154 		    meta->dbmeta.record_count = sp->qs_ndata;
155 	sp->qs_nkeys = sp->qs_ndata;
156 
157 meta_only:
158 	/* Get the metadata fields. */
159 	sp->qs_magic = meta->dbmeta.magic;
160 	sp->qs_version = meta->dbmeta.version;
161 	sp->qs_metaflags = meta->dbmeta.flags;
162 	sp->qs_pagesize = meta->dbmeta.pagesize;
163 	sp->qs_extentsize = meta->page_ext;
164 	sp->qs_re_len = meta->re_len;
165 	sp->qs_re_pad = meta->re_pad;
166 	sp->qs_first_recno = meta->first_recno;
167 	sp->qs_cur_recno = meta->cur_recno;
168 
169 	/* Discard the meta-data page. */
170 	ret = __memp_fput(mpf, dbc->thread_info, meta, dbc->priority);
171 	if ((t_ret = __LPUT(dbc, lock)) != 0 && ret == 0)
172 		ret = t_ret;
173 	if (ret != 0)
174 		goto err;
175 
176 	*(DB_QUEUE_STAT **)spp = sp;
177 
178 	if (0) {
179 err:		if (sp != NULL)
180 			__os_ufree(dbp->env, sp);
181 	}
182 
183 	if ((t_ret = __LPUT(dbc, lock)) != 0 && ret == 0)
184 		ret = t_ret;
185 
186 	return (ret);
187 }
188 
189 /*
190  * __qam_stat_print --
191  *	Display queue statistics.
192  *
193  * PUBLIC: int __qam_stat_print __P((DBC *, u_int32_t));
194  */
195 int
__qam_stat_print(dbc,flags)196 __qam_stat_print(dbc, flags)
197 	DBC *dbc;
198 	u_int32_t flags;
199 {
200 	DB *dbp;
201 	DB_QUEUE_STAT *sp;
202 	ENV *env;
203 	int ret;
204 
205 	dbp = dbc->dbp;
206 	env = dbp->env;
207 
208 	if ((ret = __qam_stat(dbc, &sp, LF_ISSET(DB_FAST_STAT))) != 0)
209 		return (ret);
210 
211 	if (LF_ISSET(DB_STAT_ALL)) {
212 		__db_msg(env, "%s", DB_GLOBAL(db_line));
213 		__db_msg(env, "Default Queue database information:");
214 	}
215 	__db_msg(env, "%lx\tQueue magic number", (u_long)sp->qs_magic);
216 	__db_msg(env, "%lu\tQueue version number", (u_long)sp->qs_version);
217 	__db_dl(env, "Fixed-length record size", (u_long)sp->qs_re_len);
218 	__db_msg(env, "%#x\tFixed-length record pad", (int)sp->qs_re_pad);
219 	__db_dl(env,
220 	    "Underlying database page size", (u_long)sp->qs_pagesize);
221 	__db_dl(env,
222 	    "Underlying database extent size", (u_long)sp->qs_extentsize);
223 	__db_dl(env,
224 	    "Number of records in the database", (u_long)sp->qs_nkeys);
225 	__db_dl(env,
226 	    "Number of data items in the database", (u_long)sp->qs_ndata);
227 	__db_dl(env, "Number of database pages", (u_long)sp->qs_pages);
228 	__db_dl_pct(env,
229 	    "Number of bytes free in database pages",
230 	    (u_long)sp->qs_pgfree,
231 	    DB_PCT_PG(sp->qs_pgfree, sp->qs_pages, sp->qs_pagesize), "ff");
232 	__db_msg(env,
233 	    "%lu\tFirst undeleted record", (u_long)sp->qs_first_recno);
234 	__db_msg(env,
235 	    "%lu\tNext available record number", (u_long)sp->qs_cur_recno);
236 
237 	__os_ufree(env, sp);
238 
239 	return (0);
240 }
241 
242 #else /* !HAVE_STATISTICS */
243 
244 int
__qam_stat(dbc,spp,flags)245 __qam_stat(dbc, spp, flags)
246 	DBC *dbc;
247 	void *spp;
248 	u_int32_t flags;
249 {
250 	COMPQUIET(spp, NULL);
251 	COMPQUIET(flags, 0);
252 
253 	return (__db_stat_not_built(dbc->env));
254 }
255 #endif
256