import math, time

from twisted.protocols import basic

class CollectingLineReceiver(basic.LineReceiver):
    def __init__(self):
        self.lines = []
        self.lineReceived = self.lines.append

def deliver(proto, chunks):
    map(proto.dataReceived, chunks)

def benchmark(chunkSize, lineLength, numLines):
    bytes = ('x' * lineLength + '\r\n') * numLines
    chunkCount = len(bytes) / chunkSize + 1
    chunks = []
    for n in xrange(chunkCount):
        chunks.append(bytes[n*chunkSize:(n+1)*chunkSize])
    assert ''.join(chunks) == bytes, (chunks, bytes)
    p = CollectingLineReceiver()

    before = time.clock()
    deliver(p, chunks)
    after = time.clock()

    assert bytes.splitlines() == p.lines, (bytes.splitlines(), p.lines)

    print 'chunkSize:', chunkSize,
    print 'lineLength:', lineLength,
    print 'numLines:', numLines,
    print 'CPU Time: ', after - before



def main():
    for numLines in 100, 1000:
        for lineLength in (10, 100, 1000):
            for chunkSize in (1, 500, 5000):
                benchmark(chunkSize, lineLength, numLines)

    for numLines in 10000, 50000:
        for lineLength in (1000, 2000):
            for chunkSize in (51, 500, 5000):
                benchmark(chunkSize, lineLength, numLines)

if __name__ == '__main__':
    main()