Bug Summary

File:tbudb/./../budb/db_text.c
Location:line 318, column 3
Description:Assigned value is always the same as the existing value

Annotated Source Code

1/*
2 * Copyright 2000, International Business Machines Corporation and others.
3 * All Rights Reserved.
4 *
5 * This software has been released under the terms of the IBM Public
6 * License. For details, see the LICENSE file in the top-level source
7 * directory or online at http://www.openafs.org/dl/license10.html
8 */
9
10#include <afsconfig.h>
11#include <afs/param.h>
12
13#include <roken.h>
14
15#include <ubik.h>
16#include <afs/bubasics.h>
17#include <afs/audit.h>
18#include <afs/afsutil.h>
19
20#include "budb_errs.h"
21#include "database.h"
22#include "error_macros.h"
23#include "budb_internal.h"
24
25/* --------------------------------
26 * interface & support code to manage text blocks within the
27 * database
28 * --------------------------------
29 */
30
31/* BUDB_GetText
32 * notes:
33 * routine mallocs storage for charListPtr, freed by stub
34 */
35
36afs_int32 GetText(struct rx_call *, afs_uint32, afs_int32, afs_int32,
37 afs_int32, afs_int32 *, charListT *);
38afs_int32 GetTextVersion(struct rx_call *, afs_int32, afs_uint32 *);
39afs_int32 SaveText(struct rx_call *, afs_uint32, afs_int32, afs_int32,
40 afs_int32, charListT *);
41
42afs_int32
43SBUDB_GetText(struct rx_call *call, afs_uint32 lockHandle, afs_int32 textType,
44 afs_int32 maxLength, afs_int32 offset, afs_int32 *nextOffset,
45 charListT *charListPtr)
46{
47 afs_int32 code;
48
49 code =
50 GetText(call, lockHandle, textType, maxLength, offset, nextOffset,
51 charListPtr);
52 osi_auditU(call, BUDB_GetTxtEvent"AFS_BUDB_GetTxt", code, AUD_LONG5, textType, AUD_END0);
53 return code;
54}
55
56afs_int32
57GetText(struct rx_call *call, afs_uint32 lockHandle, afs_int32 textType,
58 afs_int32 maxLength, afs_int32 offset, afs_int32 *nextOffset,
59 charListT *charListPtr)
60{
61 struct ubik_trans *ut = 0;
62 struct block block;
63 afs_int32 transferSize, chunkSize;
64 afs_int32 blockOffset;
65 dbadr lastBlockAddr;
66 afs_int32 nblocks;
67 struct textBlock *tbPtr;
68 afs_int32 textRemaining;
69 char *textPtr;
70 afs_int32 code;
71
72 LogDebug(5, "GetText: type %d, offset %d, nextOffset %"AFS_PTR_FMT"p"
73 ", maxLength %d\n", textType, offset, nextOffset, maxLength);
74
75 if (callPermitted(call) == 0) {
76 code = BUDB_NOTPERMITTED(156303880L);
77 goto no_xfer_abort;
78 }
79
80 /* check parameters */
81 if ((offset < 0)
82 || (textType < 0)
83 || (textType >= TB_NUM3)
84 ) {
85 code = BUDB_BADARGUMENT(156303882L);
86 goto no_xfer_abort;
87 }
88
89 /* start the transaction */
90 code = InitRPC(&ut, LOCKWRITE2, 1);
91 if (code)
92 goto no_xfer_abort;
93
94 /* fetch the lock state */
95 if (checkLockHandle(ut, lockHandle) == 0) {
96 code = BUDB_NOTLOCKED(156303888L);
97 goto no_xfer_abort;
98 }
99
100 tbPtr = &db.h.textBlock[textType];
101
102 if ((ntohl(tbPtr->size)(__builtin_constant_p(tbPtr->size) ? ((((__uint32_t)(tbPtr
->size)) >> 24) | ((((__uint32_t)(tbPtr->size)) &
(0xff << 16)) >> 8) | ((((__uint32_t)(tbPtr->
size)) & (0xff << 8)) << 8) | (((__uint32_t)(
tbPtr->size)) << 24)) : __bswap32_var(tbPtr->size
)) > 0)
103 && (offset >= ntohl(tbPtr->size)(__builtin_constant_p(tbPtr->size) ? ((((__uint32_t)(tbPtr
->size)) >> 24) | ((((__uint32_t)(tbPtr->size)) &
(0xff << 16)) >> 8) | ((((__uint32_t)(tbPtr->
size)) & (0xff << 8)) << 8) | (((__uint32_t)(
tbPtr->size)) << 24)) : __bswap32_var(tbPtr->size
)))
104 ) {
105 code = BUDB_BADARGUMENT(156303882L);
106 goto no_xfer_abort;
107 }
108
109 LogDebug(5, "GetText: store size is %d\n", ntohl(tbPtr->size)(__builtin_constant_p(tbPtr->size) ? ((((__uint32_t)(tbPtr
->size)) >> 24) | ((((__uint32_t)(tbPtr->size)) &
(0xff << 16)) >> 8) | ((((__uint32_t)(tbPtr->
size)) & (0xff << 8)) << 8) | (((__uint32_t)(
tbPtr->size)) << 24)) : __bswap32_var(tbPtr->size
)));
110
111 /* compute minimum of remaining text or user buffer */
112 textRemaining = ntohl(tbPtr->size)(__builtin_constant_p(tbPtr->size) ? ((((__uint32_t)(tbPtr
->size)) >> 24) | ((((__uint32_t)(tbPtr->size)) &
(0xff << 16)) >> 8) | ((((__uint32_t)(tbPtr->
size)) & (0xff << 8)) << 8) | (((__uint32_t)(
tbPtr->size)) << 24)) : __bswap32_var(tbPtr->size
)) - offset;
113 transferSize = MIN(textRemaining, maxLength)(((textRemaining)<(maxLength))?(textRemaining):(maxLength)
);
114
115 /* allocate the transfer storage */
116 if (transferSize <= 0) {
117 charListPtr->charListT_len = 0L;
118 charListPtr->charListT_val = NULL((void *)0);
119 } else {
120 charListPtr->charListT_len = transferSize;
121 charListPtr->charListT_val = (char *)malloc(transferSize);
122 if (charListPtr->charListT_val == 0)
123 ABORT(BUDB_NOMEM)do { code = (156303901L); goto abort_exit; } while (0);
124 }
125
126 textPtr = charListPtr->charListT_val;
127 *nextOffset = offset + transferSize;
128
129 /* setup the datablock. read and discard all blocks up to the one the
130 * offset specifies
131 */
132 nblocks = offset / BLOCK_DATA_SIZE(2048 -sizeof(struct blockHeader));
133 lastBlockAddr = ntohl(tbPtr->textAddr)(__builtin_constant_p(tbPtr->textAddr) ? ((((__uint32_t)(tbPtr
->textAddr)) >> 24) | ((((__uint32_t)(tbPtr->textAddr
)) & (0xff << 16)) >> 8) | ((((__uint32_t)(tbPtr
->textAddr)) & (0xff << 8)) << 8) | (((__uint32_t
)(tbPtr->textAddr)) << 24)) : __bswap32_var(tbPtr->
textAddr));
134
135 while (nblocks--) {
136 code = dbread(ut, lastBlockAddr, (char *)&block, sizeof(block));
137 if (code)
138 ABORT(BUDB_IO)do { code = (156303892L); goto abort_exit; } while (0);
139 lastBlockAddr = ntohl(block.h.next)(__builtin_constant_p(block.h.next) ? ((((__uint32_t)(block.h
.next)) >> 24) | ((((__uint32_t)(block.h.next)) & (
0xff << 16)) >> 8) | ((((__uint32_t)(block.h.next
)) & (0xff << 8)) << 8) | (((__uint32_t)(block
.h.next)) << 24)) : __bswap32_var(block.h.next));
140 }
141
142 while (transferSize > 0) {
143 code = dbread(ut, lastBlockAddr, (char *)&block, sizeof(block));
144 if (code)
145 ABORT(BUDB_IO)do { code = (156303892L); goto abort_exit; } while (0);
146
147 LogDebug(5, "fetched block %d\n", lastBlockAddr);
148
149 /* compute the data size to extract */
150 blockOffset = offset % BLOCK_DATA_SIZE(2048 -sizeof(struct blockHeader));
151 textRemaining = BLOCK_DATA_SIZE(2048 -sizeof(struct blockHeader)) - blockOffset;
152 chunkSize = min(textRemaining, transferSize)(((textRemaining) < (transferSize)) ? (textRemaining) : (transferSize
));
153
154 memcpy(textPtr, &block.a[blockOffset], chunkSize);
155
156 /* LogDebug(5, "transfering %d bytes: %s\n", chunkSize, textPtr); */
157
158 transferSize -= chunkSize;
159 offset += chunkSize;
160 textPtr += chunkSize;
161
162 if (transferSize) {
163 /* setup lastBlockAddr */
164 lastBlockAddr = ntohl(block.h.next)(__builtin_constant_p(block.h.next) ? ((((__uint32_t)(block.h
.next)) >> 24) | ((((__uint32_t)(block.h.next)) & (
0xff << 16)) >> 8) | ((((__uint32_t)(block.h.next
)) & (0xff << 8)) << 8) | (((__uint32_t)(block
.h.next)) << 24)) : __bswap32_var(block.h.next));
165 }
166 }
167
168 if (*nextOffset == ntohl(tbPtr->size)(__builtin_constant_p(tbPtr->size) ? ((((__uint32_t)(tbPtr
->size)) >> 24) | ((((__uint32_t)(tbPtr->size)) &
(0xff << 16)) >> 8) | ((((__uint32_t)(tbPtr->
size)) & (0xff << 8)) << 8) | (((__uint32_t)(
tbPtr->size)) << 24)) : __bswap32_var(tbPtr->size
))) {
169 /* all done */
170 *nextOffset = -1;
171 }
172
173 /* error_exit: */
174 code = ubik_EndTrans(ut);
175/* printf("in error exit, code=%ld\n", code); */
176 return (code);
177
178 no_xfer_abort:
179 charListPtr->charListT_len = 0;
180 charListPtr->charListT_val = (char *)malloc(0);
181
182 abort_exit:
183 if (ut)
184 ubik_AbortTrans(ut);
185/* printf("in abort exit, code=%ld\n", code); */
186 return (code);
187}
188
189int
190freeOldBlockChain(struct ubik_trans *ut, dbadr diskAddr)
191{
192 struct blockHeader blockHeader;
193 dbadr nextDiskAddr;
194 afs_int32 code = 0;
195
196 while (diskAddr != 0) {
197 /* read in the header */
198 code =
199 dbread(ut, diskAddr, (char *)&blockHeader, sizeof(blockHeader));
200 if (code)
201 ABORT(code)do { code = code; goto abort_exit; } while (0);
202 nextDiskAddr = ntohl(blockHeader.next)(__builtin_constant_p(blockHeader.next) ? ((((__uint32_t)(blockHeader
.next)) >> 24) | ((((__uint32_t)(blockHeader.next)) &
(0xff << 16)) >> 8) | ((((__uint32_t)(blockHeader
.next)) & (0xff << 8)) << 8) | (((__uint32_t)
(blockHeader.next)) << 24)) : __bswap32_var(blockHeader
.next));
203 code = FreeBlock(ut, &blockHeader, diskAddr);
204 if (code)
205 ABORT(code)do { code = code; goto abort_exit; } while (0);
206 diskAddr = nextDiskAddr;
207 }
208 abort_exit:
209 return (code);
210}
211
212/* BUDB_GetTextVersion
213 * get the version number for the specified text block
214 */
215
216afs_int32
217SBUDB_GetTextVersion(struct rx_call *call, afs_int32 textType,
218 afs_uint32 *tversion)
219{
220 afs_int32 code;
221
222 code = GetTextVersion(call, textType, tversion);
223 osi_auditU(call, BUDB_GetTxVEvent"AFS_BUDB_GetTxV", code, AUD_LONG5, textType, AUD_END0);
224 return code;
225}
226
227afs_int32
228GetTextVersion(struct rx_call *call, afs_int32 textType,
229 afs_uint32 *tversion)
230{
231 afs_int32 code;
232 struct ubik_trans *ut;
233
234 if (callPermitted(call) == 0)
235 return (BUDB_NOTPERMITTED(156303880L));
236
237 if ((textType < 0) || (textType >= TB_NUM3))
238 return (BUDB_BADARGUMENT(156303882L));
239
240 code = InitRPC(&ut, LOCKREAD1, 1);
241 if (code)
242 return (code);
243
244 *tversion = ntohl(db.h.textBlock[textType].version)(__builtin_constant_p(db.h.textBlock[textType].version) ? (((
(__uint32_t)(db.h.textBlock[textType].version)) >> 24) |
((((__uint32_t)(db.h.textBlock[textType].version)) & (0xff
<< 16)) >> 8) | ((((__uint32_t)(db.h.textBlock[textType
].version)) & (0xff << 8)) << 8) | (((__uint32_t
)(db.h.textBlock[textType].version)) << 24)) : __bswap32_var
(db.h.textBlock[textType].version));
245 code = ubik_EndTrans(ut);
246 return (code);
247}
248
249/* text blocks
250 * next - next disk addr
251 * host/network ordering????
252 */
253
254/* BUDB_SaveText
255 * notes:
256 * charListPtr storage automatically malloced and freed
257 */
258
259afs_int32
260SBUDB_SaveText(struct rx_call *call, afs_uint32 lockHandle,
261 afs_int32 textType, afs_int32 offset, afs_int32 flags,
262 charListT *charListPtr)
263{
264 afs_int32 code;
265
266 code = SaveText(call, lockHandle, textType, offset, flags, charListPtr);
267 osi_auditU(call, BUDB_SavTxtEvent"AFS_BUDB_SavTxt", code, AUD_LONG5, textType, AUD_END0);
268 return code;
269}
270
271afs_int32
272SaveText(struct rx_call *call, afs_uint32 lockHandle, afs_int32 textType,
273 afs_int32 offset, afs_int32 flags, charListT *charListPtr)
274{
275 struct ubik_trans *ut;
276 struct block diskBlock;
277 dbadr diskBlockAddr;
278 afs_int32 remainingInBlock, chunkSize;
279 struct textBlock *tbPtr;
280 afs_int32 textLength = charListPtr->charListT_len;
281 char *textptr = charListPtr->charListT_val;
282 afs_int32 code;
283
284 LogDebug(5, "SaveText: type %d, offset %d, length %d\n", textType, offset,
285 textLength);
286
287 if (callPermitted(call) == 0)
1
Taking false branch
288 return (BUDB_NOTPERMITTED(156303880L));
289
290 if ((textLength > BLOCK_DATA_SIZE(2048 -sizeof(struct blockHeader))) || (offset < 0))
2
Taking false branch
291 return (BUDB_BADARGUMENT(156303882L));
292
293 code = InitRPC(&ut, LOCKWRITE2, 1);
294 if (code)
3
Taking false branch
295 return (code);
296
297 /* fetch the lock state */
298 if (checkLockHandle(ut, lockHandle) == 0)
4
Taking false branch
299 ABORT(BUDB_NOTLOCKED)do { code = (156303888L); goto abort_exit; } while (0);
300
301 if ((textType < 0) || (textType >= TB_NUM3))
5
Taking false branch
302 ABORT(BUDB_BADARGUMENT)do { code = (156303882L); goto abort_exit; } while (0);
303
304 tbPtr = &db.h.textBlock[textType];
305
306 LogDebug(5,
307 "SaveText: lockHandle %d textType %d offset %d flags %d txtlength %d\n",
308 lockHandle, textType, offset, flags, textLength);
309
310 if (offset == 0) {
6
Taking true branch
311 /* release any blocks from previous transactions */
312 diskBlockAddr = ntohl(tbPtr->newTextAddr)(__builtin_constant_p(tbPtr->newTextAddr) ? ((((__uint32_t
)(tbPtr->newTextAddr)) >> 24) | ((((__uint32_t)(tbPtr
->newTextAddr)) & (0xff << 16)) >> 8) | ((
((__uint32_t)(tbPtr->newTextAddr)) & (0xff << 8)
) << 8) | (((__uint32_t)(tbPtr->newTextAddr)) <<
24)) : __bswap32_var(tbPtr->newTextAddr));
313 freeOldBlockChain(ut, diskBlockAddr);
314
315 if (textLength) {
7
Taking true branch
316 code = AllocBlock(ut, &diskBlock, &diskBlockAddr);
317 if (code)
8
Taking true branch
318 ABORT(code)do { code = code; goto abort_exit; } while (0);
9
Within the expansion of the macro 'ABORT':
a
Assigned value is always the same as the existing value
319
320 LogDebug(5, "allocated block %d\n", diskBlockAddr);
321
322 /* set block type */
323 diskBlock.h.type = text_BLOCK6;
324
325 /* save it in the database header */
326 tbPtr->newsize = 0;
327 tbPtr->newTextAddr = htonl(diskBlockAddr)(__builtin_constant_p(diskBlockAddr) ? ((((__uint32_t)(diskBlockAddr
)) >> 24) | ((((__uint32_t)(diskBlockAddr)) & (0xff
<< 16)) >> 8) | ((((__uint32_t)(diskBlockAddr)) &
(0xff << 8)) << 8) | (((__uint32_t)(diskBlockAddr
)) << 24)) : __bswap32_var(diskBlockAddr));
328 dbwrite(ut, (char *)tbPtr - (char *)&db.h, (char *)tbPtr,
329 sizeof(struct textBlock));
330 } else {
331 tbPtr->newsize = 0;
332 tbPtr->newTextAddr = 0;
333 }
334 } else {
335 /* non-zero offset */
336 int nblocks;
337
338 if (offset != ntohl(tbPtr->newsize)(__builtin_constant_p(tbPtr->newsize) ? ((((__uint32_t)(tbPtr
->newsize)) >> 24) | ((((__uint32_t)(tbPtr->newsize
)) & (0xff << 16)) >> 8) | ((((__uint32_t)(tbPtr
->newsize)) & (0xff << 8)) << 8) | (((__uint32_t
)(tbPtr->newsize)) << 24)) : __bswap32_var(tbPtr->
newsize)))
339 ABORT(BUDB_BADARGUMENT)do { code = (156303882L); goto abort_exit; } while (0);
340
341 /* locate the block to which offset refers */
342 nblocks = offset / BLOCK_DATA_SIZE(2048 -sizeof(struct blockHeader));
343
344 diskBlockAddr = ntohl(tbPtr->newTextAddr)(__builtin_constant_p(tbPtr->newTextAddr) ? ((((__uint32_t
)(tbPtr->newTextAddr)) >> 24) | ((((__uint32_t)(tbPtr
->newTextAddr)) & (0xff << 16)) >> 8) | ((
((__uint32_t)(tbPtr->newTextAddr)) & (0xff << 8)
) << 8) | (((__uint32_t)(tbPtr->newTextAddr)) <<
24)) : __bswap32_var(tbPtr->newTextAddr));
345 if (diskBlockAddr == 0)
346 ABORT(BUDB_BADARGUMENT)do { code = (156303882L); goto abort_exit; } while (0);
347
348 code =
349 dbread(ut, diskBlockAddr, (char *)&diskBlock, sizeof(diskBlock));
350 if (code)
351 ABORT(code)do { code = code; goto abort_exit; } while (0);
352
353 while (nblocks--) {
354 diskBlockAddr = ntohl(diskBlock.h.next)(__builtin_constant_p(diskBlock.h.next) ? ((((__uint32_t)(diskBlock
.h.next)) >> 24) | ((((__uint32_t)(diskBlock.h.next)) &
(0xff << 16)) >> 8) | ((((__uint32_t)(diskBlock.
h.next)) & (0xff << 8)) << 8) | (((__uint32_t
)(diskBlock.h.next)) << 24)) : __bswap32_var(diskBlock.
h.next));
355 code =
356 dbread(ut, diskBlockAddr, (char *)&diskBlock,
357 sizeof(diskBlock));
358 if (code)
359 ABORT(code)do { code = code; goto abort_exit; } while (0);
360 }
361 }
362
363 /* diskBlock and diskBlockAddr now point to the last block in the chain */
364
365 while (textLength) {
366 /* compute the transfer size */
367 remainingInBlock = (BLOCK_DATA_SIZE(2048 -sizeof(struct blockHeader)) - (offset % BLOCK_DATA_SIZE(2048 -sizeof(struct blockHeader))));
368 chunkSize = MIN(remainingInBlock, textLength)(((remainingInBlock)<(textLength))?(remainingInBlock):(textLength
));
369
370 /* copy in the data */
371 memcpy(&diskBlock.a[offset % BLOCK_DATA_SIZE(2048 -sizeof(struct blockHeader))], textptr, chunkSize);
372
373 /* LogDebug(5, "text is %s\n", textptr); */
374
375 textLength -= chunkSize;
376 textptr += chunkSize;
377 offset += chunkSize;
378 tbPtr->newsize = htonl(ntohl(tbPtr->newsize) + chunkSize)(__builtin_constant_p((__builtin_constant_p(tbPtr->newsize
) ? ((((__uint32_t)(tbPtr->newsize)) >> 24) | ((((__uint32_t
)(tbPtr->newsize)) & (0xff << 16)) >> 8) |
((((__uint32_t)(tbPtr->newsize)) & (0xff << 8))
<< 8) | (((__uint32_t)(tbPtr->newsize)) << 24
)) : __bswap32_var(tbPtr->newsize)) + chunkSize) ? ((((__uint32_t
)((__builtin_constant_p(tbPtr->newsize) ? ((((__uint32_t)(
tbPtr->newsize)) >> 24) | ((((__uint32_t)(tbPtr->
newsize)) & (0xff << 16)) >> 8) | ((((__uint32_t
)(tbPtr->newsize)) & (0xff << 8)) << 8) | (
((__uint32_t)(tbPtr->newsize)) << 24)) : __bswap32_var
(tbPtr->newsize)) + chunkSize)) >> 24) | ((((__uint32_t
)((__builtin_constant_p(tbPtr->newsize) ? ((((__uint32_t)(
tbPtr->newsize)) >> 24) | ((((__uint32_t)(tbPtr->
newsize)) & (0xff << 16)) >> 8) | ((((__uint32_t
)(tbPtr->newsize)) & (0xff << 8)) << 8) | (
((__uint32_t)(tbPtr->newsize)) << 24)) : __bswap32_var
(tbPtr->newsize)) + chunkSize)) & (0xff << 16)) >>
8) | ((((__uint32_t)((__builtin_constant_p(tbPtr->newsize
) ? ((((__uint32_t)(tbPtr->newsize)) >> 24) | ((((__uint32_t
)(tbPtr->newsize)) & (0xff << 16)) >> 8) |
((((__uint32_t)(tbPtr->newsize)) & (0xff << 8))
<< 8) | (((__uint32_t)(tbPtr->newsize)) << 24
)) : __bswap32_var(tbPtr->newsize)) + chunkSize)) & (0xff
<< 8)) << 8) | (((__uint32_t)((__builtin_constant_p
(tbPtr->newsize) ? ((((__uint32_t)(tbPtr->newsize)) >>
24) | ((((__uint32_t)(tbPtr->newsize)) & (0xff <<
16)) >> 8) | ((((__uint32_t)(tbPtr->newsize)) &
(0xff << 8)) << 8) | (((__uint32_t)(tbPtr->newsize
)) << 24)) : __bswap32_var(tbPtr->newsize)) + chunkSize
)) << 24)) : __bswap32_var((__builtin_constant_p(tbPtr->
newsize) ? ((((__uint32_t)(tbPtr->newsize)) >> 24) |
((((__uint32_t)(tbPtr->newsize)) & (0xff << 16)
) >> 8) | ((((__uint32_t)(tbPtr->newsize)) & (0xff
<< 8)) << 8) | (((__uint32_t)(tbPtr->newsize)
) << 24)) : __bswap32_var(tbPtr->newsize)) + chunkSize
));
379
380 if (textLength > 0) {
381 afs_int32 prevBlockAddr;
382 afs_int32 linkOffset;
383 afs_int32 linkValue;
384
385 /* have to add another block to the chain */
386
387 code =
388 dbwrite(ut, diskBlockAddr, (char *)&diskBlock,
389 sizeof(diskBlock));
390 if (code)
391 ABORT(code)do { code = code; goto abort_exit; } while (0);
392
393 prevBlockAddr = (afs_int32) diskBlockAddr;
394 code = AllocBlock(ut, &diskBlock, &diskBlockAddr);
395 if (code)
396 ABORT(code)do { code = code; goto abort_exit; } while (0);
397
398 LogDebug(5, "allocated block %d\n", diskBlockAddr);
399
400 /* set block type */
401 diskBlock.h.type = text_BLOCK6;
402
403 /* now have to update the previous block's link */
404 linkOffset =
405 (afs_int32) ((char*)& diskBlock.h.next - (char*)& diskBlock);
406 linkValue = htonl(diskBlockAddr)(__builtin_constant_p(diskBlockAddr) ? ((((__uint32_t)(diskBlockAddr
)) >> 24) | ((((__uint32_t)(diskBlockAddr)) & (0xff
<< 16)) >> 8) | ((((__uint32_t)(diskBlockAddr)) &
(0xff << 8)) << 8) | (((__uint32_t)(diskBlockAddr
)) << 24)) : __bswap32_var(diskBlockAddr));
407
408 code =
409 dbwrite(ut, (afs_int32) prevBlockAddr + linkOffset,
410 (char *)&linkValue, sizeof(afs_int32));
411 if (code)
412 ABORT(code)do { code = code; goto abort_exit; } while (0);
413 } else {
414 /* just write the old block */
415 code =
416 dbwrite(ut, diskBlockAddr, (char *)&diskBlock,
417 sizeof(diskBlock));
418 if (code)
419 ABORT(code)do { code = code; goto abort_exit; } while (0);
420 }
421 }
422
423 if (flags & BUDB_TEXT_COMPLETE1) { /* done */
424 /* this was the last chunk of text */
425 diskBlockAddr = ntohl(tbPtr->textAddr)(__builtin_constant_p(tbPtr->textAddr) ? ((((__uint32_t)(tbPtr
->textAddr)) >> 24) | ((((__uint32_t)(tbPtr->textAddr
)) & (0xff << 16)) >> 8) | ((((__uint32_t)(tbPtr
->textAddr)) & (0xff << 8)) << 8) | (((__uint32_t
)(tbPtr->textAddr)) << 24)) : __bswap32_var(tbPtr->
textAddr));
426 freeOldBlockChain(ut, diskBlockAddr);
427
428 tbPtr->textAddr = tbPtr->newTextAddr;
429 tbPtr->newTextAddr = 0;
430 tbPtr->size = tbPtr->newsize;
431 tbPtr->newsize = 0;
432 tbPtr->version = htonl(ntohl(tbPtr->version) + 1)(__builtin_constant_p((__builtin_constant_p(tbPtr->version
) ? ((((__uint32_t)(tbPtr->version)) >> 24) | ((((__uint32_t
)(tbPtr->version)) & (0xff << 16)) >> 8) |
((((__uint32_t)(tbPtr->version)) & (0xff << 8))
<< 8) | (((__uint32_t)(tbPtr->version)) << 24
)) : __bswap32_var(tbPtr->version)) + 1) ? ((((__uint32_t)
((__builtin_constant_p(tbPtr->version) ? ((((__uint32_t)(tbPtr
->version)) >> 24) | ((((__uint32_t)(tbPtr->version
)) & (0xff << 16)) >> 8) | ((((__uint32_t)(tbPtr
->version)) & (0xff << 8)) << 8) | (((__uint32_t
)(tbPtr->version)) << 24)) : __bswap32_var(tbPtr->
version)) + 1)) >> 24) | ((((__uint32_t)((__builtin_constant_p
(tbPtr->version) ? ((((__uint32_t)(tbPtr->version)) >>
24) | ((((__uint32_t)(tbPtr->version)) & (0xff <<
16)) >> 8) | ((((__uint32_t)(tbPtr->version)) &
(0xff << 8)) << 8) | (((__uint32_t)(tbPtr->version
)) << 24)) : __bswap32_var(tbPtr->version)) + 1)) &
(0xff << 16)) >> 8) | ((((__uint32_t)((__builtin_constant_p
(tbPtr->version) ? ((((__uint32_t)(tbPtr->version)) >>
24) | ((((__uint32_t)(tbPtr->version)) & (0xff <<
16)) >> 8) | ((((__uint32_t)(tbPtr->version)) &
(0xff << 8)) << 8) | (((__uint32_t)(tbPtr->version
)) << 24)) : __bswap32_var(tbPtr->version)) + 1)) &
(0xff << 8)) << 8) | (((__uint32_t)((__builtin_constant_p
(tbPtr->version) ? ((((__uint32_t)(tbPtr->version)) >>
24) | ((((__uint32_t)(tbPtr->version)) & (0xff <<
16)) >> 8) | ((((__uint32_t)(tbPtr->version)) &
(0xff << 8)) << 8) | (((__uint32_t)(tbPtr->version
)) << 24)) : __bswap32_var(tbPtr->version)) + 1)) <<
24)) : __bswap32_var((__builtin_constant_p(tbPtr->version
) ? ((((__uint32_t)(tbPtr->version)) >> 24) | ((((__uint32_t
)(tbPtr->version)) & (0xff << 16)) >> 8) |
((((__uint32_t)(tbPtr->version)) & (0xff << 8))
<< 8) | (((__uint32_t)(tbPtr->version)) << 24
)) : __bswap32_var(tbPtr->version)) + 1));
433
434 /* saveTextToFile(ut, tbPtr); */
435 }
436
437 /* update size and other text header info */
438 code =
439 dbwrite(ut, (char *)tbPtr - (char *)&db.h, (char *)tbPtr,
440 sizeof(struct textBlock));
441 if (code)
442 ABORT(code)do { code = code; goto abort_exit; } while (0);
443
444/*error_exit: */
445 code = ubik_EndTrans(ut);
446 return (code);
447
448 abort_exit:
449 ubik_AbortTrans(ut);
450 return (code);
451}
452
453/* debug support */
454void
455saveTextToFile(struct ubik_trans *ut, struct textBlock *tbPtr)
456{
457 afs_int32 blockAddr;
458 struct block block;
459 char filename[128];
460 afs_int32 size, chunkSize;
461 int fid;
462
463 sprintf(filename, "%s/%s", gettmpdir(), "dbg_XXXXXX");
464
465 fid = mkstemp(filename);
466 size = ntohl(tbPtr->size)(__builtin_constant_p(tbPtr->size) ? ((((__uint32_t)(tbPtr
->size)) >> 24) | ((((__uint32_t)(tbPtr->size)) &
(0xff << 16)) >> 8) | ((((__uint32_t)(tbPtr->
size)) & (0xff << 8)) << 8) | (((__uint32_t)(
tbPtr->size)) << 24)) : __bswap32_var(tbPtr->size
));
467 blockAddr = ntohl(tbPtr->textAddr)(__builtin_constant_p(tbPtr->textAddr) ? ((((__uint32_t)(tbPtr
->textAddr)) >> 24) | ((((__uint32_t)(tbPtr->textAddr
)) & (0xff << 16)) >> 8) | ((((__uint32_t)(tbPtr
->textAddr)) & (0xff << 8)) << 8) | (((__uint32_t
)(tbPtr->textAddr)) << 24)) : __bswap32_var(tbPtr->
textAddr));
468 while (size) {
469 chunkSize = MIN(BLOCK_DATA_SIZE, size)((((2048 -sizeof(struct blockHeader)))<(size))?((2048 -sizeof
(struct blockHeader))):(size));
470 dbread(ut, blockAddr, (char *)&block, sizeof(block));
471 write(fid, &block.a[0], chunkSize);
472 blockAddr = ntohl(block.h.next)(__builtin_constant_p(block.h.next) ? ((((__uint32_t)(block.h
.next)) >> 24) | ((((__uint32_t)(block.h.next)) & (
0xff << 16)) >> 8) | ((((__uint32_t)(block.h.next
)) & (0xff << 8)) << 8) | (((__uint32_t)(block
.h.next)) << 24)) : __bswap32_var(block.h.next));
473 size -= chunkSize;
474 }
475 close(fid);
476 printf("wrote debug file %s\n", filename);
477}
478