121 static size_t _recv(int rs, char *msg, size_t len)  in _recv()  argument
126 		ret = rrecv(rs, msg + offset, len - offset, 0);  in _recv()
134 static int msg_recv_hdr(int rs, struct msg_hdr *hdr)  in msg_recv_hdr()  argument
138 	ret = _recv(rs, (char *) hdr, sizeof *hdr);  in msg_recv_hdr()
151 static int msg_get_resp(int rs, struct msg_hdr *msg, uint8_t cmd)  in msg_get_resp()  argument
155 	ret = msg_recv_hdr(rs, msg);  in msg_get_resp()
168 static void msg_send_resp(int rs, struct msg_hdr *msg, uint32_t status)  in msg_send_resp()  argument
177 	rsend(rs, (char *) &resp, sizeof resp, 0);  in msg_send_resp()
183 	int ret, rs;  in server_listen()  local
193 	rs = rsocket(res->ai_family, res->ai_socktype, res->ai_protocol);  in server_listen()
194 	if (rs < 0) {  in server_listen()
196 		ret = rs;  in server_listen()
201 	ret = rsetsockopt(rs, SOL_SOCKET, SO_REUSEADDR, &ret, sizeof ret);  in server_listen()
207 	ret = rbind(rs, res->ai_addr, res->ai_addrlen);  in server_listen()
213 	ret = rlisten(rs, 1);  in server_listen()
219 	ret = rs;  in server_listen()
223 	rclose(rs);  in server_listen()
229 static int server_open(int rs, struct msg_hdr *msg)  in server_open()  argument
250 	ret = _recv(rs, path, len);  in server_open()
269 	msg_send_resp(rs, msg, ret);  in server_open()
273 static void server_close(int rs, struct msg_hdr *msg)  in server_close()  argument
277 	msg_send_resp(rs, msg, 0);  in server_close()
291 static int server_write(int rs, struct msg_hdr *msg)  in server_write()  argument
310 	ret = _recv(rs, (char *) &bytes, sizeof bytes);  in server_write()
327 	len = _recv(rs, file_addr, bytes);  in server_write()
333 	msg_send_resp(rs, msg, ret);  in server_write()
337 static void server_process(int rs)  in server_process()  argument
343 		ret = msg_recv_hdr(rs, &msg);  in server_process()
349 			ret = server_open(rs, &msg);  in server_process()
352 			server_close(rs, &msg);  in server_process()
356 			ret = server_write(rs, &msg);  in server_process()
359 			msg_send_resp(rs, &msg, EINVAL);  in server_process()
369 	int lrs, rs;  in server_run()  local
381 		rs = raccept(lrs, &rsa.sa, &len);  in server_run()
384 		server_process(rs);  in server_run()
386 		rshutdown(rs, SHUT_RDWR);  in server_run()
387 		rclose(rs);  in server_run()
395 	int ret, rs;  in client_connect()  local
403 	rs = rsocket(res->ai_family, res->ai_socktype, res->ai_protocol);  in client_connect()
404 	if (rs < 0) {  in client_connect()
409 	ret = rconnect(rs, res->ai_addr, res->ai_addrlen);  in client_connect()
412 		rclose(rs);  in client_connect()
413 		rs = ret;  in client_connect()
418 	return rs;  in client_connect()
421 static int client_open(int rs)  in client_open()  argument
456 	ret = rsend(rs, msg, msg->hdr.len, 0);  in client_open()
460 	ret = msg_get_resp(rs, &msg->hdr, CMD_OPEN);  in client_open()
475 static int client_start_write(int rs)  in client_start_write()  argument
487 	ret = rsend(rs, &msg, sizeof msg, 0);  in client_start_write()
494 static int client_close(int rs)  in client_close()  argument
504 	ret = rsend(rs, (char *) &msg, msg.len, 0);  in client_close()
508 	ret = msg_get_resp(rs, &msg, CMD_CLOSE);  in client_close()
522 	int ret, rs;  in client_run()  local
525 	rs = client_connect();  in client_run()
526 	if (rs < 0)  in client_run()
527 		return rs;  in client_run()
529 	ret = client_open(rs);  in client_run()
533 	ret = client_start_write(rs);  in client_run()
540 	len = rsend(rs, file_addr, bytes, 0);  in client_run()
542 		ret = msg_get_resp(rs, &ack, CMD_WRITE);  in client_run()
549 	client_close(rs);  in client_run()
551 	rshutdown(rs, SHUT_RDWR);  in client_run()
552 	rclose(rs);  in client_run()