ServiceDirectory.hpp

Go to the documentation of this file.

#ifndef FIPA_SERVICES_SERVICE_DIRECTORY_HPP
#define FIPA_SERVICES_SERVICE_DIRECTORY_HPP

#include <map>
#include <set>
#include <stdexcept>
#include <boost/thread.hpp>
#include <fipa_services/ServiceDirectoryEntry.hpp>
#include <fipa_services/ErrorHandling.hpp>

namespace fipa {
namespace services {

class ServiceDirectory
{
    // Map of registered services
    ServiceDirectoryMap mServices;
    base::Time mTimestamp;

protected:
    // Mutex to guarantee thread-safe operation
    boost::mutex mMutex;

public:
    typedef boost::shared_ptr<ServiceDirectory> Ptr;

    ServiceDirectory();
    virtual ~ServiceDirectory() {}

    virtual void registerService(const ServiceDirectoryEntry& entry);

    void deregisterService(const ServiceDirectoryEntry& entry);

    virtual void deregisterService(const std::string& regex, ServiceDirectoryEntry::Field field = ServiceDirectoryEntry::NAME);

    ServiceDirectoryList search(const ServiceDirectoryEntry& entry) const;

    virtual ServiceDirectoryList search(const std::string& regex, ServiceDirectoryEntry::Field field = ServiceDirectoryEntry::NAME, bool doThrow = true) const;

    void modify(const ServiceDirectoryEntry& entry);

    void updateTimestamp() { mTimestamp = base::Time::now(); }

    base::Time getTimestamp() const { return mTimestamp; }

    ServiceDirectoryList getAll() const;

    virtual void mergeSelectively(const ServiceDirectoryList& updateList, ServiceDirectoryEntry::Field selectiveMerge);

private:
    static std::set<std::string> getUniqueFieldValues(const ServiceDirectoryList& list, ServiceDirectoryEntry::Field field);

    void clearSelectively(const std::string& regex, ServiceDirectoryEntry::Field field);
};

} // end namespace services
} // end namespace fipa
#endif // FIPA_SERVICES_SERVICE_DIRECTORY_HPP