src/flush/flush.c

700 static int flush_request_receive(VSTREAM *client_stream, VSTRING *request)
707     attr_print(client_stream, ATTR_FLAG_NONE,
710     (void) vstream_fflush(client_stream);
715     if (read_wait(vstream_fileno(client_stream), var_ipc_timeout) < 0) {
717 		 VSTREAM_PATH(client_stream));
720     if ((count = peekfd(vstream_fileno(client_stream))) < 0) {
722 		 VSTREAM_PATH(client_stream));
730 	if (vstring_get_null(request, client_stream) == VSTREAM_EOF) {
732 		     VSTREAM_PATH(client_stream));
741 	if (attr_scan(client_stream,
753 static void flush_service(VSTREAM *client_stream, char *unused_service,
780     if (flush_request_receive(client_stream, request) == 0) {
784 	    if (attr_scan(client_stream, ATTR_FLAG_STRICT,
790 	    attr_print(client_stream, ATTR_FLAG_NONE,
795 	    if (attr_scan(client_stream, ATTR_FLAG_STRICT,
799 	    attr_print(client_stream, ATTR_FLAG_NONE,
804 	    if (attr_scan(client_stream, ATTR_FLAG_STRICT,
808 	    attr_print(client_stream, ATTR_FLAG_NONE,
813 	    attr_print(client_stream, ATTR_FLAG_NONE,
816 	    vstream_fflush(client_stream);
819 	    attr_print(client_stream, ATTR_FLAG_NONE,
822 	    vstream_fflush(client_stream);
826 	attr_print(client_stream, ATTR_FLAG_NONE,