2 # -*- coding: utf-8 -*-
4 from __future__
import absolute_import
8 from bwmon
.pipe
import Pipe
, PipeMonitor
10 sys
.path
.insert(0, os
.path
.dirname(__file__
) or '.')
12 if __name__
== '__main__':
14 port
= newport
= int(sys
.argv
[1])
16 if len(sys
.argv
) == 4:
17 newport
= int(sys
.argv
[3])
18 pipe
= Pipe(port
, newhost
, newport
)
19 monitor
= PipeMonitor(pipe
)
23 except KeyboardInterrupt:
25 print 'Waiting for threads to finish...'
29 print >> sys
.stderr
, '''
31 runpipe.py <port> <remotehost>
32 runpipe.py <localport> <remotehost> <remoteport>