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
|
//------------------------------------------------------------------------------
// Author: Andrey Kuznetsov
// Description: Composite filtrator which composites both CIFS&NFS
// TODO: THIS CODE MUST BE TOTALLY REFACTORED!
// Copyright (c) 2014 EPAM Systems
//------------------------------------------------------------------------------
/*
This file is part of Nfstrace.
Nfstrace is free software: you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation, version 2 of the License.
Nfstrace is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with Nfstrace. If not, see <http://www.gnu.org/licenses/>.
*/
//------------------------------------------------------------------------------
#ifndef FILTRATORS_H
#define FILTRATORS_H
//------------------------------------------------------------------------------
#include "cifs_filtrator.h"
#include "rpc_filtrator.h"
#include "utils/log.h"
//------------------------------------------------------------------------------
namespace NST
{
namespace filtration
{
/*!
* Composite filtrator which composites both CIFS&NFS
*/
template<typename Writer>
class Filtrators
{
enum class FiltratorTypes
{
DEFAULT = 0,
RPC,
CIFS
};
CIFSFiltrator<Writer> filtratorCIFS;//!< CIFS filtrator
RPCFiltrator<Writer> filtratorRPC;//!< RPC filtrator
FiltratorTypes currentFiltrator;//!< Indicates which filtrator is currently active?
public:
Filtrators() :
currentFiltrator(FiltratorTypes::DEFAULT)
{
}
Filtrators(Filtrators&&) = delete;
Filtrators(const Filtrators&) = delete;
Filtrators& operator=(const Filtrators&) = delete;
/*!
* resets state of filtrator
*/
inline void reset()
{
filtratorCIFS.reset();
filtratorRPC.reset ();
currentFiltrator = FiltratorTypes::DEFAULT;
}
/*!
* Sets queue
* \param session_ptr - TCP session
* \param w - queue, where we are going to write messages
* \param max_rpc_hdr -
*/
inline void set_writer(utils::NetworkSession* session_ptr, Writer* w, uint32_t max_rpc_hdr)
{
assert(w);
filtratorCIFS.set_writer (session_ptr, w, max_rpc_hdr);
filtratorRPC.set_writer (session_ptr, w, max_rpc_hdr);
}
inline void lost(const uint32_t n) // we are lost n bytes in sequence
{
filtratorCIFS.lost (n);
filtratorRPC.lost (n);
}
/*!
* Receives and filtrates next part of TCP-stream
* \param info - data
*/
inline void push(PacketInfo& info)
{
// is it RPC message?
if (currentFiltrator == FiltratorTypes::RPC || filtratorRPC.inProgress(info))
{
currentFiltrator = FiltratorTypes::RPC;
filtratorRPC.push (info);
}
// is it CIFS message?
else if (currentFiltrator == FiltratorTypes::CIFS || filtratorCIFS.inProgress(info))
{
currentFiltrator = FiltratorTypes::CIFS;
filtratorCIFS.push (info);
}
// it is Unknown message
else
{
LOG("Unknown packet");
}
}
};
} // namespace filtration
} // namespace NST
//------------------------------------------------------------------------------
#endif//FILTRATORS_H
//------------------------------------------------------------------------------
|
