Brian Warner
df2384bea2
twisted.transit: move FileConsumer into RecordPipe
...
This adds an expected= argument to Connection.connectConsumer(), which
then returns a Deferred that fires when enough bytes have been written
to the consumer. It also adds Connection.writeToFile(), a helper method
that writes bytes to a filehandle.
2016-03-02 00:48:43 -08:00
Brian Warner
7234e25897
twisted.transit: handle multiple records in one chunk
...
I made the classic dataReceived() mistake, and exited the function after
delivering the first record. Keep at it until there are no complete
records left.
2016-03-02 00:48:43 -08:00
Brian Warner
8d82726c51
add DebugTiming object, --dump-timing= option
...
This writes timeline data to a .json file, which can be examined later
to find likely candidates for optimization.
2016-03-01 18:23:06 -08:00
Brian Warner
84def8a54b
add some inlineCallbacks for simplicity
...
This control flow was getting too hairy.
2016-03-01 18:22:03 -08:00
Brian Warner
6654efb429
move describe() from Transit to RecordPipe
2016-02-28 01:42:46 -08:00
Brian Warner
7ceffd783a
add more assertions around transit_key
2016-02-17 19:02:35 -08:00
Brian Warner
e2f3bebe38
allow --relay-helper="" to disable relay
...
test_scripts now uses this to avoid accidentally using a relay
2016-02-17 13:53:18 -08:00
Brian Warner
a235b507c8
twisted.transit: implement producer/consumer flow control
2016-02-15 21:23:20 -08:00
Brian Warner
763d72f582
twisted.transit: implement Deferred-based receive_record()
2016-02-15 11:40:21 -08:00
Brian Warner
fb1461fa8c
add twisted.transit, with tests
2016-02-14 17:57:09 -08:00
