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

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

src/a/n/Anomos-HEAD/Anomos/Protocol/AnomosEndPointProtocol.py   Anomos(Download)
# Written by John Schanck
 
from Anomos.Protocol import CHOKE, UNCHOKE, INTERESTED, NOT_INTERESTED, \
                            HAVE, BITFIELD, REQUEST, PIECE, CANCEL, \
                            TCODE, CONFIRM, ENCRYPTED, BREAK, PARTIAL, \

src/a/n/Anomos-HEAD/Anomos/Protocol/AnomosRelayerProtocol.py   Anomos(Download)
# Written by John Schanck
 
from Anomos.Protocol import TCODE, CONFIRM, UNCHOKE, CHOKE, ENCRYPTED, BREAK, PARTIAL, ACKBREAK
from Anomos.Protocol import AnomosProtocol, toint
from Anomos import bttime, log_on_call, LOG as log
    def send_tracking_code(self, trackcode):
        log.info("Queuing tracking code")
        self.neighbor.queue_message(self.stream_id, TCODE+trackcode)
        if self.next_upload is None:
            self.ratelimiter.queue(self)

src/a/n/Anomos-HEAD/Anomos/Protocol/AnomosNeighborProtocol.py   Anomos(Download)
import Anomos.Crypto
 
from Anomos.Protocol import PARTIAL, TCODE, tobinary, toint, AnomosProtocol
from Anomos.TCReader import TCReader
from Anomos import LOG as log
    def __init__(self):
        AnomosProtocol.__init__(self)
 
        self.msgmap.update({PARTIAL:self.got_partial,
                            TCODE: self.got_tcode})