Did I find the right examples for you? yes no

All Samples(8)  |  Call(5)  |  Derive(0)  |  Import(3)

src/c/i/ciel-HEAD/src/python/ciel/runtime/producer.py   ciel(Download)
import ciel.runtime.tcp_server
import ciel.runtime.file_watcher as fwt
from ciel.runtime.block_store import get_own_netloc, producer_filename,\
    filename_for_ref
from ciel.public.references import SWDataValue, encode_datavalue, SW2_ConcreteReference, \
                    self.started = True
                    ciel.log("Producer for %s: timed out waiting for a consumer; writing to local block store" % self.refid, "BLOCKPIPE", logging.DEBUG)
        return (producer_filename(self.refid), False)
 
    def get_stream_ref(self):
        if self.direct_write_filename is not None or self.direct_write_fd is not None:
            return SW2_CompletedReference(self.refid)
        completed_file = producer_filename(self.refid)
        if self.current_size < 1024:
            with open(completed_file, "r") as fp:
    ciel.log.error('Creating file for output %s' % id, 'BLOCKSTORE', logging.DEBUG)
    new_ctx = FileOutputContext(id, subscribe_callback, may_pipe=may_pipe, can_use_fd=can_use_fd)
    dot_filename = producer_filename(id)
    open(dot_filename, 'wb').close()
    streaming_producers[id] = new_ctx

src/c/i/ciel-HEAD/src/python/ciel/runtime/fetcher.py   ciel(Download)
from ciel.runtime.pycurl_data_fetch import HttpTransferContext
from ciel.runtime.tcp_data_fetch import TcpTransferContext
from ciel.runtime.block_store import filename_for_ref, producer_filename,\
    get_own_netloc, create_datavalue_file
from ciel.runtime.producer import get_producer_for_id,\
            else:
                ciel.log("Fetch-ref %s: following local producer's file" % self.ref, "BLOCKSTORE", logging.DEBUG)
                filename = producer_filename(self.ref.id)
            self.set_filename(filename, is_pipe)
 

src/c/i/ciel-HEAD/src/python/ciel/runtime/tcp_server.py   ciel(Download)
import ciel.runtime.pycurl_thread
import ciel.runtime.producer
from ciel.runtime.block_store import producer_filename
 
import threading
            # Otherwise we'll get progress/result callbacks as we follow the producer's on-disk file.
            os.close(self.write_fd)
            self.read_filename = producer_filename(self.refid)
            ciel.log("Auxiliary TCP connection for output %s (chunk %s) attached via push thread" % (self.refid, self.chunk_size), "TCP_FETCH", logging.DEBUG)