diff options
author | Michael DeHaan <mdehaan@redhat.com> | 2008-01-23 12:38:13 -0500 |
---|---|---|
committer | Michael DeHaan <mdehaan@redhat.com> | 2008-01-23 12:38:13 -0500 |
commit | 504041eb26aba41092aa528e1a724fa5554063d7 (patch) | |
tree | f27263d205c0304e898028c5993cc04a62f1c939 | |
parent | 6e901789f539a25b50512c0504a4338fa638a743 (diff) | |
download | func-504041eb26aba41092aa528e1a724fa5554063d7.tar.gz func-504041eb26aba41092aa528e1a724fa5554063d7.tar.xz func-504041eb26aba41092aa528e1a724fa5554063d7.zip |
Moving the async and multiprocess stuff to top level so we can use them
on the minion for minion side async funness.
-rw-r--r-- | func/forkbomb.py (renamed from func/overlord/forkbomb.py) | 0 | ||||
-rw-r--r-- | func/jobthing.py (renamed from func/overlord/jobthing.py) | 3 | ||||
-rwxr-xr-x | func/overlord/client.py | 4 | ||||
-rw-r--r-- | test/async_test.py | 2 | ||||
-rw-r--r-- | test/unittest/test_client.py | 3 |
5 files changed, 8 insertions, 4 deletions
diff --git a/func/overlord/forkbomb.py b/func/forkbomb.py index c30cc9e..c30cc9e 100644 --- a/func/overlord/forkbomb.py +++ b/func/forkbomb.py diff --git a/func/overlord/jobthing.py b/func/jobthing.py index e405616..4923daa 100644 --- a/func/overlord/jobthing.py +++ b/func/jobthing.py @@ -90,6 +90,9 @@ def __access_status(jobid=0, status=0, results=0, clear=False, write=False): def batch_run(server, process_server, nforks): """ + This is the method used by the overlord side usage of jobthing. + It likely makes little sense for the minion async usage (yet). + Given an array of items (pool), call callback in each one, but divide the workload over nfork forks. Temporary files used during the operation will be created in cachedir and subsequently deleted. diff --git a/func/overlord/client.py b/func/overlord/client.py index 60b5c24..98edaed 100755 --- a/func/overlord/client.py +++ b/func/overlord/client.py @@ -22,8 +22,8 @@ from func.config import read_config, CONFIG_FILE import sslclient import command -import forkbomb -import jobthing +import func.forkbomb as forkbomb +import func.jobthing as jobthing # =================================== # defaults diff --git a/test/async_test.py b/test/async_test.py index 4c1acf5..43904c4 100644 --- a/test/async_test.py +++ b/test/async_test.py @@ -1,5 +1,5 @@ from func.overlord.client import Client -import func.overlord.jobthing as jobthing +import func.jobthing as jobthing import time import sys diff --git a/test/unittest/test_client.py b/test/unittest/test_client.py index 12cb40b..f4f2029 100644 --- a/test/unittest/test_client.py +++ b/test/unittest/test_client.py @@ -5,11 +5,12 @@ import unittest import xmlrpclib import func.overlord.client as fc +import socket class BaseTest: - th = "grimlock.devel.redhat.com" + th = "mdehaan.rdu.redhat.com" def __init__(self): pass |