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
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
|
/****************************************************************
* *
* Copyright (c) 2001-2024 Fidelity National Information *
* Services, Inc. and/or its subsidiaries. All rights reserved. *
* *
* This source code contains the intellectual property *
* of its copyright holder(s), and is made available *
* under a license. If you do not know the terms of *
* the license, please stop and do not read further. *
* *
****************************************************************/
#include "mdef.h"
#include <errno.h>
#include "gtm_stdio.h"
#include "gtm_stdlib.h" /* for EXIT() */
#include "gtm_unistd.h"
#include "gdsroot.h"
#include "gdsbt.h"
#include "gtm_facility.h"
#include "fileinfo.h"
#include "gdsfhead.h"
#include "gdsblk.h"
#include "getzposition.h"
#include "filestruct.h"
#include "iosp.h"
#include "copy.h"
#include "gdsbml.h"
#include "gtmio.h"
#include "mucblkini.h"
#include "anticipatory_freeze.h"
#include "jnl.h"
#define DIR_ROOT 1
#define DIR_DATA 2
GBLREF sgmnt_addrs *csa;
GBLREF uint4 mu_upgrade_in_prog;
error_def(ERR_AUTODBCREFAIL);
error_def(ERR_FILECREERR);
error_def(ERR_MUCREFILERR);
/* This function is only called during the creation of a new region */
unsigned char mucblkini(gd_region *reg, enum db_ver desired_db_ver)
{
uchar_ptr_t c, bmp, bmp_base;
blk_hdr_ptr_t bp1, bp2;
rec_hdr_ptr_t rp;
sgmnt_data_ptr_t csd;
sgmnt_addrs *csa;
unix_db_info *udi;
int4 bmpsize, status;
block_id blk;
boolean_t isv7blk;
DCL_THREADGBL_ACCESS;
SETUP_THREADGBL_ACCESS;
isv7blk = (GDSV7m <= desired_db_ver);
udi = FILE_INFO(reg);
csa = &udi->s_addrs;
csd = csa->hdr;
bp1 = (blk_hdr_ptr_t)malloc(csd->blk_size);
bp2 = (blk_hdr_ptr_t)malloc(csd->blk_size);
bmpsize = BM_SIZE(csd->bplmap);
if (csd->write_fullblk)
bmpsize = (int4)ROUND_UP(bmpsize, csa->fullblockwrite_len);
bmp_base = (uchar_ptr_t)malloc(bmpsize + OS_PAGE_SIZE); /* UPGRADE opens an AIO DB, need to align buffer */
bmp = (sm_uc_ptr_t)ROUND_UP2((sm_long_t)bmp_base, OS_PAGE_SIZE);
DB_LSEEKREAD(udi, udi->fd, (off_t)BLK_ZERO_OFF(csd->start_vbn), bmp, bmpsize, status);
if (0 != status)
{
if (IS_MUMPS_IMAGE)
{
RTS_ERROR_CSA_ABT(csa, VARLSTCNT(7) ERR_FILECREERR, 4, LEN_AND_LIT("reading first bitmap"),
DB_LEN_STR(reg), status);
} else
{
gtm_putmsg_csa(CSA_ARG(csa) VARLSTCNT(7) ERR_FILECREERR, 4, LEN_AND_LIT("reading first bitmap"),
DB_LEN_STR(reg), status);
}
return EXIT_ERR;
}
bml_busy(DIR_ROOT, bmp + SIZEOF(blk_hdr));
bml_busy(DIR_DATA, bmp + SIZEOF(blk_hdr));
ASSERT_NO_DIO_ALIGN_NEEDED(udi); /* creating the database, so effectively have standalone access */
DB_LSEEKWRITE(csa, udi, udi->fn, udi->fd, (off_t)BLK_ZERO_OFF(csd->start_vbn), bmp, bmpsize, status);
free(bmp_base);
if (0 != status)
{
if (IS_MUMPS_IMAGE)
{
RTS_ERROR_CSA_ABT(csa, VARLSTCNT(7) ERR_FILECREERR, 4, LEN_AND_LIT("writing out first bitmap"),
DB_LEN_STR(reg), status);
} else
{
gtm_putmsg_csa(CSA_ARG(csa) VARLSTCNT(7) ERR_FILECREERR, 4, LEN_AND_LIT("writing out first bitmap"),
DB_LEN_STR(reg), status);
}
return EXIT_ERR;
}
rp = (rec_hdr_ptr_t)((uchar_ptr_t)bp1 + SIZEOF(blk_hdr));
bstar_rec((sm_uc_ptr_t)rp, isv7blk); /* This function is creating a new region so it will always be making V7 blocks */
c = CST_BOK(rp);
blk = DIR_DATA;
if (isv7blk)
PUT_BLK_ID_64(c, blk);
else
PUT_BLK_ID_32(c, blk);
bp1->bver = desired_db_ver;
bp1->levl = 1;
bp1->bsiz = bstar_rec_size(isv7blk) + SIZEOF(blk_hdr);
bp1->tn = 0;
bp2->bver = desired_db_ver;
bp2->levl = 0;
bp2->bsiz = SIZEOF(blk_hdr);
bp2->tn = 0;
DSK_WRITE_NOCACHE(reg, DIR_ROOT, (uchar_ptr_t)bp1, csd->desired_db_format, status);
free(bp1);
if (0 != status)
{
if (IS_MUMPS_IMAGE)
RTS_ERROR_CSA_ABT(csa, VARLSTCNT(7) ERR_AUTODBCREFAIL, 4, DB_LEN_STR(reg),
REG_LEN_STR(reg), status);
else
{
gtm_putmsg_csa(CSA_ARG(csa) VARLSTCNT(7) ERR_FILECREERR, 4, LEN_AND_LIT("writing to disk"),
DB_LEN_STR(reg), status);
}
return EXIT_ERR;
}
DSK_WRITE_NOCACHE(reg, DIR_DATA, (uchar_ptr_t)bp2, csd->desired_db_format, status);
free(bp2);
if (0 != status)
{
if (IS_MUMPS_IMAGE)
RTS_ERROR_CSA_ABT(csa, VARLSTCNT(7) ERR_AUTODBCREFAIL, 4, DB_LEN_STR(reg),
REG_LEN_STR(reg), status);
else
gtm_putmsg_csa(CSA_ARG(csa) VARLSTCNT(7) ERR_FILECREERR, 4, LEN_AND_LIT("writing to disk"),
DB_LEN_STR(reg), status);
return EXIT_ERR;
}
return EXIT_NRM;
}
|
