tiagocoutinho

"""
Demonstrate usage of TANGO DS with gevent.

Usage example: Go to jive and in the menu select Edit->Create server, then 
fill in the fields:
Server (ServerName/Instance): GeventDS/test1
Class: Gevent
Devices: test/gevent/1

click Register server.

tiagocoutinho

# -*- coding: utf-8 -*-
#
# This file is part of the CT2 project
#
# Copyright 2015 European Synchrotron Radiation Facility, Grenoble, France
#
# Distributed under the terms of the LGPL license.
# See LICENSE.txt for more info.

""" CT2 (P201/C208) ESRF counter card

tiagocoutinho

'''
An implementation object proxy pattern in python

Example::
    from proxy import Proxy
    
    class A(object):
      def __init__(self, base):
        self.base = base
      def plus(self, *a):

tiagocoutinho

# -*- coding: utf-8 -*-

import time
import collections


class Motor(object):

    Motion = collections.namedtuple('Motion', 'ipos fpos start_time end_time')

tiagocoutinho

#!/usr/bin/env python3

import time
import random
import logging
import gevent.server

DEFAULT_BIND = ''
DEFAULT_PORT = 45000

tiagocoutinho

import hexdump


def binaries_gen(binaries):
    """                                                                                               
    Generates a sequence of bytes from a seq<(offset, bytes)>                                         
    If there are gaps between the bytes the generator yields N None where N is                        
    the length of the gap                                                                             
                                                                                                      
    Example::                                                                                         

tiagocoutinho

"""
tsb.py -- A telnet <-> serial port bridge
Copyright (C) 2005 Eli Fulkerson

This program is free software; you can redistribute it and/or
modify it under the terms of the GNU General Public License
as published by the Free Software Foundation; either version 2
of the License, or (at your option) any later version.

This program is distributed in the hope that it will be useful,

tiagocoutinho

# I dare you to find an execution that prints out 0
# (at least using the CPython implementation)
from threading import Thread

C, N = 0, 1_000_000

def f(inc=1):
    global C, N
    for i in range(N):
        C += inc

tiagocoutinho

"""
Safe XML RPC calls in multiple gevent tasks. Basically, it serializes calls.

Assuming you are running a server like this::

  import time
  from SimpleXMLRPCServer import SimpleXMLRPCServer

  def is_even(n):
      time.sleep(3)

tiagocoutinho

import time
import random
import threading

def sleep():
    time.sleep(random.random())

N = 5
sticks = [threading.Lock() for n in range(N)]