

def process(self, msg):
    self.cb_lock.acquire()
    if (isinstance(self, message.ChannelMessage) and (msg.getChannelNumber() == self.number)):
        for callback in self.cb:
            try:
                callback.process(msg)
            except:
                pass
    self.cb_lock.release()

dataset/ETHPy150Open mvillalba/python-ant/src/ant/core/node.py Channel.process/VarMisuse@24/26 `msg`->`self`