daemon/core/broker.py
def fixupremotetty(msghdr, msgdata, host):
        ''' When an interactive TTY request comes from the GUI, snoop the reply
            and add an SSH command to the appropriate remote server.
        '''
        msgtype, msgflags, msglen = coreapi.CoreMessage.unpackhdr(msghdr)
        msgcls = coreapi.msg_class(msgtype)
        msg = msgcls(msgflags, msghdr, msgdata)

        nodenum = msg.gettlv(coreapi.CORE_TLV_EXEC_NODE)
        execnum = msg.gettlv(coreapi.CORE_TLV_EXEC_NUM)
        cmd = msg.gettlv(coreapi.CORE_TLV_EXEC_CMD)
        res = msg.gettlv(coreapi.CORE_TLV_EXEC_RESULT)

        tlvdata = ""
        tlvdata += coreapi.CoreExecTlv.pack(coreapi.CORE_TLV_EXEC_NODE, nodenum)
        tlvdata += coreapi.CoreExecTlv.pack(coreapi.CORE_TLV_EXEC_NUM, execnum)
        tlvdata += coreapi.CoreExecTlv.pack(coreapi.CORE_TLV_EXEC_CMD, cmd)
        title = "\\\"CORE: n%s @ %s\\\"" % (nodenum, host)
        res = "ssh -X -f " + host + " xterm -e " + res
        tlvdata += coreapi.CoreExecTlv.pack(coreapi.CORE_TLV_EXEC_RESULT, res)

        return coreapi.CoreExecMessage.pack(msgflags, tlvdata)
 When an interactive TTY request comes from the GUI, snoop the reply
            and add an SSH command to the appropriate remote server.
        
When an interactive TTY request comes from the GUI, snoop the reply
and add an SSH command to the appropriate remote server.
When an interactive TTY request comes from the GUI snoop the reply and add an SSH command to the appropriate remote server .
def fixupremotetty(msghdr, msgdata, host):
        msgtype, msgflags, msglen = coreapi.CoreMessage.unpackhdr(msghdr)
        msgcls = coreapi.msg_class(msgtype)
        msg = msgcls(msgflags, msghdr, msgdata)
        nodenum = msg.gettlv(coreapi.CORE_TLV_EXEC_NODE)
        execnum = msg.gettlv(coreapi.CORE_TLV_EXEC_NUM)
        cmd = msg.gettlv(coreapi.CORE_TLV_EXEC_CMD)
        res = msg.gettlv(coreapi.CORE_TLV_EXEC_RESULT)
        tlvdata = ""
        tlvdata += coreapi.CoreExecTlv.pack(coreapi.CORE_TLV_EXEC_NODE, nodenum)
        tlvdata += coreapi.CoreExecTlv.pack(coreapi.CORE_TLV_EXEC_NUM, execnum)
        tlvdata += coreapi.CoreExecTlv.pack(coreapi.CORE_TLV_EXEC_CMD, cmd)
        title = "\\\"CORE: n%s @ %s\\\"" % (nodenum, host)
        res = "ssh -X -f " + host + " xterm -e " + res
        tlvdata += coreapi.CoreExecTlv.pack(coreapi.CORE_TLV_EXEC_RESULT, res)
        return coreapi.CoreExecMessage.pack(msgflags, tlvdata)
def fixupremotetty ( msghdr , msgdata , host ) : msgtype , msgflags , msglen = coreapi . CoreMessage . unpackhdr ( msghdr ) msgcls = coreapi . msg_class ( msgtype ) msg = msgcls ( msgflags , msghdr , msgdata ) nodenum = msg . gettlv ( coreapi . CORE_TLV_EXEC_NODE ) execnum = msg . gettlv ( coreapi . CORE_TLV_EXEC_NUM ) cmd = msg . gettlv ( coreapi . CORE_TLV_EXEC_CMD ) res = msg . gettlv ( coreapi . CORE_TLV_EXEC_RESULT ) tlvdata = "" tlvdata += coreapi . CoreExecTlv . pack ( coreapi . CORE_TLV_EXEC_NODE , nodenum ) tlvdata += coreapi . CoreExecTlv . pack ( coreapi . CORE_TLV_EXEC_NUM , execnum ) tlvdata += coreapi . CoreExecTlv . pack ( coreapi . CORE_TLV_EXEC_CMD , cmd ) title = "\\\"CORE: n%s @ %s\\\"" % ( nodenum , host ) res = "ssh -X -f " + host + " xterm -e " + res tlvdata += coreapi . CoreExecTlv . pack ( coreapi . CORE_TLV_EXEC_RESULT , res ) return coreapi . CoreExecMessage . pack ( msgflags , tlvdata )
When an interactive TTY request comes from the GUI, snoop the reply
and add an SSH command to the appropriate remote server.
When an interactive TTY request comes from the GUI snoop the reply and add an SSH command to the appropriate remote server .
''' When an interactive TTY request comes from the GUI, snoop the reply
            and add an SSH command to the appropriate remote server.
        '''
msghdr
msgdata
host