Did I find the right examples for you? yes no

All Samples(12)  |  Call(8)  |  Derive(0)  |  Import(4)

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
 
                    if callback is None:
                        callback = self.master_post_result_callback
                    post_string_noreturn(url, payload, result_callback=callback)
                    return
            elif method == "GET":
                            if callback is None:
                                callback = self.master_post_result_callback
                            post_string_noreturn(url, payload, result_callback=callback)
                            return
                    elif method == "GET":

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
 
            message = simplejson.dumps(task.as_descriptor(), cls=SWReferenceJSONEncoder)
            post_string_noreturn("http://%s/control/task/" % (worker.netloc), message, result_callback=self.worker_post_result_callback)
        except:
            self.worker_failed(worker)
 
    def abort_task_on_worker(self, task, worker):
        try:
            ciel.log("Aborting task %s on worker %s" % (task.task_id, worker), "WORKER_POOL", logging.WARNING)
            post_string_noreturn('http://%s/control/abort/%s/%s' % (worker.netloc, task.job.id, task.task_id), "", result_callback=self.worker_post_result_callback)

src/c/i/ciel-HEAD/src/python/ciel/runtime/remote_stat.py   ciel(Download)
# OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
 
from ciel.runtime.pycurl_rpc import post_string_noreturn
from ciel.runtime.block_store import get_own_netloc
 
def subscribe_remote_output(refid, remote_netloc, chunk_size, subscriber):
    subscribe_remote_output_nopost(refid, subscriber)
    post_data = simplejson.dumps({"netloc": get_own_netloc(), "chunk_size": chunk_size})
    post_string_noreturn("http://%s/control/streamstat/%s/subscribe" % (remote_netloc, refid), post_data, result_callback=(lambda success, url: subscribe_result(refid, success, url)))
 
def unsubscribe_remote_output(refid):
    unsubscribe_remote_output_nopost(refid)
    netloc = get_own_netloc()
    post_data = simplejson.dumps({"netloc": netloc})
    post_string_noreturn("http://%s/control/streamstat/%s/unsubscribe" 

src/c/i/ciel-HEAD/src/python/ciel/runtime/producer_stat.py   ciel(Download)
import os
 
from ciel.runtime.pycurl_rpc import post_string_noreturn
from ciel.runtime.block_store import filename
from ciel.runtime.producer import get_producer_for_id
    def post(self, message):
        post_string_noreturn("http://%s/control/streamstat/%s/advert" % (self.netloc, self.file_output.refid), message)
 
    def progress(self, bytes):
        self.current_size = bytes
            post = simplejson.dumps({"absent": True})
    if post is not None:
        post_string_noreturn("http://%s/control/streamstat/%s/advert" % (otherend_netloc, id), post)
 
def unsubscribe_output(otherend_netloc, id):