diff -urN rt_v34/bin.py rt_v35/bin.py
--- rt_v34/bin.py	2018-05-01 23:19:45.000000000 +0900
+++ rt_v35/bin.py	2018-05-09 21:31:17.000000000 +0900
@@ -88,7 +88,7 @@
 	(rev, s) = unpack_i4(s)
 	return ( cylx.new(r, rev), s )
 
-pack_fx = lambda fx: pack_f8(fx.dz) + pack_i4(fx,rev)
+pack_fx = lambda fx: pack_f8(fx.dz) + pack_i4(fx.rev)
 
 def unpack_fx(s):
 	(dz, s) = unpack_f8(s)
diff -urN rt_v34/cg.py rt_v35/cg.py
--- rt_v34/cg.py	2018-05-09 00:38:57.000000000 +0900
+++ rt_v35/cg.py	2018-05-09 21:43:25.000000000 +0900
@@ -55,7 +55,7 @@
 
 		img.cli.v_add_img()
 		if 'no_show' not in sys.argv:
-			wsec = max( cnt.wait_sec(), 0 ) if n > 1 else -1
+			wsec = max( cnt.wait_sec(), 0 )
 			fn_img = val.cli.get_prop('saved_fn_img')
 			img.show(fn_img, '', wsec, zm)
 	img.cli.v_close()
diff -urN rt_v34/cross.c rt_v35/cross.c
--- rt_v34/cross.c	2018-05-01 23:19:45.000000000 +0900
+++ rt_v35/cross.c	2018-05-09 21:31:17.000000000 +0900
@@ -351,11 +351,11 @@
 	char buf[ sizeof(l_g) + sizeof(prev_idx) ], *bp = buf;
 	struct cross_ret ret, send_buf;
 
-	read(fd, &sz, sizeof(sz));
+	read_n(fd, &sz, sizeof(sz));
 	if(sz != sizeof(buf)){
 		fprintf(stderr, "? srv_cross sz=%d sizeof(buf)=%d\n", sz, (int)sizeof(buf));
 	}
-	read(fd, buf, sizeof(buf));
+	read_n(fd, buf, sizeof(buf));
 
 	bp = COPY_FROM_BP(bp, l_g);
 	bp = COPY_FROM_BP(bp, prev_idx);
@@ -363,8 +363,8 @@
 	cross_cross(&l_g, prev_idx, &ret);
 
 	sz = pack_cross_ret((char *)&send_buf, &ret);
-	write(fd, &sz, sizeof(sz));
-	write(fd, &send_buf, sz);
+	write_n(fd, &sz, sizeof(sz));
+	write_n(fd, &send_buf, sz);
 }
 
 int
diff -urN rt_v34/dat.c rt_v35/dat.c
--- rt_v34/dat.c	2018-05-07 21:48:31.000000000 +0900
+++ rt_v35/dat.c	2018-05-09 21:31:17.000000000 +0900
@@ -163,4 +163,52 @@
 	return &data_get()->lst[idx];
 }
 
+/**/
+
+void
+free_lstx(struct lstx *lx)
+{
+	FREE_LST(*lx, "lx");
+}
+
+void
+free_map(struct map *m)
+{
+	free_lstx(&m->xyz2g);
+	free_lstx(&m->wh2xyz);
+}
+
+void
+free_maps(struct maps *maps)
+{
+	int i;
+	for(i=0; i<maps->n; i++){
+		free_map(&maps->lst[i]);
+	}
+	FREE_LST(*maps, "maps");
+}
+
+void
+free_data_one(struct data_one *d)
+{
+	free_lstx(&d->l2g);
+	free_maps(&d->maps);
+}
+
+void
+free_data(struct data *data)
+{
+	int i;
+	for(i=0; i<data->n; i++){
+		free_data_one(&data->lst[i]);
+	}
+	FREE_LST(*data, "data");
+}
+
+void
+free_lights(struct lights *lights)
+{
+	FREE_LST(*lights, "lights");
+}
+
 /* EOF */
diff -urN rt_v34/dat.h rt_v35/dat.h
--- rt_v34/dat.h	2018-05-01 23:19:45.000000000 +0900
+++ rt_v35/dat.h	2018-05-09 21:31:17.000000000 +0900
@@ -60,4 +60,22 @@
 
 struct data_one *data_one_get(int idx);
 
+/**/
+
+void free_lstx(struct lstx *lx);
+void free_map(struct map *m);
+void free_maps(struct maps *maps);
+void free_data_one(struct data_one *d);
+void free_data(struct data *data);
+void free_lights(struct lights *lights);
+
+/**/
+
+char *unpack_vs(char *bp, struct vecs *vs);
+char *unpack_xx(char *bp, struct x_x *xx);
+char *unpack_lx(char *bp, struct lstx *lx);
+char *unpack_map(char *bp, struct map *m);
+char *unpack_maps(char *bp, struct maps *maps);
+char *unpack_rtd(char *bp, struct rtd *rtd);
+
 #endif
diff -urN rt_v34/img.c rt_v35/img.c
--- rt_v34/img.c	2018-05-09 00:10:25.000000000 +0900
+++ rt_v35/img.c	2018-05-09 21:31:17.000000000 +0900
@@ -9,6 +9,8 @@
 #define IMG_V_LINE	5
 #define IMG_V_ADD_IMG	6
 #define IMG_V_CUR_SEC	7
+#define IMG_V_GET_CNT	8
+#define IMG_V_SETS	9
 
 
 static int fd = -1;
@@ -154,4 +156,49 @@
 	return sec;
 }
 
+int
+v_get_cnt(int n, int *ret_xy_lst)
+{
+	int cmd = IMG_V_GET_CNT;
+	int rets_sz = 0, i, x, y;
+	char *rets, *bp;
+
+	img_conn();
+	bp = rets = sock_cli_call(fd, cmd, sizeof(n), (char *)&n, &rets_sz, NULL);
+	bp = COPY_FROM_BP(bp, n);
+	
+	for(i=0; i<n; i++){
+		bp = COPY_FROM_BP(bp, x);
+		bp = COPY_FROM_BP(bp, y);
+		*ret_xy_lst++ = x;
+		*ret_xy_lst++ = y;
+	}
+	if(rets){
+		free(rets);
+	}
+	return n;
+}
+
+void
+v_sets(int x, int y, int col_n, int *col)
+{
+	int cmd = IMG_V_SETS;
+	int col_sz = sizeof(*col)*3*col_n;
+	int args_sz = sizeof(x) + sizeof(y) + sizeof(col_n) + col_sz;
+	char *args = malloc(args_sz), *bp = args;
+
+	img_conn();
+
+	bp = COPY_TO_BP(bp, x);
+	bp = COPY_TO_BP(bp, y);
+	bp = COPY_TO_BP(bp, col_n);
+	bp = COPY_SZ_TO_BP(bp, col, col_sz);
+
+	sock_cli_call(fd, cmd, args_sz, args, NULL, NULL);
+
+	if(args){
+		free(args);
+	}
+}
+
 /* EOF */
diff -urN rt_v34/img.h rt_v35/img.h
--- rt_v34/img.h	2018-05-09 00:09:37.000000000 +0900
+++ rt_v35/img.h	2018-05-09 21:31:17.000000000 +0900
@@ -15,6 +15,8 @@
 void v_line(int sx, int sy, int ex, int ey, int *col);
 void v_add_img(void);
 double v_cur_sec(void);
+int v_get_cnt(int n, int *ret_xy_lst);
+void v_sets(int x, int y, int col_n, int *col);
 
 #endif
 
diff -urN rt_v34/img.py rt_v35/img.py
--- rt_v34/img.py	2018-05-09 02:33:46.000000000 +0900
+++ rt_v35/img.py	2018-05-09 21:31:17.000000000 +0900
@@ -225,10 +225,18 @@
 
 ###
 
+name_seq_jpg = lambda nm, i: nm + '0000{}'.format(i)[-5:] + '.jpg'
+
 def new_v_funcs():
 	e = ut.Empty()
 	e.v = None
 	e.name = ''
+	e.wh = lambda : img_wh(e.v.img) if e.v else (0,0)
+	e.cnt = None
+
+	def new_cnt():
+		(w, h) = e.wh()
+		return ut.new_cnt_wh(w, h, 'v_wh')
 
 	def open(name, fps, w, h, zm):
 		if e.v:
@@ -237,6 +245,7 @@
 		codec = 'H264'
 		fn = e.name + '.mp4'
 		e.v = new_video(codec, fn, fps, w, h, zm)	
+		e.cnt = new_cnt()
 	e.open = open
 
 	def close():
@@ -254,14 +263,36 @@
 		if e.v:
 			e.v.add_img()
 			i = e.v.i
-			fn_img = e.name + '0000{}'.format(i)[-5:] + '.jpg'
+			fn_img = name_seq_jpg(e.name, i)
 			e.v.write(fn_img)
 			val.cli.set_prop('saved_fn_img', 'str', fn_img) # !
 			e.v.clear()
+			(w, h) = e.wh()
+			e.cnt = new_cnt()
 	e.add_img = add_img
 
 	e.cur_sec = lambda : e.v.cur_sec() if e.v else 0
 
+	def get_cnt(n):
+		lst = []
+		if e.cnt:
+			for i in range(n):
+				if not e.cnt.up(show=False, show_fin=False):
+					break
+				lst.append( e.cnt.cur() )
+		return lst
+	e.get_cnt = get_cnt
+
+	def sets(x, y, cols):
+		(w, h) = e.wh()
+		i = y * w + x
+		for col in cols:
+			if col:
+				e.set(x, y, col)
+			i += 1
+			(x, y) = (i%w, i//w)
+	e.sets = sets
+
 	return e
 	
 v_funcs = new_v_funcs()
@@ -292,7 +323,7 @@
 	ut.mkdir_if_not(img_name)
 	for i in range(n):
 		img = read_video( videos.get(fn), i )
-		fn_i = ( img_name+'0000{}'.format(i)[-5:] ) + '.jpg'
+		fn_i = name_seq_jpg(img_name, i)
 		cv2.imwrite(fn_i, img)
 
 def video_play(fn):
@@ -301,31 +332,49 @@
 	fps = videos.fps(fn)
 	st_sec = ut.now_sec()
 	wait_sec = lambda i: float(i) / fps - ( ut.now_sec() - st_sec )
-	for (i, img) in enumerate( videos.imgs(fn) ):
-		cv2.imshow('', img)
+	n = videos.frn(fn)
+	for i in range(n):
+		img = read_video( videos.get(fn), i )
 		sec = max( wait_sec(i), 0 )
-		msec = max( 1, int(sec * 1000) )
-		cv2.waitKey(msec)
+		show_img(img, '', sec)
 
 def video_to_3M(video_name):
+
+	mkdir_empty = lambda path: ut.cmd_exec('rm -rf {} ; mkdir -p {}'.format(path, path))
+
 	wk = '/tmp/img_wk'
-	ut.cmd_exec('rm -rf {} ; mkdir -p {}'.format(wk, wk))
-	video_to_imgs('{}/img'.format(wk), video_name)
+	mkdir_empty(wk)
+
+	img_name = wk + '/img'
+	video_to_imgs(img_name, video_name)
 	s = ut.cmd_exec('ls {} | wc -l'.format(wk)).decode().strip()
 	n = int(s)
 	print('n={}'.format(n))
 
-	imgs_to_video('{}/img'.format(wk), '{}/v'.format(wk), 30, 1.0)
-	sz = ut.get_size('{}/v.mp4'.format(wk))
-	print('sz={}'.format(sz))
-
-	while sz > 3*1024*1024:
-		n -= 1
-		ut.cmd_exec('rm {}'.format(wk) + '/img' + '0000{}'.format(n)[-5:] + '.jpg' )
-		imgs_to_video('{}/img'.format(wk), '{}/v'.format(wk), 30, 1.0)
-		sz = ut.get_size('{}/v.mp4'.format(wk))
-		print('sz={}'.format(sz))
-	ut.cmd_exec('mv {}/v.mp4 ./'.format(wk))
+	v_name = wk + '/v.mp4'
+
+	def mkv(n):
+		ttt = wk + '/ttt'
+		mkdir_empty(ttt)
+		for i in range(n):
+			cmd = 'cp {} {}/'.format( name_seq_jpg(img_name, i), ttt )
+			ut.cmd_exec(cmd)
+		imgs_to_video(ttt + '/img', v_name, 30, 1.0)
+		return ut.get_size(v_name )
+
+	M3 = 3*1024*1024
+	L = 0
+	R = n
+	if mkv(R) > M3:
+		while R - L > 1:
+			C = int( (L + R) / 2 )
+			if mkv(C) > M3:
+				R = C
+			else:
+				L = C
+		mkv(L)
+
+	ut.cmd_exec('mv {} ./'.format(v_name))
 	print('./v.mp4')
 
 ###
@@ -343,6 +392,8 @@
 	{ 'cmd': 'v_line', 'func': v_funcs.line, 'args': '(i4,i4,i4,i4,col)' },
 	{ 'cmd': 'v_add_img', 'func': v_funcs.add_img },
 	{ 'cmd': 'v_cur_sec', 'func': v_funcs.cur_sec, 'rets': 'f8' },
+	{ 'cmd': 'v_get_cnt', 'func': v_funcs.get_cnt, 'args': '(i4)', 'rets': '[(i4,i4)]' },
+	{ 'cmd': 'v_sets', 'func': v_funcs.sets, 'args': '(i4,i4,[col])' },
 ]
 
 cli = sock.new_client('srv.img', cmd_infs)
diff -urN rt_v34/rt.c rt_v35/rt.c
--- rt_v34/rt.c	2018-05-08 20:47:52.000000000 +0900
+++ rt_v35/rt.c	2018-05-09 21:31:17.000000000 +0900
@@ -33,6 +33,15 @@
 }
 
 void
+col_max_255(int *s, int *d)
+{
+	int i;
+	for(i=0; i<3; i++){
+		d[i] = s[i] < 255 ? s[i] : 255;
+	}
+}
+
+void
 map_col(int idx, struct line *l_nv_g, int rev, double sec, int *ret_col)
 {
 	struct data_one *d = data_one_get(idx);
@@ -77,9 +86,7 @@
 		copy_col(ret_col, d->def_col);
 		return;
 	}
-	for(i=0; i<3; i++){
-		ret_col[i] = sum_col[i] < 255 ? sum_col[i] : 255;
-	}
+	col_max_255(sum_col, ret_col);
 }
 
 double
@@ -264,6 +271,33 @@
 	}
 }
 
+void
+set_cols(double *eyep, struct lstx *wh2g, double d_, double sec, int xys_n, int *xys)
+{
+	int i, x, y;
+	double lp[3], p[3];
+	struct line l_g;
+	int cols_n = xys_n;
+	int *cols = malloc( sizeof(*cols)*3*cols_n ), *col = cols;
+
+	lp[2] = -d_;
+	for(i=0; i<xys_n; i++){
+		lp[0] = x = *xys++;
+		lp[1] = y = *xys++;
+		lstx_tr_p(wh2g, L2G, lp, p);
+		line_new_p2(&l_g, eyep, p);
+
+		get_col(&l_g, sec, 1.0, -1, col);
+
+		if(!is_no_col(col)){
+			col_max_255(col, col);
+		}
+		col += 3;
+	}
+	v_sets(x, y, cols_n, cols);
+	free(cols);
+}
+
 #ifdef SRV_RT
 void
 srv_map_col(int fd)
@@ -277,8 +311,8 @@
 	int col[3];
 	int sz;
 
-	read(fd, &sz, sizeof(sz));
-	read(fd, buf, sz);
+	read_n(fd, &sz, sizeof(sz));
+	read_n(fd, buf, sz);
 
 	bp = COPY_FROM_BP(bp, idx);
 	bp = COPY_FROM_BP(bp, l_nv_g);
@@ -288,8 +322,8 @@
 	map_col(idx, &l_nv_g, rev, sec, col);
 
 	sz = sizeof(col);
-	write(fd, &sz, sizeof(sz));
-	write(fd, col, sz);
+	write_n(fd, &sz, sizeof(sz));
+	write_n(fd, col, sz);
 }
 
 void
@@ -302,8 +336,8 @@
 	int sz;
 	double diff;
 
-	read(fd, &sz, sizeof(sz));
-	read(fd, buf, sz);
+	read_n(fd, &sz, sizeof(sz));
+	read_n(fd, buf, sz);
 
 	bp = COPY_FROM_BP(bp, idx);
 	bp = COPY_FROM_BP_ARR(bp, crsp);
@@ -313,8 +347,8 @@
 	diff = calc_diff(idx, crsp, nv, ang_nv_eyev);
 
 	sz = sizeof(diff);
-	write(fd, &sz, sizeof(sz));
-	write(fd, &diff, sz);
+	write_n(fd, &sz, sizeof(sz));
+	write_n(fd, &diff, sz);
 }
 
 void
@@ -327,8 +361,8 @@
 	char *bp = buf;
 	int col[3], sz;
 
-	read(fd, &sz, sizeof(sz));
-	read(fd, buf, sz);
+	read_n(fd, &sz, sizeof(sz));
+	read_n(fd, buf, sz);
 
 	bp = COPY_FROM_BP(bp, l_g);
 	bp = COPY_FROM_BP(bp, sec);
@@ -338,8 +372,47 @@
 	get_col(&l_g, sec, nest_rate, prev_idx, col);
 
 	sz = sizeof(col);
-	write(fd, &sz, sizeof(sz));
-	write(fd, col, sz);
+	write_n(fd, &sz, sizeof(sz));
+	write_n(fd, col, sz);
+}
+
+void
+srv_set_cols(int fd)
+{
+	double eyep[3], d_, sec;
+	struct lstx wh2g;
+	int *xys, xys_n;
+	
+	char *buf, *bp;
+	int sz;
+
+	read_n(fd, &sz, sizeof(sz));
+	bp = buf = malloc(sz);
+	read_n(fd, buf, sz);
+	
+	bp = COPY_FROM_BP_ARR(bp, eyep);
+	bp = unpack_lx(bp, &wh2g);
+	bp = COPY_FROM_BP(bp, d_);
+	bp = COPY_FROM_BP(bp, sec);
+	bp = COPY_FROM_BP(bp, xys_n);
+
+	sz = sizeof(*xys)*2*xys_n;
+	xys = malloc(sz);
+	bp = COPY_SZ_FROM_BP(bp, xys, sz);
+
+	if(buf){
+		free(buf);
+	}
+
+	set_cols(eyep, &wh2g, d_, sec, xys_n, xys);
+
+	if(xys){
+		free(xys);
+	}
+	free_lstx(&wh2g);
+
+	sz = 0;
+	write_n(fd, &sz, sizeof(sz));
 }
 
 int
@@ -349,6 +422,7 @@
 		srv_map_col,
 		srv_calc_diff,
 		srv_get_col,
+		srv_set_cols,
 	};
 
 	if(arg_is(ac, av, 1, "boot")){
diff -urN rt_v34/rt.py rt_v35/rt.py
--- rt_v34/rt.py	2018-05-09 00:41:21.000000000 +0900
+++ rt_v35/rt.py	2018-05-09 21:57:54.000000000 +0900
@@ -150,6 +150,17 @@
 
 	return col
 
+def set_cols(eyep, wh2g, d_, sec, xys):
+	for (ix, iy) in xys:
+		p = lstx.tr_p( wh2g, 'l2g', mt.arr( [ix,iy,-d_] ) )
+		l_g = line.new_p2(eyep, p)
+
+		col = cli.get_col(l_g, sec, 1.0, -1)
+
+		if col != []:
+			col = np.fmin( col, 255 )
+			img.cli.v_set(ix, iy, col)
+
 def draw(eye2g, wh2eye, sc_sz):
 	(w, h, d_) = sc_sz
 	wh2g = lstx.opt( wh2eye + [ eye2g ] )
@@ -160,22 +171,20 @@
 	lock = threading.Lock()
 
 	def func(cli):
+		n = int( w * h * cli.rate )
 		while True:
-			lock.acquire()
-			run = cnt.up(show)
-			(ix, iy) = cnt.cur()
-			#print('{} {} {}'.format(cli.name, ix, iy))
-			lock.release()
-			if not run:
+			xys = img.cli.v_get_cnt(n)
+			if not xys:
 				break
-			p = lstx.tr_p( wh2g, 'l2g', mt.arr( [ix,iy,-d_] ) )
-			l_g = line.new_p2(eye2g.p, p)
 
-			col = cli.get_col(l_g, sec, 1.0, -1)
+			cli.set_cols(eye2g.p, wh2g, d_, sec, xys)
 
-			if col != []:
-				col = np.fmin( col, 255 )
-				img.cli.v_set(ix, iy, col)
+			for (ix, iy) in xys:
+				lock.acquire()
+				#print(cli.name)
+				cnt.up(show)
+				lock.release()
+		cnt.up(show)
 
 	ths = list( map( lambda cli: ut.th_start( func, cli ), clis ) )
 	for th in ths:
@@ -186,6 +195,7 @@
 	{ 'cmd': 'map_col', 'func': map_col, 'args': '(i4,line,bool,f8)', 'rets': 'col' },
 	{ 'cmd': 'calc_diff', 'func': calc_diff, 'args': '(i4,xyz,xyz,f8)', 'rets': 'f8' },
 	{ 'cmd': 'get_col', 'func': get_col, 'args': '(line,f8,f8,i4)', 'rets': 'col' },
+	{ 'cmd': 'set_cols', 'func': set_cols, 'args':'(xyz,lx,f8,f8,[(i4,i4)])' },
 ]
 
 cli = sock.new_client('srv.rt', cmd_infs)
@@ -199,7 +209,15 @@
 #names = [ 'srv.rt' ]
 #names = [ 'srv.rt-2', 'srv.rt-3', 'srv.rt-4', 'srv.rt-5' ]
 
-clis = list( map( new_client, names ) )
+clis = ut.map_lst( new_client, names )
+
+rates = map( lambda name: 0.2 / len(names), names )
+
+def add_rate(cli_rate):
+	(cli, rate) = cli_rate
+	cli.rate = rate
+	return cli
+clis = ut.map_lst( add_rate, zip(clis, rates) )
 
 if __name__ == "__main__":
 	if ut.arg_is(1, 'boot'):
diff -urN rt_v34/sock.c rt_v35/sock.c
--- rt_v34/sock.c	2018-05-08 20:47:52.000000000 +0900
+++ rt_v35/sock.c	2018-05-09 21:54:21.000000000 +0900
@@ -112,19 +112,53 @@
 
 /**/
 
+int
+read_n(int fd, void *buf, int n)
+{
+	char *bp = buf;
+	int n_ = n, rn;
+
+	while(n_ > 0){
+		rn = read(fd, bp, n_);
+		if(rn <= 0){
+			return n - n_;
+		}
+		bp += rn;
+		n_ -= rn;
+	}
+	return n;
+}
+
+int
+write_n(int fd, void *buf, int n)
+{
+	char *bp = buf;
+	int n_ = n, wn;
+
+	while(n_ > 0){
+		wn = write(fd, bp, n_);
+		if(wn <= 0){
+			return n - n_;
+		}
+		bp += wn;
+		n_ -= wn;
+	}
+	return n;
+}
+
 char *
 sock_cli_call(int fd, int cmd, int args_sz, char *args, int *rets_sz, char *rets)
 {
 	int sz;
 	char *buf;
 
-	write(fd, &cmd, sizeof(cmd));
-	write(fd, &args_sz, sizeof(args_sz));
+	write_n(fd, &cmd, sizeof(cmd));
+	write_n(fd, &args_sz, sizeof(args_sz));
 	if(args_sz > 0){
-		write(fd, args, args_sz);
+		write_n(fd, args, args_sz);
 	}
 
-	read(fd, &sz, sizeof(sz));
+	read_n(fd, &sz, sizeof(sz));
 
 	buf = rets;
 	if(sz > 0){
@@ -132,7 +166,7 @@
 			buf = sock_alloc(sz, "sock_cli_call");
 		}
 
-		read(fd, buf, sz);
+		read_n(fd, buf, sz);
 
 		if(rets && rets_sz && sz <= *rets_sz && rets != buf){
 			memcpy(rets, buf, *rets_sz); /* best effort */
@@ -170,7 +204,7 @@
 	pthread_mutex_unlock(&lock_arg);
 	pthread_cond_signal(&cond_arg);
 
-	while( read(fd, &cmd, cmd_sz) == cmd_sz ){
+	while( read_n(fd, &cmd, cmd_sz) == cmd_sz ){
 		if(!(0 <= cmd && cmd < func_n)){
 			break;
 		}
diff -urN rt_v34/sock.h rt_v35/sock.h
--- rt_v34/sock.h	2018-05-01 22:49:03.000000000 +0900
+++ rt_v35/sock.h	2018-05-09 21:31:17.000000000 +0900
@@ -41,11 +41,15 @@
 	name.lst : type *
  */
 #define ALLOC_LST(name, id)		do{ (name).lst = sock_alloc( sizeof(*(name).lst) * (name).n, "ALLOC_LST/" id ); }while(0)
+#define FREE_LST(name, id)		do{ if((name).lst){ free((name).lst); (name).lst = NULL; (name).n = 0; } }while(0)
 
 char *alloc_add_bsz(int usz, int n, char *s, int *ret_sz);
 
 /**/
 
+int read_n(int fd, void *buf, int n);
+int write_n(int fd, void *buf, int n);
+
 char *sock_cli_call(int fd, int cmd, int args_sz, char *args, int *rets_sz, char *rets);
 void sock_srv_main_loop(int port, int func_n, void **funcs);
 
diff -urN rt_v34/sock.py rt_v35/sock.py
--- rt_v34/sock.py	2018-05-08 20:47:52.000000000 +0900
+++ rt_v35/sock.py	2018-05-09 21:53:39.000000000 +0900
@@ -7,6 +7,16 @@
 import bin
 import pks
 
+def sock_recv_n(sock, n):
+	ret = b''
+	while n > 0:
+		r = sock.recv(n)
+		if not r:
+			break
+		ret += r
+		n -= len(r)
+	return ret
+
 def cmd_infs_copy(cmd_infs, typ):
 	args_f = pks.conv_unpack if typ == 'server' else pks.conv_pack
 	rets_f = pks.conv_unpack if typ == 'client' else pks.conv_pack
@@ -34,7 +44,7 @@
 	e.sock = None
 	def new_sock():
 		e.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
-		e.sock.settimeout(5)
+		#e.sock.settimeout(5)
 
 	e.conn_ok = False
 	def conn():
@@ -73,7 +83,7 @@
 		srvs.kill(name)
 	e.kill = kill
 
-	read = lambda n: e.sock.recv(n) if n > 0 else ''
+	read = lambda n: sock_recv_n(e.sock, n)
 	write = lambda s: e.sock.sendall(s)
 
 	recv = lambda : read( bin.unpack_i4( read(4) )[0] )
@@ -123,7 +133,7 @@
 	return e
 
 def cmd_loop(sock, cmd_infs, lock):
-	read = lambda n: sock.recv(n) if n > 0 else ''
+	read = lambda n: sock_recv_n(sock, n)
 	write = lambda s: sock.sendall(s)
 
 	recv = lambda : read( bin.unpack_i4( read(4) )[0] )
diff -urN rt_v34/ut.py rt_v35/ut.py
--- rt_v34/ut.py	2018-05-09 02:31:21.000000000 +0900
+++ rt_v35/ut.py	2018-05-09 21:31:17.000000000 +0900
@@ -104,7 +104,7 @@
 	e.show_sec = None
 	e.show_interval = 1.0
 
-	def up_no_show():
+	def up_no_show(show_fin=True):
 		if e.st_sec == None:
 			e.st_sec = now_sec()
 		else:
@@ -113,14 +113,16 @@
 		if not run:
 			now = now_sec()
 			e.total_sec = now - e.st_sec
-			show_stat(now)
+			if show_fin:
+				show_stat(now)
 		return run
 
-	def up(show=True):
+	def up(show=True, show_fin=True):
+		# show_fin is valid at show == False
 		if e.i >= e.n:
 			return False
 		if not show:
-			return up_no_show()
+			return up_no_show(show_fin)
 		now = now_sec()
 		if e.st_sec == None:
 			e.st_sec = now