Lines Matching refs:msg
203 struct msg_write_open msg; in file_vprint() local
215 msg.stream = 1; in file_vprint()
216 msg.fd = STDOUT_FILENO; in file_vprint()
217 msg.flags = 0; in file_vprint()
218 proc_send(c->peer, MSG_WRITE_OPEN, -1, &msg, sizeof msg); in file_vprint()
230 struct msg_write_open msg; in file_print_buffer() local
242 msg.stream = 1; in file_print_buffer()
243 msg.fd = STDOUT_FILENO; in file_print_buffer()
244 msg.flags = 0; in file_print_buffer()
245 proc_send(c->peer, MSG_WRITE_OPEN, -1, &msg, sizeof msg); in file_print_buffer()
257 struct msg_write_open msg; in file_error() local
272 msg.stream = 2; in file_error()
273 msg.fd = STDERR_FILENO; in file_error()
274 msg.flags = 0; in file_error()
275 proc_send(c->peer, MSG_WRITE_OPEN, -1, &msg, sizeof msg); in file_error()
290 struct msg_write_open *msg; in file_write() local
336 msglen = strlen(cf->path) + 1 + sizeof *msg; in file_write()
341 msg = xmalloc(msglen); in file_write()
342 msg->stream = cf->stream; in file_write()
343 msg->fd = fd; in file_write()
344 msg->flags = flags; in file_write()
345 memcpy(msg + 1, cf->path, msglen - sizeof *msg); in file_write()
346 if (proc_send(cf->peer, MSG_WRITE_OPEN, -1, msg, msglen) != 0) { in file_write()
347 free(msg); in file_write()
351 free(msg); in file_write()
363 struct msg_read_open *msg; in file_read() local
412 msglen = strlen(cf->path) + 1 + sizeof *msg; in file_read()
417 msg = xmalloc(msglen); in file_read()
418 msg->stream = cf->stream; in file_read()
419 msg->fd = fd; in file_read()
420 memcpy(msg + 1, cf->path, msglen - sizeof *msg); in file_read()
421 if (proc_send(cf->peer, MSG_READ_OPEN, -1, msg, msglen) != 0) { in file_read()
422 free(msg); in file_read()
426 free(msg); in file_read()
438 struct msg_read_cancel msg; in file_cancel() local
446 msg.stream = cf->stream; in file_cancel()
447 proc_send(cf->peer, MSG_READ_CANCEL, -1, &msg, sizeof msg); in file_cancel()
465 struct msg_write_data *msg; in file_push() local
469 msg = xmalloc(sizeof *msg); in file_push()
473 if (sent > MAX_IMSGSIZE - IMSG_HEADER_SIZE - sizeof *msg) in file_push()
474 sent = MAX_IMSGSIZE - IMSG_HEADER_SIZE - sizeof *msg; in file_push()
476 msglen = (sizeof *msg) + sent; in file_push()
477 msg = xrealloc(msg, msglen); in file_push()
478 msg->stream = cf->stream; in file_push()
479 memcpy(msg + 1, EVBUFFER_DATA(cf->buffer), sent); in file_push()
480 if (proc_send(cf->peer, MSG_WRITE, -1, msg, msglen) != 0) in file_push()
495 free(msg); in file_push()
562 struct msg_write_open *msg = imsg->data; in file_write_open() local
570 if (msglen < sizeof *msg) in file_write_open()
572 if (msglen == sizeof *msg) in file_write_open()
575 path = (const char *)(msg + 1); in file_write_open()
576 log_debug("open write file %d %s", msg->stream, path); in file_write_open()
578 find.stream = msg->stream; in file_write_open()
583 cf = file_create_with_peer(peer, files, msg->stream, cb, cbdata); in file_write_open()
590 if (msg->fd == -1) in file_write_open()
591 cf->fd = open(path, msg->flags|flags, 0644); in file_write_open()
593 if (msg->fd != STDOUT_FILENO && msg->fd != STDERR_FILENO) in file_write_open()
596 cf->fd = dup(msg->fd); in file_write_open()
598 close(msg->fd); /* can only be used once */ in file_write_open()
615 reply.stream = msg->stream; in file_write_open()
624 struct msg_write_data *msg = imsg->data; in file_write_data() local
627 size_t size = msglen - sizeof *msg; in file_write_data()
629 if (msglen < sizeof *msg) in file_write_data()
631 find.stream = msg->stream; in file_write_data()
637 bufferevent_write(cf->event, msg + 1, size); in file_write_data()
644 struct msg_write_close *msg = imsg->data; in file_write_close() local
648 if (msglen != sizeof *msg) in file_write_close()
650 find.stream = msg->stream; in file_write_close()
671 struct msg_read_done msg; in file_read_error_callback() local
675 msg.stream = cf->stream; in file_read_error_callback()
676 msg.error = 0; in file_read_error_callback()
677 proc_send(cf->peer, MSG_READ_DONE, -1, &msg, sizeof msg); in file_read_error_callback()
692 struct msg_read_data *msg; in file_read_callback() local
695 msg = xmalloc(sizeof *msg); in file_read_callback()
702 if (bsize > MAX_IMSGSIZE - IMSG_HEADER_SIZE - sizeof *msg) in file_read_callback()
703 bsize = MAX_IMSGSIZE - IMSG_HEADER_SIZE - sizeof *msg; in file_read_callback()
706 msglen = (sizeof *msg) + bsize; in file_read_callback()
707 msg = xrealloc(msg, msglen); in file_read_callback()
708 msg->stream = cf->stream; in file_read_callback()
709 memcpy(msg + 1, bdata, bsize); in file_read_callback()
710 proc_send(cf->peer, MSG_READ, -1, msg, msglen); in file_read_callback()
714 free(msg); in file_read_callback()
723 struct msg_read_open *msg = imsg->data; in file_read_open() local
731 if (msglen < sizeof *msg) in file_read_open()
733 if (msglen == sizeof *msg) in file_read_open()
736 path = (const char *)(msg + 1); in file_read_open()
737 log_debug("open read file %d %s", msg->stream, path); in file_read_open()
739 find.stream = msg->stream; in file_read_open()
744 cf = file_create_with_peer(peer, files, msg->stream, cb, cbdata); in file_read_open()
751 if (msg->fd == -1) in file_read_open()
754 if (msg->fd != STDIN_FILENO) in file_read_open()
757 cf->fd = dup(msg->fd); in file_read_open()
759 close(msg->fd); /* can only be used once */ in file_read_open()
776 reply.stream = msg->stream; in file_read_open()
785 struct msg_read_cancel *msg = imsg->data; in file_read_cancel() local
789 if (msglen != sizeof *msg) in file_read_cancel()
791 find.stream = msg->stream; in file_read_cancel()
803 struct msg_write_ready *msg = imsg->data; in file_write_ready() local
807 if (msglen != sizeof *msg) in file_write_ready()
809 find.stream = msg->stream; in file_write_ready()
812 if (msg->error != 0) { in file_write_ready()
813 cf->error = msg->error; in file_write_ready()
823 struct msg_read_data *msg = imsg->data; in file_read_data() local
826 void *bdata = msg + 1; in file_read_data()
827 size_t bsize = msglen - sizeof *msg; in file_read_data()
829 if (msglen < sizeof *msg) in file_read_data()
831 find.stream = msg->stream; in file_read_data()
849 struct msg_read_done *msg = imsg->data; in file_read_done() local
853 if (msglen != sizeof *msg) in file_read_done()
855 find.stream = msg->stream; in file_read_done()
860 cf->error = msg->error; in file_read_done()