StatisticsSenderService.h

Go to the documentation of this file.

#ifndef Utilities_StorageFactory_StatisticsSenderService_H
#define Utilities_StorageFactory_StatisticsSenderService_H

#include <string>
#include <sstream>
#include <atomic>
#include <mutex>

namespace edm {

  class ParameterSet;
  class ActivityRegistry;

  namespace storage {

    class StatisticsSenderService {
    public:
      StatisticsSenderService(edm::ParameterSet const &pset, edm::ActivityRegistry &ar);

      void setSize(size_t size);
      void setCurrentServer(const std::string &servername);
      void filePreCloseEvent(std::string const &lfn, bool usedFallback);
      static const char *getJobID();
      static bool getX509Subject(std::string &);

    private:
      class FileStatistics {
      public:
        FileStatistics();
        void fillUDP(std::ostringstream &os);

      private:
        ssize_t m_read_single_operations;
        ssize_t m_read_single_bytes;
        ssize_t m_read_single_square;
        ssize_t m_read_vector_operations;
        ssize_t m_read_vector_bytes;
        ssize_t m_read_vector_square;
        ssize_t m_read_vector_count_sum;
        ssize_t m_read_vector_count_square;
        time_t m_start_time;
      };

      void determineHostnames(void);
      void fillUDP(const std::string &, bool, std::string &);
      std::string m_clienthost;
      std::string m_clientdomain;
      std::string m_serverhost;
      std::string m_serverdomain;
      std::string m_filelfn;
      FileStatistics m_filestats;
      std::string m_guid;
      size_t m_counter;
      std::atomic<ssize_t> m_size;
      std::string m_userdn;
      std::mutex m_servermutex;
    };

  }  // namespace storage
}  // namespace edm

#endif