Lines Matching refs:msg
200 struct msg_write_open msg; in file_vprint() local
212 msg.stream = 1; in file_vprint()
213 msg.fd = STDOUT_FILENO; in file_vprint()
214 msg.flags = 0; in file_vprint()
215 proc_send(c->peer, MSG_WRITE_OPEN, -1, &msg, sizeof msg); in file_vprint()
227 struct msg_write_open msg; in file_print_buffer() local
239 msg.stream = 1; in file_print_buffer()
240 msg.fd = STDOUT_FILENO; in file_print_buffer()
241 msg.flags = 0; in file_print_buffer()
242 proc_send(c->peer, MSG_WRITE_OPEN, -1, &msg, sizeof msg); in file_print_buffer()
254 struct msg_write_open msg; in file_error() local
269 msg.stream = 2; in file_error()
270 msg.fd = STDERR_FILENO; in file_error()
271 msg.flags = 0; in file_error()
272 proc_send(c->peer, MSG_WRITE_OPEN, -1, &msg, sizeof msg); in file_error()
287 struct msg_write_open *msg; in file_write() local
333 msglen = strlen(cf->path) + 1 + sizeof *msg; in file_write()
338 msg = xmalloc(msglen); in file_write()
339 msg->stream = cf->stream; in file_write()
340 msg->fd = fd; in file_write()
341 msg->flags = flags; in file_write()
342 memcpy(msg + 1, cf->path, msglen - sizeof *msg); in file_write()
343 if (proc_send(cf->peer, MSG_WRITE_OPEN, -1, msg, msglen) != 0) { in file_write()
344 free(msg); in file_write()
348 free(msg); in file_write()
360 struct msg_read_open *msg; in file_read() local
409 msglen = strlen(cf->path) + 1 + sizeof *msg; in file_read()
414 msg = xmalloc(msglen); in file_read()
415 msg->stream = cf->stream; in file_read()
416 msg->fd = fd; in file_read()
417 memcpy(msg + 1, cf->path, msglen - sizeof *msg); in file_read()
418 if (proc_send(cf->peer, MSG_READ_OPEN, -1, msg, msglen) != 0) { in file_read()
419 free(msg); in file_read()
423 free(msg); in file_read()
435 struct msg_read_cancel msg; in file_cancel() local
443 msg.stream = cf->stream; in file_cancel()
444 proc_send(cf->peer, MSG_READ_CANCEL, -1, &msg, sizeof msg); in file_cancel()
462 struct msg_write_data *msg; in file_push() local
466 msg = xmalloc(sizeof *msg); in file_push()
470 if (sent > MAX_IMSGSIZE - IMSG_HEADER_SIZE - sizeof *msg) in file_push()
471 sent = MAX_IMSGSIZE - IMSG_HEADER_SIZE - sizeof *msg; in file_push()
473 msglen = (sizeof *msg) + sent; in file_push()
474 msg = xrealloc(msg, msglen); in file_push()
475 msg->stream = cf->stream; in file_push()
476 memcpy(msg + 1, EVBUFFER_DATA(cf->buffer), sent); in file_push()
477 if (proc_send(cf->peer, MSG_WRITE, -1, msg, msglen) != 0) in file_push()
492 free(msg); in file_push()
559 struct msg_write_open *msg = imsg->data; in file_write_open() local
567 if (msglen < sizeof *msg) in file_write_open()
569 if (msglen == sizeof *msg) in file_write_open()
572 path = (const char *)(msg + 1); in file_write_open()
573 log_debug("open write file %d %s", msg->stream, path); in file_write_open()
575 find.stream = msg->stream; in file_write_open()
580 cf = file_create_with_peer(peer, files, msg->stream, cb, cbdata); in file_write_open()
587 if (msg->fd == -1) in file_write_open()
588 cf->fd = open(path, msg->flags|flags, 0644); in file_write_open()
590 if (msg->fd != STDOUT_FILENO && msg->fd != STDERR_FILENO) in file_write_open()
593 cf->fd = dup(msg->fd); in file_write_open()
595 close(msg->fd); /* can only be used once */ in file_write_open()
612 reply.stream = msg->stream; in file_write_open()
621 struct msg_write_data *msg = imsg->data; in file_write_data() local
624 size_t size = msglen - sizeof *msg; in file_write_data()
626 if (msglen < sizeof *msg) in file_write_data()
628 find.stream = msg->stream; in file_write_data()
634 bufferevent_write(cf->event, msg + 1, size); in file_write_data()
641 struct msg_write_close *msg = imsg->data; in file_write_close() local
645 if (msglen != sizeof *msg) in file_write_close()
647 find.stream = msg->stream; in file_write_close()
668 struct msg_read_done msg; in file_read_error_callback() local
672 msg.stream = cf->stream; in file_read_error_callback()
673 msg.error = 0; in file_read_error_callback()
674 proc_send(cf->peer, MSG_READ_DONE, -1, &msg, sizeof msg); in file_read_error_callback()
689 struct msg_read_data *msg; in file_read_callback() local
692 msg = xmalloc(sizeof *msg); in file_read_callback()
699 if (bsize > MAX_IMSGSIZE - IMSG_HEADER_SIZE - sizeof *msg) in file_read_callback()
700 bsize = MAX_IMSGSIZE - IMSG_HEADER_SIZE - sizeof *msg; in file_read_callback()
703 msglen = (sizeof *msg) + bsize; in file_read_callback()
704 msg = xrealloc(msg, msglen); in file_read_callback()
705 msg->stream = cf->stream; in file_read_callback()
706 memcpy(msg + 1, bdata, bsize); in file_read_callback()
707 proc_send(cf->peer, MSG_READ, -1, msg, msglen); in file_read_callback()
711 free(msg); in file_read_callback()
720 struct msg_read_open *msg = imsg->data; in file_read_open() local
728 if (msglen < sizeof *msg) in file_read_open()
730 if (msglen == sizeof *msg) in file_read_open()
733 path = (const char *)(msg + 1); in file_read_open()
734 log_debug("open read file %d %s", msg->stream, path); in file_read_open()
736 find.stream = msg->stream; in file_read_open()
741 cf = file_create_with_peer(peer, files, msg->stream, cb, cbdata); in file_read_open()
748 if (msg->fd == -1) in file_read_open()
751 if (msg->fd != STDIN_FILENO) in file_read_open()
754 cf->fd = dup(msg->fd); in file_read_open()
756 close(msg->fd); /* can only be used once */ in file_read_open()
773 reply.stream = msg->stream; in file_read_open()
782 struct msg_read_cancel *msg = imsg->data; in file_read_cancel() local
786 if (msglen != sizeof *msg) in file_read_cancel()
788 find.stream = msg->stream; in file_read_cancel()
800 struct msg_write_ready *msg = imsg->data; in file_write_ready() local
804 if (msglen != sizeof *msg) in file_write_ready()
806 find.stream = msg->stream; in file_write_ready()
809 if (msg->error != 0) { in file_write_ready()
810 cf->error = msg->error; in file_write_ready()
820 struct msg_read_data *msg = imsg->data; in file_read_data() local
823 void *bdata = msg + 1; in file_read_data()
824 size_t bsize = msglen - sizeof *msg; in file_read_data()
826 if (msglen < sizeof *msg) in file_read_data()
828 find.stream = msg->stream; in file_read_data()
846 struct msg_read_done *msg = imsg->data; in file_read_done() local
850 if (msglen != sizeof *msg) in file_read_done()
852 find.stream = msg->stream; in file_read_done()
857 cf->error = msg->error; in file_read_done()