ffmpeg-dbus/tryserver.py at master · jcdr/ffmpeg-dbus · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
#!/usr/bin/env python
import subprocess
import signal
import gobject
import dbus
import dbus.service
import dbus.mainloop.glib
import os

service = "ch.cett.misse.ffmpeg"

class FFMpeg(dbus.service.Object):
    width=160
    height=128
    imrate=25
    bitrate=200
    clip='127.0.0.1'
    qscale=6
    @dbus.service.method(service, in_signature='', out_signature='i')
    def start(self):
        print "Should start ffmpeg"


	s='ffmpeg -f video4linux2 -s '+ str(self.width)+'x'+str(self.height)+' -r '+ str(self.imrate) +' -b '+str(self.bitrate) +' -i  /dev/video0 -qscale '+str(self.qscale)+' -f mjpeg  udp:'+self.clip+':1234'
        self.p =subprocess.Popen(s, shell=True,stdout=subprocess.PIPE)
        return 0

    @dbus.service.method(service, in_signature='', out_signature='i')
    def stop(self):
        print "Should stop ffmpeg"
        try:
            os.kill(self.p.pid, signal.SIGTERM)
            while self.p.poll() == 0:
                pass
        except:
            pass
        return 0

    @dbus.service.method(service, in_signature='ii', out_signature='i')
    def image_size_set(self, width, height):
        print "image_size_set: width=%d height=%d"%(width, height)
	self.width = width
	self.height = height
        return 0

    @dbus.service.method(service, in_signature='', out_signature='ii')
    def image_size_get(self):
        print "image_size_get:"
	return (self.width, self.height)


    @dbus.service.method(service, in_signature='i', out_signature='i')
    def image_rate_set(self,imrate):
        print "image_rate_set: %d"%imrate
	self.imrate=imrate
	return 0

    @dbus.service.method(service, in_signature='', out_signature='i')
    def image_rate_get(self):
        print "image_rate_get:"
	return (self.imrate)

    @dbus.service.method(service, in_signature='i', out_signature='i')
    def bit_rate_set(self,bitrate):
        print "bit_rate_set: %d"%bitrate
	self.bitrate=bitrate
	return 0


    @dbus.service.method(service, in_signature='', out_signature='i')
    def bit_rate_get(self):
        print "Bit_rate_get:"
	return (self.bitrate)


    @dbus.service.method(service, in_signature='i', out_signature='i')
    def qscale_set(self,qscale):
        print "qscale_set: %d"%qscale
	self.qscale=qscale
	return 0


    @dbus.service.method(service, in_signature='', out_signature='i')
    def qscale_get(self):
        print "qscale_get:"
	return (self.qscale)


    @dbus.service.method(service, in_signature='s', out_signature='i')
    def client_ip_set(self,clip):
        print "client_ip_set:"
        self.clip=clip
	return 0


    @dbus.service.method(service, in_signature='', out_signature='s')
    def client_ip_get(self):
        print "client_ip_get:"
	return (self.clip)


if __name__ == '__main__':
    dbus.mainloop.glib.DBusGMainLoop(set_as_default=True)
    bus = dbus.SessionBus()
    name = dbus.service.BusName(service, bus)
    object = FFMpeg(bus, '/')
    mainloop = gobject.MainLoop()
    mainloop.run()