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
|
#
# sfive
#
# sfive - spreadspace streaming statistics suite is a generic
# statistic collection tool for streaming server infrastuctures.
# The system collects and stores meta data like number of views
# and throughput from a number of streaming servers and stores
# it in a global data store.
# The data acquisition is designed to be generic and extensible in
# order to support different streaming software.
# sfive also contains tools and applications to filter and visualize
# live and recorded data.
#
#
# Copyright (C) 2014 Christian Pointner <equinox@spreadspace.org>
# Markus Grüneis <gimpf@gimpf.org>
#
# This file is part of sfive.
#
# sfive is free software: you can redistribute it and/or modify
# it under the terms of the GNU General Public License version 3
# as published by the Free Software Foundation.
#
# sfive is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with sfive. If not, see <http://www.gnu.org/licenses/>.
#
import os
from flumotion.component.plugs import base
from flumotion.common import messages, i18n, log
from flumotion.common.poller import Poller
from flumotion.common.i18n import N_
T_ = i18n.gettexter()
_DEFAULT_POLL_INTERVAL = 5 # in seconds
__version__ = "$Rev$"
class ComponentSFivePlug(base.ComponentPlug):
"""Class to send statistics to the spreadspace streaming statistic suite"""
### ComponentPlug methods
def start(self, component):
self.debug('SFive: plug loaded')
self._sfivepoller = None
self._component = component
properties = self.args['properties']
self._socket = properties['socket']
self._hostename = properties['hostname']
self._content_id = properties.get('content-id')
self._format = properties.get('format')
self._quality = properties.get('quality')
self._duration = properties.get('duration', _DEFAULT_POLL_INTERVAL)
self._sfivepoller = Poller(self._updateSFive, self._duration, start=False)
self._initSocket()
def stop(self, component):
if self._sfivepoller:
self._sfivepoller.stop()
## TODO: close unix socket
def _initSocket(self)
self.debug('SFive: connecting to %s...', self._socket)
## TODO: init unix socket and call _socketReady when socket is ready
## TODO: how handle connection drop???
def _socketError(self)
self.warning('SFive: connection lost... trying reconnect')
## TODO: try reconnect...
def _socketReady(self)
self.info('SFive: connection to sfive hub established')
if self._sfivepoller:
self._sfivepoller(start)
def _sendInit(self)
# TODO: create json and send it out
# {
# "hostname": "myhostname",
# "streamer-id": { "content-id": "av-orig", "format": "flash", "quality": "medium" },
# "tags": [ "elevate", "2014", "discourse" ]
# }
def _updateSFive(self):
"""send data update"""
client_count = self._component.getClients()
bytes_received = self._component.getBytesReceived()
bytes_sent = self._component.getBytesSent()
# TODO: create json and send it out
# {
# "start-time": "2014-08-03Z12:34:56.123",
# "duration-ms": 5000,
# "data": {
# "clients": [
# { "ip": "127.0.0.1:2345", "bytes-transferred": 12094, "user-agent": "Mozilla Version 28", .... },
# .....
# ],
# "client-count": 12,
# "bytes-received": 12345,
# "bytes-sent": 921734098,
# ....
# }
|
