OksValidateJob Struct Reference

Inheritance diagram for OksValidateJob:

Collaboration diagram for OksValidateJob:

Public Member Functions
	OksValidateJob (OksKernel &kernel, const std::string &file_name)
void	run ()
Public Member Functions inherited from dunedaq::oks::OksJob
virtual	~OksJob ()

Private Member Functions
	OksValidateJob (const OksValidateJob &)
OksValidateJob &	operator= (const OksValidateJob &)

Private Attributes
OksKernel	m_kernel
const std::string &	m_file_name

Detailed Description

Definition at line 55 of file oks_validate_repository.cxx.

Constructor & Destructor Documentation

OksValidateJob() [1/2]

OksValidateJob::OksValidateJob ( OksKernel & kernel, const std::string & file_name )

inline

Definition at line 58 of file oks_validate_repository.cxx.

    : m_kernel(kernel)
    , m_file_name(file_name)
  {
    ;
  }

OksValidateJob() [2/2]

OksValidateJob::OksValidateJob ( const OksValidateJob & )

private

Member Function Documentation

operator=()

OksValidateJob & OksValidateJob::operator= ( const OksValidateJob & )

private

run()

void OksValidateJob::run ( void )

inlinevirtual

Implements dunedaq::oks::OksJob.

Definition at line 65 of file oks_validate_repository.cxx.

  {
    static std::mutex s_mutex;
 
    try {
      auto start_usage = std::chrono::steady_clock::now();
 
      m_kernel.set_silence_mode(true);
 
      m_kernel.load_file(m_file_name);
 
      if (!m_kernel.get_bind_classes_status().empty() || !m_kernel.get_bind_objects_status().empty()) {
        std::lock_guard lock(s_mutex);
 
        if (s_load_error.empty()) {
          init_file_load_error(m_file_name);
 
          if (!m_kernel.get_bind_classes_status().empty()) {
            s_load_error += "the schema contains dangling references to non-loaded classes:\n";
            s_load_error += m_kernel.get_bind_classes_status();
          }
 
          if (!m_kernel.get_bind_objects_status().empty()) {
            s_load_error += "the data contain dangling references to non-loaded objects:\n";
            s_load_error += m_kernel.get_bind_objects_status();
          }
        }
      }
 
      static std::mutex s_log_mutex;
      std::lock_guard scoped_lock(s_log_mutex);
 
      log_timestamp() << "validated file \"" << m_file_name << "\" in "
                      << std::chrono::duration_cast<std::chrono::microseconds>(std::chrono::steady_clock::now() -
                                                                               start_usage)
                             .count() /
                           1000.
                      << " ms\n";
    } catch (std::exception& ex) {
      std::lock_guard lock(s_mutex);
 
      if (s_load_error.empty()) {
        init_file_load_error(m_file_name);
        s_load_error += ex.what();
 
        const std::string& user_repository(m_kernel.get_user_repository_root());
        const std::size_t user_repository_len(m_kernel.get_user_repository_root().length() + 1);
 
        std::size_t pos;
        while ((pos = s_load_error.find(user_repository)) != std::string::npos)
          s_load_error.replace(pos, user_repository_len, "");
      }
    }
  }

Member Data Documentation

m_file_name

const std::string& OksValidateJob::m_file_name

private

Definition at line 122 of file oks_validate_repository.cxx.

m_kernel

OksKernel OksValidateJob::m_kernel

private

Definition at line 121 of file oks_validate_repository.cxx.

---

The documentation for this struct was generated from the following file:

• /github/workspace/dunedaq/sourcecode/oks/apps/oks_validate_repository.cxx