Did I find the right examples for you? yes no

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

src/c/i/ciel-HEAD/src/python/ciel/runtime/executors/proc.py   ciel(Download)
    spawn_task_helper, OngoingOutput, package_lookup
import subprocess
from ciel.public.io_helpers import write_framed_json, read_framed_json
import logging
from ciel.runtime.fetcher import retrieve_filename_for_ref,\
        #ciel.log('Got reader and writer FIFOs', 'PROC', logging.INFO)
 
        write_framed_json(("start_task", task_private), writer)
 
        try:
    def _subscribe_output(self, index, chunk_size):
        message = ("subscribe", {"index": index, "chunk_size": chunk_size})
        with self.transmit_lock:
            write_framed_json(message, self.writer)
 
    def _unsubscribe_output(self, index):
        message = ("unsubscribe", {"index": index})
        with self.transmit_lock:
            write_framed_json(message, self.writer)
                if response is not None:
                    with self.transmit_lock:
                        write_framed_json((method, response), writer)
                if response_fd is not None:
                    socket_name = args["fd_socket_name"]

src/c/i/ciel-HEAD/src/python/ciel/public/rpc_helper.py   ciel(Download)
import select
import sys
from ciel.public.io_helpers import read_framed_json, write_framed_json
 
class ShutdownException(Exception):
    def send_message(self, method, args):
        try:
            write_framed_json((method, args), self.out_fp)
            self.out_fp.flush()
 

src/c/i/ciel-HEAD/src/python/ciel/runtime/worker/process_pool.py   ciel(Download)
from ciel.runtime.pycurl_rpc import post_string
from ciel.runtime.block_store import is_ref_local
from ciel.public.io_helpers import write_framed_json
from ciel.runtime.producer import write_fixed_ref_string
 
    def kill(self):
        ciel.log("Garbage collecting process %s" % self.id, "PROCESSPOOL", logging.INFO)
        write_fp = self.get_write_fifo()
        write_framed_json(("die", {"reason": "Garbage collected"}), write_fp)
        self.cleanup()

src/c/i/ciel-HEAD/src/python/ciel/runtime/executors/__init__.py   ciel(Download)
    SW2_FixedReference, SWReferenceJSONEncoder, SW2_ConcreteReference,\
    decode_datavalue_string, encode_datavalue, SW2_TombstoneReference
from ciel.public.io_helpers import read_framed_json, write_framed_json
from ciel.runtime.exceptions import BlameUserException, ReferenceUnavailableException,\
    MissingInputException, TaskFailedError