151 irs_irp_connect(struct irp_p *pvt) {  in irs_irp_connect()  argument
164 	if (pvt->fdCxn != -1) {  in irs_irp_connect()
208 	pvt->fdCxn = socket(addr->sa_family, SOCK_STREAM, PF_UNSPEC);  in irs_irp_connect()
209 	if (pvt->fdCxn < 0) {  in irs_irp_connect()
214 	if (connect(pvt->fdCxn, addr, socklen) != 0) {  in irs_irp_connect()
219 	flags = fcntl(pvt->fdCxn, F_GETFL, 0);  in irs_irp_connect()
221 		close(pvt->fdCxn);  in irs_irp_connect()
228 	if (fcntl(pvt->fdCxn, F_SETFL, flags) < 0) {  in irs_irp_connect()
229 		close(pvt->fdCxn);  in irs_irp_connect()
235 	code = irs_irp_read_response(pvt, text, sizeof text);  in irs_irp_connect()
240 		irs_irp_disconnect(pvt);  in irs_irp_connect()
257 irs_irp_is_connected(struct irp_p *pvt) {  in irs_irp_is_connected()  argument
258 	return (pvt->fdCxn >= 0);  in irs_irp_is_connected()
269 irs_irp_disconnect(struct irp_p *pvt) {  in irs_irp_disconnect()  argument
270 	if (pvt->fdCxn != -1) {  in irs_irp_disconnect()
271 		close(pvt->fdCxn);  in irs_irp_disconnect()
272 		pvt->fdCxn = -1;  in irs_irp_disconnect()
279 irs_irp_read_line(struct irp_p *pvt, char *buffer, int len) {  in irs_irp_read_line()  argument
280 	char *realstart = &pvt->inbuffer[0];  in irs_irp_read_line()
288 		start = p = &pvt->inbuffer[pvt->incurr];  in irs_irp_read_line()
289 		end = &pvt->inbuffer[pvt->inlast];  in irs_irp_read_line()
300 				pvt->inlast = end - start;  in irs_irp_read_line()
302 				pvt->incurr = 0;  in irs_irp_read_line()
303 				end = &pvt->inbuffer[pvt->inlast];  in irs_irp_read_line()
306 			spare = sizeof (pvt->inbuffer) - pvt->inlast;  in irs_irp_read_line()
309 			i = read(pvt->fdCxn, end, spare);  in irs_irp_read_line()
311 				close(pvt->fdCxn);  in irs_irp_read_line()
312 				pvt->fdCxn = -1;  in irs_irp_read_line()
319 			pvt->inlast += i;  in irs_irp_read_line()
327 			i = sizeof pvt->inbuffer;  in irs_irp_read_line()
336 		pvt->incurr += i;  in irs_irp_read_line()
365 irs_irp_read_response(struct irp_p *pvt, char *text, size_t textlen) {  in irs_irp_read_response()  argument
370 	if (irs_irp_read_line(pvt, line, sizeof line) <= 0) {  in irs_irp_read_response()
410 irs_irp_read_body(struct irp_p *pvt, size_t *size) {  in irs_irp_read_body()  argument
421 		if (irs_irp_read_line(pvt, line, sizeof line) <= 0 ||  in irs_irp_read_body()
481 irs_irp_get_full_response(struct irp_p *pvt, int *code, char *text,  in irs_irp_get_full_response()  argument
483 	int result = irs_irp_read_response(pvt, text, textlen);  in irs_irp_get_full_response()
497 		*body = irs_irp_read_body(pvt, bodylen);  in irs_irp_get_full_response()
519 irs_irp_send_command(struct irp_p *pvt, const char *fmt, ...) {  in irs_irp_send_command()  argument
526 	if (pvt->fdCxn < 0) {  in irs_irp_send_command()
542 		i = write(pvt->fdCxn, buffer + pos, todo);  in irs_irp_send_command()
550 			close(pvt->fdCxn);  in irs_irp_send_command()
551 			pvt->fdCxn = -1;  in irs_irp_send_command()