forked from joyieldInc/predixy
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathResponseParser.h
86 lines (81 loc) · 1.51 KB
/
ResponseParser.h
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
/*
* predixy - A high performance and full features proxy for redis.
* Copyright (C) 2017 Joyield, Inc. <[email protected]>
* All rights reserved.
*/
#ifndef _PREDIXY_RESPONSE_PARSER_H_
#define _PREDIXY_RESPONSE_PARSER_H_
#include "Predixy.h"
class ResponseParser
{
public:
static const int MaxArrayDepth = 8;
enum State
{
Idle,
StatusHead,
ErrorHead,
IntegerHead,
StringHead,
ArrayHead,
HeadLF,
ArrayBody,
StringLen,
StringBody,
StringBodyLF,
LineBody,
SubStringLen,
SubStringLenLF,
SubStringBody,
SubStringBodyLF,
SubArrayLen,
SubArrayLenLF,
ElementLF,
Finished,
Error
};
enum Status
{
Normal,
Partial,
Complete,
ParseError
};
public:
ResponseParser();
~ResponseParser();
void reset();
Status parse(Buffer* buf, int& pos);
bool isIdle() const
{
return mState == Idle;
}
Reply::Type type() const
{
return mType;
}
Segment& response()
{
return mRes;
}
const Segment& response() const
{
return mRes;
}
int64_t integer() const
{
return mInteger;
}
private:
Reply::Type mType;
Segment mRes;
State mState;
int64_t mInteger;
int mStringLen;
int mStringCnt;
int mArrayNum[MaxArrayDepth];
int mElementCnt[MaxArrayDepth];
int mDepth;
bool mSign;
};
#endif