#!/usr/bin/env python
"""
Example script that executes jobs via a pool of job servers and prints the
results when they become ready ... not in any predetermined order.
"""

import pp

from random import randint


def sleep(name, wait):
    """
    Example function to run as a job.
    """
    time.sleep(wait)
    return "%s (%s)" %(name, wait)


def main():
    """
    Main function.
    """
    # Pool of ppservers to use as a 'server'
    job_server = pp.Server(ppservers=('127.0.0.1', ))

    # Array of all submitted jobs
    jobs = []
    #                            Function  Params                 Libs/Modules 
    #                               v       v                          v 
    jobs.append(job_server.submit(sleep, ('f1', randint(3,15)), (), ('time',)))
    jobs.append(job_server.submit(sleep, ('f2', randint(3,15)), (), ('time',)))
    jobs.append(job_server.submit(sleep, ('f3', randint(3,15)), (), ('time',)))
    jobs.append(job_server.submit(sleep, ('f4', randint(3,15)), (), ('time',)))

    # Loop
    while True:
        jobs_len = len(jobs)
        # For each job ...
        for x in range(jobs_len):
            # See if it's finished
            if jobs[x].finished == True:
                # If so, print the result, delete the job and loop again
                print jobs[x]()
                del jobs[x]
                break
        # All out of jobs? Exit!
        if jobs_len == 0:
            raise SystemExit(0)


if __name__ == '__main__':
    main()

[steve@tachikoman ~]$ python ppexample.py
f4 (3)
f1 (4)
f3 (6)
f2 (11)
[steve@tachikoman ~]$ python ppexample.py
f4 (3)
f3 (3)
f1 (4)
f2 (9)
[steve@tachikoman ~]$ python ppexamples.py 
f1 (7)
f4 (8)
f2 (13)
f3 (14)

[steve@tachikoman director]$ date; ~/jython2.5a3/jython setup.py build; \
~/jython2.5a3/jython setup.py test; date
Sun Oct 12 16:32:49 EDT 2008
running build
running build_py
creating build
creating build/lib
creating build/lib/director
copying src/director/__init__.py -> build/lib/director
copying src/director/decorators.py -> build/lib/director
copying src/director/filter.py -> build/lib/director
running test
test_parse_options (tests.test_director.ActionRunnerTests) ... ok
test_run_code (tests.test_director.ActionRunnerTests) ... ok
test_run_with_filter (tests.test_director.ActionRunnerTests) ... ok
test__action_help (tests.test_director.ActionTests) ... ok
test__list_verbs (tests.test_director.ActionTests) ... ok
test_description (tests.test_director.ActionTests) ... ok
test_help (tests.test_director.ActionTests) ... ok
test_filter (tests.test_filter.ExceptionFilterTests) ... ok
test_execute_filters (tests.test_filter.FilterTests) ... ok
test_register_filter (tests.test_filter.FilterTests) ... ok
test_general_help (tests.test_decorators.ActionTests) ... ok
test_simple_help (tests.test_decorators.ActionTests) ... ok

----------------------------------------------------------------------
Ran 12 tests in 0.235s

OK
Sun Oct 12 16:32:55 EDT 2008
[steve@tachikoman director]$ 

[steve@tachikoman director]$ rm -rf build/
[steve@tachikoman director]$ date; ./setup.py build; ./setup.py test; date
Sun Oct 12 16:34:30 EDT 2008
running build
running build_py
creating build
creating build/lib
creating build/lib/director
copying src/director/__init__.py -> build/lib/director
copying src/director/decorators.py -> build/lib/director
copying src/director/filter.py -> build/lib/director
running test
test_parse_options (tests.test_director.ActionRunnerTests) ... ok
test_run_code (tests.test_director.ActionRunnerTests) ... ok
test_run_with_filter (tests.test_director.ActionRunnerTests) ... ok
test__action_help (tests.test_director.ActionTests) ... ok
test__list_verbs (tests.test_director.ActionTests) ... ok
test_description (tests.test_director.ActionTests) ... ok
test_help (tests.test_director.ActionTests) ... ok
test_filter (tests.test_filter.ExceptionFilterTests) ... ok
test_execute_filters (tests.test_filter.FilterTests) ... ok
test_register_filter (tests.test_filter.FilterTests) ... ok
test_general_help (tests.test_decorators.ActionTests) ... ok
test_simple_help (tests.test_decorators.ActionTests) ... ok

----------------------------------------------------------------------
Ran 12 tests in 0.009s

OK
Sun Oct 12 16:34:30 EDT 2008

# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements.  See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership.  The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License.  You may obtain a copy of the License at
# 
#   http://www.apache.org/licenses/LICENSE-2.0
# 
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied.  See the License for the
# specific language governing permissions and limitations
# under the License.
"""
Qpid related classes.
"""

from qpid.util import connect
from qpid.connection import Connection
from qpid.datatypes import uuid4
from qpid.queue import Empty


class QPIDConnectionManager(object):
    """
    QPID Connection manager.
    """

    def __init__(self, host, port, user,
                 password, uuid=uuid4(), auto_connect=False):
        """
        Constructor.

        :host is the hostname to connect to.
        :port is the port to connect to.
        :user is the username to authenticate with.
        :password is the password to authenticate with.
        :uuid is the uuid4 to use.
        :auto_connect lets you skip using the connect method yourself.
        """
        # Set up variables
        self.host = host
        self.port = int(port)
        self.user = user
        self.password = password
        self.uuid = str(uuid)

        # Defaults for internal variables
        self._socket = None
        self._connection = None
        self._session = None

        # Honor autoconnect
        if auto_connect:
            self.connect()

    def __str__(self):
        """
        String representation of the object.
        """
        return '<QPID "%s@%s:%s">' % (self.user, self.host, self.port)

    def _is_closed(self):
        """
        Internal check to see if the connection is closed.
        """
        if self._session == None:
            return True
        return False

    def __del__(self):
        """
        Clean up after your own mess, boy!
        """
        if not self.closed:
            self.disconnect()

    def connect(self):
        """
        Connects based on the information inside the object.
        """
        self._socket = connect(self.host, self.port)
        self._connection = Connection(sock=self._socket)
        self._connection.start()
        self._session = self._connection.session(self.uuid)

    def disconnect(self, timeout=10):
        """
        Cleanly disconnect from the server.

        :timeout is the amount of seconds to wait for disconnection.
        """
        self._session.close(timeout=timeout)
        self._connection.close()
        self._socket.close()
        self._session = None

    # All properties
    session = property(lambda self: self._session)
    closed = property(lambda self: self._is_closed())

#!/usr/bin/env python

# Only needed in 2.5
from __future__ import with_statement


class Alsome(object):
    """
    An alsome object to use with a with statement.
    """

    def __enter__(self):
        """
        Executed at the point of with'ing. We return outselves so that we can
        use this object like "with Alsome() as a:"
        """
        print "Entering ..."
        return self

    def __exit__(self, ttype, value, traceback):
        """
        Executed at the end of the with statement which is either when all
        code within the with statement has been executed successfully or
        if an exception is raised.

        ttype is the type of the traceback.
        value is the value of the traceback (like a message).
        traceback is the traceback itself.
        """
        if traceback != None:
            print "Rolling back due to %s: %s" % (ttype.__name__, value)
        print "Exiting ..."

    def __init__(self):
        """
        Simple constructor.
        """
        print "Created the object ..."
        self.hello = None


if __name__ == '__main__':
    # Work
    with Alsome() as a:
        a.hello = "Hi!"
        print a.hello

    # Raise an error
    with Alsome() as a:
        a.hello = "Ho!"
        sda
        print a.hello

[steve@tachikoman ~]$ python t.py 
Created the object ...
Entering ...
Hi!
Exiting ...
Created the object ...
Entering ...
Rolling back due to NameError: name 'sda' is not defined
Exiting ...
Traceback (most recent call last):
  File "t.py", line 51, in <module>
    sda
NameError: name 'sda' is not defined
[steve@tachikoman ~]$ 

[steve@tachikoman ~]$ python t.py 
50
100
0
[steve@tachikoman ~]$ 

class T(object):

    def __init__(self):
        """
        Create the object and set t to 50.
        """
        self.__t = 50

    def _set_t(self, t):
        """
        Set t but follow rules that t can not be under 0 or above 100.
        """
        # Force to an int
        t = int(t)
        if t < 0:
            t = 0
        elif t > 100:
            t = 100
        self.__t = t

    # Wire the property up.
    t = property(lambda self: self.__t, set_t)


if __name__ == '__main__':
    a = T()
    print a.t
    a.t = 999
    print a.t
    a.t = -10
    print a.t