mirror of
https://github.com/MariaDB/server.git
synced 2025-01-22 23:04:20 +01:00
110754f57c
Current tests fail (not regressions, they fail as of 13461)
* {{{x1.tdbrun}}}
* {{{test_log(2,3,4,5,6,7,8,9,10).recover}}}
* {{{test-recover(1,2,3).tdbrun}}}
* {{{test1324.tdbrun}}}
ULE_DEBUG disabled (defined to 0) Can be re-enabled for test purposes (set to 1).
refs [t:1125]
Merging into the temp branch (tokudb.main_13461+1125)
{{{svn merge --accept=postpone -r 12527:13461 ../tokudb.1125 ./}}}
Merging into main
{{{svn merge --accept=postpone -r13462:13463 ../tokudb.main_13461+1125/ ./}}}
git-svn-id: file:///svn/toku/tokudb@13464 c7de825b-a66e-492c-adef-691d508d4ae1
142 lines
3.8 KiB
C
142 lines
3.8 KiB
C
/* -*- mode: C; c-basic-offset: 4 -*- */
|
|
#ident "Copyright (c) 2007, 2008 Tokutek Inc. All rights reserved."
|
|
|
|
|
|
/* Purpose of this file is to define and handle the fifo_msg, which
|
|
* is the stored format of a brt_msg.
|
|
*
|
|
* Note, when translating from fifo_msg to brt_msg, the brt_msg
|
|
* will be created with a pointer into the xids in the fifo_msg.
|
|
* (The xids will not be embedded in the brt_msg.) This means
|
|
* that a valid xids struct must be embedded in the fifo_msg.
|
|
*
|
|
* NOTE: fifo_msg is stored in memory and on disk in same format.
|
|
* fifo_msg is stored in same byte order both in-memory
|
|
* and on-disk. Accessors are responsible for tranposition
|
|
* to host order.
|
|
*/
|
|
|
|
|
|
#include <string.h>
|
|
|
|
#include <toku_portability.h>
|
|
#include "brttypes.h"
|
|
#include "xids.h"
|
|
#include "xids-internal.h"
|
|
#include "brt_msg.h"
|
|
#include "fifo_msg.h"
|
|
#include <toku_htod.h>
|
|
|
|
|
|
// xids_and_key_and_val field is XIDS_S followed by key
|
|
// followed by value.
|
|
|
|
struct fifo_msg_t {
|
|
u_int32_t keylen;
|
|
u_int32_t vallen;
|
|
u_int8_t type;
|
|
// u_int8_t pad[7]; // force 64-bit alignment if needed ???
|
|
u_int8_t xids_and_key_and_val[]; // undifferentiated bytes
|
|
};
|
|
|
|
|
|
u_int32_t
|
|
fifo_msg_get_keylen(FIFO_MSG fifo_msg) {
|
|
u_int32_t rval = fifo_msg->keylen;
|
|
rval = toku_dtoh32(rval);
|
|
return rval;
|
|
}
|
|
|
|
u_int32_t
|
|
fifo_msg_get_vallen(FIFO_MSG fifo_msg) {
|
|
u_int32_t rval = fifo_msg->vallen;
|
|
rval = toku_dtoh32(rval);
|
|
return rval;
|
|
}
|
|
|
|
XIDS
|
|
fifo_msg_get_xids(FIFO_MSG fifo_msg) {
|
|
XIDS rval = (XIDS) &fifo_msg->xids_and_key_and_val;
|
|
return rval;
|
|
}
|
|
|
|
|
|
static u_int32_t
|
|
fifo_msg_get_xids_size(FIFO_MSG fifo_msg) {
|
|
u_int32_t rval;
|
|
XIDS xids = fifo_msg_get_xids(fifo_msg);
|
|
rval = xids_get_size(xids);
|
|
return rval;
|
|
}
|
|
|
|
|
|
void *
|
|
fifo_msg_get_key(FIFO_MSG fifo_msg) {
|
|
void * rval;
|
|
u_int32_t xidslen = fifo_msg_get_xids_size(fifo_msg);
|
|
rval = (void*)fifo_msg->xids_and_key_and_val + xidslen;
|
|
return rval;
|
|
}
|
|
|
|
void *
|
|
fifo_msg_get_val(FIFO_MSG fifo_msg) {
|
|
void * rval;
|
|
void * key = fifo_msg_get_key(fifo_msg);
|
|
u_int32_t keylen = fifo_msg_get_keylen(fifo_msg);
|
|
rval = key + keylen;
|
|
return rval;
|
|
}
|
|
|
|
brt_msg_type
|
|
fifo_msg_get_type(FIFO_MSG fifo_msg) {
|
|
brt_msg_type rval = fifo_msg->type;
|
|
return rval;
|
|
}
|
|
|
|
|
|
// Finds size of a fifo msg.
|
|
u_int32_t
|
|
fifo_msg_get_size(FIFO_MSG fifo_msg) {
|
|
u_int32_t rval;
|
|
u_int32_t keylen = fifo_msg_get_keylen(fifo_msg);
|
|
u_int32_t vallen = fifo_msg_get_vallen(fifo_msg);
|
|
u_int32_t xidslen = fifo_msg_get_xids_size(fifo_msg);
|
|
rval = keylen + vallen + xidslen + sizeof(*fifo_msg);
|
|
return rval;
|
|
}
|
|
|
|
// Return number of bytes required for a fifo_msg created from
|
|
// the given brt_msg
|
|
u_int32_t
|
|
fifo_msg_get_size_required(BRT_MSG brt_msg) {
|
|
u_int32_t rval;
|
|
u_int32_t keylen = brt_msg_get_keylen(brt_msg);
|
|
u_int32_t vallen = brt_msg_get_vallen(brt_msg);
|
|
XIDS xids = brt_msg_get_xids(brt_msg);
|
|
u_int32_t xidslen = xids_get_size(xids);
|
|
rval = keylen + vallen + xidslen + sizeof(struct fifo_msg_t);
|
|
return rval;
|
|
}
|
|
|
|
void
|
|
fifo_msg_from_brt_msg(FIFO_MSG fifo_msg, BRT_MSG brt_msg) {
|
|
u_int32_t keylen_host = brt_msg_get_keylen(brt_msg);
|
|
u_int32_t vallen_host = brt_msg_get_vallen(brt_msg);
|
|
fifo_msg->type = brt_msg_get_type(brt_msg);
|
|
fifo_msg->keylen = toku_htod32(keylen_host);
|
|
fifo_msg->vallen = toku_htod32(vallen_host);
|
|
//Copy XIDS
|
|
XIDS xids = brt_msg_get_xids(brt_msg);
|
|
XIDS xids_target = fifo_msg_get_xids(fifo_msg);
|
|
u_int32_t xidslen = xids_get_size(xids);
|
|
memcpy(xids_target, xids, xidslen);
|
|
//Copy Key
|
|
void *key = brt_msg_get_key(brt_msg);
|
|
void *key_target = fifo_msg_get_key(fifo_msg);
|
|
memcpy(key_target, key, keylen_host);
|
|
//Copy Val
|
|
void *val = brt_msg_get_val(brt_msg);
|
|
void *val_target = fifo_msg_get_val(fifo_msg);
|
|
memcpy(val_target, val, vallen_host);
|
|
}
|
|
|