Add pipe_to_tcp utility
This commit is contained in:
parent
bea8d64115
commit
aaff11808e
53
fstream-util-pipe_to_tcp.py
Normal file
53
fstream-util-pipe_to_tcp.py
Normal file
@ -0,0 +1,53 @@
|
||||
#!/usr/bin/env python3
|
||||
import sys
|
||||
|
||||
oldexcepthook = sys.excepthook
|
||||
def newexcepthook(type,value,traceback):
|
||||
oldexcepthook(type,value,traceback)
|
||||
#input("Press ENTER to quit.")
|
||||
sys.excepthook = newexcepthook
|
||||
|
||||
import os
|
||||
p = os.path.join
|
||||
pUp = os.path.dirname
|
||||
s = False
|
||||
if getattr(sys, 'frozen', False) and hasattr(sys, '_MEIPASS'):
|
||||
s = os.path.realpath(sys.executable)
|
||||
else:
|
||||
s = os.path.realpath(__file__)
|
||||
sp = pUp(s)
|
||||
|
||||
# script start
|
||||
import socket
|
||||
import threading
|
||||
import queue
|
||||
|
||||
serverAddr = ("127.0.0.1",61921)
|
||||
serverSocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
||||
serverSocket.bind(serverAddr)
|
||||
serverSocket.listen(1)
|
||||
|
||||
connection = False
|
||||
connectionLock = threading.Lock()
|
||||
|
||||
class pipeThread(threading.Thread):
|
||||
def __init__(self):
|
||||
threading.Thread.__init__(self)
|
||||
|
||||
def run(self):
|
||||
while True:
|
||||
data = sys.stdin.buffer.read(1000)
|
||||
try:
|
||||
with connectionLock:
|
||||
connection.send(data)
|
||||
except Exception as e:
|
||||
print(e)
|
||||
|
||||
pThread = pipeThread()
|
||||
pThread.start()
|
||||
|
||||
while True:
|
||||
conn, address = serverSocket.accept()
|
||||
with connectionLock:
|
||||
connection = conn
|
||||
connection.settimeout(None)
|
Loading…
Reference in New Issue
Block a user