{{toc}}

Migrating to artdaq v3_09_00

artdaq v3_09_00 adds a new plugin type “fragmentTypeHelper” to allow usage of the ArtdaqFragmentNamingService functionality outside of an art process. Updating a v3_08_00 FragmentNamingService is trivial, see artdaq-core-demo:source:artdaq-core-demo/Overlays/ArtdaqDemo_fragmentNameHelper.cc for an example.

You should then update your ArtdaqFragmentNamingServiceInterface configuration as follows: art.services.ArtdaqFragmentNamingServiceInterface: { service_provider: ArtdaqFragmentNamingService helper_plugin: YourExperiment }

Also, this version requires the configuration variable receive_requests: true to be added to all pull-mode BoardReaders.

Example Configurations (BEFORE DAQInterface bookkeeping)

BoardReader

  daq: {
  fragment_receiver: {

    # CommandableFragmentGenerator Configuration: 
    fragment_ids: []
    fragment_id: -99 # Please define only one of these

    sleep_on_stop_us: 0

     # Possible values are: Ignored, Single, Buffer, Window
    request_mode: "Ignored"

    data_buffer_depth_fragments: 1000
    data_buffer_depth_mb: 1000

        receive_requests: true
    request_port: 3001
    request_address: "227.128.12.26" # Multicast request address

    # Request message contains tzero. Window will be from tzero -
    # offset to tzero + width

    request_window_offset: 0 
    request_window_width: 0

    # How long to wait before discarding request messages that are
        # outside the available data

    stale_request_timeout: "0xFFFFFFFF" 

    # If request windows are unique, avoids a copy operation, but
    # the same data point cannot be used for two requests. If this
    # is not anticipated, leave set to "true"

    request_windows_are_unique: true 

    # separate_data_thread MUST be true for requests to be
        # applied! If requests are not desired, but a separate readout
        # thread is, set this to true and request_mode to ignored.

    separate_data_thread: false 

    # Whether a thread should be started which periodically calls
        # checkHWStatus_, a user-defined function which should be used
        # to check hardware status registers and report to MetricMan:

    separate_monitoring_thread: false 

    # How often, in microseconds, checkHWStatus_() should be
        # called. 0 to disable:

    hardware_poll_interval_us: 0 

        generator: ToySimulator
      fragment_type: TOY1
      fragment_id: 0
      board_id: 0
      starting_fragment_id: 0
      random_seed: 8250
      sleep_on_stop_us: 500000 
      nADCcounts: 40
      max_fragment_size_bytes: 200
      throttle_usecs: 100000
      distribution_type: 2
      timestamp_scale_factor: 1

        destinations: { }

    routing_table_config: {
        use_routing_master: false
    }
  }

  metrics: {
    brFile: {
      metricPluginType: "file"
      level: 4
      fileName: "boardreader/br_%UID%_metrics.log"
         absolute_file_path: false
      uniquify: true
    }
  }
}

EventBuilder

daq: {
  event_builder: {
    expected_fragments_per_event: 0  # Will be set by DAQInterface
        init_fragment_count: 0 # Will be set by DAQInterface
    use_art: true
    print_event_store_stats: true
    buffer_count: 20
    max_incomplete_events: 75 # Same as boardreader sync interval
    verbose: true
    send_requests: false

    routing_token_config: {
    use_routing_master: false
    }

    sources: { }
  }
  metrics: {
    evbFile: {
      metricPluginType: "file"
      level: 4
      fileName: "eventbuilder/evb_%UID%_metrics.log"
         absolute_file_path: false
      uniquify: true
    }
  }
} 

art: {
services: {
  ArtdaqSharedMemoryServiceInterface: {
   service_provider: ArtdaqSharedMemoryService
  waiting_time: 2500000
  resume_after_timeout: true
  }
  ArtdaqFragmentNamingServiceInterface: { service_provider: ArtdaqFragmentNamingService helper_plugin: "Demo" }
}

outputs: {
  rootNetOutput: {
    module_type: RootNetOutput
    #SelectEvents: { SelectEvents: [ pmod2,pmod3 ] }
    #broadcast_sends: true
    destinations: { }

    routing_table_config: {
        use_routing_master: false
    }
  }
  #normalOutput: {
  #  module_type: RootDAQOut
  #  fileName: "/tmp/artdaqdemo_eb00_r%06r_sr%02s_%to_%#.root"
  #  #SelectEvents: { SelectEvents: [ pmod2,pmod3 ] }
  #  fileProperties: { maxSubRuns: 1 maxRuns: 1  }
  #  compressionLevel: 3
  #  fastCloning: false
 #}
}

physics: {
  analyzers: {
    toy1Integ: {
      module_type: CheckIntegrity
      raw_data_label: "daq"
      frag_type: "TOY1"      
    }
    toy2Integ: {
      module_type: CheckIntegrity
      raw_data_label: "daq"
      frag_type: "TOY2"
    }
  }

  producers: {
  }

  filters: {

    prescaleMod2: {
       module_type: NthEvent
       nth: 2
    }

    prescaleMod3: {
       module_type: NthEvent
       nth: 3
    }
  }

  pmod2: [ prescaleMod2 ]
  pmod3: [ prescaleMod3 ]

  a1: [ toy1Integ, toy2Integ ]
  my_output_modules: [ rootNetOutput ]
  #my_output_modules: [ normalOutput ]
}
source: {
  module_type: ArtdaqInput
}
process_name: DAQ
}

DataLogger

daq: {
  aggregator: {
    expected_events_per_bunch: 1
    init_fragment_count: 0 # Will be set by DAQInterface
    print_event_store_stats: true
    event_queue_depth: 40
    event_queue_wait_time: 5
    buffer_count: 40
    onmon_event_prescale: 1
    is_data_logger: true

    auto_suppression_enabled: false

    routing_token_config: {
        use_routing_master: false
    }

    sources: { }
  }

  metrics: {
    aggFile: {
      metricPluginType: "file"
      level: 4
      fileName: "aggregator/agg_%UID%_metrics.log"
      absolute_file_path: false
      uniquify: true
    }
    #ganglia: {
    #  metricPluginType: "ganglia"
    #  level: 4
    #  reporting_interval: 15.0
    #  configFile: "/etc/ganglia/gmond.conf"
    #  group: "ARTDAQ"
    #}
  }

}

art: {
services: {
  ArtdaqSharedMemoryServiceInterface: {
   service_provider: ArtdaqSharedMemoryService
  }
}
source: {
  module_type: ArtdaqInput
  register_fragment_types: false
}
outputs: {
  normalOutput: {
    module_type: RootDAQOut
    fileName: "/tmp/artdaqdemo_r%06r_sr%02s_%to_%#.root"
    fileProperties: { maxSubRuns: 1 maxRuns: 1  }
    fastCloning: false
    compressionLevel: 3
  }
  rootNetOutput: {
    module_type: RootNetOutput
    #SelectEvents: { SelectEvents: [ pmod2,pmod3 ] }
    broadcast_sends: true
    nonblocking_sends: true
    destinations: { }
  }

}
physics: {
  analyzers: {


   checkintegrity: {
     module_type: CheckIntegrity
     raw_data_label: daq
     frag_type: TOY1
   }
   checkintegrity2: {
     module_type: CheckIntegrity
     raw_data_label: daq
     frag_type: TOY2
   }

  }

  producers: {

     BuildInfo:
     {
       module_type: ArtdaqDemoBuildInfo
       instance_name: ArtdaqDemo
     }
   }

  p2: [ BuildInfo ]
  a1: [ checkintegrity, checkintegrity2 ]
  my_output_modules: [ normalOutput ]
  my_mpi_output_modules: [rootNetOutput]
}
process_name: DAQDL
}