1cabdff1aSopenharmony_ci#!/usr/bin/env python2 2cabdff1aSopenharmony_ci 3cabdff1aSopenharmony_ciimport sys, zmq, cmd 4cabdff1aSopenharmony_ci 5cabdff1aSopenharmony_ciclass LavfiCmd(cmd.Cmd): 6cabdff1aSopenharmony_ci prompt = 'lavfi> ' 7cabdff1aSopenharmony_ci 8cabdff1aSopenharmony_ci def __init__(self, bind_address): 9cabdff1aSopenharmony_ci context = zmq.Context() 10cabdff1aSopenharmony_ci self.requester = context.socket(zmq.REQ) 11cabdff1aSopenharmony_ci self.requester.connect(bind_address) 12cabdff1aSopenharmony_ci cmd.Cmd.__init__(self) 13cabdff1aSopenharmony_ci 14cabdff1aSopenharmony_ci def onecmd(self, cmd): 15cabdff1aSopenharmony_ci if cmd == 'EOF': 16cabdff1aSopenharmony_ci sys.exit(0) 17cabdff1aSopenharmony_ci print 'Sending command:[%s]' % cmd 18cabdff1aSopenharmony_ci self.requester.send(cmd) 19cabdff1aSopenharmony_ci message = self.requester.recv() 20cabdff1aSopenharmony_ci print 'Received reply:[%s]' % message 21cabdff1aSopenharmony_ci 22cabdff1aSopenharmony_citry: 23cabdff1aSopenharmony_ci bind_address = sys.argv[1] if len(sys.argv) > 1 else "tcp://localhost:5555" 24cabdff1aSopenharmony_ci LavfiCmd(bind_address).cmdloop('FFmpeg libavfilter interactive shell') 25cabdff1aSopenharmony_ciexcept KeyboardInterrupt: 26cabdff1aSopenharmony_ci pass 27