summaryrefslogtreecommitdiff
path: root/misc/mon_ami/mon_ami_server.py
blob: d3d7c0f4afb230f59c4d925789f2011ab23933c1 (plain)
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
# -*- coding: utf-8 -*-
# MonAMI Asterisk Manger Interface Server
# Asterisk AMI Emulator server thread
# (c) AMOOMA GmbH 2012-2013

from threading import Thread
from log import ldebug, linfo, lwarn, lerror, lcritic
from time import sleep
from traceback import format_exc
from tcp_server import TCPServer
from mon_ami_handler import MonAMIHandler
import socket

class MonAMIServer(Thread):

  def __init__(self, address=None, port=None, event_socket=None):
    Thread.__init__(self)
    self.runthread = True
    self.port = port
    self.address = address
    self.event_socket = event_socket
    self.handler_threads = {}
    self.user_password_authentication = None

  def stop(self):
    ldebug('thread stop', self)
    ldebug('client connections: %s' % len(self.handler_threads), self)
    for thread_id, handler_thread in self.handler_threads.items():
      if handler_thread.isAlive():
        handler_thread.stop()
    self.runthread = False

  def register_handler_thread(self, handler_thread):
    if handler_thread.isAlive():
      ldebug('registering handler thread %d ' % id(handler_thread), self)
      self.handler_threads[id(handler_thread)] = handler_thread
    else:
      lwarn('handler thread passed away: %d' % id(handler_thread), self)


  def deregister_handler_thread(self, handler_thread):
    if id(handler_thread) in self.handler_threads:
      ldebug('deregistering handler thread %d ' % id(handler_thread), self)
      del self.handler_threads[id(handler_thread)]
    else:
      lwarn('handler thread %d not registered' % id(handler_thread), self)


  def run(self):
    ldebug('starting MonAMI server thread', self)
    serversocket = TCPServer(self.address, self.port).listen()
    #serversocket.setblocking(0)

    if not serversocket:
      ldebug('server socket could not be bound', self)
      return 1

    while self.runthread:
      try:
        client_socket, client_address = serversocket.accept()
      except socket.timeout as exception:
          # Socket timeout occured
          continue
      except socket.error as exception:
        lerror('socket error (%s): %s - ' % (exception, format_exc()), self)
        sleep(1)
        continue
      except:
        lerror('general error: %s - ' % format_exc(), self)
        sleep(1)
        continue

      ldebug('connected to %s:%d' % client_address, self)

      client_thread = MonAMIHandler(client_socket, client_address, self.event_socket)
      client_thread.deregister_at_server = self.deregister_handler_thread
      client_thread.user_password_authentication = self.user_password_authentication
      client_thread.start()
      if client_thread.isAlive():
        self.register_handler_thread(client_thread)

      ldebug('registered handler threads: %d' % len(self.handler_threads), self)      

    ldebug('exiting MonAMI server thread', self)