<gh_stars>1-10
"""
pynorm - Python wrapper for NRL's libnorm
By: <NAME> <<EMAIL>>
"""

from __future__ import absolute_import

import ctypes
from select import select
from weakref import WeakValueDictionary
from platform import system
import sys

if system() == 'Windows':
    import win32event

import pynorm.constants as c
from pynorm.core import libnorm, NormError, NormEventStruct
from pynorm.session import Session
from pynorm.event import Event
from pynorm.node import Node
from pynorm.object import Object

class Instance(object):
    """Represents an instance of the NORM protocal engine"""

    def __init__(self, priorityBoost=False):
        """Creates a new instance of the NORM protocol engine"""
        self._instance = libnorm.NormCreateInstance(priorityBoost)
        self._sessions = dict()
        self._senders = WeakValueDictionary()
        self._objects = WeakValueDictionary()
        self._estruct = NormEventStruct()

        if system() == 'Windows':
            self._select = self._select_windows
        else:
            self._select = self._select_everythingelse

    ## Public functions
    def destroy(self):
        libnorm.NormDestroyInstance(self)

    def stop(self):
        libnorm.NormStopInstance(self)

    def restart(self):
        libnorm.NormRestartInstance(self)

    def setCacheDirectory(self, path):
        libnorm.NormSetCacheDirectory(self, path)
        
    def setDebugLevel(self, level):
        libnorm.NormSetDebugLevel(level)

    def openDebugLog(self, path):
        libnorm.NormOpenDebugLog(self, path)

    def closeDebugLog(self):
        libnorm.NormCloseDebugLog(self)

    def openDebugPipe(self, pipeName):
        libnorm.NormOpenDebugPipe(self, pipeName)

    def getNextEvent(self, timeout=None):
        # Use python's select because letting the C NormGetNextEvent block
        # seems to stop signals (CTRL+C) from killing the process
        if not self._select(timeout):
            return None

        result = libnorm.NormGetNextEvent(self, ctypes.byref(self._estruct), True)

        if not result:
            sys.stderr.write("NormInstance.getNextEvent() warning: no more NORM events\n")
            return False
        # Note a NORM_EVENT_INVALID can be OK (with NORM_SESSION_INVALID)    
        if self._estruct.type == c.NORM_EVENT_INVALID:
            return Event(c.NORM_EVENT_INVALID, None, None, None)
        
        if self._estruct.session == c.NORM_SESSION_INVALID:
            raise NormError("No new event")
        try:
            sender = self._senders[self._estruct.sender]
        except KeyError:
            sender = self._senders[self._estruct.sender] = Node(self._estruct.sender)
        try:
            object = self._objects[self._estruct.object]
        except KeyError:
            object = self._objects[self._estruct.object] = Object(self._estruct.object)
        return Event(self._estruct.type, self._sessions[self._estruct.session], sender, object)

    def getDescriptor(self):
        return libnorm.NormGetDescriptor(self)

    def fileno(self):
        return libnorm.NormGetDescriptor(self)

    def createSession(self, address, port, localId=None):
        if localId == None:
            localId = c.NORM_NODE_ANY
        session = Session(self, address, port, localId)
        self._sessions[session] = session
        return session

    ## Properties
    descriptor = property(getDescriptor)

    ## Private functions
    def __del__(self):
        del self._sessions
        self.destroy()

    def _select_windows(self, timeout):
        if timeout is None:
            timeout = win32event.INFINITE
        else:
            # Windows wants milliseconds...
            timeout *= 1000
        rv = win32event.WaitForSingleObject(self.getDescriptor(), timeout)
        return True if rv == win32event.WAIT_OBJECT_0 else False

    def _select_everythingelse(self, timeout):
        return True if select([self], [], [], timeout)[0] else False

    @property
    def _as_parameter_(self):
        """This is for ctypes, so we can pass this object into C functions"""
        return self._instance

    def __iter__(self):
        return self

    def next(self):
        """So you can iterate over the events."""
        try:
          return self.getNextEvent()
        except NormError:
          raise StopIteration

    def __cmp__(self, other):
        return cmp(self._as_parameter_, other._as_parameter)

    def __hash__(self):
        return self._as_parameter_

"""
pynorm - Python wrapper for NRL's libnorm
By: <NAME> <<EMAIL>>
"""

from __future__ import absolute_import

import ctypes
from select import select
from weakref import WeakValueDictionary
from platform import system
import sys

if system() == 'Windows':
    import win32event

import pynorm.constants as c
from pynorm.core import libnorm, NormError, NormEventStruct
from pynorm.session import Session
from pynorm.event import Event
from pynorm.node import Node
from pynorm.object import Object

class Instance(object):
    """Represents an instance of the NORM protocal engine"""

    def __init__(self, priorityBoost=False):
        """Creates a new instance of the NORM protocol engine"""
        self._instance = libnorm.NormCreateInstance(priorityBoost)
        self._sessions = dict()
        self._senders = WeakValueDictionary()
        self._objects = WeakValueDictionary()
        self._estruct = NormEventStruct()

        if system() == 'Windows':
            self._select = self._select_windows
        else:
            self._select = self._select_everythingelse

    ## Public functions
    def destroy(self):
        libnorm.NormDestroyInstance(self)

    def stop(self):
        libnorm.NormStopInstance(self)

    def restart(self):
        libnorm.NormRestartInstance(self)

    def setCacheDirectory(self, path):
        libnorm.NormSetCacheDirectory(self, path)
        
    def setDebugLevel(self, level):
        libnorm.NormSetDebugLevel(level)

    def openDebugLog(self, path):
        libnorm.NormOpenDebugLog(self, path)

    def closeDebugLog(self):
        libnorm.NormCloseDebugLog(self)

    def openDebugPipe(self, pipeName):
        libnorm.NormOpenDebugPipe(self, pipeName)

    def getNextEvent(self, timeout=None):
        # Use python's select because letting the C NormGetNextEvent block
        # seems to stop signals (CTRL+C) from killing the process
        if not self._select(timeout):
            return None

        result = libnorm.NormGetNextEvent(self, ctypes.byref(self._estruct), True)

        if not result:
            sys.stderr.write("NormInstance.getNextEvent() warning: no more NORM events\n")
            return False
        # Note a NORM_EVENT_INVALID can be OK (with NORM_SESSION_INVALID)    
        if self._estruct.type == c.NORM_EVENT_INVALID:
            return Event(c.NORM_EVENT_INVALID, None, None, None)
        
        if self._estruct.session == c.NORM_SESSION_INVALID:
            raise NormError("No new event")
        try:
            sender = self._senders[self._estruct.sender]
        except KeyError:
            sender = self._senders[self._estruct.sender] = Node(self._estruct.sender)
        try:
            object = self._objects[self._estruct.object]
        except KeyError:
            object = self._objects[self._estruct.object] = Object(self._estruct.object)
        return Event(self._estruct.type, self._sessions[self._estruct.session], sender, object)

    def getDescriptor(self):
        return libnorm.NormGetDescriptor(self)

    def fileno(self):
        return libnorm.NormGetDescriptor(self)

    def createSession(self, address, port, localId=None):
        if localId == None:
            localId = c.NORM_NODE_ANY
        session = Session(self, address, port, localId)
        self._sessions[session] = session
        return session

    ## Properties
    descriptor = property(getDescriptor)

    ## Private functions
    def __del__(self):
        del self._sessions
        self.destroy()

    def _select_windows(self, timeout):
        if timeout is None:
            timeout = win32event.INFINITE
        else:
            # Windows wants milliseconds...
            timeout *= 1000
        rv = win32event.WaitForSingleObject(self.getDescriptor(), timeout)
        return True if rv == win32event.WAIT_OBJECT_0 else False

    def _select_everythingelse(self, timeout):
        return True if select([self], [], [], timeout)[0] else False

    @property
    def _as_parameter_(self):
        """This is for ctypes, so we can pass this object into C functions"""
        return self._instance

    def __iter__(self):
        return self

    def next(self):
        """So you can iterate over the events."""
        try:
          return self.getNextEvent()
        except NormError:
          raise StopIteration

    def __cmp__(self, other):
        return cmp(self._as_parameter_, other._as_parameter)

    def __hash__(self):
        return self._as_parameter_
pynorm - Python wrapper for NRL's libnorm By: <NAME> <<EMAIL>> Represents an instance of the NORM protocal engine Creates a new instance of the NORM protocol engine ## Public functions # Use python's select because letting the C NormGetNextEvent block # seems to stop signals (CTRL+C) from killing the process # Note a NORM_EVENT_INVALID can be OK (with NORM_SESSION_INVALID) ## Properties ## Private functions # Windows wants milliseconds... This is for ctypes, so we can pass this object into C functions So you can iterate over the events.