blob: 10c276419608edb09d8e0e060e5f96c5abe1916d [file] [log] [blame]
Tom Joseph3e61aa02016-08-08 08:42:39 -05001#include "sessions_manager.hpp"
2
Vernon Mauery9e801a22018-10-12 13:20:49 -07003#include "session.hpp"
4
Tom Joseph3e61aa02016-08-08 08:42:39 -05005#include <algorithm>
6#include <cstdlib>
7#include <iomanip>
8#include <iostream>
9#include <memory>
10
Tom Joseph3e61aa02016-08-08 08:42:39 -050011namespace 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
Vernon Mauery9e801a22018-10-12 13:20:49 -070027std::weak_ptr<Session>
28 Manager::startSession(SessionID remoteConsoleSessID, Privilege priv,
29 cipher::rakp_auth::Algorithms authAlgo,
30 cipher::integrity::Algorithms intAlgo,
31 cipher::crypt::Algorithms cryptAlgo)
Tom Joseph3e61aa02016-08-08 08:42:39 -050032{
33 std::shared_ptr<Session> session = nullptr;
34 SessionID sessionID = 0;
35 cleanStaleEntries();
36 auto activeSessions = sessionsMap.size() - MAX_SESSIONLESS_COUNT;
37
38 if (activeSessions < MAX_SESSION_COUNT)
39 {
40 do
41 {
42 session = std::make_shared<Session>(remoteConsoleSessID, priv);
43
44 /*
45 * Every IPMI Session has two ID's attached to it Remote Console
46 * Session ID and BMC Session ID. The remote console ID is passed
47 * along with the Open Session request command. The BMC session ID
48 * is the key for the session map and is generated using std::rand.
49 * There is a rare chance for collision of BMC session ID, so the
50 * following check validates that. In the case of collision the
Gunnar Mills62ec6222018-04-08 16:28:23 -050051 * created session is reset and a new session is created for
Tom Joseph3e61aa02016-08-08 08:42:39 -050052 * validating collision.
53 */
54 auto iterator = sessionsMap.find(session->getBMCSessionID());
55 if (iterator != sessionsMap.end())
56 {
Vernon Mauery9e801a22018-10-12 13:20:49 -070057 // Detected BMC Session ID collisions
Tom Joseph3e61aa02016-08-08 08:42:39 -050058 session.reset();
59 continue;
60 }
61 else
62 {
63 break;
64 }
Vernon Mauery9e801a22018-10-12 13:20:49 -070065 } while (1);
Tom Joseph3e61aa02016-08-08 08:42:39 -050066
Vernon Mauery9b307be2017-11-22 09:28:16 -080067 // Set the Authentication Algorithm
Tom Joseph3e61aa02016-08-08 08:42:39 -050068 switch (authAlgo)
69 {
70 case cipher::rakp_auth::Algorithms::RAKP_HMAC_SHA1:
71 {
72 session->setAuthAlgo(
Vernon Mauery9e801a22018-10-12 13:20:49 -070073 std::make_unique<cipher::rakp_auth::AlgoSHA1>(intAlgo,
74 cryptAlgo));
Tom Joseph3e61aa02016-08-08 08:42:39 -050075 break;
76 }
Vernon Mauery7e9e2ef2017-11-29 08:36:29 -080077 case cipher::rakp_auth::Algorithms::RAKP_HMAC_SHA256:
78 {
79 session->setAuthAlgo(
Vernon Mauery9e801a22018-10-12 13:20:49 -070080 std::make_unique<cipher::rakp_auth::AlgoSHA256>(intAlgo,
81 cryptAlgo));
Vernon Mauery7e9e2ef2017-11-29 08:36:29 -080082 break;
83 }
Tom Joseph3e61aa02016-08-08 08:42:39 -050084 default:
85 {
86 throw std::runtime_error("Invalid Authentication Algorithm");
87 }
88 }
89 sessionID = session->getBMCSessionID();
90 sessionsMap.emplace(sessionID, std::move(session));
91 }
92 else
93 {
Vernon Mauery9e801a22018-10-12 13:20:49 -070094 std::cerr << "E> No free sessions left: Active: " << activeSessions
95 << " Allowed: " << MAX_SESSION_COUNT << "\n";
Tom Joseph3e61aa02016-08-08 08:42:39 -050096
97 for (const auto& iterator : sessionsMap)
98 {
99 std::cerr << "E> Active Session: 0x" << std::hex
100 << std::setfill('0') << std::setw(8)
101 << (iterator.second)->getBMCSessionID() << "\n";
102 }
103 throw std::runtime_error("No free sessions left");
104 }
105
106 return getSession(sessionID);
107}
108
Tom Joseph9662c3a2016-12-06 17:52:16 +0530109bool Manager::stopSession(SessionID bmcSessionID)
Tom Joseph3e61aa02016-08-08 08:42:39 -0500110{
Tom Joseph9662c3a2016-12-06 17:52:16 +0530111 auto iter = sessionsMap.find(bmcSessionID);
112 if (iter != sessionsMap.end())
Tom Joseph3e61aa02016-08-08 08:42:39 -0500113 {
Tom Joseph9662c3a2016-12-06 17:52:16 +0530114 iter->second->state = State::TEAR_DOWN_IN_PROGRESS;
115 return true;
116 }
117 else
118 {
119 return false;
Tom Joseph3e61aa02016-08-08 08:42:39 -0500120 }
121}
122
123std::weak_ptr<Session> Manager::getSession(SessionID sessionID,
124 RetrieveOption option)
125{
126 switch (option)
127 {
128 case RetrieveOption::BMC_SESSION_ID:
129 {
130 auto iter = sessionsMap.find(sessionID);
131 if (iter != sessionsMap.end())
132 {
133 return iter->second;
134 }
Tom Joseph6516cef2017-07-31 18:48:34 +0530135 break;
Tom Joseph3e61aa02016-08-08 08:42:39 -0500136 }
137 case RetrieveOption::RC_SESSION_ID:
138 {
Vernon Mauery9e801a22018-10-12 13:20:49 -0700139 auto iter = std::find_if(
140 sessionsMap.begin(), sessionsMap.end(),
141 [sessionID](
142 const std::pair<const uint32_t, std::shared_ptr<Session>>&
143 in) -> bool {
144 return sessionID == in.second->getRCSessionID();
145 });
Tom Joseph3e61aa02016-08-08 08:42:39 -0500146
147 if (iter != sessionsMap.end())
148 {
149 return iter->second;
150 }
Tom Joseph6516cef2017-07-31 18:48:34 +0530151 break;
Tom Joseph3e61aa02016-08-08 08:42:39 -0500152 }
153 default:
154 throw std::runtime_error("Invalid retrieval option");
155 }
156
157 throw std::runtime_error("Session ID not found");
158}
159
160void Manager::cleanStaleEntries()
161{
Vernon Mauery9e801a22018-10-12 13:20:49 -0700162 for (auto iter = sessionsMap.begin(); iter != sessionsMap.end();)
Tom Joseph3e61aa02016-08-08 08:42:39 -0500163 {
164 auto session = iter->second;
165 if ((session->getBMCSessionID() != SESSION_ZERO) &&
166 !(session->isSessionActive()))
167 {
168 iter = sessionsMap.erase(iter);
169 }
170 else
171 {
172 ++iter;
173 }
174 }
175}
176
177} // namespace session