145 irs_irp_connect(struct irp_p *pvt) {  in irs_irp_connect()  argument
158 	if (pvt->fdCxn != -1) {  in irs_irp_connect()
202 	pvt->fdCxn = socket(addr->sa_family, SOCK_STREAM, PF_UNSPEC);  in irs_irp_connect()
203 	if (pvt->fdCxn < 0) {  in irs_irp_connect()
208 	if (connect(pvt->fdCxn, addr, socklen) != 0) {  in irs_irp_connect()
213 	flags = fcntl(pvt->fdCxn, F_GETFL, 0);  in irs_irp_connect()
215 		close(pvt->fdCxn);  in irs_irp_connect()
222 	if (fcntl(pvt->fdCxn, F_SETFL, flags) < 0) {  in irs_irp_connect()
223 		close(pvt->fdCxn);  in irs_irp_connect()
229 	code = irs_irp_read_response(pvt, text, sizeof text);  in irs_irp_connect()
234 		irs_irp_disconnect(pvt);  in irs_irp_connect()
251 irs_irp_is_connected(struct irp_p *pvt) {  in irs_irp_is_connected()  argument
252 	return (pvt->fdCxn >= 0);  in irs_irp_is_connected()
263 irs_irp_disconnect(struct irp_p *pvt) {  in irs_irp_disconnect()  argument
264 	if (pvt->fdCxn != -1) {  in irs_irp_disconnect()
265 		close(pvt->fdCxn);  in irs_irp_disconnect()
266 		pvt->fdCxn = -1;  in irs_irp_disconnect()
273 irs_irp_read_line(struct irp_p *pvt, char *buffer, int len) {  in irs_irp_read_line()  argument
274 	char *realstart = &pvt->inbuffer[0];  in irs_irp_read_line()
282 		start = p = &pvt->inbuffer[pvt->incurr];  in irs_irp_read_line()
283 		end = &pvt->inbuffer[pvt->inlast];  in irs_irp_read_line()
294 				pvt->inlast = end - start;  in irs_irp_read_line()
296 				pvt->incurr = 0;  in irs_irp_read_line()
297 				end = &pvt->inbuffer[pvt->inlast];  in irs_irp_read_line()
300 			spare = sizeof (pvt->inbuffer) - pvt->inlast;  in irs_irp_read_line()
303 			i = read(pvt->fdCxn, end, spare);  in irs_irp_read_line()
305 				close(pvt->fdCxn);  in irs_irp_read_line()
306 				pvt->fdCxn = -1;  in irs_irp_read_line()
313 			pvt->inlast += i;  in irs_irp_read_line()
321 			i = sizeof pvt->inbuffer;  in irs_irp_read_line()
330 		pvt->incurr += i;  in irs_irp_read_line()
359 irs_irp_read_response(struct irp_p *pvt, char *text, size_t textlen) {  in irs_irp_read_response()  argument
364 	if (irs_irp_read_line(pvt, line, sizeof line) <= 0) {  in irs_irp_read_response()
404 irs_irp_read_body(struct irp_p *pvt, size_t *size) {  in irs_irp_read_body()  argument
415 		if (irs_irp_read_line(pvt, line, sizeof line) <= 0 ||  in irs_irp_read_body()
475 irs_irp_get_full_response(struct irp_p *pvt, int *code, char *text,  in irs_irp_get_full_response()  argument
477 	int result = irs_irp_read_response(pvt, text, textlen);  in irs_irp_get_full_response()
491 		*body = irs_irp_read_body(pvt, bodylen);  in irs_irp_get_full_response()
513 irs_irp_send_command(struct irp_p *pvt, const char *fmt, ...) {  in irs_irp_send_command()  argument
520 	if (pvt->fdCxn < 0) {  in irs_irp_send_command()
536 		i = write(pvt->fdCxn, buffer + pos, todo);  in irs_irp_send_command()
544 			close(pvt->fdCxn);  in irs_irp_send_command()
545 			pvt->fdCxn = -1;  in irs_irp_send_command()