daemon/core/session.py
def handledistributed(self, msg):
        ''' Handle the session options config message as it has reached the
        broker. Options requiring modification for distributed operation should
        be handled here.
        '''
        if not self.session.master:
            return
        if msg.msgtype != coreapi.CORE_API_CONF_MSG or \
           msg.gettlv(coreapi.CORE_TLV_CONF_OBJ) != "session":
            return
        values_str = msg.gettlv(coreapi.CORE_TLV_CONF_VALUES)
        if values_str is None:
            return
        values = values_str.split('|')
        if not self.haskeyvalues(values):
            return
        for v in values:
            key, value = v.split('=', 1)
            if key == "controlnet":
                self.handledistributedcontrolnet(msg, values, values.index(v))
 Handle the session options config message as it has reached the
        broker. Options requiring modification for distributed operation should
        be handled here.
        
Handle the session options config message as it has reached the
broker. Options requiring modification for distributed operation should
be handled here.
Handle the session options config message as it has reached the broker . Options requiring modification for distributed operation should be handled here .
def handledistributed(self, msg):
        if not self.session.master:
            return
        if msg.msgtype != coreapi.CORE_API_CONF_MSG or \
           msg.gettlv(coreapi.CORE_TLV_CONF_OBJ) != "session":
            return
        values_str = msg.gettlv(coreapi.CORE_TLV_CONF_VALUES)
        if values_str is None:
            return
        values = values_str.split('|')
        if not self.haskeyvalues(values):
            return
        for v in values:
            key, value = v.split('=', 1)
            if key == "controlnet":
                self.handledistributedcontrolnet(msg, values, values.index(v))
def handledistributed ( self , msg ) : if not self . session . master : return if msg . msgtype != coreapi . CORE_API_CONF_MSG or msg . gettlv ( coreapi . CORE_TLV_CONF_OBJ ) != "session" : return values_str = msg . gettlv ( coreapi . CORE_TLV_CONF_VALUES ) if values_str is None : return values = values_str . split ( '|' ) if not self . haskeyvalues ( values ) : return for v in values : key , value = v . split ( '=' , 1 ) if key == "controlnet" : self . handledistributedcontrolnet ( msg , values , values . index ( v ) )
Handle the session options config message as it has reached the
broker.
Handle the session options config message as it has reached the broker .
''' Handle the session options config message as it has reached the
        broker. Options requiring modification for distributed operation should
        be handled here.
        '''
self
msg