minrk

minrk

#!/usr/bin/python
"""
zmq_cli - 0MQ Server interruptability test case, client module.

"""


import zmq

minrk

# override ioloop.IOLoop with zmq's IOLoop
import sys
import tornado.ioloop
from zmq.eventloop import ioloop
tornado.ioloop.IOLoop = ioloop.IOLoop

import trombi

loop = ioloop.IOLoop.instance()
# check that tornado's ioloop instance is actually zmq's

minrk

import thread
import time
import zmq

# global zmg context
context = zmq.Context()
endpoint = "tcp://*:8888"

# the subscriber thread function
def subscriber(name, address, cnt, subscriptions):

minrk

"""
A test forking server

To start a single kernel by forking, do::

    python -i testfork.py
    
The kernel object will be in the ``a`` variable.  When you close the 
python session, the forked kernel will be killed.
"""

minrk

from IPython.frontend.qt.console.qtconsoleapp import IPythonQtConsoleApp
a = IPythonQtConsoleApp()
a.initialize()
# load the sympyprinting extension in the kernel before starting
a.kernel_manager.shell_channel.execute("%load_ext sympyprinting", silent=True)
a.start()

minrk

import json, time, threading

import zmq
from zmq.eventloop import ioloop, zmqstream

class Logger( threading.Thread ):
    def __init__( self, *args, **kwargs ):
        threading.Thread.__init__( self )
        self.rtrSocket = None
        self.stream = None

minrk

minrk

import os

from IPython.frontend.qt.console.rich_ipython_widget import RichIPythonWidget
from IPython.frontend.qt.kernelmanager import QtKernelManager
from IPython.frontend.qt.inprocess_kernelmanager import QtInProcessKernelManager
from IPython.kernel.zmq.ipkernel import Kernel
from IPython.kernel.inprocess.ipkernel import InProcessKernel
from IPython.lib import guisupport

minrk

from IPython.parallel import Client
from IPython.parallel import interactive
import time
import random

@interactive
def work(i):
    import time
    import random
    sleeptime = 1 + random.random() * 2