queue/queue.cpp at master · oceanwavewyt/queue · GitHub

Repository navigation

History

115 lines (97 loc) · 2.84 KB

Raw

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

#include "format.h"

#include "file_env.h"

#include "reader.h"

#include "writer.h"

#include "mem_list.h"

#include "include/queue.h"

#include <iostream>

#include <fstream>

using namespace std;

size_t readtest(string &filename, string &r) {

char * buffer;

size_t size;

ifstream file(filename.c_str(), ios::in|ios::binary|ios::ate);

size = file.tellg();

file.seekg (0, ios::beg);

buffer = new char [size];

file.read (buffer, size);

r.assign(buffer, size);

delete []buffer;

file.close();

return size;

}

void TestWrite() {

for(int j=0;j<140;j++) {

char testData2[100]={0};

sprintf(testData2, "%d_共产主义好，生活幸福美满",j);

//sprintf(testData2, "%d_abcde,efghijk",j);

//levelque::MemList::Instance()->WriteRecord(testData2, strlen(testData2));

}

char testData3[15] = "33333333333333";

MemList::Instance()->WriteRecord(testData3, 15);

string dataFilename = "1.jpg";

string imgdata;

size_t len = readtest(dataFilename, imgdata);

MemList::Instance()->WriteRecord(imgdata, len);

ofstream out2("../tmp/444.jpg",ios::binary);

out2<<imgdata;

out2.close();

}

void TestRead(levelque::Files &f, const string &filename) {

levelque::SequentialFile* file;

f.NewSequentialFile(filename, &file);

levelque::Reader reader(file,false,0);

string record;

string scratch;

int i=0;

uint32_t id;

uint32_t blockid;

while((id = reader.ReadRecord(record, scratch, blockid))!=0){

//cout << "read: " << record << endl;

//if(i==2) {

//char name[20];

//sprintf(name, "../tmp/%d.jpg",i);

//ofstream out(name,ios::binary);

//out<<record;

//out.close();

//}else{

//cout << "read: " << record << endl;

//}

//cout <<"id: "<< id << endl;

//cout << record << " read offset: "<< reader.LastRecordEndOffset() << endl;

i++;

}

int main_(int argc, char *args[])

{

levelque::Queue *db;

levelque::Queue::Open("/tmp","abc", &db);

db->CreateQueueName("/tmp", "abc_two");

string data;

char testData2[100]={0};

sprintf(testData2, "%ld_共产主义好，生活幸福美满_1",time(NULL));

db->Write("abc",testData2, strlen(testData2),1);

for(int i=1;i<=1000000; i++) {

sprintf(testData2, "%ld_%d_共产主义好，生活幸福美满_2",time(NULL),i);

db->Write("abc", testData2, strlen(testData2),2);

cout << "abc number: "<< db->Size("abc") << endl;

}

for(int j=1;j<10; j++) {

if(db->Read("abc", data)) {

cout << "max read: " << data << endl;

cout << "abc number: "<< db->Size("abc") << endl;

}

return 1;

sprintf(testData2, "%ld_test_dbtwo_2",time(NULL));

db->Write("abc_two", testData2, strlen(testData2),2);

cout << "abc_two number: "<< db->Size("abc_two") << endl;

if(db->Read("abc_two", data, 2)) {

cout << "read: " << data << endl;

}

return 1;

}

queue/queue.cpp at master · oceanwavewyt/queue · GitHub

Repository navigation

Expand file tree

Breadcrumbs

queue.cpp

Latest commit

History

Breadcrumbs

queue.cpp

File metadata and controls