mirror of
https://github.com/sshuttle/sshuttle.git
synced 2025-05-15 05:24:49 +02:00
Removed a little bit of legacy code
Removed a few lines of legacy code (to make it look more clean)
This commit is contained in:
parent
53da036879
commit
b8e6ebf741
@ -193,7 +193,6 @@ class SockWrapper:
|
|||||||
if not self.shut_read:
|
if not self.shut_read:
|
||||||
debug2('%r: done reading' % self)
|
debug2('%r: done reading' % self)
|
||||||
self.shut_read = True
|
self.shut_read = True
|
||||||
# self.rsock.shutdown(SHUT_RD) # doesn't do anything anyway
|
|
||||||
|
|
||||||
def nowrite(self):
|
def nowrite(self):
|
||||||
if not self.shut_write:
|
if not self.shut_write:
|
||||||
@ -373,11 +372,6 @@ class Mux(Handler):
|
|||||||
if not self.too_full:
|
if not self.too_full:
|
||||||
self.send(0, CMD_PING, b('rttest'))
|
self.send(0, CMD_PING, b('rttest'))
|
||||||
self.too_full = True
|
self.too_full = True
|
||||||
# ob = []
|
|
||||||
# for b in self.outbuf:
|
|
||||||
# (s1,s2,c) = struct.unpack('!ccH', b[:4])
|
|
||||||
# ob.append(c)
|
|
||||||
# log('outbuf: %d %r' % (self.amount_queued(), ob))
|
|
||||||
|
|
||||||
def send(self, channel, cmd, data):
|
def send(self, channel, cmd, data):
|
||||||
assert isinstance(data, bytes)
|
assert isinstance(data, bytes)
|
||||||
@ -476,8 +470,6 @@ class Mux(Handler):
|
|||||||
|
|
||||||
def handle(self):
|
def handle(self):
|
||||||
self.fill()
|
self.fill()
|
||||||
# log('inbuf is: (%d,%d) %r'
|
|
||||||
# % (self.want, len(self.inbuf), self.inbuf))
|
|
||||||
while 1:
|
while 1:
|
||||||
if len(self.inbuf) >= (self.want or HDR_LEN):
|
if len(self.inbuf) >= (self.want or HDR_LEN):
|
||||||
(s1, s2, channel, cmd, datalen) = \
|
(s1, s2, channel, cmd, datalen) = \
|
||||||
|
Loading…
Reference in New Issue
Block a user