Did I find the right examples for you? yes no

All Samples(6)  |  Call(4)  |  Derive(0)  |  Import(2)

src/c/i/ciel-HEAD/src/python/ciel/runtime/worker/master_proxy.py   ciel(Download)
import socket
import httplib2
from ciel.runtime.pycurl_rpc import post_string, post_string_noreturn, get_string
from threading import Event
 
                    return
            elif method == "GET":
                content = get_string(url)
            else:
                raise Exception("Invalid method %s" % method)
                            return
                    elif method == "GET":
                        content = get_string(url)
                    else:
                        raise Exception("Invalid method %s" % method)

src/c/i/ciel-HEAD/src/python/ciel/runtime/master/worker_pool.py   ciel(Download)
from Queue import Queue
from ciel.public.references import SWReferenceJSONEncoder
from ciel.runtime.pycurl_rpc import post_string_noreturn, get_string
import ciel
import datetime
    def shutdown(self):
        for worker in self.workers.values():
            try:
                get_string('http://%s/control/kill/' % worker.netloc)
            except:
    def investigate_worker_failure(self, worker):
        ciel.log.error('Investigating possible failure of worker %s (%s)' % (worker.id, worker.netloc), 'WORKER_POOL', logging.WARNING)
        try:
            content = get_string('http://%s/control/master/' % worker.netloc)
            worker_fetch = simplejson.loads(content)