Did I find the right examples for you? yes no

All Samples(4)  |  Call(3)  |  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
                else:
                    ciel.log("TCP-fetch %s: request failed: other end said '%s'" % (self.ref.id, response), "TCP_FETCH", logging.WARNING)
                    unsubscribe_remote_output_nopost(self.ref.id)
                    self.done = True
                    self.sock.close()
                    self.fetch_ctx.result(False)
        except Exception as e:
            unsubscribe_remote_output_nopost(self.ref.id)
                self.done = True
                should_callback = True
                unsubscribe_remote_output_nopost(self.ref.id)
        if should_callback:
            self.fetch_ctx.result(False)