sock_ut

• 構想
  • 仕組み概要
• いざ実装
  • ソースコード
  • とりあえず動かしてみます
• 内部の詳細
  • ソケットのユーティリティ
  • ベースサーバに送信するコマンドの仕様
  • コマンド文字列の判定
  • サーバ登録やaccept要求の管理用のグローバル変数
  • ベースサーバ内部の処理関数
  • I/F用の関数
  • コマンドとして実行した時の処理
• v2
• v3
  • recv_bt_all()関数を追加
  • サーバが終了したときの不具合
  • パッチ
  • 動作確認
• v4
  • recv_str_all()関数を追加
  • srv_loop()関数の修正
  • accept()関数の修正
  • パッチ
• v5
  • サーバの終了処理
  • パッチ
  • 動作確認
• v6
  • 不具合
  • とりあえず対策
  • パッチ
  • 動作確認
• v7
  • ホスト名の指定
  • コマンドライン引数の指定
  • acceptの問題
  • パッチ
  • 動作確認
• v8
  • ncを使ってみたいなと
  • 文字列の末尾に改行
  • パッチ
  • 動作確認
  • ncでサーバのふり
• v9
  • 改行問題
  • コマンドのサーバ化
  • クライアント側も
  • サーバのリスト
  • ファイルディスクリプタのリードライト
  • パッチ
  • 動作確認
• v10
  • fio_ut.py
  • パッチ
  • 動作確認
• v11
  • 入力を終了しないと変換しないコマンドの場合
  • モードの指定
  • パッチ
  • 動作確認
• テストプログラム
  • アイデア
  • bashの出力の記録
  • pty.spawnを使ってみます
  • 入力部分の指定
  • プログラムで読み込み
  • プログラムでコマンド実行
  • ワイルドカード
  • 仕上げ

#!/usr/bin/env python

import sys
import socket

import empty
import thr
import fio_ut
import dbg

add_tail = lambda s, add: s + add
cut_tail = lambda s, cut: s[ : -len( cut ) ] if s.endswith( cut ) else s

close = fio_ut.close

def port_conn( port, host='localhost' ):
	cs = socket.socket( socket.AF_INET, socket.SOCK_STREAM )
	try:
		cs.connect( ( host, port ) )
	except:
		return None
	fio_ut.set_fs_sock( cs )
	return cs

def send_str( sc, s ):
	s = add_tail( s, '\n' )
	return fio_ut.p_s( sc, s )

def recv_str_line( sc ):
	s = fio_ut.g_s_line( sc )
	return cut_tail( s, '\n' )

def recv_str_all( sc ):
	s = fio_ut.g_s_all( sc )
	return cut_tail( s, '\n' )

def pipe_loop( sc_from, sc_to ):
	while True:
		b = fio_ut.g_b( sc_from )
		if not b:
			break
		if not fio_ut.p_b( sc_to, b ):
			break

# srv=name,port=xxx,host=xxx
# srv=name,id=xxx,port=xxx,host=xxx
# srv=name,id=xxx
# get_srvs
# kill=name
# kill_base_srv
# name

def get_dic( s ):
	if '=' not in s:
		return {}
	return dict( map( lambda t: t.split( '=' ), s.split( ',' ) ) )

is_keys_dic = lambda d, ks: len( d ) == len( ks ) and all( map( lambda k: k in d, ks ) )

is_key_dic = lambda d, k: len( d ) == 1 and k in d

is_srv_dic = lambda d: is_keys_dic( d, [ 'srv', 'port', 'host' ] )

is_kill_dic = lambda d: is_key_dic( d, 'kill' )

is_accept_dic = lambda d: is_keys_dic( d, [ 'srv', 'id', 'port', 'host' ] )

def get_port_host_from_dic( d ):
	port = int( d.get( 'port' ) )
	host = d.get( 'host' )
	return ( port, host )

srvs = {}
reqs = {}

def base_th_srv( sc, d ):
	name = d.get( 'srv' )
	if name in srvs:
		return

	( port, host ) = get_port_host_from_dic( d )

	q = thr.que_new()
	srvs[ name ] = q

	dbg.out( 'srv {} start'.format( name ) )
	while True:
		s = q.get()
		if s == 'kill':
			break
		s += ',port={},host={}'.format( port, host )
		if not send_str( sc, s ):
			break

	srvs.pop( name )
	dbg.out( 'srv {} quit'.format( name ) )

def base_th_accept( sc, s ):
	s = ','.join( s.split( ',' )[ : -2 ] )
	if s not in reqs:
		return

	( sc2, ev ) = reqs.get( s )
	ev2 = thr.event_new()
	reqs[ s ] = [ sc, ev2 ]
	ev.set()
	ev2.wait()
	if not send_str( sc, 'ok' ):
		return

	pipe_loop( sc, sc2 )

def base_th_connect( sc, s ):
	name = s
	q = srvs.get( name )
	id = sc.fileno()
	s = 'srv={},id={}'.format( name, id )
	ev = thr.event_new()
	reqs[ s ] = [ sc, ev ]
	q.put( s )
	ev.wait()
	[ sc2, ev2 ] = reqs.pop( s )
	ev2.set()
	if not send_str( sc, 'ok' ):
		return

	pipe_loop( sc, sc2 )

def base_th( port, sc, ev_quit ):
	fio_ut.set_fs_sock( sc )

	s = recv_str_line( sc )
	if not s:
		close( sc )
		return

	d = get_dic( s )

	if is_srv_dic( d ):
		base_th_srv( sc, d )

	elif is_accept_dic( d ):
		base_th_accept( sc, s )

	elif is_kill_dic( d ):
		name = d.get( 'kill' )
		if name in srvs:
			q = srvs.get( name )
			q.put( 'kill' )

	elif s == 'get_srvs':
		r = '\n'.join( srvs.keys() )
		send_str( sc, r )

	elif s == 'kill_base_srv':
		ev_quit.set()
		send_str( sc, 'next' )

	elif s in srvs:
		base_th_connect( sc, s )

	close( sc )

def ping_th():
	id = 'ping'
	for ( name, q ) in srvs.items():
		s = 'srv={},id={}'.format( name, id )
		q.put( s )

def base_srv( port ):
	th_p = thr.loop_new( ping_th, wait_tmout=1.0 )
	thr.ths.start( th_p )

	ss = socket.socket( socket.AF_INET, socket.SOCK_STREAM )
	ss.setsockopt( socket.SOL_SOCKET, socket.SO_REUSEADDR, 1 )
	ss.bind( ( '', port ) )
	ss.listen( 5 )

	ev_quit = thr.event_new()
	while not ev_quit.wait( 0 ):
		( cs, adr ) = ss.accept()
		th = thr.th_new( base_th, ( port, cs, ev_quit ) )
		thr.ths.start( th )

	th_p.quit_ev.set()
	dbg.out( 'base_srv quit' )

def server( port, name, host='localhost' ):
	ss = port_conn( port, host )
	if not ss:
		return None

	s = 'srv={},port={},host={}'.format( name, port, host )
	if not send_str( ss, s ):
		close( ss )
		return None
	return ss

def accept_recv_ping( ss ):
	s = recv_str_line( ss )
	if not s:
		return None

	d = get_dic( s )
	if not is_accept_dic( d ):
		return None

	if d.get( 'id' ) == 'ping':
		return 'ping'

	return ( s, d )

def accept_recv( ss ):
	r = None
	while True:
		r = accept_recv_ping( ss )
		if r != 'ping':
			break
	return r  # None or ( s, d )

def accept_conn( r ):
	if not r:
		return None
	( s, d ) = r
	( port, host ) = get_port_host_from_dic( d )
	cs = port_conn( port, host )
	if not send_str( cs, s ):
		close( cs )
		return None
	s = recv_str_line( cs )
	if s != 'ok':
		close( cs )
		return None
	return cs

def accept( ss ):
	r = accept_recv( ss )
	return accept_conn( r )

def srv_loop( port, name, th_func, host='localhost' ):
	ss = server( port, name, host )
	if not ss:
		return
	while True:
		cs = accept( ss )
		if not cs:
			break
		th = thr.th_new( th_func, ( cs, ) )
		thr.ths.start( th )
	close( ss )

def srv_func_new( cb, use_b=False, use_all=False ):
	send = fio_ut.p_s
	recv = fio_ut.g_s
	if use_all:
		recv = fio_ut.g_s_all
	if use_b:
		send = fio_ut.p_b
		recv = fio_ut.g_b
		if use_all:
			recv = fio_ut.g_b_all

	send_ = send
	recv_ = recv
	if not use_b:
		send = lambda f, s: send_( f, add_tail( s, '\n' ) )
		recv = lambda f: cut_tail( recv_( f ), '\n' )

	def func( sc ):
		while True:
			s = recv( sc )
			if not s:
				break
			r = cb( s )
			if not r:
				break
			if not send( sc, r ):
				break
		close( sc )

	return empty.new( locals() )

def srv_loop_cmd( host, port, name, cmd, mode ):

	def th_func( sc ):
		proc = fio_ut.proc_new( cmd )

		def cb( b ):
			fio_ut.p_b( proc.fo, b )
			if mode == 'all':
				fio_ut.close( proc.fo )
			return fio_ut.g_b_all( proc.fi )

		srv_func = srv_func_new( cb, use_b=True, use_all=True )
		srv_func.func( sc )
		proc.stop()

	srv_loop( port, name, th_func, host )

def connect( port, name, host='localhost' ):
	cs = port_conn( port, host )
	if not cs:
		return None

	if not send_str( cs, name ):
		close( cs )
		return None

	s = recv_str_line( cs  )
	if s != 'ok':
		close( cs )
		return None
	return cs

def get_srvs( host, port ):
	cs = port_conn( port, host )
	if not cs:
		return
	send_str( cs, 'get_srvs' )
	r = recv_str_all( cs )
	close( cs )
	return r.split( '\n' )

def kill_srv( port, name, host='loaclhost' ):
	cs = port_conn( port, host )
	if not cs:
		return
	s = 'kill=' + name
	#dbg.out( s )
	send_str( cs, s )
	close( cs )

def kill_base_srv( port, host='loaclhost' ):
	cs = port_conn( port, host )
	if not cs:
		return
	dbg.out( 'kill_base_srv' )
	send_str( cs, 'kill_base_srv' )
	r = recv_str_line( cs )
	close( cs )

	cs = port_conn( port, host )  # for accept loop
	if cs:
		close( cs )

def help():
	lst = [
		'\\',
		'base [ port=13579 ]',
		'srv [ host=localhost ][ port=13579 ] upper',
		'srv [ host=localhost ][ port=13579 ] eval',
		'srv [ host=localhost ][ port=13579 ] srv_name cmd arg ...',
		'srv -a [ host=localhost ][ port=13579 ] srv_name cmd arg ... ( all mode )',
		'cli [ host=localhost ][ port=13579 ] upper word word word ...',
		'cli [ host=localhost ][ port=13579 ] eval word word word ...',
		'cli [ host=localhost ][ port=13579 ] srv_name',
		'cli -a [ host=localhost ][ port=13579 ] srv_name ( all mode )',
		'srvs [ host=localhost ][ port=13579 ]',
		'kill_base [ host=localhost ][ port=13579 ]',
		'kill [ host=localhost ][ port=13579 ] srv_name ( srv_name is upper, eval or ... )'
	]
	dbg.help_exit( '\n'.join( lst ) )

def run_cli( sc, mode ):
	( fi, fo ) = fio_ut.set_fs_sys_stdio()

	def cnv_out( b ):
		if not fio_ut.p_b( sc, b ):
			return False

		b = fio_ut.g_b_all( sc )
		if not b:
			return False

		if not fio_ut.p_b( fo, b ):
			return False

		return True

	if mode == 'all':
		buf = b''
		while True:
			b = fio_ut.g_b_all( fi )
			if not b:
				break
			buf += b
		cnv_out( buf )
		return

	# mode == 'line'
	while True:
		b = fio_ut.g_b_line( fi )
		if not b:
			break
		if not cnv_out( b ):
			break

def run():
	if len( sys.argv ) < 2:
		help()

	argv = sys.argv[ 1 : ]

	def pop():
		if len( argv ) <= 0:
			help()
		return argv.pop( 0 )

	def popk( k, dv=None ):
		for i in range( len( argv ) ):
			if argv[ i ].startswith( k ):
				return argv.pop( i )[ len( k ) : ]
		return dv

	def pop_mode():
		if argv[ 0 ] == '-a':
			pop()
			return 'all'
		return 'line'

	host = popk( 'host=', 'localhost' )
	port = int( popk( 'port=', '13579' ) )

	names = {
		'upper': lambda s: s.upper(),
		'eval': lambda s: str( eval( s ) ),
	}

	cmd = pop()
	if cmd == 'base':
		base_srv( port )
	elif cmd == 'srv':
		mode = pop_mode()
		name = pop()
		if name in names:
			cb = names.get( name )
			srv_func = srv_func_new( cb )
			srv_loop( port, name, srv_func.func, host )
		else:
			cmd = ' '.join( argv )
			srv_loop_cmd( host, port, name, cmd, mode )
	elif cmd == 'cli':
		mode = pop_mode()
		lst = get_srvs( host, port )
		name = pop()
		if name not in lst:
			return

		sc = connect( port, name, host )
		if not sc:
			return

		if name in names:
			while len( argv ) > 0:
				w = pop()
				if not send_str( sc, w ):
					break
				r = recv_str_line( sc )
				if not r:
					break
				dbg.out( '{} --> {}'.format( w, r ) )
		else:
			run_cli( sc, mode )
		close( sc )

	elif cmd == 'srvs':
		lst = get_srvs( host, port )
		dbg.out( '\n'.join( lst ) )

	elif cmd == 'kill':
		name = pop()
		kill_srv( port, name, host )

	elif cmd == 'kill_base':
		kill_base_srv( port, host )


if __name__ == "__main__":
	run()
# EOF

diff -ur v1/sock_ut.py v2/sock_ut.py
--- v1/sock_ut.py	2021-06-09 16:10:05.000000000 +0900
+++ v2/sock_ut.py	2021-06-10 21:09:48.000000000 +0900
@@ -17,26 +17,32 @@
 		return None
 	return cs

-def send_str( sc, s ):
-	bt = s.encode( 'utf-8' )
+def send_bt( sc, bt ):
 	try:
 		sc.sendall( bt )
 	except:
 		return False
 	return True

-def recv_str( sc ):
+def recv_bt( sc ):
 	bufmax = 16 * 1024
 	bt = sc.recv( bufmax )
-	s = bt.decode( 'utf-8' )
-	return s
+	return bt
+
+def send_str( sc, s ):
+	bt = s.encode( 'utf-8' )
+	return send_bt( sc, bt )
+
+def recv_str( sc ):
+	bt = recv_bt( sc )
+	return bt.decode( 'utf-8' )

 def pipe_loop( sc_from, sc_to ):
 	while True:
-		s = recv_str( sc_from )
-		if not s:
+		bt = recv_bt( sc_from )
+		if not bt:
 			break
-		if not send_str( sc_to, s ):
+		if not send_bt( sc_to, bt ):
 			break

 # srv=name

diff -ur v2/sock_ut.py v3/sock_ut.py
--- v2/sock_ut.py	2021-06-10 21:09:48.000000000 +0900
+++ v3/sock_ut.py	2021-06-24 21:26:04.000000000 +0900
@@ -9,6 +9,8 @@
 import thr
 import dbg

+can_read = lambda sc, tmout=0: select.select( [ sc ], [], [], tmout )[ 0 ] == [ sc ]
+
 def port_conn( port, host='localhost' ):
 	cs = socket.socket( socket.AF_INET, socket.SOCK_STREAM )
 	try:
@@ -29,6 +31,15 @@
 	bt = sc.recv( bufmax )
 	return bt

+def recv_bt_all( sc ):
+	buf = b''
+	while not buf or can_read( sc ):
+		bt = recv_bt( sc )
+		if not bt:
+			break
+		buf += bt
+	return buf
+
 def send_str( sc, s ):
 	bt = s.encode( 'utf-8' )
 	return send_bt( sc, bt )
@@ -73,11 +84,15 @@
 	q = thr.que_new()
 	srvs[ name ] = q

+	dbg.out( 'srv {} start'.format( name ) )
 	while True:
 		s = q.get()
 		if not send_str( sc, s ):
 			break

+	srvs.pop( name )
+	dbg.out( 'srv {} quit'.format( name ) )
+
 def base_th_accept( sc, s ):
 	if s not in reqs:
 		return
@@ -131,7 +146,16 @@

 	sc.close()

+def ping_th( port ):
+	id = 'ping'
+	for ( name, q ) in srvs.items():
+		s = 'port={},srv={},id={}'.format( port, name, id )
+		q.put( s )
+
 def base_srv( port ):
+	th_p = thr.loop_new( ping_th, ( port, ), wait_tmout=1.0 )
+	thr.ths.start( th_p )
+
 	ss = socket.socket( socket.AF_INET, socket.SOCK_STREAM )
 	ss.setsockopt( socket.SOL_SOCKET, socket.SO_REUSEADDR, 1 )
 	ss.bind( ( '', port ) )
@@ -143,6 +167,7 @@
 		th = thr.th_new( base_th, ( port, cs, ev_quit ) )
 		thr.ths.start( th )

+	th_p.quit_ev.set()
 	dbg.out( 'base_srv quit' )

 def server( port, name ):
@@ -156,7 +181,7 @@
 		return None
 	return ss

-def accept( ss ):
+def accept_inner( ss ):
 	s = recv_str( ss )
 	if not s:
 		return None
@@ -165,6 +190,9 @@
 	if not is_accept_dic( d ):
 		return None

+	if d.get( 'id' ) == 'ping':
+		return 'ping'
+
 	port = int( d.get( 'port' ) )
 	cs = port_conn( port )
 	if not send_str( cs, s ):
@@ -176,6 +204,15 @@
 		return None
 	return cs

+def accept( ss ):
+	cs = None
+	while True:
+		cs = accept_inner( ss )
+		if cs != 'ping':
+			break
+		#dbg.out( 'accept ping' )
+	return cs
+
 def srv_loop( port, name, th_func ):
 	ss = server( port, name )
 	if not ss:

diff -ur v3/sock_ut.py v4/sock_ut.py
--- v3/sock_ut.py	2021-06-24 21:26:04.000000000 +0900
+++ v4/sock_ut.py	2021-06-28 19:46:14.000000000 +0900
@@ -48,6 +48,10 @@
 	bt = recv_bt( sc )
 	return bt.decode( 'utf-8' )

+def recv_str_all( sc ):
+	bt = recv_bt_all( sc )
+	return bt.decode( 'utf-8' )
+
 def pipe_loop( sc_from, sc_to ):
 	while True:
 		bt = recv_bt( sc_from )
@@ -181,7 +185,7 @@
 		return None
 	return ss

-def accept_inner( ss ):
+def accept_recv_ping( ss ):
 	s = recv_str( ss )
 	if not s:
 		return None
@@ -193,6 +197,20 @@
 	if d.get( 'id' ) == 'ping':
 		return 'ping'

+	return ( s, d )
+
+def accept_recv( ss ):
+	r = None
+	while True:
+		r = accept_recv_ping( ss )
+		if r != 'ping':
+			break
+	return r  # None or ( s, d )
+
+def accept_conn( r ):
+	if not r:
+		return None
+	( s, d ) = r
 	port = int( d.get( 'port' ) )
 	cs = port_conn( port )
 	if not send_str( cs, s ):
@@ -205,13 +223,8 @@
 	return cs

 def accept( ss ):
-	cs = None
-	while True:
-		cs = accept_inner( ss )
-		if cs != 'ping':
-			break
-		#dbg.out( 'accept ping' )
-	return cs
+	r = accept_recv( ss )
+	return accept_conn( r )

 def srv_loop( port, name, th_func ):
 	ss = server( port, name )
@@ -223,6 +236,7 @@
 			break
 		th = thr.th_new( th_func, ( cs, ) )
 		thr.ths.start( th )
+	ss.close()

 def srv_func_new( cb ):

diff -ur v4/sock_ut.py v5/sock_ut.py
--- v4/sock_ut.py	2021-06-28 19:46:14.000000000 +0900
+++ v5/sock_ut.py	2021-06-30 04:15:08.000000000 +0900
@@ -62,6 +62,7 @@

 # srv=name
 # port=xxx,srv=name,id=xxx
+# kill=name
 # kill_base_srv
 # name

@@ -70,8 +71,11 @@
 		return {}
 	return dict( map( lambda t: t.split( '=' ), s.split( ',' ) ) )

-def is_srv_dic( d ):
-	return len( d ) == 1 and 'srv' in d
+is_key_dic = lambda d, k: len( d ) == 1 and k in d
+
+is_srv_dic = lambda d: is_key_dic( d, 'srv' )
+
+is_kill_dic = lambda d: is_key_dic( d, 'kill' )

 def is_accept_dic( d ):
 	ks = [ 'port', 'srv', 'id' ]
@@ -91,6 +95,8 @@
 	dbg.out( 'srv {} start'.format( name ) )
 	while True:
 		s = q.get()
+		if s == 'kill':
+			break
 		if not send_str( sc, s ):
 			break

@@ -141,6 +147,12 @@
 	elif is_accept_dic( d ):
 		base_th_accept( sc, s )

+	elif is_kill_dic( d ):
+		name = d.get( 'kill' )
+		if name in srvs:
+			q = srvs.get( name )
+			q.put( 'kill' )
+
 	elif s == 'kill_base_srv':
 		ev_quit.set()
 		send_str( sc, 'next' )
@@ -267,6 +279,15 @@
 		return None
 	return cs

+def kill_srv( port, name ):
+	cs = port_conn( port )
+	if not cs:
+		return
+	s = 'kill=' + name
+	#dbg.out( s )
+	send_str( cs, s )
+	cs.close()
+
 def kill_base_srv( port ):
 	cs = port_conn( port )
 	if not cs:
@@ -289,6 +310,7 @@
 		'port cli upper word word word ...',
 		'port cli eval word word word ...',
 		'port kill_base',
+		'port kill srv_name ( srv_name is upper, eval or ... )'
 	]
 	dbg.help_exit( '\n'.join( lst ) )

@@ -333,6 +355,10 @@
 					break
 				dbg.out( '{} --> {}'.format( w, r ) )
 			sc.close()
+	elif cmd == 'kill':
+		name = pop()
+		kill_srv( port, name )
+
 	elif cmd == 'kill_base':
 		kill_base_srv( port )

diff -ur v5/sock_ut.py v6/sock_ut.py
--- v5/sock_ut.py	2021-06-30 04:15:08.000000000 +0900
+++ v6/sock_ut.py	2021-07-02 21:40:11.000000000 +0900
@@ -26,8 +26,7 @@
 		return False
 	return True

-def recv_bt( sc ):
-	bufmax = 16 * 1024
+def recv_bt( sc, bufmax=16*1024 ):
 	bt = sc.recv( bufmax )
 	return bt

@@ -44,8 +43,8 @@
 	bt = s.encode( 'utf-8' )
 	return send_bt( sc, bt )

-def recv_str( sc ):
-	bt = recv_bt( sc )
+def recv_str( sc, bufmax=16*1024 ):
+	bt = recv_bt( sc, bufmax )
 	return bt.decode( 'utf-8' )

 def recv_str_all( sc ):
@@ -228,7 +227,7 @@
 	if not send_str( cs, s ):
 		cs.close()
 		return None
-	s = recv_str( cs )
+	s = recv_str( cs, bufmax=2 )
 	if s != 'ok':
 		cs.close()
 		return None
@@ -273,7 +272,7 @@
 		cs.close()
 		return None

-	s = recv_str( cs )
+	s = recv_str( cs, bufmax=2 )
 	if s != 'ok':
 		cs.close()
 		return None

diff -ur v6/sock_ut.py v7/sock_ut.py
--- v6/sock_ut.py	2021-07-02 21:40:11.000000000 +0900
+++ v7/sock_ut.py	2021-07-14 22:40:49.000000000 +0900
@@ -59,8 +59,9 @@
 		if not send_bt( sc_to, bt ):
 			break

-# srv=name
-# port=xxx,srv=name,id=xxx
+# srv=name,port=xxx,host=xxx
+# srv=name,id=xxx,port=xxx,host=xxx
+# srv=name,id=xxx
 # kill=name
 # kill_base_srv
 # name
@@ -70,15 +71,20 @@
 		return {}
 	return dict( map( lambda t: t.split( '=' ), s.split( ',' ) ) )

+is_keys_dic = lambda d, ks: len( d ) == len( ks ) and all( map( lambda k: k in d, ks ) )
+
 is_key_dic = lambda d, k: len( d ) == 1 and k in d

-is_srv_dic = lambda d: is_key_dic( d, 'srv' )
+is_srv_dic = lambda d: is_keys_dic( d, [ 'srv', 'port', 'host' ] )

 is_kill_dic = lambda d: is_key_dic( d, 'kill' )

-def is_accept_dic( d ):
-	ks = [ 'port', 'srv', 'id' ]
-	return len( d ) == len( ks ) and all( map( lambda k: k in d, ks ) )
+is_accept_dic = lambda d: is_keys_dic( d, [ 'srv', 'id', 'port', 'host' ] )
+
+def get_port_host_from_dic( d ):
+	port = int( d.get( 'port' ) )
+	host = d.get( 'host' )
+	return ( port, host )

 srvs = {}
 reqs = {}
@@ -88,6 +94,8 @@
 	if name in srvs:
 		return

+	( port, host ) = get_port_host_from_dic( d )
+
 	q = thr.que_new()
 	srvs[ name ] = q

@@ -96,6 +104,7 @@
 		s = q.get()
 		if s == 'kill':
 			break
+		s += ',port={},host={}'.format( port, host )
 		if not send_str( sc, s ):
 			break

@@ -103,6 +112,7 @@
 	dbg.out( 'srv {} quit'.format( name ) )

 def base_th_accept( sc, s ):
+	s = ','.join( s.split( ',' )[ : -2 ] )
 	if s not in reqs:
 		return

@@ -116,11 +126,11 @@

 	pipe_loop( sc, sc2 )

-def base_th_connect( port, sc, s ):
+def base_th_connect( sc, s ):
 	name = s
 	q = srvs.get( name )
 	id = sc.fileno()
-	s = 'port={},srv={},id={}'.format( port, name, id )
+	s = 'srv={},id={}'.format( name, id )
 	ev = thr.event_new()
 	reqs[ s ] = [ sc, ev ]
 	q.put( s )
@@ -157,18 +167,18 @@
 		send_str( sc, 'next' )

 	elif s in srvs:
-		base_th_connect( port, sc, s )
+		base_th_connect( sc, s )

 	sc.close()

-def ping_th( port ):
+def ping_th():
 	id = 'ping'
 	for ( name, q ) in srvs.items():
-		s = 'port={},srv={},id={}'.format( port, name, id )
+		s = 'srv={},id={}'.format( name, id )
 		q.put( s )

 def base_srv( port ):
-	th_p = thr.loop_new( ping_th, ( port, ), wait_tmout=1.0 )
+	th_p = thr.loop_new( ping_th, wait_tmout=1.0 )
 	thr.ths.start( th_p )

 	ss = socket.socket( socket.AF_INET, socket.SOCK_STREAM )
@@ -185,12 +195,12 @@
 	th_p.quit_ev.set()
 	dbg.out( 'base_srv quit' )

-def server( port, name ):
-	ss = port_conn( port )
+def server( port, name, host='localhost' ):
+	ss = port_conn( port, host )
 	if not ss:
 		return None

-	s = 'srv=' + name
+	s = 'srv={},port={},host={}'.format( name, port, host )
 	if not send_str( ss, s ):
 		ss.close()
 		return None
@@ -222,8 +232,8 @@
 	if not r:
 		return None
 	( s, d ) = r
-	port = int( d.get( 'port' ) )
-	cs = port_conn( port )
+	( port, host ) = get_port_host_from_dic( d )
+	cs = port_conn( port, host )
 	if not send_str( cs, s ):
 		cs.close()
 		return None
@@ -237,8 +247,8 @@
 	r = accept_recv( ss )
 	return accept_conn( r )

-def srv_loop( port, name, th_func ):
-	ss = server( port, name )
+def srv_loop( port, name, th_func, host='localhost' ):
+	ss = server( port, name, host )
 	if not ss:
 		return
 	while True:
@@ -263,8 +273,8 @@

 	return empty.new( locals() )

-def connect( port, name ):
-	cs = port_conn( port )
+def connect( port, name, host='localhost' ):
+	cs = port_conn( port, host )
 	if not cs:
 		return None

@@ -278,8 +288,8 @@
 		return None
 	return cs

-def kill_srv( port, name ):
-	cs = port_conn( port )
+def kill_srv( port, name, host='loaclhost' ):
+	cs = port_conn( port, host )
 	if not cs:
 		return
 	s = 'kill=' + name
@@ -287,8 +297,8 @@
 	send_str( cs, s )
 	cs.close()

-def kill_base_srv( port ):
-	cs = port_conn( port )
+def kill_base_srv( port, host='loaclhost' ):
+	cs = port_conn( port, host )
 	if not cs:
 		return
 	dbg.out( 'kill_base_srv' )
@@ -296,20 +306,20 @@
 	r = recv_str( cs )
 	cs.close()

-	cs = port_conn( port )  # for accept loop
+	cs = port_conn( port, host )  # for accept loop
 	if cs:
 		cs.close()

 def help():
 	lst = [
 		'\\',
-		'port base',
-		'port srv upper',
-		'port srv eval',
-		'port cli upper word word word ...',
-		'port cli eval word word word ...',
-		'port kill_base',
-		'port kill srv_name ( srv_name is upper, eval or ... )'
+		'base [ port=13579 ]',
+		'srv [ host=localhost ][ port=13579 ] upper',
+		'srv [ host=localhost ][ port=13579 ] eval',
+		'cli [ host=localhost ][ port=13579 ] upper word word word ...',
+		'cli [ host=localhost ][ port=13579 ] eval word word word ...',
+		'kill_base [ host=localhost ][ port=13579 ]',
+		'kill [ host=localhost ][ port=13579 ] srv_name ( srv_name is upper, eval or ... )'
 	]
 	dbg.help_exit( '\n'.join( lst ) )

@@ -324,7 +334,15 @@
 			help()
 		return argv.pop( 0 )

-	port = int( pop() )
+	def popk( k, dv=None ):
+		for i in range( len( argv ) ):
+			if argv[ i ].startswith( k ):
+				return argv.pop( i )[ len( k ) : ]
+		return dv
+
+	host = popk( 'host=', 'localhost' )
+	port = int( popk( 'port=', '13579' ) )
+
 	names = {
 		'upper': lambda s: s.upper(),
 		'eval': lambda s: str( eval( s ) ),
@@ -338,11 +356,11 @@
 		if name in names:
 			cb = names.get( name )
 			srv_func = srv_func_new( cb )
-			srv_loop( port, name, srv_func.func )
+			srv_loop( port, name, srv_func.func, host )
 	elif cmd == 'cli':
 		name = pop()
 		if name in names:
-			sc = connect( port, name )
+			sc = connect( port, name, host )
 			if not sc:
 				return
 			while len( argv ) > 0:
@@ -356,10 +374,10 @@
 			sc.close()
 	elif cmd == 'kill':
 		name = pop()
-		kill_srv( port, name )
+		kill_srv( port, name, host )

 	elif cmd == 'kill_base':
-		kill_base_srv( port )
+		kill_base_srv( port, host )


 if __name__ == "__main__":

diff -ur v7/sock_ut.py v8/sock_ut.py
--- v7/sock_ut.py	2021-07-14 22:40:49.000000000 +0900
+++ v8/sock_ut.py	2021-07-16 10:25:21.000000000 +0900
@@ -11,6 +11,10 @@

 can_read = lambda sc, tmout=0: select.select( [ sc ], [], [], tmout )[ 0 ] == [ sc ]

+add_tail = lambda s, add: s + add
+
+cut_tail = lambda s, cut: s[ : -len( cut ) ] if s.endswith( cut ) else s
+
 def port_conn( port, host='localhost' ):
 	cs = socket.socket( socket.AF_INET, socket.SOCK_STREAM )
 	try:
@@ -40,16 +44,19 @@
 	return buf

 def send_str( sc, s ):
+	s = add_tail( s, '\n' )
 	bt = s.encode( 'utf-8' )
 	return send_bt( sc, bt )

 def recv_str( sc, bufmax=16*1024 ):
-	bt = recv_bt( sc, bufmax )
-	return bt.decode( 'utf-8' )
+	bt = recv_bt( sc, bufmax + 1 )  # '\n'
+	s = bt.decode( 'utf-8' )
+	return cut_tail( s, '\n' )

 def recv_str_all( sc ):
 	bt = recv_bt_all( sc )
-	return bt.decode( 'utf-8' )
+	s = bt.decode( 'utf-8' )
+	return cut_tail( s, '\n' )

 def pipe_loop( sc_from, sc_to ):
 	while True:

def fio_new( get_b1_, put_b_, get_b_=None ):

	to_s = lambda bt: bt.decode( 'utf-8' )
	to_b = lambda s: s.encode( 'utf-8' )

	def get_b1( f ):
		b1 = get_b1_( f )
		return b1 if b1 else b''

	get_s1 = lambda f : to_s( get_b1( f ) )

	def get_b_line( f ):
		b = b''
		while True:
			b1 = get_b1( f )
			if not b1:
				break
			b += b1
			if b1 == b'\n':
				break
		return b

	get_s_line = lambda f: to_s( get_b_line( f ) )

	def get_b( f ):
		if get_b_:
			return get_b_( f )

		b = b''
		while not b or can_read( f ):
			b1 = get_b1( f )
			if not b1:
				break
			b += b1
		return b

	get_s = lambda f: to_s( get_b( f ) )

	def get_b_all( f ):
		b = b''
		while not b or can_read( f ):
			b_ = get_b( f )
			if not b_:
				break
			b += b_
		return b

	get_s_all = lambda f: to_s( get_b_all( f ) )


	def put_b( f, b ):
		try:
			put_b_( f, b )
		except:
			return False
		if hasattr( f, 'flush' ):
			f.flush()
		return True

	put_s = lambda f, s: put_b( f, to_b( s ) )


	def get_func( use_b, use_all ):
		if use_b:
			return get_b_all if use_all else get_b
		return get_s_all if use_all else get_s

	def put_func( use_b ):
		return put_b if use_b else put_s


	return empty.new( locals() )

diff -ur v8/sock_ut.py v9/sock_ut.py
--- v8/sock_ut.py	2021-07-16 10:25:21.000000000 +0900
+++ v9/sock_ut.py	2021-07-17 01:34:19.000000000 +0900
@@ -7,6 +7,7 @@

 import empty
 import thr
+import cmd_ut
 import dbg

 can_read = lambda sc, tmout=0: select.select( [ sc ], [], [], tmout )[ 0 ] == [ sc ]
@@ -15,6 +16,106 @@

 cut_tail = lambda s, cut: s[ : -len( cut ) ] if s.endswith( cut ) else s

+def fio_new( get_b1_, put_b_, get_b_=None ):
+
+	to_s = lambda bt: bt.decode( 'utf-8' )
+	to_b = lambda s: s.encode( 'utf-8' )
+
+	def get_b1( f ):
+		b1 = get_b1_( f )
+		return b1 if b1 else b''
+
+	get_s1 = lambda f : to_s( get_b1( f ) )
+
+	def get_b_line( f ):
+		b = b''
+		while True:
+			b1 = get_b1( f )
+			if not b1:
+				break
+			b += b1
+			if b1 == b'\n':
+				break
+		return b
+
+	get_s_line = lambda f: to_s( get_b_line( f ) )
+
+	def get_b( f ):
+		if get_b_:
+			return get_b_( f )
+
+		b = b''
+		while not b or can_read( f ):
+			b1 = get_b1( f )
+			if not b1:
+				break
+			b += b1
+		return b
+
+	get_s = lambda f: to_s( get_b( f ) )
+
+	def get_b_all( f ):
+		b = b''
+		while not b or can_read( f ):
+			b_ = get_b( f )
+			if not b_:
+				break
+			b += b_
+		return b
+
+	get_s_all = lambda f: to_s( get_b_all( f ) )
+
+
+	def put_b( f, b ):
+		try:
+			put_b_( f, b )
+		except:
+			return False
+		if hasattr( f, 'flush' ):
+			f.flush()
+		return True
+
+	put_s = lambda f, s: put_b( f, to_b( s ) )
+
+
+	def get_func( use_b, use_all ):
+		if use_b:
+			return get_b_all if use_all else get_b
+		return get_s_all if use_all else get_s
+
+	def put_func( use_b ):
+		return put_b if use_b else put_s
+
+
+	return empty.new( locals() )
+
+
+def get_std_b( f ):
+	return f.buffer if hasattr( f, 'buffer' ) else f
+
+stdin_b = get_std_b( sys.stdin )
+stdout_b = get_std_b( sys.stdout )
+std_fio = fio_new( lambda f: f.read( 1 ), lambda f, b: f.write( b ) )
+
+
+def proc_new( cmd ):
+	proc = cmd_ut.proc_new( cmd, stdin=cmd_ut.PIPE, stdout=cmd_ut.PIPE )
+
+	stdin = proc.get_stdin()
+	stdout = proc.get_stdout()
+
+	get_b1 = lambda f: f.read( 1 )
+	put_b = lambda f, b: f.write( b ) if f else 0
+
+	fio = fio_new( get_b1, put_b )
+
+	def stop():
+		proc.kill()
+		proc.wait()
+
+	return empty.new( locals() )
+
+
 def port_conn( port, host='localhost' ):
 	cs = socket.socket( socket.AF_INET, socket.SOCK_STREAM )
 	try:
@@ -23,52 +124,33 @@
 		return None
 	return cs

-def send_bt( sc, bt ):
-	try:
-		sc.sendall( bt )
-	except:
-		return False
-	return True
-
-def recv_bt( sc, bufmax=16*1024 ):
-	bt = sc.recv( bufmax )
-	return bt
-
-def recv_bt_all( sc ):
-	buf = b''
-	while not buf or can_read( sc ):
-		bt = recv_bt( sc )
-		if not bt:
-			break
-		buf += bt
-	return buf
+bufmax = 16 * 1024
+sc_fio = fio_new( lambda f: f.recv( 1 ), lambda f, b: f.sendall( b ), lambda f: f.recv( bufmax ) )

 def send_str( sc, s ):
 	s = add_tail( s, '\n' )
-	bt = s.encode( 'utf-8' )
-	return send_bt( sc, bt )
+	return sc_fio.put_s( sc, s )

-def recv_str( sc, bufmax=16*1024 ):
-	bt = recv_bt( sc, bufmax + 1 )  # '\n'
-	s = bt.decode( 'utf-8' )
+def recv_str_line( sc ):
+	s = sc_fio.get_s_line( sc )
 	return cut_tail( s, '\n' )

 def recv_str_all( sc ):
-	bt = recv_bt_all( sc )
-	s = bt.decode( 'utf-8' )
+	s = sc_fio.get_s_all( sc )
 	return cut_tail( s, '\n' )

 def pipe_loop( sc_from, sc_to ):
 	while True:
-		bt = recv_bt( sc_from )
-		if not bt:
+		b = sc_fio.get_b( sc_from )
+		if not b:
 			break
-		if not send_bt( sc_to, bt ):
+		if not sc_fio.put_b( sc_to, b ):
 			break

 # srv=name,port=xxx,host=xxx
 # srv=name,id=xxx,port=xxx,host=xxx
 # srv=name,id=xxx
+# get_srvs
 # kill=name
 # kill_base_srv
 # name
@@ -150,7 +232,7 @@
 	pipe_loop( sc, sc2 )

 def base_th( port, sc, ev_quit ):
-	s = recv_str( sc )
+	s = recv_str_line( sc )
 	if not s:
 		sc.close()
 		return
@@ -169,6 +251,10 @@
 			q = srvs.get( name )
 			q.put( 'kill' )

+	elif s == 'get_srvs':
+		r = '\n'.join( srvs.keys() )
+		send_str( sc, r )
+
 	elif s == 'kill_base_srv':
 		ev_quit.set()
 		send_str( sc, 'next' )
@@ -214,7 +300,7 @@
 	return ss

 def accept_recv_ping( ss ):
-	s = recv_str( ss )
+	s = recv_str_line( ss )
 	if not s:
 		return None

@@ -244,7 +330,7 @@
 	if not send_str( cs, s ):
 		cs.close()
 		return None
-	s = recv_str( cs, bufmax=2 )
+	s = recv_str_line( cs )
 	if s != 'ok':
 		cs.close()
 		return None
@@ -266,20 +352,42 @@
 		thr.ths.start( th )
 	ss.close()

-def srv_func_new( cb ):
+def srv_func_new( cb, use_b=False, use_all=False ):
+	send = send_ = sc_fio.put_func( use_b )
+	recv = recv_ = sc_fio.get_func( use_b, use_all )
+	if not use_b:
+		send = lambda f, s: send_( f, add_tail( s, '\n' ) )
+		recv = lambda f: cut_tail( recv_( f ), '\n' )

 	def func( sc ):
 		while True:
-			s = recv_str( sc )
+			s = recv( sc )
 			if not s:
 				break
 			r = cb( s )
-			if not send_str( sc, r ):
+			if not r:
+				break
+			if not send( sc, r ):
 				break
 		sc.close()

 	return empty.new( locals() )

+def srv_loop_cmd( host, port, name, cmd ):
+
+	def th_func( sc ):
+		proc = proc_new( cmd )
+
+		def cb( b ):
+			proc.fio.put_b( proc.stdin, b )
+			return proc.fio.get_b_line( proc.stdout )
+
+		srv_func = srv_func_new( cb, use_b=True, use_all=True )
+		srv_func.func( sc )
+		proc.stop()
+
+	srv_loop( port, name, th_func, host )
+
 def connect( port, name, host='localhost' ):
 	cs = port_conn( port, host )
 	if not cs:
@@ -289,12 +397,21 @@
 		cs.close()
 		return None

-	s = recv_str( cs, bufmax=2 )
+	s = recv_str_line( cs  )
 	if s != 'ok':
 		cs.close()
 		return None
 	return cs

+def get_srvs( host, port ):
+	cs = port_conn( port, host )
+	if not cs:
+		return
+	send_str( cs, 'get_srvs' )
+	r = recv_str_all( cs )
+	cs.close()
+	return r.split( '\n' )
+
 def kill_srv( port, name, host='loaclhost' ):
 	cs = port_conn( port, host )
 	if not cs:
@@ -310,7 +427,7 @@
 		return
 	dbg.out( 'kill_base_srv' )
 	send_str( cs, 'kill_base_srv' )
-	r = recv_str( cs )
+	r = recv_str_line( cs )
 	cs.close()

 	cs = port_conn( port, host )  # for accept loop
@@ -323,8 +440,11 @@
 		'base [ port=13579 ]',
 		'srv [ host=localhost ][ port=13579 ] upper',
 		'srv [ host=localhost ][ port=13579 ] eval',
+		'srv [ host=localhost ][ port=13579 ] srv_name cmd arg ...',
 		'cli [ host=localhost ][ port=13579 ] upper word word word ...',
 		'cli [ host=localhost ][ port=13579 ] eval word word word ...',
+		'cli [ host=localhost ][ port=13579 ] srv_name',
+		'srvs [ host=localhost ][ port=13579 ]',
 		'kill_base [ host=localhost ][ port=13579 ]',
 		'kill [ host=localhost ][ port=13579 ] srv_name ( srv_name is upper, eval or ... )'
 	]
@@ -345,7 +465,7 @@
 		for i in range( len( argv ) ):
 			if argv[ i ].startswith( k ):
 				return argv.pop( i )[ len( k ) : ]
-		return dv
+		return dv

 	host = popk( 'host=', 'localhost' )
 	port = int( popk( 'port=', '13579' ) )
@@ -358,27 +478,55 @@
 	cmd = pop()
 	if cmd == 'base':
 		base_srv( port )
-	elif cmd == 'srv':
+	elif cmd == 'srv':
 		name = pop()
 		if name in names:
 			cb = names.get( name )
 			srv_func = srv_func_new( cb )
 			srv_loop( port, name, srv_func.func, host )
-	elif cmd == 'cli':
+		else:
+			cmd = ' '.join( argv )
+			srv_loop_cmd( host, port, name, cmd )
+	elif cmd == 'cli':
+		lst = get_srvs( host, port )
 		name = pop()
+		if name not in lst:
+			return
+
+		sc = connect( port, name, host )
+		if not sc:
+			return
+
 		if name in names:
-			sc = connect( port, name, host )
-			if not sc:
-				return
 			while len( argv ) > 0:
 				w = pop()
 				if not send_str( sc, w ):
 					break
-				r = recv_str( sc )
+				r = recv_str_line( sc )
 				if not r:
 					break
 				dbg.out( '{} --> {}'.format( w, r ) )
-			sc.close()
+		else:
+			while True:
+				b = std_fio.get_b_line( stdin_b )
+				if not b:
+					break
+
+				if not sc_fio.put_b( sc, b ):
+					break
+
+				b = sc_fio.get_b_all( sc )
+				if not b:
+					break
+
+				if not std_fio.put_b( stdout_b, b ):
+					break
+		sc.close()
+
+	elif cmd == 'srvs':
+		lst = get_srvs( host, port )
+		dbg.out( '\n'.join( lst ) )
+
 	elif cmd == 'kill':
 		name = pop()
 		kill_srv( port, name, host )

diff -ur v9/sock_ut.py v10/sock_ut.py
--- v9/sock_ut.py	2021-07-17 01:34:19.000000000 +0900
+++ v10/sock_ut.py	2021-07-19 00:10:50.000000000 +0900
@@ -2,119 +2,16 @@

 import sys
 import socket
-import select
-import time

 import empty
 import thr
-import cmd_ut
+import fio_ut
 import dbg

-can_read = lambda sc, tmout=0: select.select( [ sc ], [], [], tmout )[ 0 ] == [ sc ]
-
 add_tail = lambda s, add: s + add
-
 cut_tail = lambda s, cut: s[ : -len( cut ) ] if s.endswith( cut ) else s

-def fio_new( get_b1_, put_b_, get_b_=None ):
-
-	to_s = lambda bt: bt.decode( 'utf-8' )
-	to_b = lambda s: s.encode( 'utf-8' )
-
-	def get_b1( f ):
-		b1 = get_b1_( f )
-		return b1 if b1 else b''
-
-	get_s1 = lambda f : to_s( get_b1( f ) )
-
-	def get_b_line( f ):
-		b = b''
-		while True:
-			b1 = get_b1( f )
-			if not b1:
-				break
-			b += b1
-			if b1 == b'\n':
-				break
-		return b
-
-	get_s_line = lambda f: to_s( get_b_line( f ) )
-
-	def get_b( f ):
-		if get_b_:
-			return get_b_( f )
-
-		b = b''
-		while not b or can_read( f ):
-			b1 = get_b1( f )
-			if not b1:
-				break
-			b += b1
-		return b
-
-	get_s = lambda f: to_s( get_b( f ) )
-
-	def get_b_all( f ):
-		b = b''
-		while not b or can_read( f ):
-			b_ = get_b( f )
-			if not b_:
-				break
-			b += b_
-		return b
-
-	get_s_all = lambda f: to_s( get_b_all( f ) )
-
-
-	def put_b( f, b ):
-		try:
-			put_b_( f, b )
-		except:
-			return False
-		if hasattr( f, 'flush' ):
-			f.flush()
-		return True
-
-	put_s = lambda f, s: put_b( f, to_b( s ) )
-
-
-	def get_func( use_b, use_all ):
-		if use_b:
-			return get_b_all if use_all else get_b
-		return get_s_all if use_all else get_s
-
-	def put_func( use_b ):
-		return put_b if use_b else put_s
-
-
-	return empty.new( locals() )
-
-
-def get_std_b( f ):
-	return f.buffer if hasattr( f, 'buffer' ) else f
-
-stdin_b = get_std_b( sys.stdin )
-stdout_b = get_std_b( sys.stdout )
-std_fio = fio_new( lambda f: f.read( 1 ), lambda f, b: f.write( b ) )
-
-
-def proc_new( cmd ):
-	proc = cmd_ut.proc_new( cmd, stdin=cmd_ut.PIPE, stdout=cmd_ut.PIPE )
-
-	stdin = proc.get_stdin()
-	stdout = proc.get_stdout()
-
-	get_b1 = lambda f: f.read( 1 )
-	put_b = lambda f, b: f.write( b ) if f else 0
-
-	fio = fio_new( get_b1, put_b )
-
-	def stop():
-		proc.kill()
-		proc.wait()
-
-	return empty.new( locals() )
-
+close = fio_ut.close

 def port_conn( port, host='localhost' ):
 	cs = socket.socket( socket.AF_INET, socket.SOCK_STREAM )
@@ -122,29 +19,27 @@
 		cs.connect( ( host, port ) )
 	except:
 		return None
+	fio_ut.set_fs_sock( cs )
 	return cs

-bufmax = 16 * 1024
-sc_fio = fio_new( lambda f: f.recv( 1 ), lambda f, b: f.sendall( b ), lambda f: f.recv( bufmax ) )
-
 def send_str( sc, s ):
 	s = add_tail( s, '\n' )
-	return sc_fio.put_s( sc, s )
+	return fio_ut.p_s( sc, s )

 def recv_str_line( sc ):
-	s = sc_fio.get_s_line( sc )
+	s = fio_ut.g_s_line( sc )
 	return cut_tail( s, '\n' )

 def recv_str_all( sc ):
-	s = sc_fio.get_s_all( sc )
+	s = fio_ut.g_s_all( sc )
 	return cut_tail( s, '\n' )

 def pipe_loop( sc_from, sc_to ):
 	while True:
-		b = sc_fio.get_b( sc_from )
+		b = fio_ut.g_b( sc_from )
 		if not b:
 			break
-		if not sc_fio.put_b( sc_to, b ):
+		if not fio_ut.p_b( sc_to, b ):
 			break

 # srv=name,port=xxx,host=xxx
@@ -232,9 +127,11 @@
 	pipe_loop( sc, sc2 )

 def base_th( port, sc, ev_quit ):
+	fio_ut.set_fs_sock( sc )
+
 	s = recv_str_line( sc )
 	if not s:
-		sc.close()
+		close( sc )
 		return

 	d = get_dic( s )
@@ -262,7 +159,7 @@
 	elif s in srvs:
 		base_th_connect( sc, s )

-	sc.close()
+	close( sc )

 def ping_th():
 	id = 'ping'
@@ -295,7 +192,7 @@

 	s = 'srv={},port={},host={}'.format( name, port, host )
 	if not send_str( ss, s ):
-		ss.close()
+		close( ss )
 		return None
 	return ss

@@ -328,11 +225,11 @@
 	( port, host ) = get_port_host_from_dic( d )
 	cs = port_conn( port, host )
 	if not send_str( cs, s ):
-		cs.close()
+		close( cs )
 		return None
 	s = recv_str_line( cs )
 	if s != 'ok':
-		cs.close()
+		close( cs )
 		return None
 	return cs

@@ -350,11 +247,21 @@
 			break
 		th = thr.th_new( th_func, ( cs, ) )
 		thr.ths.start( th )
-	ss.close()
+	close( ss )

 def srv_func_new( cb, use_b=False, use_all=False ):
-	send = send_ = sc_fio.put_func( use_b )
-	recv = recv_ = sc_fio.get_func( use_b, use_all )
+	send = fio_ut.p_s
+	recv = fio_ut.g_s
+	if use_all:
+		recv = fio_ut.g_s_all
+	if use_b:
+		send = fio_ut.p_b
+		recv = fio_ut.g_b
+		if use_all:
+			recv = fio_ut.g_b_all
+
+	send_ = send
+	recv_ = recv
 	if not use_b:
 		send = lambda f, s: send_( f, add_tail( s, '\n' ) )
 		recv = lambda f: cut_tail( recv_( f ), '\n' )
@@ -369,18 +276,18 @@
 				break
 			if not send( sc, r ):
 				break
-		sc.close()
+		close( sc )

 	return empty.new( locals() )

 def srv_loop_cmd( host, port, name, cmd ):

 	def th_func( sc ):
-		proc = proc_new( cmd )
+		proc = fio_ut.proc_new( cmd )

 		def cb( b ):
-			proc.fio.put_b( proc.stdin, b )
-			return proc.fio.get_b_line( proc.stdout )
+			fio_ut.p_b( proc.fo, b )
+			return fio_ut.g_b_all( proc.fi )

 		srv_func = srv_func_new( cb, use_b=True, use_all=True )
 		srv_func.func( sc )
@@ -394,12 +301,12 @@
 		return None

 	if not send_str( cs, name ):
-		cs.close()
+		close( cs )
 		return None

 	s = recv_str_line( cs  )
 	if s != 'ok':
-		cs.close()
+		close( cs )
 		return None
 	return cs

@@ -409,7 +316,7 @@
 		return
 	send_str( cs, 'get_srvs' )
 	r = recv_str_all( cs )
-	cs.close()
+	close( cs )
 	return r.split( '\n' )

 def kill_srv( port, name, host='loaclhost' ):
@@ -419,7 +326,7 @@
 	s = 'kill=' + name
 	#dbg.out( s )
 	send_str( cs, s )
-	cs.close()
+	close( cs )

 def kill_base_srv( port, host='loaclhost' ):
 	cs = port_conn( port, host )
@@ -428,11 +335,11 @@
 	dbg.out( 'kill_base_srv' )
 	send_str( cs, 'kill_base_srv' )
 	r = recv_str_line( cs )
-	cs.close()
+	close( cs )

 	cs = port_conn( port, host )  # for accept loop
 	if cs:
-		cs.close()
+		close( cs )

 def help():
 	lst = [
@@ -507,21 +414,22 @@
 					break
 				dbg.out( '{} --> {}'.format( w, r ) )
 		else:
+			( fi, fo ) = fio_ut.set_fs_sys_stdio()
 			while True:
-				b = std_fio.get_b_line( stdin_b )
+				b = fio_ut.g_b_line( fi )
 				if not b:
 					break

-				if not sc_fio.put_b( sc, b ):
+				if not fio_ut.p_b( sc, b ):
 					break

-				b = sc_fio.get_b_all( sc )
+				b = fio_ut.g_b_all( sc )
 				if not b:
 					break

-				if not std_fio.put_b( stdout_b, b ):
+				if not fio_ut.p_b( fo, b ):
 					break
-		sc.close()
+		close( sc )

 	elif cmd == 'srvs':
 		lst = get_srvs( host, port )

$ ./sock_ut.py 
Usage: ./sock_ut.py \
base [ port=13579 ]
srv [ host=localhost ][ port=13579 ] upper
srv [ host=localhost ][ port=13579 ] eval
srv [ host=localhost ][ port=13579 ] srv_name cmd arg ...
cli [ host=localhost ][ port=13579 ] upper word word word ...
cli [ host=localhost ][ port=13579 ] eval word word word ...
cli [ host=localhost ][ port=13579 ] srv_name
srvs [ host=localhost ][ port=13579 ]
kill_base [ host=localhost ][ port=13579 ]
kill [ host=localhost ][ port=13579 ] srv_name ( srv_name is upper, eval or ... )

$ ./sock_ut.py base &
[1] 36633

$ ./sock_ut.py srv upper &
[2] 36634
srv upper start

$ ./sock_ut.py srv eval &
[3] 36635
srv eval start

$ ./sock_ut.py cli upper foo bar hoge
foo --> FOO
bar --> BAR
hoge --> HOGE

$ ./sock_ut.py cli eval 1+1 2+3
1+1 --> 2
2+3 --> 5

$ ./sock_ut.py srvs
upper
eval

$ ./sock_ut.py srv bc bc -l &
[4] 36639
srv bc start

$ ./sock_ut.py cli bc
1+1
2
2+3.14
5.14
10/3
3.33333333333333333333
^D
$

$ ./sock_ut.py srvs
upper
eval
bc

$ ./sock_ut.py kill bc
srv bc quit
[4]+  Done                    ./sock_ut.py srv bc bc -l

$ ./sock_ut.py kill_base
kill_base_srv
base_srv quit
[1]   Done                    ./sock_ut.py base
[2]-  Done                    ./sock_ut.py srv upper
[3]+  Done                    ./sock_ut.py srv eval
$

diff -ur v10/sock_ut.py v11/sock_ut.py
--- v10/sock_ut.py	2021-07-19 00:10:50.000000000 +0900
+++ v11/sock_ut.py	2021-07-25 11:38:44.000000000 +0900
@@ -280,13 +280,15 @@

 	return empty.new( locals() )

-def srv_loop_cmd( host, port, name, cmd ):
+def srv_loop_cmd( host, port, name, cmd, mode ):

 	def th_func( sc ):
 		proc = fio_ut.proc_new( cmd )

 		def cb( b ):
 			fio_ut.p_b( proc.fo, b )
+			if mode == 'all':
+				fio_ut.close( proc.fo )
 			return fio_ut.g_b_all( proc.fi )

 		srv_func = srv_func_new( cb, use_b=True, use_all=True )
@@ -348,15 +350,51 @@
 		'srv [ host=localhost ][ port=13579 ] upper',
 		'srv [ host=localhost ][ port=13579 ] eval',
 		'srv [ host=localhost ][ port=13579 ] srv_name cmd arg ...',
+		'srv -a [ host=localhost ][ port=13579 ] srv_name cmd arg ... ( all mode )',
 		'cli [ host=localhost ][ port=13579 ] upper word word word ...',
 		'cli [ host=localhost ][ port=13579 ] eval word word word ...',
 		'cli [ host=localhost ][ port=13579 ] srv_name',
+		'cli -a [ host=localhost ][ port=13579 ] srv_name ( all mode )',
 		'srvs [ host=localhost ][ port=13579 ]',
 		'kill_base [ host=localhost ][ port=13579 ]',
 		'kill [ host=localhost ][ port=13579 ] srv_name ( srv_name is upper, eval or ... )'
 	]
 	dbg.help_exit( '\n'.join( lst ) )

+def run_cli( sc, mode ):
+	( fi, fo ) = fio_ut.set_fs_sys_stdio()
+
+	def cnv_out( b ):
+		if not fio_ut.p_b( sc, b ):
+			return False
+
+		b = fio_ut.g_b_all( sc )
+		if not b:
+			return False
+
+		if not fio_ut.p_b( fo, b ):
+			return False
+
+		return True
+
+	if mode == 'all':
+		buf = b''
+		while True:
+			b = fio_ut.g_b_all( fi )
+			if not b:
+				break
+			buf += b
+		cnv_out( buf )
+		return
+
+	# mode == 'line'
+	while True:
+		b = fio_ut.g_b_line( fi )
+		if not b:
+			break
+		if not cnv_out( b ):
+			break
+
 def run():
 	if len( sys.argv ) < 2:
 		help()
@@ -374,6 +412,12 @@
 				return argv.pop( i )[ len( k ) : ]
 		return dv

+	def pop_mode():
+		if argv[ 0 ] == '-a':
+			pop()
+			return 'all'
+		return 'line'
+
 	host = popk( 'host=', 'localhost' )
 	port = int( popk( 'port=', '13579' ) )

@@ -386,6 +430,7 @@
 	if cmd == 'base':
 		base_srv( port )
 	elif cmd == 'srv':
+		mode = pop_mode()
 		name = pop()
 		if name in names:
 			cb = names.get( name )
@@ -393,8 +438,9 @@
 			srv_loop( port, name, srv_func.func, host )
 		else:
 			cmd = ' '.join( argv )
-			srv_loop_cmd( host, port, name, cmd )
+			srv_loop_cmd( host, port, name, cmd, mode )
 	elif cmd == 'cli':
+		mode = pop_mode()
 		lst = get_srvs( host, port )
 		name = pop()
 		if name not in lst:
@@ -414,21 +460,7 @@
 					break
 				dbg.out( '{} --> {}'.format( w, r ) )
 		else:
-			( fi, fo ) = fio_ut.set_fs_sys_stdio()
-			while True:
-				b = fio_ut.g_b_line( fi )
-				if not b:
-					break
-
-				if not fio_ut.p_b( sc, b ):
-					break
-
-				b = fio_ut.g_b_all( sc )
-				if not b:
-					break
-
-				if not fio_ut.p_b( fo, b ):
-					break
+			run_cli( sc, mode )
 		close( sc )

 	elif cmd == 'srvs':

$ ./sock_ut.py base &
[1] 62391


$ ./sock_ut.py srv upper &
[2] 62392
srv upper start

$ ./sock_ut.py srv eval &
[3] 62393
srv eval start

$ ./sock_ut.py cli upper foo bar hoge
foo --> FOO
bar --> BAR
hoge --> HOGE

$ ./sock_ut.py cli eval 1+1 2+3
1+1 --> 2
2+3 --> 5

$ ./sock_ut.py srv bc bc -l &
[4] 62396
srv bc start

$ ./sock_ut.py srvs
upper
eval
bc

$ ./sock_ut.py cli bc
1+1
2
10/3
3.33333333333333333333
^D
$

$ ./sock_ut.py kill upper
srv upper quit
[2]   Done                    ./sock_ut.py srv upper

$ ./sock_ut.py kill_base
kill_base_srv
base_srv quit
[1]   Done                    ./sock_ut.py base
[3]-  Done                    ./sock_ut.py srv eval
[4]+  Done                    ./sock_ut.py srv bc bc -l
$

#!/usr/bin/env python

import os
import sys
import pty
import dbg

if __name__ == "__main__":
	cmd = sys.argv[1:]
	if cmd:
		pty.spawn( cmd )
	else:
		dbg.help_exit( 'cmd ...' )
# EOF

$ CMD>>>PS1='> '
> CMD>>>./sock_ut.py base &
[1] 81095
> CMD>>>./sock_ut.py srv upper &
[2] 81096
> srv upper start
CMD>>>./sock_ut.py srv eval &
[3] 81097
> srv eval start
CMD>>>./sock_ut.py cli upper foo bar hoge
foo --> FOO
bar --> BAR
hoge --> HOGE
> CMD>>>./sock_ut.py cli eval 1+1 2+3
1+1 --> 2
2+3 --> 5
> CMD>>>./sock_ut.py srv bc bc -l &
[4] 81113
> srv bc start
CMD>>>./sock_ut.py srvs
upper
eval
bc
> CMD>>>./sock_ut.py cli bc
CMD>>>1+1
2
CMD>>>10/3
3.33333333333333333333
CMD>>>^D> CMD>>>./sock_ut.py kill upper
srv upper quit
> CMD>>>./sock_ut.py kill_base
kill_base_srv
base_srv quit
[2]   Done                    ./sock_ut.py srv upper
> CMD>>>
[1]   Done                    ./sock_ut.py base
[3]-  Done                    ./sock_ut.py srv eval
[4]+  Done                    ./sock_ut.py srv bc bc -l
> CMD>>>exit
exit

#!/usr/bin/env python

import sys

import dbg

def run():
	s = sys.stdin.read()
	s = s.replace( '\r', '' )
	lst = s.split( 'CMD>>>' )
	for i in range( len( lst ) ):
		dbg.out( 'lst[{}]="{}"'.format( i, lst[ i ] ) )

if __name__ == "__main__":
	run()
# EOF

$ ./test.py < LOG2
lst[0]="$ "
lst[1]="PS1='> '
> "
lst[2]="./sock_ut.py base &
[1] 81095
> "
lst[3]="./sock_ut.py srv upper &
[2] 81096
> srv upper start
"
lst[4]="./sock_ut.py srv eval &
[3] 81097
> srv eval start
"
lst[5]="./sock_ut.py cli upper foo bar hoge
foo --> FOO
bar --> BAR
hoge --> HOGE
> "
lst[6]="./sock_ut.py cli eval 1+1 2+3
1+1 --> 2
2+3 --> 5
> "
lst[7]="./sock_ut.py srv bc bc -l &
[4] 81113
> srv bc start
"
lst[8]="./sock_ut.py srvs
upper
eval
bc
> "
lst[9]="./sock_ut.py cli bc
"
lst[10]="1+1
2
"
lst[11]="10/3
3.33333333333333333333
"
lst[12]="^D> "
lst[13]="./sock_ut.py kill upper
srv upper quit
> "
lst[14]="./sock_ut.py kill_base
kill_base_srv
base_srv quit
[2]   Done                    ./sock_ut.py srv upper
> "
lst[15]="
[1]   Done                    ./sock_ut.py base
[3]-  Done                    ./sock_ut.py srv eval
[4]+  Done                    ./sock_ut.py srv bc bc -l
> "
lst[16]="exit
exit
"
$

#!/usr/bin/env python

import sys

import dbg

def run():
	s = sys.stdin.read()
	s = s.replace( '\r', '' )
	lst = s.split( 'CMD>>>' )

	def func( s ):
		n = 0
		if s.startswith( '^D' ):
			n = 2
		elif '\n' in s:
			n = s.index( '\n' ) + 1
		return ( s[ : n ], s[ n : ] )

	lst = list( map( func, lst ) )

	for i in range( len( lst ) ):
		dbg.out( 'lst[{}]={}'.format( i, lst[ i ] ) )

if __name__ == "__main__":
	run()
# EOF

$ ./test.py < LOG2
lst[0]=('', '$ ')
lst[1]=("PS1='> '\n", '> ')
lst[2]=('./sock_ut.py base &\n', '[1] 81095\n> ')
lst[3]=('./sock_ut.py srv upper &\n', '[2] 81096\n> srv upper start\n')
lst[4]=('./sock_ut.py srv eval &\n', '[3] 81097\n> srv eval start\n')
lst[5]=('./sock_ut.py cli upper foo bar hoge\n', 'foo --> FOO\nbar --> BAR\nhoge --> HOGE\n> ')
lst[6]=('./sock_ut.py cli eval 1+1 2+3\n', '1+1 --> 2\n2+3 --> 5\n> ')
lst[7]=('./sock_ut.py srv bc bc -l &\n', '[4] 81113\n> srv bc start\n')
lst[8]=('./sock_ut.py srvs\n', 'upper\neval\nbc\n> ')
lst[9]=('./sock_ut.py cli bc\n', '')
lst[10]=('1+1\n', '2\n')
lst[11]=('10/3\n', '3.33333333333333333333\n')
lst[12]=('^D', '> ')
lst[13]=('./sock_ut.py kill upper\n', 'srv upper quit\n> ')
lst[14]=('./sock_ut.py kill_base\n', 'kill_base_srv\nbase_srv quit\n[2]   Done                    ./sock_ut.py srv upper\n> ')
lst[15]=('\n', '[1]   Done                    ./sock_ut.py base\n[3]-  Done                    ./sock_ut.py srv eval\n[4]+  Done                    ./sock_ut.py srv bc bc -l\n> ')
lst[16]=('exit\n', 'exit\n')
$

#!/usr/bin/env python

import sys
import time

import fio_ut
import dbg

def run():
	s = sys.stdin.read()
	s = s.replace( '\r', '' )
	lst = s.split( 'CMD>>>' )

	def func( s ):
		n = 0
		if s.startswith( '^D' ):
			n = 2
		elif '\n' in s:
			n = s.index( '\n' ) + 1
		return ( s[ : n ], s[ n : ] )

	lst = list( map( func, lst ) )

	cmd = 'python -m pty_spawn bash'
	proc = fio_ut.proc_new( cmd )

	for ( si, so ) in lst:
		if si:
			dbg.out( 'si="{}"'.format( si ) )
			if not fio_ut.p_s( proc.fo, si ):
				dbg.out( 'err p_s' )

		dbg.out( 'so="{}"'.format( so ) )

		r = fio_ut.g_s_all( proc.fi )
		if not r:
			dbg.out( 'err g_s_all' )

		r = r.replace( '\r', '' )
		dbg.out( 'r="{}"'.format( r ) )

	proc.stop()

if __name__ == "__main__":
	run()
# EOF

$ ./test.py < LOG2
so="$ "
r="$ "
si="PS1='> '
"
so="> "
r="PS1='> '
> "
si="./sock_ut.py base &
"
so="[1] 81095
> "
r="./sock_ut.py base &
"
si="./sock_ut.py srv upper &
"
so="[2] 81096
> srv upper start
"
r="[1] 81548
> ./sock_ut.py srv upper &
"
si="./sock_ut.py srv eval &
"
so="[3] 81097
> srv eval start
"
r="[2] 81549
> ./sock_ut.py srv eval &
"
si="./sock_ut.py cli upper foo bar hoge
"
so="foo --> FOO
bar --> BAR
hoge --> HOGE
> "
r="./sock_ut.py cli upper foo bar hoge
"
si="./sock_ut.py cli eval 1+1 2+3
"
so="1+1 --> 2
2+3 --> 5
> "
r="[3] 81550
> ./sock_ut.py cli eval 1+1 2+3
"
si="./sock_ut.py srv bc bc -l &
"
so="[4] 81113
> srv bc start
"
r="./sock_ut.py srv bc bc -l &
"
si="./sock_ut.py srvs
"
so="upper
eval
bc
> "
r="./sock_ut.py srvs
"
si="./sock_ut.py cli bc
"
so=""
r="./sock_ut.py cli bc
"
si="1+1
"
so="2
"
r="1+1
"
si="10/3
"
so="3.33333333333333333333
"
r="10/3
"
si="^D"
so="> "
r="^D"
si="./sock_ut.py kill upper
"
so="srv upper quit
> "
r="./sock_ut.py kill upper
"
si="./sock_ut.py kill_base
"
so="kill_base_srv
base_srv quit
[2]   Done                    ./sock_ut.py srv upper
> "
r="./sock_ut.py kill_base
"
si="
"
so="[1]   Done                    ./sock_ut.py base
[3]-  Done                    ./sock_ut.py srv eval
[4]+  Done                    ./sock_ut.py srv bc bc -l
> "
r="
"
si="exit
"
so="exit
"
r="exit
"
$

$ ./test.py < LOG2
si+so="$ "
r="$ "
si+so="PS1='> '
> "
r="PS1='> '
> "
si+so="./sock_ut.py base &
[1] 81095
> "
r="./sock_ut.py base &
[1] 81605
> "
si+so="./sock_ut.py srv upper &
[2] 81096
> srv upper start
"
r="./sock_ut.py srv upper &
[2] 81606
> srv upper start
"
si+so="./sock_ut.py srv eval &
[3] 81097
> srv eval start
"
r="./sock_ut.py srv eval &
[3] 81607
> srv eval start
"
si+so="./sock_ut.py cli upper foo bar hoge
foo --> FOO
bar --> BAR
hoge --> HOGE
> "
r="./sock_ut.py cli upper foo bar hoge
foo --> FOO
bar --> BAR
hoge --> HOGE
> "
si+so="./sock_ut.py cli eval 1+1 2+3
1+1 --> 2
2+3 --> 5
> "
r="./sock_ut.py cli eval 1+1 2+3
1+1 --> 2
2+3 --> 5
> "
si+so="./sock_ut.py srv bc bc -l &
[4] 81113
> srv bc start
"
r="./sock_ut.py srv bc bc -l &
[4] 81610
> srv bc start
"
si+so="./sock_ut.py srvs
upper
eval
bc
> "
r="./sock_ut.py srvs
upper
eval
bc
> "
si+so="./sock_ut.py cli bc
"
r="./sock_ut.py cli bc
"
si+so="1+1
2
"
r="1+1
2
"
si+so="10/3
3.33333333333333333333
"
r="10/3
3.33333333333333333333
"
si+so="^D> "
r="> "
si+so="./sock_ut.py kill upper
srv upper quit
> "
r="./sock_ut.py kill upper
srv upper quit
[2]   Done                    ./sock_ut.py srv upper
> "
si+so="./sock_ut.py kill_base
kill_base_srv
base_srv quit
[2]   Done                    ./sock_ut.py srv upper
> "
r="./sock_ut.py kill_base
kill_base_srv
base_srv quit
> "
si+so="
[1]   Done                    ./sock_ut.py base
[3]-  Done                    ./sock_ut.py srv eval
[4]+  Done                    ./sock_ut.py srv bc bc -l
> "
r="
[1]   Done                    ./sock_ut.py base
[3]-  Done                    ./sock_ut.py srv eval
[4]+  Done                    ./sock_ut.py srv bc bc -l
> "
si+so="exit
exit
"
r="exit
exit
"
$

$ ./test.py < LOG2
exp="$ "
r="$ "
exp="PS1='> '
> "
r="PS1='> '
> "
exp="./sock_ut.py base &
[1] 81095
> "
r="./sock_ut.py base &
[1] 81633
> "
exp="./sock_ut.py srv upper &
[2] 81096
> srv upper start
"
r="./sock_ut.py srv upper &
[2] 81634
> srv upper start
"
exp="./sock_ut.py srv eval &
[3] 81097
> srv eval start
"
r="./sock_ut.py srv eval &
[3] 81635
> srv eval start
"
exp="./sock_ut.py cli upper foo bar hoge
foo --> FOO
bar --> BAR
hoge --> HOGE
> "
r="./sock_ut.py cli upper foo bar hoge
foo --> FOO
bar --> BAR
hoge --> HOGE
> "
exp="./sock_ut.py cli eval 1+1 2+3
1+1 --> 2
2+3 --> 5
> "
r="./sock_ut.py cli eval 1+1 2+3
1+1 --> 2
2+3 --> 5
> "
exp="./sock_ut.py srv bc bc -l &
[4] 81113
> srv bc start
"
r="./sock_ut.py srv bc bc -l &
[4] 81638
> srv bc start
"
exp="./sock_ut.py srvs
upper
eval
bc
> "
r="./sock_ut.py srvs
upper
eval
bc
> "
exp="./sock_ut.py cli bc
"
r="./sock_ut.py cli bc
"
exp="1+1
2
"
r="1+1
2
"
exp="10/3
3.33333333333333333333
"
r="10/3
3.33333333333333333333
"
exp="> "
r="> "
exp="./sock_ut.py kill upper
srv upper quit
[2]   Done                    ./sock_ut.py srv upper
> "
r="./sock_ut.py kill upper
srv upper quit
[2]   Done                    ./sock_ut.py srv upper
> "
exp="./sock_ut.py kill_base
kill_base_srv
base_srv quit
> "
r="./sock_ut.py kill_base
kill_base_srv
base_srv quit
> "
exp="
[1]   Done                    ./sock_ut.py base
[3]-  Done                    ./sock_ut.py srv eval
[4]+  Done                    ./sock_ut.py srv bc bc -l
> "
r="
[1]   Done                    ./sock_ut.py base
[3]-  Done                    ./sock_ut.py srv eval
[4]+  Done                    ./sock_ut.py srv bc bc -l
> "
exp="exit
exit
"
r="exit
exit
"
$

$ chmod +x t.py

$ ./t.py abcdefghi abc
False

$ ./t.py abcdefghi abcdefghi
True

$ ./t.py abcdefghi abc*ghi
True

$ ./t.py abcdefghi abc*
True

$ ./t.py abcdefghi *abcdefghi
True

$ ./t.py abcdefghi abcdefghi*
True

$ ./t.py abcdefghi *abcdefghi*
True

$ ./t.py abcdefghi a*bc*fg*
True

$ ./t.py abcdefghi *fed*
False

$ ./t.py abcdefghi "*"
True

$ CMD>>>PS1='> '
> CMD>>>./sock_ut.py base &
[1] *
> CMD>>>./sock_ut.py srv upper &
[2] *
> srv upper start
CMD>>>./sock_ut.py srv eval &
[3] *
> srv eval start
CMD>>>./sock_ut.py cli upper foo bar hoge
foo --> FOO
bar --> BAR
hoge --> HOGE
> CMD>>>./sock_ut.py cli eval 1+1 2+3
1+1 --> 2
2+3 --> 5
> CMD>>>./sock_ut.py srv bc bc -l &
[4] *
> srv bc start
CMD>>>./sock_ut.py srvs
upper
eval
bc
> CMD>>>./sock_ut.py cli bc
CMD>>>1+1
2
CMD>>>10/3
3.33333333333333333333
CMD>>>^D> CMD>>>./sock_ut.py kill upper
srv upper quit
[2]   Done                    ./sock_ut.py srv upper
> CMD>>>./sock_ut.py kill_base
kill_base_srv
base_srv quit
> CMD>>>
[1]   Done                    ./sock_ut.py base
[3]-  Done                    ./sock_ut.py srv eval
[4]+  Done                    ./sock_ut.py srv bc bc -l
> CMD>>>exit
exit

#!/usr/bin/env python

import sys
import time

import fio_ut
import dbg

def wild_eq( s, t ):
	if '*' not in t:
		return s == t

	lst = t.split( '*' )

	t = lst.pop( 0 )
	if t:
		if not s.startswith( t ):
			return False
		s = s[ len( t ) : ]

	t = lst.pop( -1 )
	if t:
		if not s.endswith( t ):
			return False
		s = s[ : -len( t ) ]

	for t in lst:
		if not t:
			continue
		if t not in s:
			return False
		i = s.index( t ) + len( t )
		s = s[ i : ]

	return True

def run():
	s = sys.stdin.read()
	s = s.replace( '\r', '' )
	lst = s.split( 'CMD>>>' )

	def func( s ):
		n = 0
		if s.startswith( '^D' ):
			n = 2
		elif '\n' in s:
			n = s.index( '\n' ) + 1
		return ( s[ : n ], s[ n : ] )

	lst = list( map( func, lst ) )

	cmd = 'python -m pty_spawn bash'
	proc = fio_ut.proc_new( cmd )

	res = True
	for ( si, so ) in lst:
		if si:
			s = '\x04' if si == '^D' else si
			if not fio_ut.p_s( proc.fo, s ):
				dbg.out( 'err p_s' )
		exp = ''
		if si != '^D':
			exp = si
		exp += so
		#dbg.out( 'exp="{}"'.format( exp ) )
		time.sleep( 1.0 )

		r = fio_ut.g_s_all( proc.fi )
		if not r:
			dbg.out( 'err g_s_all' )

		r = r.replace( '\r', '' )
		#dbg.out( 'r="{}"'.format( r ) )

		res = wild_eq( r, exp )
		if not res:
			dbg.out( 'NG cmd "{}" get "{}", exp is "{}"'.format( si, r, exp ) )
			break
	if res:
		dbg.out( 'OK' )

	proc.stop()

if __name__ == "__main__":
	run()
# EOF

$ CMD>>>PS1='> '
> CMD>>>./sock_ut.py base &
[1] *
> CMD>>>./sock_ut.py srv upper &
[2] *
> srv upper start
CMD>>>./sock_ut.py srv eval &
[3] *
> srv eval start
CMD>>>./sock_ut.py cli upper foo bar hoge
foo --> FOO
bar --> BAR
hoge --> HOGE
> CMD>>>./sock_ut.py cli eval 1+1 2+3
1+1 --> 2
2+3 --> 5
> CMD>>>./sock_ut.py srv bc bc -l &
[4] *
> srv bc start
CMD>>>./sock_ut.py srvs
upper
eval
bc
> CMD>>>./sock_ut.py cli bc
CMD>>>1+1
2
CMD>>>10/3
3.33333333333333333333
CMD>>>^D> CMD>>>./sock_ut.py kill upper
srv upper quit
[2]   Done                    ./sock_ut.py srv upper
> CMD>>>./sock_ut.py kill_base
kill_base_srv
base_srv quit
> CMD>>>
[1]   Done                    ./sock_ut.py base
[3]-  Done                    ./sock_ut.py srv eval
[4]+  Done                    ./sock_ut.py srv bc bc -l
> CMD>>>exit
exit

$ ./test.py < LOG2
exp="$ "
exp="PS1='> '
> "
exp="./sock_ut.py base &
[1] *
> "
exp="./sock_ut.py srv upper &
[2] *
> srv upper start
"
exp="./sock_ut.py srv eval &
[3] *
> srv eval start
"
exp="./sock_ut.py cli upper foo bar hoge
foo --> FOO
bar --> BAR
hoge --> HOGE
> "
exp="./sock_ut.py cli eval 1+1 2+3
1+1 --> 2
2+3 --> 5
> "
exp="./sock_ut.py srv bc bc -l &
[4] *
> srv bc start
"
exp="./sock_ut.py srvs
upper
eval
bc
> "
exp="./sock_ut.py cli bc
"
exp="1+1
2
"
exp="10/3
3.33333333333333333333
"
exp="> "
exp="./sock_ut.py kill upper
srv upper quit
[2]   Done                    ./sock_ut.py srv upper
> "
NG cmd "./sock_ut.py kill upper
" get "./sock_ut.py kill upper
srv upper quit
> ", exp is "./sock_ut.py kill upper
srv upper quit
[2]   Done                    ./sock_ut.py srv upper
> "
['2e', '2f', '73', '6f', '63', '6b', '5f', '75', '74', '2e', '70', '79', '20', '6b', '69', '6c', '6c', '20', '75', '70', '70', '65', '72', 'a', '73', '72', '76', '20', '75', '70', '70', '65', '72', '20', '71', '75', '69', '74', 'a', '3e', '20']
$

$ CMD>>>PS1='> '
> CMD>>>./sock_ut.py base &
[1] *
> CMD>>>./sock_ut.py srv upper &
[2] *
> srv upper start
CMD>>>./sock_ut.py srv eval &
[3] *
> srv eval start
CMD>>>./sock_ut.py cli upper foo bar hoge
foo --> FOO
bar --> BAR
hoge --> HOGE
> CMD>>>./sock_ut.py cli eval 1+1 2+3
1+1 --> 2
2+3 --> 5
> CMD>>>./sock_ut.py srv bc bc -l &
[4] *
> srv bc start
CMD>>>./sock_ut.py srvs
upper
eval
bc
> CMD>>>./sock_ut.py cli bc
CMD>>>1+1
2
CMD>>>10/3
3.33333333333333333333
CMD>>>^D> CMD>>>./sock_ut.py kill upper
srv upper quit
> CMD>>>
[2]   Done                    ./sock_ut.py srv upper
> CMD>>>./sock_ut.py kill_base
kill_base_srv
base_srv quit
> CMD>>>
[1]   Done                    ./sock_ut.py base
[3]-  Done                    ./sock_ut.py srv eval
[4]+  Done                    ./sock_ut.py srv bc bc -l
> CMD>>>exit
exit

$ ./test.py < LOG2
exp="$ "
exp="PS1='> '
> "
exp="./sock_ut.py base &
[1] *
> "
exp="./sock_ut.py srv upper &
[2] *
> srv upper start
"
exp="./sock_ut.py srv eval &
[3] *
> srv eval start
"
exp="./sock_ut.py cli upper foo bar hoge
foo --> FOO
bar --> BAR
hoge --> HOGE
> "
exp="./sock_ut.py cli eval 1+1 2+3
1+1 --> 2
2+3 --> 5
> "
exp="./sock_ut.py srv bc bc -l &
[4] *
> srv bc start
"
exp="./sock_ut.py srvs
upper
eval
bc
> "
exp="./sock_ut.py cli bc
"
exp="1+1
2
"
exp="10/3
3.33333333333333333333
"
exp="> "
exp="./sock_ut.py kill upper
srv upper quit
> "
exp="
[2]   Done                    ./sock_ut.py srv upper
> "
exp="./sock_ut.py kill_base
kill_base_srv
base_srv quit
> "
exp="
[1]   Done                    ./sock_ut.py base
[3]-  Done                    ./sock_ut.py srv eval
[4]+  Done                    ./sock_ut.py srv bc bc -l
> "
exp="exit
exit
"
OK
$

#!/usr/bin/env python

import sys
import time

import fio_ut
import dbg

def wild_eq( s, t ):
	if '*' not in t:
		return s == t

	lst = t.split( '*' )

	t = lst.pop( 0 )
	if t:
		if not s.startswith( t ):
			return False
		s = s[ len( t ) : ]

	t = lst.pop( -1 )
	if t:
		if not s.endswith( t ):
			return False
		s = s[ : -len( t ) ]

	for t in lst:
		if not t:
			continue
		if t not in s:
			return False
		i = s.index( t ) + len( t )
		s = s[ i : ]

	return True

def run():
	s = sys.stdin.read()
	s = s.replace( '\r', '' )
	lst = s.split( 'CMD>>>' )

	def func( s ):
		n = 0
		if s.startswith( '^D' ):
			n = 2
		elif '\n' in s:
			n = s.index( '\n' ) + 1
		return ( s[ : n ], s[ n : ] )

	lst = list( map( func, lst ) )

	cmd = 'python -m pty_spawn bash'
	proc = fio_ut.proc_new( cmd )

	res = True
	for ( si, so ) in lst:
		if si:
			dbg.out( si, '' )
			s = '\x04' if si == '^D' else si
			if not fio_ut.p_s( proc.fo, s ):
				dbg.out( 'err p_s' )
		exp = si + so
		#dbg.out( 'exp="{}"'.format( exp ) )
		time.sleep( 1.0 )

		r = fio_ut.g_s_all( proc.fi )
		if not r:
			dbg.out( 'err g_s_all' )

		r = r.replace( '\r', '' )
		#dbg.out( 'r="{}"'.format( r ) )

		res = wild_eq( r, exp )
		if not res:
			dbg.out( 'NG cmd "{}" get "{}", exp is "{}"'.format( si, r, exp ) )
			#dbg.out( '{}'.format( list( map( lambda c: '{:x}'.format( ord( c ) ), r ) ) ) )
			break
	if res:
		dbg.out( 'OK' )

	proc.stop()

if __name__ == "__main__":
	run()
# EOF

$ ./test.py < LOG2
PS1='> '
./sock_ut.py base &
./sock_ut.py srv upper &
./sock_ut.py srv eval &
./sock_ut.py cli upper foo bar hoge
./sock_ut.py cli eval 1+1 2+3
./sock_ut.py srv bc bc -l &
./sock_ut.py srvs
./sock_ut.py cli bc
1+1
10/3
^D./sock_ut.py kill upper

./sock_ut.py kill_base

exit
OK
$