RepCRec_Distributed_Database_Simulation/operation.cpp at main · joleson15/RepCRec_Distributed_Database_Simulation · GitHub

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
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
#include <iostream>
#include <fstream>
#include <string>
#include <list>

#include "operation.hpp"

void Operation::opREAD(std::string &line)
{
    int transactionID = 0;
    int variableID = 0;
    type = OP::READ;

    int idx = line.find('T');
    while (isdigit(line[++idx]))
    {
        transactionID = transactionID * 10 + (line[idx] - '0');
    }
    tID = transactionID;

    idx = line.find('x');
    while (isdigit(line[++idx]))
    {
        variableID = variableID * 10 + (line[idx] - '0');
    }
    varID = variableID;
}

void Operation::opWRITE(std::string &line)
{

    int transactionID = 0;
    int variableID = 0;
    int value = 0;
    type = OP::WRITE;

    int idx = line.find('T');
    while (isdigit(line[++idx]))
    {
        transactionID = transactionID * 10 + (line[idx] - '0');
    }
    tID = transactionID;

    idx = line.find('x');
    while (isdigit(line[++idx]))
    {
        variableID = variableID * 10 + (line[idx] - '0');
    }
    varID = variableID;

    if(line[++idx] != ' ')
    {
        --idx;
    }

    while (isdigit(line[++idx]))
    {
        value = value * 10 + (line[idx] - '0');
    }
    val = value;
}

void Operation::opBEGIN(std::string &line)
{

    int transactionID = 0;
    type = OP::BEGIN;

    int idx = line.find('T');
    while (isdigit(line[++idx]))
    {
        transactionID = transactionID * 10 + (line[idx] - '0');
    }
    tID = transactionID;
}

void Operation::opEND(std::string &line)
{

    int transactionID = 0;
    type = OP::END;

    int idx = line.find('T');
    while (isdigit(line[++idx]))
    {
        transactionID = transactionID * 10 + (line[idx] - '0');
    }
    tID = transactionID;
}

void Operation::opFAIL(std::string &line)
{

    int siteNum = 0;
    type = OP::FAIL;

    int idx = line.find('(');
    while (isdigit(line[++idx]))
    {
        siteNum = siteNum * 10 + (line[idx] - '0');
    }
    site = siteNum;
}

void Operation::opRECOVER(std::string &line)
{

    int siteNum = 0;
    type = OP::RECOVER;

    int idx = line.find('(');
    while (isdigit(line[++idx]))
    {
        siteNum = siteNum * 10 + (line[idx] - '0');
    }
    site = siteNum;
}

void Operation::opDUMP(std::string &line)
{
    type = OP::DUMP;
}