Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- moteinotest.py(10): mynetwork = MoteinoNetwork(port='/dev/ttyAMA0', frequency=MoteinoNetwork.RF69_868MHZ, high_power=False, network_id=1, base_id=1, encryption_key='0123456789abcdef')
- --- modulename: moteino23, funcname: __init__
- moteino23.py(518): if port is None:
- moteino23.py(521): self._Serial = MySerial(port=port, baudrate=115200)
- --- modulename: moteino23, funcname: __init__
- moteino23.py(19): self.Serial = serial.Serial(**kwargs)
- --- modulename: serialutil, funcname: __init__
- serialutil.py(196): self.is_open = False
- serialutil.py(197): self.portstr = None
- serialutil.py(198): self.name = None
- serialutil.py(200): self._port = None
- serialutil.py(201): self._baudrate = None
- serialutil.py(202): self._bytesize = None
- serialutil.py(203): self._parity = None
- serialutil.py(204): self._stopbits = None
- serialutil.py(205): self._timeout = None
- serialutil.py(206): self._write_timeout = None
- serialutil.py(207): self._xonxoff = None
- serialutil.py(208): self._rtscts = None
- serialutil.py(209): self._dsrdtr = None
- serialutil.py(210): self._inter_byte_timeout = None
- serialutil.py(211): self._rs485_mode = None # disabled by default
- serialutil.py(212): self._rts_state = True
- serialutil.py(213): self._dtr_state = True
- serialutil.py(214): self._break_state = False
- serialutil.py(215): self._exclusive = None
- serialutil.py(218): self.port = port
- --- modulename: serialutil, funcname: port
- serialutil.py(263): if port is not None and not isinstance(port, basestring):
- serialutil.py(265): was_open = self.is_open
- serialutil.py(266): if was_open:
- serialutil.py(268): self.portstr = port
- serialutil.py(269): self._port = port
- serialutil.py(270): self.name = self.portstr
- serialutil.py(271): if was_open:
- serialutil.py(219): self.baudrate = baudrate
- --- modulename: serialutil, funcname: baudrate
- serialutil.py(286): try:
- serialutil.py(287): b = int(baudrate)
- serialutil.py(291): if b < 0:
- serialutil.py(293): self._baudrate = b
- serialutil.py(294): if self.is_open:
- serialutil.py(220): self.bytesize = bytesize
- --- modulename: serialutil, funcname: bytesize
- serialutil.py(305): if bytesize not in self.BYTESIZES:
- serialutil.py(307): self._bytesize = bytesize
- serialutil.py(308): if self.is_open:
- serialutil.py(221): self.parity = parity
- --- modulename: serialutil, funcname: parity
- serialutil.py(331): if parity not in self.PARITIES:
- serialutil.py(333): self._parity = parity
- serialutil.py(334): if self.is_open:
- serialutil.py(222): self.stopbits = stopbits
- --- modulename: serialutil, funcname: stopbits
- serialutil.py(345): if stopbits not in self.STOPBITS:
- serialutil.py(347): self._stopbits = stopbits
- serialutil.py(348): if self.is_open:
- serialutil.py(223): self.timeout = timeout
- --- modulename: serialutil, funcname: timeout
- serialutil.py(359): if timeout is not None:
- serialutil.py(366): self._timeout = timeout
- serialutil.py(367): if self.is_open:
- serialutil.py(224): self.write_timeout = write_timeout
- --- modulename: serialutil, funcname: write_timeout
- serialutil.py(378): if timeout is not None:
- serialutil.py(386): self._write_timeout = timeout
- serialutil.py(387): if self.is_open:
- serialutil.py(225): self.xonxoff = xonxoff
- --- modulename: serialutil, funcname: xonxoff
- serialutil.py(418): self._xonxoff = xonxoff
- serialutil.py(419): if self.is_open:
- serialutil.py(226): self.rtscts = rtscts
- --- modulename: serialutil, funcname: rtscts
- serialutil.py(430): self._rtscts = rtscts
- serialutil.py(431): if self.is_open:
- serialutil.py(227): self.dsrdtr = dsrdtr
- --- modulename: serialutil, funcname: dsrdtr
- serialutil.py(442): if dsrdtr is None:
- serialutil.py(447): self._dsrdtr = dsrdtr
- serialutil.py(448): if self.is_open:
- serialutil.py(228): self.inter_byte_timeout = inter_byte_timeout
- --- modulename: serialutil, funcname: inter_byte_timeout
- serialutil.py(398): if ic_timeout is not None:
- serialutil.py(406): self._inter_byte_timeout = ic_timeout
- serialutil.py(407): if self.is_open:
- serialutil.py(229): self.exclusive = exclusive
- --- modulename: serialutil, funcname: exclusive
- serialutil.py(319): self._exclusive = exclusive
- serialutil.py(320): if self.is_open:
- serialutil.py(232): if 'writeTimeout' in kwargs:
- serialutil.py(234): if 'interCharTimeout' in kwargs:
- serialutil.py(236): if kwargs:
- serialutil.py(239): if port is not None:
- serialutil.py(240): self.open()
- --- modulename: serialposix, funcname: open
- serialposix.py(258): if self._port is None:
- serialposix.py(260): if self.is_open:
- serialposix.py(262): self.fd = None
- serialposix.py(264): try:
- serialposix.py(265): self.fd = os.open(self.portstr, os.O_RDWR | os.O_NOCTTY | os.O_NONBLOCK)
- serialposix.py(271): try:
- serialposix.py(272): self._reconfigure_port(force_update=True)
- --- modulename: serialposix, funcname: _reconfigure_port
- serialposix.py(303): if self.fd is None:
- serialposix.py(307): if self._exclusive is not None:
- serialposix.py(316): custom_baud = None
- serialposix.py(318): vmin = vtime = 0 # timeout is done via select
- serialposix.py(319): if self._inter_byte_timeout is not None:
- serialposix.py(322): try:
- serialposix.py(323): orig_attr = termios.tcgetattr(self.fd)
- serialposix.py(324): iflag, oflag, cflag, lflag, ispeed, ospeed, cc = orig_attr
- serialposix.py(328): cflag |= (termios.CLOCAL | termios.CREAD)
- serialposix.py(329): lflag &= ~(termios.ICANON | termios.ECHO | termios.ECHOE |
- serialposix.py(331): termios.ISIG | termios.IEXTEN) # |termios.ECHOPRT
- serialposix.py(332): for flag in ('ECHOCTL', 'ECHOKE'): # netbsd workaround for Erk
- serialposix.py(333): if hasattr(termios, flag):
- serialposix.py(334): lflag &= ~getattr(termios, flag)
- serialposix.py(332): for flag in ('ECHOCTL', 'ECHOKE'): # netbsd workaround for Erk
- serialposix.py(333): if hasattr(termios, flag):
- serialposix.py(334): lflag &= ~getattr(termios, flag)
- serialposix.py(332): for flag in ('ECHOCTL', 'ECHOKE'): # netbsd workaround for Erk
- serialposix.py(336): oflag &= ~(termios.OPOST | termios.ONLCR | termios.OCRNL)
- serialposix.py(337): iflag &= ~(termios.INLCR | termios.IGNCR | termios.ICRNL | termios.IGNBRK)
- serialposix.py(338): if hasattr(termios, 'IUCLC'):
- serialposix.py(339): iflag &= ~termios.IUCLC
- serialposix.py(340): if hasattr(termios, 'PARMRK'):
- serialposix.py(341): iflag &= ~termios.PARMRK
- serialposix.py(344): try:
- serialposix.py(345): ispeed = ospeed = getattr(termios, 'B{}'.format(self._baudrate))
- serialposix.py(362): cflag &= ~termios.CSIZE
- serialposix.py(363): if self._bytesize == 8:
- serialposix.py(364): cflag |= termios.CS8
- serialposix.py(374): if self._stopbits == serial.STOPBITS_ONE:
- serialposix.py(375): cflag &= ~(termios.CSTOPB)
- serialposix.py(383): iflag &= ~(termios.INPCK | termios.ISTRIP)
- serialposix.py(384): if self._parity == serial.PARITY_NONE:
- serialposix.py(385): cflag &= ~(termios.PARENB | termios.PARODD | CMSPAR)
- serialposix.py(401): if hasattr(termios, 'IXANY'):
- serialposix.py(402): if self._xonxoff:
- serialposix.py(405): iflag &= ~(termios.IXON | termios.IXOFF | termios.IXANY)
- serialposix.py(412): if hasattr(termios, 'CRTSCTS'):
- serialposix.py(413): if self._rtscts:
- serialposix.py(416): cflag &= ~(termios.CRTSCTS)
- serialposix.py(426): if vmin < 0 or vmin > 255:
- serialposix.py(428): cc[termios.VMIN] = vmin
- serialposix.py(430): if vtime < 0 or vtime > 255:
- serialposix.py(432): cc[termios.VTIME] = vtime
- serialposix.py(434): if force_update or [iflag, oflag, cflag, lflag, ispeed, ospeed, cc] != orig_attr:
- serialposix.py(435): termios.tcsetattr(
- serialposix.py(436): self.fd,
- serialposix.py(437): termios.TCSANOW,
- serialposix.py(438): [iflag, oflag, cflag, lflag, ispeed, ospeed, cc])
- serialposix.py(441): if custom_baud is not None:
- serialposix.py(444): if self._rs485_mode is not None:
- serialposix.py(283): self.is_open = True
- serialposix.py(284): try:
- serialposix.py(285): if not self._dsrdtr:
- serialposix.py(286): self._update_dtr_state()
- --- modulename: serialposix, funcname: _update_dtr_state
- serialposix.py(633): if self._dtr_state:
- serialposix.py(634): fcntl.ioctl(self.fd, TIOCMBIS, TIOCM_DTR_str)
- serialposix.py(287): if not self._rtscts:
- serialposix.py(288): self._update_rts_state()
- --- modulename: serialposix, funcname: _update_rts_state
- serialposix.py(626): if self._rts_state:
- serialposix.py(627): fcntl.ioctl(self.fd, TIOCMBIS, TIOCM_RTS_str)
- serialposix.py(295): self.reset_input_buffer()
- --- modulename: serialposix, funcname: reset_input_buffer
- serialposix.py(593): if not self.is_open:
- serialposix.py(595): termios.tcflush(self.fd, termios.TCIFLUSH)
- serialposix.py(296): self.pipe_abort_read_r, self.pipe_abort_read_w = os.pipe()
- serialposix.py(297): self.pipe_abort_write_r, self.pipe_abort_write_w = os.pipe()
- serialposix.py(298): fcntl.fcntl(self.pipe_abort_read_r, fcntl.F_SETFL, os.O_NONBLOCK)
- serialposix.py(299): fcntl.fcntl(self.pipe_abort_write_r, fcntl.F_SETFL, os.O_NONBLOCK)
- moteino23.py(20): self.read = self.Serial.read
- moteino23.py(21): self.readline = self.Serial.readline
- moteino23.py(22): self.isOpen = self.Serial.isOpen
- moteino23.py(23): self.open = self.Serial.open
- moteino23.py(24): self.close = self.Serial.close
- moteino23.py(523): if init_base:
- moteino23.py(524): self._initiate_base(frequency, high_power, network_id, base_id, encryption_key, promiscous_mode)
- --- modulename: moteino23, funcname: _initiate_base
- moteino23.py(566): self._Serial.write('X') # send reset sign
- --- modulename: moteino23, funcname: write
- moteino23.py(27): if isinstance(s, unicode):
- moteino23.py(30): self.Serial.write(s)
- --- modulename: serialposix, funcname: write
- serialposix.py(530): if not self.is_open:
- serialposix.py(532): d = to_bytes(data)
- --- modulename: serialutil, funcname: to_bytes
- serialutil.py(56): if isinstance(seq, bytes):
- serialutil.py(57): return seq
- serialposix.py(533): tx_len = length = len(d)
- serialposix.py(534): timeout = Timeout(self._write_timeout)
- --- modulename: serialutil, funcname: __init__
- serialutil.py(125): self.is_infinite = (duration is None)
- serialutil.py(126): self.is_non_blocking = (duration == 0)
- serialutil.py(127): self.duration = duration
- serialutil.py(128): if duration is not None:
- serialutil.py(131): self.target_time = None
- serialposix.py(535): while tx_len > 0:
- serialposix.py(536): try:
- serialposix.py(537): n = os.write(self.fd, d)
- serialposix.py(538): if timeout.is_non_blocking:
- serialposix.py(542): elif not timeout.is_infinite:
- serialposix.py(554): assert timeout.time_left() is None
- --- modulename: serialutil, funcname: time_left
- serialutil.py(139): if self.is_non_blocking:
- serialutil.py(141): elif self.is_infinite:
- serialutil.py(142): return None
- serialposix.py(556): abort, ready, _ = select.select([self.pipe_abort_write_r], [self.fd], [], None)
- serialposix.py(557): if abort:
- serialposix.py(560): if not ready:
- serialposix.py(562): d = d[n:]
- serialposix.py(563): tx_len -= n
- serialposix.py(578): if not timeout.is_non_blocking and timeout.expired():
- --- modulename: serialutil, funcname: expired
- serialutil.py(135): return self.target_time is not None and self.time_left() <= 0
- serialposix.py(535): while tx_len > 0:
- serialposix.py(580): return length - len(d)
- moteino23.py(567): logging.debug("Restarting base")
- --- modulename: __init__, funcname: debug
- __init__.py(1628): if len(root.handlers) == 0:
- __init__.py(1629): basicConfig()
- --- modulename: __init__, funcname: basicConfig
- __init__.py(1534): _acquireLock()
- --- modulename: __init__, funcname: _acquireLock
- __init__.py(217): if _lock:
- __init__.py(218): _lock.acquire()
- --- modulename: threading, funcname: acquire
- threading.py(168): me = _get_ident()
- threading.py(169): if self.__owner == me:
- threading.py(174): rc = self.__block.acquire(blocking)
- threading.py(175): if rc:
- threading.py(176): self.__owner = me
- threading.py(177): self.__count = 1
- threading.py(179): self._note("%s.acquire(%s): initial success", self, blocking)
- --- modulename: threading, funcname: _note
- threading.py(65): if self.__verbose:
- threading.py(183): return rc
- __init__.py(1535): try:
- __init__.py(1536): if len(root.handlers) == 0:
- __init__.py(1537): filename = kwargs.get("filename")
- __init__.py(1538): if filename:
- __init__.py(1542): stream = kwargs.get("stream")
- __init__.py(1543): hdlr = StreamHandler(stream)
- --- modulename: __init__, funcname: __init__
- __init__.py(831): Handler.__init__(self)
- --- modulename: __init__, funcname: __init__
- __init__.py(668): Filterer.__init__(self)
- --- modulename: __init__, funcname: __init__
- __init__.py(589): self.filters = []
- __init__.py(669): self._name = None
- __init__.py(670): self.level = _checkLevel(level)
- --- modulename: __init__, funcname: _checkLevel
- __init__.py(184): if isinstance(level, (int, long)):
- __init__.py(185): rv = level
- __init__.py(192): return rv
- __init__.py(671): self.formatter = None
- __init__.py(673): _addHandlerRef(self)
- --- modulename: __init__, funcname: _addHandlerRef
- __init__.py(648): _acquireLock()
- --- modulename: __init__, funcname: _acquireLock
- __init__.py(217): if _lock:
- __init__.py(218): _lock.acquire()
- --- modulename: threading, funcname: acquire
- threading.py(168): me = _get_ident()
- threading.py(169): if self.__owner == me:
- threading.py(170): self.__count = self.__count + 1
- threading.py(172): self._note("%s.acquire(%s): recursive success", self, blocking)
- --- modulename: threading, funcname: _note
- threading.py(65): if self.__verbose:
- threading.py(173): return 1
- __init__.py(649): try:
- __init__.py(650): _handlerList.append(weakref.ref(handler, _removeHandlerRef))
- __init__.py(652): _releaseLock()
- --- modulename: __init__, funcname: _releaseLock
- __init__.py(224): if _lock:
- __init__.py(225): _lock.release()
- --- modulename: threading, funcname: release
- threading.py(203): if self.__owner != _get_ident():
- threading.py(205): self.__count = count = self.__count - 1
- threading.py(206): if not count:
- threading.py(213): self._note("%s.release(): non-final release", self)
- --- modulename: threading, funcname: _note
- threading.py(65): if self.__verbose:
- __init__.py(674): self.createLock()
- --- modulename: __init__, funcname: createLock
- __init__.py(696): if thread:
- __init__.py(697): self.lock = threading.RLock()
- --- modulename: threading, funcname: RLock
- threading.py(123): return _RLock(*args, **kwargs)
- --- modulename: threading, funcname: __init__
- threading.py(133): _Verbose.__init__(self, verbose)
- --- modulename: threading, funcname: __init__
- threading.py(60): if verbose is None:
- threading.py(61): verbose = _VERBOSE
- threading.py(62): self.__verbose = verbose
- threading.py(134): self.__block = _allocate_lock()
- threading.py(135): self.__owner = None
- threading.py(136): self.__count = 0
- __init__.py(832): if stream is None:
- __init__.py(833): stream = sys.stderr
- __init__.py(834): self.stream = stream
- __init__.py(1544): fs = kwargs.get("format", BASIC_FORMAT)
- __init__.py(1545): dfs = kwargs.get("datefmt", None)
- __init__.py(1546): fmt = Formatter(fs, dfs)
- --- modulename: __init__, funcname: __init__
- __init__.py(405): if fmt:
- __init__.py(406): self._fmt = fmt
- __init__.py(409): self.datefmt = datefmt
- __init__.py(1547): hdlr.setFormatter(fmt)
- --- modulename: __init__, funcname: setFormatter
- __init__.py(766): self.formatter = fmt
- __init__.py(1548): root.addHandler(hdlr)
- --- modulename: __init__, funcname: addHandler
- __init__.py(1295): _acquireLock()
- --- modulename: __init__, funcname: _acquireLock
- __init__.py(217): if _lock:
- __init__.py(218): _lock.acquire()
- --- modulename: threading, funcname: acquire
- threading.py(168): me = _get_ident()
- threading.py(169): if self.__owner == me:
- threading.py(170): self.__count = self.__count + 1
- threading.py(172): self._note("%s.acquire(%s): recursive success", self, blocking)
- --- modulename: threading, funcname: _note
- threading.py(65): if self.__verbose:
- threading.py(173): return 1
- __init__.py(1296): try:
- __init__.py(1297): if not (hdlr in self.handlers):
- __init__.py(1298): self.handlers.append(hdlr)
- __init__.py(1300): _releaseLock()
- --- modulename: __init__, funcname: _releaseLock
- __init__.py(224): if _lock:
- __init__.py(225): _lock.release()
- --- modulename: threading, funcname: release
- threading.py(203): if self.__owner != _get_ident():
- threading.py(205): self.__count = count = self.__count - 1
- threading.py(206): if not count:
- threading.py(213): self._note("%s.release(): non-final release", self)
- --- modulename: threading, funcname: _note
- threading.py(65): if self.__verbose:
- __init__.py(1549): level = kwargs.get("level")
- __init__.py(1550): if level is not None:
- __init__.py(1553): _releaseLock()
- --- modulename: __init__, funcname: _releaseLock
- __init__.py(224): if _lock:
- __init__.py(225): _lock.release()
- --- modulename: threading, funcname: release
- threading.py(203): if self.__owner != _get_ident():
- threading.py(205): self.__count = count = self.__count - 1
- threading.py(206): if not count:
- threading.py(207): self.__owner = None
- threading.py(208): self.__block.release()
- threading.py(210): self._note("%s.release(): final release", self)
- --- modulename: threading, funcname: _note
- threading.py(65): if self.__verbose:
- __init__.py(1630): root.debug(msg, *args, **kwargs)
- --- modulename: __init__, funcname: debug
- __init__.py(1147): if self.isEnabledFor(DEBUG):
- --- modulename: __init__, funcname: isEnabledFor
- __init__.py(1357): if self.manager.disable >= level:
- __init__.py(1359): return level >= self.getEffectiveLevel()
- --- modulename: __init__, funcname: getEffectiveLevel
- __init__.py(1346): logger = self
- __init__.py(1347): while logger:
- __init__.py(1348): if logger.level:
- __init__.py(1349): return logger.level
- moteino23.py(568): time.sleep(0.6) # sleep for 0.6 seconds, bootloader uses 0.5 seconds
- moteino23.py(569): logging.debug("Waiting for wakeup sign from base...")
- --- modulename: __init__, funcname: debug
- __init__.py(1628): if len(root.handlers) == 0:
- __init__.py(1630): root.debug(msg, *args, **kwargs)
- --- modulename: __init__, funcname: debug
- __init__.py(1147): if self.isEnabledFor(DEBUG):
- --- modulename: __init__, funcname: isEnabledFor
- __init__.py(1357): if self.manager.disable >= level:
- __init__.py(1359): return level >= self.getEffectiveLevel()
- --- modulename: __init__, funcname: getEffectiveLevel
- __init__.py(1346): logger = self
- __init__.py(1347): while logger:
- __init__.py(1348): if logger.level:
- __init__.py(1349): return logger.level
- moteino23.py(570): incoming = self._Serial.readline().rstrip()
- --- modulename: serialposix, funcname: read
- serialposix.py(477): if not self.is_open:
- serialposix.py(479): read = bytearray()
- serialposix.py(480): timeout = Timeout(self._timeout)
- --- modulename: serialutil, funcname: __init__
- serialutil.py(125): self.is_infinite = (duration is None)
- serialutil.py(126): self.is_non_blocking = (duration == 0)
- serialutil.py(127): self.duration = duration
- serialutil.py(128): if duration is not None:
- serialutil.py(131): self.target_time = None
- serialposix.py(481): while len(read) < size:
- serialposix.py(482): try:
- serialposix.py(483): ready, _, _ = select.select([self.fd, self.pipe_abort_read_r], [], [], timeout.time_left())
- --- modulename: serialutil, funcname: time_left
- serialutil.py(139): if self.is_non_blocking:
- serialutil.py(141): elif self.is_infinite:
- serialutil.py(142): return None
Advertisement
Add Comment
Please, Sign In to add comment