Made buffer smaller.
This commit is contained in:
parent
415c16b4ef
commit
74bfdf8ed5
@ -12,7 +12,7 @@ def parse_args():
|
|||||||
parser.add_argument("--host-service", type=str, required=False, default="127.0.0.1")
|
parser.add_argument("--host-service", type=str, required=False, default="127.0.0.1")
|
||||||
parser.add_argument("--port-service", type=int, required=False, default=4433)
|
parser.add_argument("--port-service", type=int, required=False, default=4433)
|
||||||
parser.add_argument("--host-ssh", type=str, required=False, default="127.0.0.1")
|
parser.add_argument("--host-ssh", type=str, required=False, default="127.0.0.1")
|
||||||
parser.add_argument("--port-ssh", type=int, required=False, default=22)
|
parser.add_argument("--port-ssh", type=int, required=False, default=222)
|
||||||
return parser.parse_args()
|
return parser.parse_args()
|
||||||
|
|
||||||
|
|
||||||
|
@ -29,7 +29,7 @@ class Application(BaseApplication):
|
|||||||
|
|
||||||
async def stream(self, reader, writer, port):
|
async def stream(self, reader, writer, port):
|
||||||
while True:
|
while True:
|
||||||
chunk = await reader.read(4096)
|
chunk = await reader.read(64)
|
||||||
if not chunk:
|
if not chunk:
|
||||||
writer.close()
|
writer.close()
|
||||||
log.info("Forward connection closed.")
|
log.info("Forward connection closed.")
|
||||||
|
Loading…
Reference in New Issue
Block a user