SupportSharedWriter

Adds a proxy for a metadata object to the input metadata store. More...

virtual StatusCode	MetaDataSvc::prepareOutput (const std::string &outputName)
	Makes the metadata store ready for output with SharedWriter Calls the metaDataStop method of all MetaDataTool interfaces in m_metaDataTool. More...
virtual StatusCode	MetaDataSvc::shmProxy (const std::string &filename) override
	Loads file metadata from memory shared between streams in SharedWriter This function clears the input and output metadata stores. More...

Detailed Description

Adds a proxy for a metadata object to the input metadata store.

The file, class, container, key, and stream number of the metadata object are parsed from the provided string token. An opaque address for the object is generated from the parsed information and recorded in the input metadata store under the key name. If the key contains 'Aux.' it is linked to a IConstAuxStore.

Note that the MetaDataTool corresponding to the object is looked up via classID and created if not found in m_metaDataTools. Some special handling for the EventFormat, EventStreamInfo, and FileMetaData tools should ensure proper propagation —this part seems fragile.

This function may be called directly or when a BeginInputFile incident is fired.

Parameters

tokenStr

is the string representation of a Token of a metadata object

Returns

SUCCESS unless the proxy could not be generated or added or the tool could not be found or set up

Function Documentation

prepareOutput()

StatusCode MetaDataSvc::prepareOutput ( const std::string &  outputName )

virtual

Makes the metadata store ready for output with SharedWriter Calls the metaDataStop method of all MetaDataTool interfaces in m_metaDataTool.

Then release the metadata tools.

Parameters

outputName

is the name of the output file being written

Returns

SUCCESS unless a MetaDataTool fails, then FAILURE

Definition at line 292 of file MetaDataSvc.cxx.

{
   // default to the serial implementation if no output name given
   if( outputName.empty() ) return prepareOutput();
   ATH_MSG_DEBUG( "prepareOutput('" << outputName << "')" );
 
   StatusCode rc = StatusCode::SUCCESS;
   for (auto it = m_metaDataTools.begin(); it != m_metaDataTools.end(); ++it) {
      ATH_MSG_DEBUG("  calling metaDataStop for " << (*it)->name());
      // planning to replace the call below with  (*it)->prepareOutput(outputName)
      if ( (*it)->metaDataStop().isFailure() ) {
         ATH_MSG_ERROR("Unable to call metaDataStop for " << (*it)->name());
         rc = StatusCode::FAILURE;
      }
   }
   // MN: not releasing tools here - revisit when clear what happens on new file open
   return rc;
}

shmProxy()

StatusCode MetaDataSvc::shmProxy ( const std::string &  filename )

overridevirtual

Loads file metadata from memory shared between streams in SharedWriter This function clears the input and output metadata stores.

Then calls addProxyToInputMetaDataStore using filename as argument.

See also

addProxyToInputMetaDataStore()

Parameters

filename

stream token with "[NUM=n]" appended, n is the stream number

Returns

FAILURE if any step isn't successful, else SUCCESS

Definition at line 312 of file MetaDataSvc.cxx.

{
   if (!m_clearedInputDataStore) {
      if (!m_inputDataStore->clearStore(true).isSuccess()) {
         ATH_MSG_ERROR("Unable to clear input MetaData Proxies");
     return StatusCode::FAILURE;
      }
      m_clearedInputDataStore = true;
   }
   if (!m_clearedOutputDataStore) {
      if (!m_outputDataStore->clearStore(true).isSuccess()) {
         ATH_MSG_ERROR("Unable to clear output MetaData Proxies");
     return StatusCode::FAILURE;
      }
      m_clearedOutputDataStore = true;
   }
   if (!addProxyToInputMetaDataStore(filename).isSuccess()) {
      ATH_MSG_ERROR("Unable to add proxy to InputMetaDataStore");
      return StatusCode::FAILURE;
   }
   return StatusCode::SUCCESS;
}