Did I find the right examples for you? yes no

All Samples(2)  |  Call(1)  |  Derive(0)  |  Import(1)

src/c/i/ciel-HEAD/src/python/ciel/runtime/tcp_data_fetch.py   ciel(Download)
 
from ciel.public.references import SW2_SocketStreamReference
from ciel.runtime.remote_stat import subscribe_remote_output_nopost, unsubscribe_remote_output_nopost
from ciel.runtime.block_store import get_own_netloc
import threading
                self.should_close = True            
            ciel.log("Connecting %s:%s" % (self.otherend_hostname, self.ref.socket_port), "TCP_FETCH", logging.DEBUG)
            subscribe_remote_output_nopost(self.ref.id, self)
            self.sock.connect((self.otherend_hostname, self.ref.socket_port))
            self.sock.sendall("%s %s %d\n" % (self.ref.id, get_own_netloc(), self.chunk_size))