Skip to content

Conversation

mykola-kobets-epam
Copy link
Contributor

No description provided.

mlohvynenko and others added 25 commits July 3, 2025 18:48
This patch adds a new identifier pool utility to the common
tools library.

Signed-off-by: Mykhailo Lohvynenko <[email protected]>
Reviewed-by: Mykola Kobets <[email protected]>
Reviewed-by: Mykola Solianko <[email protected]>
Reviewed-by: Oleksandr Grytsov <[email protected]>
This patch adds cloudprotocol state structures.

Signed-off-by: Mykhailo Lohvynenko <[email protected]>
Reviewed-by: Mykola Kobets <[email protected]>
Reviewed-by: Mykola Solianko <[email protected]>
Reviewed-by: Oleksandr Grytsov <[email protected]>
This patch adds storage state interfaces to the cm module.

Signed-off-by: Mykhailo Lohvynenko <[email protected]>
Reviewed-by: Mykola Kobets <[email protected]>
Reviewed-by: Mykola Solianko <[email protected]>
Reviewed-by: Oleksandr Grytsov <[email protected]>
This patch makes it possible to use instance ident
with STL containers that require a less operator.

Signed-off-by: Mykhailo Lohvynenko <[email protected]>
Reviewed-by: Mykola Kobets <[email protected]>
Reviewed-by: Mykola Solianko <[email protected]>
Reviewed-by: Oleksandr Grytsov <[email protected]>
This patch adds support for the SHA3-224 hash algorithm
in the crypto provider.

Signed-off-by: Mykhailo Lohvynenko <[email protected]>
Reviewed-by: Mykola Kobets <[email protected]>
Reviewed-by: Mykola Solianko <[email protected]>
Reviewed-by: Oleksandr Grytsov <[email protected]>
This patch enhances the platform filesystem interface
by adding a method to set user quota.

Signed-off-by: Mykhailo Lohvynenko <[email protected]>
Reviewed-by: Mykola Kobets <[email protected]>
Reviewed-by: Mykola Solianko <[email protected]>
Reviewed-by: Oleksandr Grytsov <[email protected]>
This patch removes the redundant definition of the SHA1 digest
size in the configuration header file.

Signed-off-by: Mykhailo Lohvynenko <[email protected]>
Reviewed-by: Mykola Kobets <[email protected]>
Reviewed-by: Mykola Solianko <[email protected]>
Reviewed-by: Oleksandr Grytsov <[email protected]>
This patch adds a new communication interface to the cm module
with API needed for storage state module.

Signed-off-by: Mykhailo Lohvynenko <[email protected]>
Reviewed-by: Mykola Kobets <[email protected]>
Reviewed-by: Mykola Solianko <[email protected]>
Reviewed-by: Oleksandr Grytsov <[email protected]>
Signed-off-by: Mykola Kobets <[email protected]>
Reviewed-by: Mykhailo Lohvynenko <[email protected]>
Reviewed-by: Oleksandr Grytsov <[email protected]>
Reviewed-by: Mykola Solianko <[email protected]>
Signed-off-by: Mykola Kobets <[email protected]>
Reviewed-by: Mykhailo Lohvynenko <[email protected]>
Reviewed-by: Oleksandr Grytsov <[email protected]>
Reviewed-by: Mykola Solianko <[email protected]>
Signed-off-by: Mykola Kobets <[email protected]>
Reviewed-by: Mykhailo Lohvynenko <[email protected]>
Reviewed-by: Oleksandr Grytsov <[email protected]>
Reviewed-by: Mykola Solianko <[email protected]>
Signed-off-by: Mykola Kobets <[email protected]>
Reviewed-by: Mykhailo Lohvynenko <[email protected]>
Reviewed-by: Oleksandr Grytsov <[email protected]>
Reviewed-by: Mykola Solianko <[email protected]>
Signed-off-by: Mykola Kobets <[email protected]>
Reviewed-by: Mykhailo Lohvynenko <[email protected]>
Reviewed-by: Oleksandr Grytsov <[email protected]>
Reviewed-by: Mykola Solianko <[email protected]>
Signed-off-by: Mykola Kobets <[email protected]>
Reviewed-by: Mykhailo Lohvynenko <[email protected]>
Reviewed-by: Oleksandr Grytsov <[email protected]>
Reviewed-by: Mykola Solianko <[email protected]>
Signed-off-by: Mykola Kobets <[email protected]>
Reviewed-by: Mykhailo Lohvynenko <[email protected]>
Reviewed-by: Oleksandr Grytsov <[email protected]>
Reviewed-by: Mykola Solianko <[email protected]>
Signed-off-by: Mykola Solianko <[email protected]>
Reviewed-by: Mykhailo Lohvynenko <[email protected]>
Reviewed-by: Mykola Kobets <[email protected]>
Reviewed-by: Oleksandr Grytsov <[email protected]>
InstanceIdent-s should be sorted by service,
then subject, then instance ind.

Signed-off-by: Mykola Kobets <[email protected]>
/**
* Max number of allowed connections.
*/
static constexpr auto cMaxNumConnections = AOS_CONFIG_NETWORKMANAGER_CONNECTIONS_PER_INSTANCE_MAX_COUNT;
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I guess we have to rename config options to
AOS_CONFIG_CONNECTIONS_PER_INSTANCE_MAX_COUNT
AOS_CONFIG_CONNECTION_NAME_LEN
accordingly. And create appropriate consts int types.hpp then use these consts for NetworkManager and spec.

@@ -113,6 +113,20 @@ class IdentifierRangePool : public NonCopyable {
return ErrorEnum::eNone;
}

/**
* Clear identifier in pool.
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Clears

* @param value value to check for existence.
* @return bool.
*/
bool Exist(const T& value) const { return Find(value) != end(); }
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Just wrapper around Find and FindIf. Do we need it?

@@ -1586,6 +1586,17 @@ class InstanceStateType {
using InstanceStateEnum = InstanceStateType::Enum;
using InstanceState = EnumStringer<InstanceStateType>;

/**
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

It should be part of cloudprotocol desired status: cloudprotocol.InstanceInfo

/**
* Auxiliary class to accumulate node information.
*/
class NodeHandler {
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Move node hander and related structs to nodehandler.hpp

}

if (auto err = RemoveOutdatedInstances(); !err.IsNone()) {
LOG_ERR() << "Can't remove outdated instances" << Log::Field(err);
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

ditto

void InstanceManager::OnServiceRemoved(const String& serviceID)
{
(void)serviceID;
// TODO: Clarify what to do
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Remove all cached instances that belong to this service, cleanup state/storage.
If there are active instances, error should be returned.

* @param serviceVersion version of the service.
* @param err Error.
*/
void SetInstanceError(const InstanceIdent& id, const String& serviceVersion, const Error& err);
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

id -> instanceIdent

* @param[out] info output structure to hold instance information.
* @return Error.
*/
Error GetInstanceInfo(const InstanceIdent& id, storage::InstanceInfo& info);
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

ditto


Error InstanceManager::UpdateInstanceCache()
{
auto instances = MakeUnique<StaticArray<storage::InstanceInfo, cMaxNumInstances>>(&mAllocator);
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

empty line

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Development

Successfully merging this pull request may close these issues.

3 participants