Sunbelt Computer Software

PL/B Language Development and Support

treefrog-framework/src/tcachesharedmemorystore.cpp at master · treefrogframework/treefrog-framework · GitHub

Repository navigation

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

#include "tcachesharedmemorystore.h"

#include "tsharedmemorykvs.h"

#include "TWebApplication"

TCacheSharedMemoryStore::TCacheSharedMemoryStore()

{}

TCacheSharedMemoryStore::~TCacheSharedMemoryStore()

{}

void TCacheSharedMemoryStore::init()

{

const QVariantMap &settings = Tf::app()->kvsSettings(Tf::KvsEngine::CacheKvs);

auto databaseName = settings.value("DatabaseName").toString().trimmed();

auto connectOptions = settings.value("ConnectOptions").toString().trimmed();

TSharedMemoryKvs::initialize(databaseName, connectOptions);

}

void TCacheSharedMemoryStore::cleanup()

{

TSharedMemoryKvs kvs(Tf::KvsEngine::CacheKvs);

kvs.cleanup();

}

bool TCacheSharedMemoryStore::set(const QByteArray &key, const QByteArray &value, int seconds)

{

TSharedMemoryKvs kvs(Tf::KvsEngine::CacheKvs);

return kvs.set(key, value, seconds);

}

QByteArray TCacheSharedMemoryStore::get(const QByteArray &key)

{

TSharedMemoryKvs kvs(Tf::KvsEngine::CacheKvs);

return kvs.get(key);

}

bool TCacheSharedMemoryStore::remove(const QByteArray &key)

{

TSharedMemoryKvs kvs(Tf::KvsEngine::CacheKvs);

return kvs.remove(key);

}

void TCacheSharedMemoryStore::clear()

{

TSharedMemoryKvs kvs(Tf::KvsEngine::CacheKvs);

return kvs.clear();

}

void TCacheSharedMemoryStore::gc()

{

TSharedMemoryKvs kvs(Tf::KvsEngine::CacheKvs);

return kvs.gc();

}

QMap<QString, QVariant> TCacheSharedMemoryStore::defaultSettings() const

{

QMap<QString, QVariant> settings {

{"DatabaseName", "tfcache.shm"},

{"ConnectOptions", "MEMORY_SIZE=512M"},

};

return settings;

}