← Back to branch summary

~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/transport/smart.py

Delete some obsolete code and comments.

Show diffs side-by-side

added added

removed removed

Lines of Context:
bzrlib/transport/smart.py
246
246
class SmartProtocolBase(object):
247
247
    """Methods common to client and server"""
248
248
 
249
 
    # TODO: this only actually accomodates a single block; possibly should support
250
 
    # multiple chunks?
 
249
    # TODO: this only actually accomodates a single block; possibly should
 
250
    # support multiple chunks?
251
251
    def _encode_bulk_data(self, body):
252
252
        """Encode body as a bulk data chunk."""
253
253
        return ''.join(('%d\n' % len(body), body, 'done\n'))
258
258
        for start, length in offsets:
259
259
            txt.append('%d,%d' % (start, length))
260
260
        return '\n'.join(txt)
261
 
 
262
 
    def _send_bulk_data(self, body, a_file=None):
263
 
        """Send chunked body data"""
264
 
        assert isinstance(body, str)
265
 
        bytes = self._encode_bulk_data(body)
266
 
        self._write_and_flush(bytes, a_file)
267
 
 
268
 
    def _write_and_flush(self, bytes, a_file=None):
269
 
        """Write bytes to self._out and flush it."""
270
 
        # XXX: this will be inefficient.  Just ask Robert.
271
 
        if a_file is None:
272
 
            a_file = self._out
273
 
        a_file.write(bytes)
274
 
        a_file.flush()
275
261
        
276
262
 
277
263
class SmartServerRequestProtocolOne(SmartProtocolBase):
299
285
                # no command line yet
300
286
                return
301
287
            self.has_dispatched = True
302
 
            # XXX if in_buffer not \n-terminated this will do the wrong
303
 
            # thing.
304
288
            try:
305
289
                first_line, self.in_buffer = self.in_buffer.split('\n', 1)
306
290
                first_line += '\n'
356
340
            assert isinstance(body, str), 'body must be a str'
357
341
            bytes = self._encode_bulk_data(body)
358
342
            self._write_func(bytes)
359
 
            #self._send_bulk_data(body, self._out_stream)
360
343
 
361
344
    def sync_with_request(self, request):
362
345
        self._finished_reading = request.finished_reading