Lines Matching refs:llp
606 static void fuse_ll_pipe_free(struct fuse_ll_pipe *llp) in fuse_ll_pipe_free() argument
608 close(llp->pipe[0]); in fuse_ll_pipe_free()
609 close(llp->pipe[1]); in fuse_ll_pipe_free()
610 free(llp); in fuse_ll_pipe_free()
641 struct fuse_ll_pipe *llp = pthread_getspecific(se->pipe_key); in fuse_ll_get_pipe() local
642 if (llp == NULL) { in fuse_ll_get_pipe()
645 llp = malloc(sizeof(struct fuse_ll_pipe)); in fuse_ll_get_pipe()
646 if (llp == NULL) in fuse_ll_get_pipe()
649 res = fuse_pipe(llp->pipe); in fuse_ll_get_pipe()
651 free(llp); in fuse_ll_get_pipe()
658 llp->size = pagesize * 16; in fuse_ll_get_pipe()
659 llp->can_grow = 1; in fuse_ll_get_pipe()
661 pthread_setspecific(se->pipe_key, llp); in fuse_ll_get_pipe()
664 return llp; in fuse_ll_get_pipe()
670 struct fuse_ll_pipe *llp = pthread_getspecific(se->pipe_key); in fuse_ll_clear_pipe() local
671 if (llp) { in fuse_ll_clear_pipe()
673 fuse_ll_pipe_free(llp); in fuse_ll_clear_pipe()
730 struct fuse_ll_pipe *llp; in fuse_send_data_iov() local
759 llp = fuse_ll_get_pipe(se); in fuse_send_data_iov()
760 if (llp == NULL) in fuse_send_data_iov()
774 if (llp->size < pipesize) { in fuse_send_data_iov()
775 if (llp->can_grow) { in fuse_send_data_iov()
776 res = fcntl(llp->pipe[0], F_SETPIPE_SZ, pipesize); in fuse_send_data_iov()
778 res = grow_pipe_to_max(llp->pipe[0]); in fuse_send_data_iov()
780 llp->size = res; in fuse_send_data_iov()
781 llp->can_grow = 0; in fuse_send_data_iov()
784 llp->size = res; in fuse_send_data_iov()
786 if (llp->size < pipesize) in fuse_send_data_iov()
791 res = vmsplice(llp->pipe[1], iov, iov_count, SPLICE_F_NONBLOCK); in fuse_send_data_iov()
803 pipe_buf.buf[0].fd = llp->pipe[1]; in fuse_send_data_iov()
823 fuse_ll_pipe_free(llp); in fuse_send_data_iov()
864 res = read_back(llp->pipe[0], tmpbuf, headerlen); in fuse_send_data_iov()
870 res = read_back(llp->pipe[0], mbuf, now_len); in fuse_send_data_iov()
900 res = splice(llp->pipe[0], NULL, ch ? ch->fd : se->fd, in fuse_send_data_iov()
2797 struct fuse_ll_pipe *llp; in fuse_session_destroy() local
2803 llp = pthread_getspecific(se->pipe_key); in fuse_session_destroy()
2804 if (llp != NULL) in fuse_session_destroy()
2805 fuse_ll_pipe_free(llp); in fuse_session_destroy()
2818 struct fuse_ll_pipe *llp = data; in fuse_ll_pipe_destructor() local
2819 fuse_ll_pipe_free(llp); in fuse_ll_pipe_destructor()
2834 struct fuse_ll_pipe *llp; in fuse_session_receive_buf_int() local
2840 llp = fuse_ll_get_pipe(se); in fuse_session_receive_buf_int()
2841 if (llp == NULL) in fuse_session_receive_buf_int()
2844 if (llp->size < bufsize) { in fuse_session_receive_buf_int()
2845 if (llp->can_grow) { in fuse_session_receive_buf_int()
2846 res = fcntl(llp->pipe[0], F_SETPIPE_SZ, bufsize); in fuse_session_receive_buf_int()
2848 llp->can_grow = 0; in fuse_session_receive_buf_int()
2849 res = grow_pipe_to_max(llp->pipe[0]); in fuse_session_receive_buf_int()
2851 llp->size = res; in fuse_session_receive_buf_int()
2854 llp->size = res; in fuse_session_receive_buf_int()
2856 if (llp->size < bufsize) in fuse_session_receive_buf_int()
2861 NULL, llp->pipe[1], NULL, bufsize, 0); in fuse_session_receive_buf_int()
2887 .fd = llp->pipe[0], in fuse_session_receive_buf_int()