blob: 18c96bae6982cdd55f5b83f06c938a9d055da35d [file] [log] [blame]
Tom Joseph3e61aa02016-08-08 08:42:39 -05001#include "sessions_manager.hpp"
2
3#include <algorithm>
4#include <cstdlib>
5#include <iomanip>
6#include <iostream>
7#include <memory>
8
9#include "session.hpp"
10
11namespace session
12{
13
14Manager::Manager()
15{
16 /*
17 * Session ID is 0000_0000h for messages that are sent outside the session.
18 * The session setup commands are sent on this session, so when the session
19 * manager comes up, is creates the Session ID 0000_0000h. It is active
20 * through the lifetime of the Session Manager.
21 */
22 sessionsMap.emplace(0, std::make_shared<Session>());
23 // Seeding the pseudo-random generator
24 std::srand(std::time(0));
25}
26
27std::weak_ptr<Session> Manager::startSession(SessionID remoteConsoleSessID,
Tom Josephdd1be1a2017-01-10 16:10:29 +053028 Privilege priv, cipher::rakp_auth::Algorithms authAlgo,
Tom Josephba11f792017-01-24 18:21:45 +053029 cipher::integrity::Algorithms intAlgo,
30 cipher::crypt::Algorithms cryptAlgo)
Tom Joseph3e61aa02016-08-08 08:42:39 -050031{
32 std::shared_ptr<Session> session = nullptr;
33 SessionID sessionID = 0;
34 cleanStaleEntries();
35 auto activeSessions = sessionsMap.size() - MAX_SESSIONLESS_COUNT;
36
37 if (activeSessions < MAX_SESSION_COUNT)
38 {
39 do
40 {
41 session = std::make_shared<Session>(remoteConsoleSessID, priv);
42
43 /*
44 * Every IPMI Session has two ID's attached to it Remote Console
45 * Session ID and BMC Session ID. The remote console ID is passed
46 * along with the Open Session request command. The BMC session ID
47 * is the key for the session map and is generated using std::rand.
48 * There is a rare chance for collision of BMC session ID, so the
49 * following check validates that. In the case of collision the
50 * created session is reseted and a new session is created for
51 * validating collision.
52 */
53 auto iterator = sessionsMap.find(session->getBMCSessionID());
54 if (iterator != sessionsMap.end())
55 {
56 //Detected BMC Session ID collisions
57 session.reset();
58 continue;
59 }
60 else
61 {
62 break;
63 }
64 }
65 while (1);
66
67 // Set the Authentication Algorithm to RAKP_HMAC_SHA1
68 switch (authAlgo)
69 {
70 case cipher::rakp_auth::Algorithms::RAKP_HMAC_SHA1:
71 {
72 session->setAuthAlgo(
Tom Josephba11f792017-01-24 18:21:45 +053073 std::make_unique<cipher::rakp_auth::AlgoSHA1>(intAlgo,
74 cryptAlgo));
Tom Joseph3e61aa02016-08-08 08:42:39 -050075 break;
76 }
77 default:
78 {
79 throw std::runtime_error("Invalid Authentication Algorithm");
80 }
81 }
82 sessionID = session->getBMCSessionID();
83 sessionsMap.emplace(sessionID, std::move(session));
84 }
85 else
86 {
87 std::cerr << "E> No free sessions left: Active: " << activeSessions <<
88 " Allowed: " <<
89 MAX_SESSION_COUNT << "\n";
90
91 for (const auto& iterator : sessionsMap)
92 {
93 std::cerr << "E> Active Session: 0x" << std::hex
94 << std::setfill('0') << std::setw(8)
95 << (iterator.second)->getBMCSessionID() << "\n";
96 }
97 throw std::runtime_error("No free sessions left");
98 }
99
100 return getSession(sessionID);
101}
102
Tom Joseph9662c3a2016-12-06 17:52:16 +0530103bool Manager::stopSession(SessionID bmcSessionID)
Tom Joseph3e61aa02016-08-08 08:42:39 -0500104{
Tom Joseph9662c3a2016-12-06 17:52:16 +0530105 auto iter = sessionsMap.find(bmcSessionID);
106 if (iter != sessionsMap.end())
Tom Joseph3e61aa02016-08-08 08:42:39 -0500107 {
Tom Joseph9662c3a2016-12-06 17:52:16 +0530108 iter->second->state = State::TEAR_DOWN_IN_PROGRESS;
109 return true;
110 }
111 else
112 {
113 return false;
Tom Joseph3e61aa02016-08-08 08:42:39 -0500114 }
115}
116
117std::weak_ptr<Session> Manager::getSession(SessionID sessionID,
118 RetrieveOption option)
119{
120 switch (option)
121 {
122 case RetrieveOption::BMC_SESSION_ID:
123 {
124 auto iter = sessionsMap.find(sessionID);
125 if (iter != sessionsMap.end())
126 {
127 return iter->second;
128 }
129 }
130 case RetrieveOption::RC_SESSION_ID:
131 {
132 auto iter = std::find_if(sessionsMap.begin(),
133 sessionsMap.end(),
134 [sessionID](const std::pair<const uint32_t,
135 std::shared_ptr<Session>>& in)
136 -> bool
137 {
138 return sessionID == in.second->getRCSessionID();
139 });
140
141 if (iter != sessionsMap.end())
142 {
143 return iter->second;
144 }
145 }
146 default:
147 throw std::runtime_error("Invalid retrieval option");
148 }
149
150 throw std::runtime_error("Session ID not found");
151}
152
153void Manager::cleanStaleEntries()
154{
155 for(auto iter = sessionsMap.begin(); iter != sessionsMap.end();)
156 {
157 auto session = iter->second;
158 if ((session->getBMCSessionID() != SESSION_ZERO) &&
159 !(session->isSessionActive()))
160 {
161 iter = sessionsMap.erase(iter);
162 }
163 else
164 {
165 ++iter;
166 }
167 }
168}
169
170} // namespace session