61 lines
1.9 KiB
C
61 lines
1.9 KiB
C
#include <string.h>
|
|
#include <stasis/transactional.h>
|
|
#include "page/raw.h"
|
|
#include <assert.h>
|
|
|
|
|
|
void allocBlob(int xid, recordid rid) {
|
|
assert(rid.size>0);
|
|
int pageCount = (rid.size / USABLE_SIZE_OF_PAGE) + ((rid.size % USABLE_SIZE_OF_PAGE) ? 1 : 0);
|
|
long startPage = TpageAllocMany(xid, pageCount);
|
|
blob_record_t rec;
|
|
rec.offset = startPage;
|
|
rec.size = rid.size;
|
|
recordid rid2 = rid;
|
|
rid2.size = BLOB_SLOT;
|
|
Tset(xid, rid2, &rec);
|
|
// printf("Page start = %d, count = %d, rid.size=%d\n", rec.offset, pageCount, rid.size);
|
|
// printf("rid = {%d %d %d}\n", rid.page, rid.slot, rid.size);
|
|
}
|
|
|
|
void readBlob(int xid, Page * p2, recordid rid, byte * buf) {
|
|
int chunk;
|
|
recordid rawRid = rid;
|
|
rawRid.size = BLOB_SLOT;
|
|
byte * pbuf = alloca(PAGE_SIZE);
|
|
blob_record_t rec;
|
|
recordRead(xid, p2, rawRid, (byte*)&rec);
|
|
|
|
for(chunk = 0; (chunk+1) * USABLE_SIZE_OF_PAGE < rid.size; chunk++) {
|
|
TpageGet(xid, rec.offset+chunk, pbuf);
|
|
memcpy(buf + (chunk * USABLE_SIZE_OF_PAGE), pbuf, USABLE_SIZE_OF_PAGE);
|
|
}
|
|
|
|
TpageGet(xid, rec.offset+chunk, pbuf);
|
|
memcpy(buf + (chunk * USABLE_SIZE_OF_PAGE), pbuf, rid.size % USABLE_SIZE_OF_PAGE);
|
|
// printf("Chunk = %d\n", chunk);
|
|
|
|
}
|
|
|
|
void writeBlob(int xid, Page * p2, lsn_t lsn, recordid rid, const byte * buf) {
|
|
int chunk;
|
|
recordid rawRid = rid;
|
|
rawRid.size = BLOB_SLOT;
|
|
byte * pbuf = alloca(PAGE_SIZE);
|
|
blob_record_t rec;
|
|
recordRead(xid, p2, rawRid, (byte*)&rec);
|
|
|
|
assert(rec.offset);
|
|
|
|
for(chunk = 0; (chunk+1) * USABLE_SIZE_OF_PAGE < rid.size; chunk++) {
|
|
TpageGet(xid, rec.offset+chunk, pbuf);
|
|
memcpy(pbuf, buf + (chunk * USABLE_SIZE_OF_PAGE), USABLE_SIZE_OF_PAGE);
|
|
TpageSet(xid, rec.offset+chunk, pbuf);
|
|
}
|
|
TpageGet(xid, rec.offset+chunk, pbuf);
|
|
memcpy(pbuf, buf + (chunk * USABLE_SIZE_OF_PAGE), rid.size % USABLE_SIZE_OF_PAGE);
|
|
TpageSet(xid, rec.offset+chunk, pbuf);
|
|
// printf("Write Chunk = %d (%d)\n", chunk, rec.offset+chunk);
|
|
|
|
|
|
}
|