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
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
|
#include <iostream>
#include <string>
#include <sstream>
#include <fstream>
#include <stdexcept>
#include <phosphor-logging/log.hpp>
#include "version.hpp"
#include <phosphor-logging/elog-errors.hpp>
#include "xyz/openbmc_project/Common/error.hpp"
#include "item_updater.hpp"
#include <openssl/sha.h>
namespace openpower
{
namespace software
{
namespace updater
{
using namespace sdbusplus::xyz::openbmc_project::Common::Error;
using namespace phosphor::logging;
using Argument = xyz::openbmc_project::Common::InvalidArgument;
std::string Version::getId(const std::string& version)
{
if (version.empty())
{
log<level::ERR>("Error version is empty");
elog<InvalidArgument>(Argument::ARGUMENT_NAME("Version"),
Argument::ARGUMENT_VALUE(version.c_str()));
}
unsigned char digest[SHA512_DIGEST_LENGTH];
SHA512_CTX ctx;
SHA512_Init(&ctx);
SHA512_Update(&ctx, version.c_str(), strlen(version.c_str()));
SHA512_Final(digest, &ctx);
char mdString[SHA512_DIGEST_LENGTH * 2 + 1];
for (int i = 0; i < SHA512_DIGEST_LENGTH; i++)
{
snprintf(&mdString[i * 2], 3, "%02x", (unsigned int)digest[i]);
}
// Only need 8 hex digits.
std::string hexId = std::string(mdString);
return (hexId.substr(0, 8));
}
std::map<std::string, std::string>
Version::getValue(const std::string& filePath,
std::map<std::string, std::string> keys)
{
if (filePath.empty())
{
log<level::ERR>("Error filePath is empty");
elog<InvalidArgument>(Argument::ARGUMENT_NAME("FilePath"),
Argument::ARGUMENT_VALUE(filePath.c_str()));
}
std::ifstream efile;
std::string line;
efile.exceptions(std::ifstream::failbit | std::ifstream::badbit |
std::ifstream::eofbit);
try
{
efile.open(filePath);
while (getline(efile, line))
{
for (auto& key : keys)
{
auto value = key.first + "=";
auto keySize = value.length();
if (line.compare(0, keySize, value) == 0)
{
key.second = line.substr(keySize);
break;
}
}
}
efile.close();
}
catch (const std::exception& e)
{
if (!efile.eof())
{
log<level::ERR>("Error in reading file");
}
efile.close();
}
return keys;
}
void Delete::delete_()
{
if (parent.eraseCallback)
{
parent.eraseCallback(parent.getId(parent.version()));
}
}
void Version::updateDeleteInterface(sdbusplus::message::message& msg)
{
std::string interface, chassisState;
std::map<std::string, sdbusplus::message::variant<std::string>> properties;
msg.read(interface, properties);
for (const auto& p : properties)
{
if (p.first == "CurrentPowerState")
{
chassisState = p.second.get<std::string>();
}
}
if ((parent.isVersionFunctional(this->versionId)) &&
(chassisState != CHASSIS_STATE_OFF))
{
if (deleteObject)
{
deleteObject.reset(nullptr);
}
}
else
{
if (!deleteObject)
{
deleteObject = std::make_unique<Delete>(bus, objPath, *this);
}
}
}
} // namespace updater
} // namespace software
} // namespace openpower
|
