• 以下のエラーが出ていた

  [14:28:16][ERROR] Failed to enqueue OutputChannel                                               │    "instances": [
  [14:28:16][ERROR] Failed transfer on socket Scaler-0.out[0].pull, errno: 95, reason: Operation n│        "all"
  ot supported

  • topology.sh で pull になっていた。push にすべし。

    endpoint  Scaler            out           type pull  method connect
                                                   | | |
                                                   V V V
    endpoint  Scaler            out           type push  method connect

* 2024/07/11 GR honor seminar exp. 以下のようになっていると、SubTimeFrameBuilder でデータがこない。

#!/bin/bash

redis_server=`cat redis-server.txt|sed 's/[[:blank:]]//g'`
server=redis://$redis_server/0

#function config_endpoint () {
function endpoint () {
  # Usage: 
  #   config_endpoint "service" "channel" "parameters"
  
  echo redis-cli -u $server hset daq_service:topology:endpoint:$1:$2 ${@:3}  
  redis-cli -u $server hset daq_service:topology:endpoint:$1:$2 ${@:3}  
}

#function config_link () {
function link () {
  # config_link "service1" "channel" "service2" "channel" "parameters"
  
  echo redis-cli -u $server set daq_service:topology:link:$1:$2,$3:$4 non
  redis-cli -u $server set daq_service:topology:link:$1:$2,$3:$4 none
}

echo "Clear DAQ service keys"
redis-cli -u $server keys 'daq_service:*' | xargs redis-cli -u $server del

echo "---------------------------------------------------------------------"
echo " config endpoint (socket)"
echo "---------------------------------------------------------------------"
#------------------------------------------------------------------------------------
#            service                channel         options
#------------------------------------------------------------------------------------

# Sampler 
endpoint     AmQStrTdcSampler        out           type push  method bind 

# subtime frame builder
endpoint     STFBuilder              in            type pull method connect 
endpoint     STFBuilder              out           type push method connect    autoSubChannel true
endpoint     STFBuilder              dqm           type push method bind

#Scaler      
#endpoint     Scaler                  in            type pull method connect
#endpoint     Scaler                  out           type push method connect

# tf                                                                                                                         
endpoint     TimeFrameBuilder        in            type pull  method bind
endpoint     TimeFrameBuilder        out           type push  method connect  #  autoSubChannel true
#endpoint     TimeFrameBuilder        decimator     type push  method connect

# Sink
endpoint     FileSink                in            type pull  method bind
#endpoint     DecSink                 in            type pull  method bind

echo "---------------------------------------------------------------------"
echo " config link"
echo "---------------------------------------------------------------------"
#------------------------------------------------------------------------------------
#       service1                channel1              service2        channel2      
#------------------------------------------------------------------------------------

link    AmQStrTdcSampler        out                  STFBuilder        in
link    STFBuilder              out                  TimeFrameBuilder  in
#link    STFBuilder              dqm                  Scaler           in
#link    Scaler                  out                  ScrSink          in
link    TimeFrameBuilder        out                  FileSink          in
#link    TimeFrameBuilder        decimator            DecSink           in