crans/scripts
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Dplacement des scripts tv dans le nfs.

Browse source 
darcs-hash:20050822155419-41617-aab8a29eddc92fb3add940af6d04115480dc8454.gz
This commit is contained in:
pauget 2005-08-22 17:54:19 +02:00
parent 9ce691481c
commit 4aad64077e
3 changed files with 585 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

138
tv/sap.py Executable file
View file

@ -0,0 +1,138 @@
#! /usr/bin/env python
# -*- coding: iso-8859-15 -*-
""" Génération de la configuration sap à partir des données de mumudvb
Lancement du serveur sap.
Option -d pour que le programme ne se lance pas en daemon. """
import os, sys, signal
from socket import getfqdn
from time import sleep
from commands import getoutput
sys.path.append('/usr/scripts/python-lib')
import lock
from daemon import daemonize
################CONFIG
SAP_CONF = '/etc/sap.cfg'
LOCK='/var/run/tv/sap'
CHAINES_DIFFUSES = '/var/run/tv/chaines_diffusees_carte%d'
base_conf = """##################################
# Fichier généré automatiquement #
# NE PAS EDITER #
##################################
[global]
sap_ttl=4
sap_ipversion=4
sap_delay=10
ipv6_scope=8
"""
chaine_template="""
[program]
name=%s
user=crans
machine=%s
site=http://www.crans.org
address=%s
port=%s
program_ttl=4
program_ipversion=4
playlist_group=%s
""" % ( '%(nom)s', getfqdn(), '%(ip)s', '%(port)s', '%(langue)s' )
################FIN CONFIG
# Variables globales, ne pas toucher
sap_pid = 0
sum = 0
class no_data(Exception):
pass
def gen_sap() :
""" Génération du ficher de conf du sap """
data = []
for i in range(0,6) :
try :
data.append(open(CHAINES_DIFFUSES % i).readlines())
except IOError :
continue
file = open(SAP_CONF,'w')
file.write(base_conf)
ok=0
for fichier in data :
for line in fichier :
ip, port, nom_chaine = line.strip().split(':')
file.write(chaine_template % {
'nom' : nom_chaine,
'langue': nom_chaine.split()[0],
'ip' : ip,
'port' : port} )
ok=1
file.close()
if not ok : raise no_data
def is_alive(child_pid) :
""" Vérifie si le processus fils tourne """
try :
if os.waitpid(child_pid,1) != (0,0) :
raise OSError
return True
except OSError :
return False
def term(a=None,b=None) :
""" Tue le serveur sap puis quitte """
kill()
lock.remove_lock(LOCK)
sys.exit(0)
def kill() :
""" Tue le serveur sap """
if not is_alive(sap_pid) :
return
print "Kill sap"
os.kill(sap_pid,15)
sleep(1)
if is_alive(sap_pid) :
# Salloperie
print "WARNING : sap résitant"
os.kill(sap_pid,9)
sleep(1)
if __name__ == '__main__' :
# Arguments
if '-d' not in sys.argv :
daemonize()
# Lock
lock.make_lock(LOCK,"Serveur SAP")
# Signal handler
signal.signal(signal.SIGTERM,term)
signal.signal(signal.SIGINT,term)
while 1 :
try :
gen_sap()
except no_data :
# Rien n'est diffusé
kill()
else :
# Changent de config ?
new_sum = getoutput('md5sum %s' % SAP_CONF).split()[0]
if new_sum != sum :
print "Reconfiguration"
sum = new_sum
if sap_pid>1 and is_alive(sap_pid) :
kill()
if not is_alive(sap_pid) :
# Ne tourne pas, on relance
sap_pid = os.spawnl(os.P_NOWAIT,'/usr/local/bin/sapserver','sap','-f',SAP_CONF)
print "Lancement serveur, pid=%s" % sap_pid
sleep(60)

414
tv/sat_base.py Executable file
View file

@ -0,0 +1,414 @@
#! /usr/bin/env python
# -*- coding: iso8859-15 -*-
""" Configuration de base des différents transpondeurs disponibles """
#Auteur : Frédéric Pauget
#Maintenance et adaptations : DUBOST Brice
#Licence : GPLv2
from commands import getoutput
from time import sleep
import os
IP = getoutput("host $(hostname)").split()[2]
class CarteOqp(Exception) :
""" La carte est déja utilisée """
class NotRunning(Exception) :
""" La carte ne diffuse rien """
class carte :
""" Classe parent de toute classe de transpondeur """
# Niveux de verbosite :
# 0 : ne dit rien
# 1 : messages à caractères informatifs
# 2 : messages de debug
# 3 : ne permet pas à mumudvb de daemonizer
verbose = 3
CONF_FILE = "/etc/sat/carte%i.conf" # %i : numero de la carte
timeout_accord=20 #en secondes
timeout_no_diff=300 #en secondes
entete_conf = """### Fichier généré, NE PAS EDITER
freq=%(freq)i
pol=%(pol)s
srate=%(srate)i
card=%(card)i
timeout_accord=%(timeout_accord)i
timeout_no_diff=%(timeout_no_diff)i
"""
entete_conf_TNT = """### Fichier généré, NE PAS EDITER
freq=%(freq)i
qam=%(qam)s
trans_mode=%(trans_mode)s
bandwidth=%(bandwidth)s
guardinterval=%(guardinterval)s
coderate=%(coderate)s
card=%(card)i
timeout_accord=%(timeout_accord)i
timeout_no_diff=%(timeout_no_diff)i
"""
chaine_template = """ip=%(ip)s
port=1234
name=%(name)s
pids=%(pids)s
"""
pid_file = "/var/run/tv/mumudvb_carte%i.pid" # % num carte
mumudvb = "/usr/local/bin/mumudvb "
def __cmp__(a,b) :
for attr in ( 'card', 'freq', 'chaines' ) :
if getattr(a,attr) != getattr(b,attr) :
return -2
return 0
def __init__(self,card) :
""" Initalisation card est le numéro (entier) de la carte
correspondante """
try :
self.freq = int(str(self.__class__).split('_')[-1])
except :
# On ne pourra pas faire grand chose à part killer le flux de la carte
self.freq = ''
pass
self.card = card
def gen_conf(self) :
""" Génère le fichier de conf """
if not self.freq :
if self.verbose > 1 : print "Instance ne permettant pas la génération de la conf"
return
fd = open(self.CONF_FILE % self.card,'w')
# Entète du fichier
try:
fd.write( self.entete_conf_TNT %
{ 'qam' : self.qam, 'trans_mode' : self.trans_mode ,
'bandwidth' : self.bandwidth, 'guardinterval' : self.guardinterval ,
'coderate' : self.coderate,
'freq' : self.freq , 'card' : self.card ,
'timeout_accord' : self.timeout_accord ,
'timeout_no_diff' : self.timeout_no_diff } )
except:
fd.write( self.entete_conf %
{ 'pol' : self.pol, 'srate' : self.srate ,
'freq' : self.freq , 'card' : self.card ,
'timeout_accord' : self.timeout_accord ,
'timeout_no_diff' : self.timeout_no_diff } )
# Chaines
n = 0
for pids, name in self.chaines.items() :
ip = '239.%s.20%i.2%02i' % ( IP.split('.')[-1], self.card, n)
n += 1
fd.write(self.chaine_template % vars())
fd.close()
def get_pid(self) :
""" Retourne le pid associé à la carte """
try:
pid = int(open(self.pid_file % self.card).readline().strip())
if self.verbose > 1 :
print 'pid : %i' % pid ,
return pid
except :
raise NotRunning
def is_running(self) :
""" Vérifie si le process correspondant à la carte toune """
if self.verbose > 1 :
redir = ''
else :
redir = '>/dev/null 2>&1'
try :
if not os.system('ps %i %s' % (self.get_pid() , redir) ) :
# Il tourne
return True
except NotRunning :
pass
return False
def start(self) :
""" Lance la diffusion """
if not self.freq :
if self.verbose > 1 : print "Instance ne permettant pas le lancement d'un flux"
return
if self.verbose >0 :
print "Lancement de %s sur la carte %i" % (str(self.__class__).split('.')[-1], self.card)
if self.is_running() :
raise CarteOqp
if self.verbose >0 : print "\tGénération de la conf...",
self.gen_conf()
if self.verbose >0 : print "OK"
cmd = '%s -c %s' % ( self.mumudvb, self.CONF_FILE % self.card )
if self.verbose > 2 : cmd += ' -d -s'
if self.verbose > 1 :
print "\tCommande : %s" % cmd
for i in range(2*self.timeout_accord) :
if not i%5 and i <= self.timeout_accord :
if self.verbose > 0 and i : print "ATTENTE/ERREUR"
# On fait une tentative de lancement toutes les 5s (en cas de pb de diseq)
if self.verbose > 0 : print "\tTentative %i" %(i/5+1) ,
os.system(cmd)
sleep(1)
if self.is_running() :
if self.verbose > 0 : print 'OK'
break
sleep(1)
if not self.is_running() :
if self.verbose > 0 : print 'ABANDON'
raise NotRunning
def stop(self) :
""" Arrète la diffusion de la carte """
if self.verbose >0 :
print "Arret diffusion carte %i..." % self.card ,
try :
# Ca tourne au moins ?
if not self.is_running() :
if self.verbose >0 : print "carte déja arrétée"
return
os.kill(self.get_pid(),15)
sleep(1)
if not self.is_running() :
if self.verbose >0 : print "OK"
return
# Crève !!
if not self.is_running() :
if self.verbose >0 : print "SIGKILL"
return
os.kill(self.get_pid(),9)
# Salloperie
raise CarteOqp
except NotRunning :
# Parfait, c'était le but
pass
def restart(self) :
""" Redémarre le flux """
self.stop()
self.start()
class Hotbird_10796(carte) :
pol='v'
srate=27500
chaines = {
'3534 3504' : 'rad fra France Inter',
'3535 3505' : 'rad fra France Info' }
class Hotbird_10873(carte) :
pol='v'
srate=27500
chaines = {
'3101 3131' : 'rad fra Europe 1',
'3102 3132' : 'rad fra Europe 2',
'3103 3133' : 'rad fra RFM',
'3105 3135' : 'rad fra RTL',
'3106 3136' : 'rad fra NRJ',
'3107 3137' : 'rad fra Radio Classique',
'3108 3138' : 'rad fra Cherie FM',
'3111 3141' : 'rad fra HITWEST',
'3202 3232' : 'rad fra Rires et chansons',
'3210 3240' : 'rad fra Nostalgie' }
class Hotbird_10911(carte) :
pol='v'
srate=27500
chaines = {
'3207 3237' : 'rad fra RFI',
'3301 3331' : 'rad fra Beur FM',
'3501 3531' : 'rad fra France Musiques',
'3503 3533' : 'rad fra FIP',
'3506 3536' : 'rad fra France Culture',
'3508 3538' : 'rad fra Le Mouv' }
class Hotbird_11137(carte) :
pol='h'
srate=27500
chaines = {
'3521 3641 717 3601' : 'fra TV5 FBS',
'3522 3642 719 3602' : 'fra TV5 Europe',
'3523 3643 265' : 'ita Roma uno',
'3524 3644 262' : 'ara ANN',
'3525 3645 267' : 'ita Videolook',
'3526 3646 263' : 'ara K-TV',
'3528 3648 264' : 'ita Videolina',
'3529 3649 258' : 'ita TeleGenova Sat 2',
'3531 3651 261' : 'ita Amica9 telestar' }
class Hotbird_11200(carte) :
pol='V'
srate=27500
chaines = {
'366 367 2560' : 'ita Elite shopping TV',
'382 383 768' : 'ita calabria sat',
'386 387 512' : 'x-ero tv conto',
'397 398 399' : 'ita starsat',
'382 383 2048' : 'ita italia.tv channel',
'394 395 394' : 'x-ero play TV',
'400 401 402' : 'ita people tv',
'405 406 407' : 'ita roma sat',
'413 414 415' : 'ita sat adriatico' }
class Hotbird_11242(carte) :
pol='v'
srate=27500
chaines = {
'169 116 1033 58' : 'ger MTV Germany' }
class Hotbird_11304(carte) :
pol='h'
srate=27500
chaines = {
'3011 3012 209' : 'fra TV8 mont blanc',
'1060 1020 210' : 'esp venevision continental',
'310 256 211' : 'esp TV Chile',
'513 514 212' : 'esp TV Colombia',
'101 201 214' : 'esp Cubavision international'}
class Hotbird_11604(carte) :
pol='h'
srate=27500
chaines = {
'111 112 300 114' : 'ger TV NRW',
'172 173 600 174' : 'ger Das Erste',
'1000 1001 700' : 'ger DW TV',
'175 176 900 177' : 'ger RTL2 Schweiz',
'180 181 1100 182' : 'ger SUPER RTL Schweiz',
'190 191 1200' : 'pol Viva Polska' }
class Hotbird_11623(carte) :
pol='v'
srate=27500
chaines = {
'223 233 243 203' : 'fra ger Arte',
'230 250 210 297' : 'fra 123 sat',
'225 245 205' : 'fra Best Of Shopping',
'221 241 201' : 'x-ero Videosexy TV',
'227 247 207 287' : 'rom TV romania'}
class Hotbird_11642(carte) :
pol='h'
srate=27500
chaines = {
'1360 1320 5003' : 'eng Bloomberg Europe',
'1460 1420 5004' : 'ger Bloomberg TV Deutschland',
'1560 1520 5005' : 'eng Bloomberg U.K.' }
class Hotbird_11727(carte) :
pol='v'
srate=27500
chaines = {
'2711 2712 257' : 'fra la locale',
'2730 2731 2732 264' : 'ara Al Maghribiyah',
'2741 2742 265' : 'ita Sicilia International (SET)',
'2751 2752 266' : 'ita Sardegna Uno Sat'}
class Hotbird_11785(carte) :
pol='h'
srate=27500
chaines = {
'3521 3522 3520 3525' : 'esp TVE International',
'3569 3570 3568 3573' : 'esp Canal 24 Horas',
'3553 3554 3552' : 'esp TVE Internacional Asia/Africa' }
class Hotbird_12245(carte) :
pol='h'
srate=27500
chaines = {
'127 137 117' : 'fra TELIF',
'128 138 32' : 'x-ero sexysat',
'200 201 119' : 'ita made in Italy' }
class Hotbird_12476(carte) :
pol='h'
srate=27500
chaines = {
'101 201 202 203 204 205 206 207 208 209 210 211 212 100' : 'fra autres EBS',
# '700 701 702' : 'kur CTV Kurdistan',
'601 602 257' : 'ara 2M',
'551 552 550' : 'x-ero X Stream'}
class Hotbird_12558(carte) :
pol='v'
srate=27500
chaines = {
'6660 6661 6659' : 'ita Administra.it',
'6916 6917 6915 6930' : 'ita 24 Ore' }
class Hotbird_12577(carte) :
pol='h'
srate=27500
chaines = {
'1204 1304 1104' : 'fra telesud',
'1206 1306 1106' : 'fra F men',
'1209 1309 1109' : 'fra liberty TV',
'1239 1339 1139' : 'ned liberty TV' }
class Hotbird_12597(carte) :
pol='v'
srate=27500
chaines = {
'160 80 1024 32' : 'ara Al Arabiya',
'163 92 1027' : 'eng BBC World',
'167 108 1031' : 'rus ORT International',
'2221 2231 2232 2233 2234 2235 2236 2237 2238 1034 768' : 'fra autres Euronews' }
class TNT_base(carte) :
qam="64"
trans_mode="8k"
bandwidth="8MHz"
class TNT_R1_586000(TNT_base) :
guardinterval="1/8"
coderate="3/4"
chaines = {
'120 130 110' : 'fra France 2',
'210 220 230' : 'fra France 3',
'410 420 430' : 'fra France 4',
'310 320 330' : 'fra France 5',
'510 520 530' : 'fra Arte',
'610 620 630' : 'fra LCP Public Senat' }
class TNT_R2_474000(TNT_base) :
guardinterval="1/32"
coderate="2/3"
chaines = {
'160 80 1280' : 'fra Direct 8',
'161 84 1281' : 'fra TMC'}
class TNT_R3_522000(TNT_base) :
guardinterval="1/32"
coderate="2/3"
chaines = {
'160 80 1280' : 'fra Canal'}
class TNT_R4_498000(TNT_base) :
guardinterval="1/32"
coderate="2/3"
chaines = {
'120 130 110' : 'fra M6',
'220 230 210' : 'fra W9',
'320 330 310' : 'fra NT1'}
class TNT_R6_562000(TNT_base) :
guardinterval="1/32"
coderate="2/3"
chaines = {
'120 130 100' : 'fra TF1',
'220 230 231 200' : 'fra NRJ12'}

33
tv/sat_conf.py Executable file
View file

@ -0,0 +1,33 @@
#! /usr/bin/env python
# -*- coding: iso8859-15 -*-
""" Défini les transpondeurs à associer à chacune des cartes """
from sat_base import *
from socket import gethostname
host = gethostname()
conf = []
if host == 'canard' :
conf = [ TNT_R4_498000(0) ,
Hotbird_12476(1) ,
Hotbird_10911(2) ,
Hotbird_12597(3) ,
Hotbird_12577(4)
]
if host == 'lapin' :
conf = [ Hotbird_11727(0) ,
Hotbird_11604(1) ,
TNT_R1_586000(2) ,
TNT_R6_562000(3) ,
TNT_R2_474000(4) ,
TNT_R3_522000(5) ]
if host == 'oie' :
conf = [ Hotbird_12245(0) ,
Hotbird_11137(1) ,
Hotbird_10873(2) ,
Hotbird_11304(3) ,
Hotbird_11623(4) ]