1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
|
/*-
* See the file LICENSE for redistribution information.
*
* Copyright (c) 1996, 1997, 1998, 1999
* Sleepycat Software. All rights reserved.
*/
#include "db_config.h"
#ifndef lint
static const char sccsid[] = "@(#)db_upgrade.c 11.3 (Sleepycat) 10/20/99";
#endif /* not lint */
#ifndef NO_SYSTEM_INCLUDES
#include <sys/types.h>
#include <errno.h>
#endif
#include "db_int.h"
#include "db_page.h"
#include "db_swap.h"
#include "btree.h"
#include "hash.h"
#include "qam.h"
/*
* CDB___db_upgrade --
* Upgrade an existing database.
*
* PUBLIC: int CDB___db_upgrade __P((DB *, const char *, u_int32_t));
*/
int
CDB___db_upgrade(dbp, fname, flags)
DB *dbp;
const char *fname;
u_int32_t flags;
{
DB_ENV *dbenv;
DB_FH fh;
ssize_t nr;
int ret, swapped, t_ret;
char *real_name, mbuf[256];
dbenv = dbp->dbenv;
/* Validate arguments. */
if ((ret = CDB___db_fchk(dbenv, "DB->upgrade", flags, 0)) != 0)
return (ret);
/* Get the real backing file name. */
if ((ret = CDB___db_appname(dbenv,
DB_APP_DATA, NULL, fname, 0, NULL, &real_name)) != 0)
return (ret);
/* Open the file. */
if ((ret = CDB___os_open(real_name, 0, 0, &fh)) != 0) {
CDB___db_err(dbenv, "%s: %s", fname, CDB_db_strerror(ret));
return (ret);
}
/*
* Read the metadata page. We read 256 bytes, which is larger than
* any access method's metadata page and smaller than any disk sector.
*/
if ((ret = CDB___os_read(&fh, mbuf, sizeof(mbuf), &nr)) != 0)
goto err;
swapped = 0;
retry: switch (((DBMETA *)mbuf)->magic) {
case DB_BTREEMAGIC:
if ((ret =
CDB___bam_upgrade(dbp, swapped, real_name, &fh, mbuf)) != 0)
goto err;
break;
case DB_HASHMAGIC:
if ((ret =
CDB___ham_upgrade(dbp, swapped, real_name, &fh, mbuf)) != 0)
goto err;
break;
case DB_QAMMAGIC:
break;
default:
if (swapped++) {
CDB___db_err(dbenv, "%s: unrecognized file type", fname);
ret = EINVAL;
goto err;
}
M_32_SWAP(((DBMETA *)mbuf)->magic);
M_32_SWAP(((DBMETA *)mbuf)->version);
goto retry;
}
err: if ((t_ret = CDB___os_closehandle(&fh)) != 0 && ret == 0)
ret = t_ret;
CDB___os_freestr(real_name);
return (ret);
}
|
