Did I find the right examples for you? yes no      Crawl my project      Python Jobs

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

src/k/a/kamaelia-HEAD/Sketches/RJL/bittorrent/BitTorrent/khashmir/krpc.py   kamaelia(Download)
# License.
 
from BitTorrent.defer import Deferred
from BitTorrent.bencode import bencode, bdecode
import socket
        self.mtid = (self.mtid + 1) % 256
        s = bencode(msg)
        d = Deferred()
        self.tids[msg[TID]] = d
        self.call_later(self.timeOut, KRPC_TIMEOUT, (msg[TID],))

src/k/a/kamaelia-HEAD/Sketches/RJL/bittorrent/BitTorrent/khashmir/khashmir.py   kamaelia(Download)
from BitTorrent.bencode import bencode, bdecode
 
from BitTorrent.defer import Deferred
from random import randrange
from kstore import sample
            nodes = sample(l , 4) + self.table.findNodes(id, invalid=False)[:4]
 
        d = Deferred()
        if errback:
            d.addCallbacks(callback, errback)

src/k/a/kamaelia-HEAD/Sketches/RJL/bittorrent/BitTorrent/BitTorrent/NatTraversal.py   kamaelia(Download)
    def list_ports(self):
        d = defer.Deferred()
        self.list_requests.append(d)
        self.add_task(self._flush_queue)
        return d
            self.service_name = app_name
 
        self.d = defer.Deferred()
 
    def populate_host(self):

src/k/a/kamaelia-HEAD/Sketches/RJL/bittorrent/BitTorrent/khashmir/knode.py   kamaelia(Download)
 
from node import Node
from BitTorrent.defer import Deferred
from const import NULL_ID
from krpc import KRPCProtocolError

src/k/a/kamaelia-HEAD/Sketches/RJL/bittorrent/BitTorrent/BitTorrent/RawServer.py   kamaelia(Download)
from BitTorrent.platform import bttime
from BitTorrent import WARNING, CRITICAL, FAQ_URL
from BitTorrent.defer import Deferred
 
try: