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 51 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 55 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 62 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 123 of file oks_validate_repository.cxx.

m_kernel

OksKernel OksValidateJob::m_kernel

private

Definition at line 122 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