libkak.py 文件源码

def setup_reply_channel(self_or_session):
        r = Remote._resolve(self_or_session)
        r_pre = r.pre
        r.pre = lambda f: r_pre(f) + '''
                    __reply_fifo_dir=$(mktemp -d)
                    __reply_fifo="${__reply_fifo_dir}/fifo"
                    mkfifo ${__reply_fifo}
                '''
        r.post = '''
            \ncat ${__reply_fifo}
            rm ${__reply_fifo}
            rmdir ${__reply_fifo_dir}
        ''' + r.post
        r.arg_config['reply_fifo'] = ('__reply_fifo', Args.string)
        r.required_names.add('reply_fifo')
        return r