Lines Matching refs:llp
542 static void fuse_ll_pipe_free(struct fuse_ll_pipe *llp) argument
544 close(llp->pipe[0]);
545 close(llp->pipe[1]);
546 free(llp);
577 struct fuse_ll_pipe *llp = pthread_getspecific(se->pipe_key); local
578 if (llp == NULL) {
581 llp = malloc(sizeof(struct fuse_ll_pipe));
582 if (llp == NULL)
585 res = fuse_pipe(llp->pipe);
587 free(llp);
594 llp->size = pagesize * 16;
595 llp->can_grow = 1;
597 pthread_setspecific(se->pipe_key, llp);
600 return llp;
606 struct fuse_ll_pipe *llp = pthread_getspecific(se->pipe_key); local
607 if (llp) {
609 fuse_ll_pipe_free(llp);
666 struct fuse_ll_pipe *llp; local
693 llp = fuse_ll_get_pipe(se);
694 if (llp == NULL)
708 if (llp->size < pipesize) {
709 if (llp->can_grow) {
710 res = fcntl(llp->pipe[0], F_SETPIPE_SZ, pipesize);
712 res = grow_pipe_to_max(llp->pipe[0]);
714 llp->size = res;
715 llp->can_grow = 0;
718 llp->size = res;
720 if (llp->size < pipesize)
725 res = vmsplice(llp->pipe[1], iov, iov_count, SPLICE_F_NONBLOCK);
737 pipe_buf.buf[0].fd = llp->pipe[1];
757 fuse_ll_pipe_free(llp);
798 res = read_back(llp->pipe[0], tmpbuf, headerlen);
804 res = read_back(llp->pipe[0], mbuf, now_len);
835 res = se->io->splice_send(llp->pipe[0], NULL,
839 res = splice(llp->pipe[0], NULL, ch ? ch->fd : se->fd, NULL,
2815 struct fuse_ll_pipe *llp; local
2821 llp = pthread_getspecific(se->pipe_key);
2822 if (llp != NULL)
2823 fuse_ll_pipe_free(llp);
2838 struct fuse_ll_pipe *llp = data; local
2839 fuse_ll_pipe_free(llp);
2854 struct fuse_ll_pipe *llp; local
2860 llp = fuse_ll_get_pipe(se);
2861 if (llp == NULL)
2864 if (llp->size < bufsize) {
2865 if (llp->can_grow) {
2866 res = fcntl(llp->pipe[0], F_SETPIPE_SZ, bufsize);
2868 llp->can_grow = 0;
2869 res = grow_pipe_to_max(llp->pipe[0]);
2871 llp->size = res;
2874 llp->size = res;
2876 if (llp->size < bufsize)
2882 llp->pipe[1], NULL, bufsize, 0,
2885 res = splice(ch ? ch->fd : se->fd, NULL, llp->pipe[1], NULL,
2913 .fd = llp->pipe[0],