Lines Matching refs:in_part
1467 chanpart_T *in_part = &channel->ch_part[PART_IN]; in channel_set_job() local
1469 set_bufref(&in_part->ch_bufref, job->jv_in_buf); in channel_set_job()
1471 (char *)in_part->ch_bufref.br_buf->b_ffname); in channel_set_job()
1478 in_part->ch_bufref.br_buf->b_write_to_channel = TRUE; in channel_set_job()
1479 in_part->ch_buf_append = TRUE; in channel_set_job()
1480 in_part->ch_buf_top = in channel_set_job()
1481 in_part->ch_bufref.br_buf->b_ml.ml_line_count + 1; in channel_set_job()
1484 in_part->ch_buf_top = options->jo_in_top; in channel_set_job()
1487 in_part->ch_buf_top = 1; in channel_set_job()
1489 in_part->ch_buf_bot = options->jo_in_bot; in channel_set_job()
1491 in_part->ch_buf_bot = in_part->ch_bufref.br_buf->b_ml.ml_line_count; in channel_set_job()
1557 chanpart_T *in_part = &channel->ch_part[PART_IN]; in can_write_buf_line() local
1559 if (in_part->ch_fd == INVALID_FD) in can_write_buf_line()
1563 if (in_part->ch_block_write == 1) in can_write_buf_line()
1564 in_part->ch_block_write = -1; in can_write_buf_line()
1565 else if (in_part->ch_block_write == -1) in can_write_buf_line()
1566 in_part->ch_block_write = 1; in can_write_buf_line()
1577 FD_SET((int)in_part->ch_fd, &wfds); in can_write_buf_line()
1582 ret = select((int)in_part->ch_fd + 1, NULL, &wfds, NULL, &tval); in can_write_buf_line()
1588 if (ret <= 0 || in_part->ch_block_write == 1) in can_write_buf_line()
1601 fds.fd = in_part->ch_fd; in can_write_buf_line()
1608 if (in_part->ch_block_write == 1) in can_write_buf_line()
1625 chanpart_T *in_part = &channel->ch_part[PART_IN]; in channel_write_in() local
1627 buf_T *buf = in_part->ch_bufref.br_buf; in channel_write_in()
1630 if (buf == NULL || in_part->ch_buf_append) in channel_write_in()
1632 if (!bufref_valid(&in_part->ch_bufref) || buf->b_ml.ml_mfp == NULL) in channel_write_in()
1636 in_part->ch_bufref.br_buf = NULL; in channel_write_in()
1640 for (lnum = in_part->ch_buf_top; lnum <= in_part->ch_buf_bot in channel_write_in()
1654 in_part->ch_buf_top = lnum; in channel_write_in()
1655 if (lnum > buf->b_ml.ml_line_count || lnum > in_part->ch_buf_bot) in channel_write_in()
1664 in_part->ch_bufref.br_buf = NULL; in channel_write_in()
1704 chanpart_T *in_part = &channel->ch_part[PART_IN]; in channel_write_input() local
1706 if (in_part->ch_writeque.wq_next != NULL) in channel_write_input()
1708 else if (in_part->ch_bufref.br_buf != NULL) in channel_write_input()
1710 if (in_part->ch_buf_append) in channel_write_input()
1711 channel_write_new_lines(in_part->ch_bufref.br_buf); in channel_write_input()
1742 chanpart_T *in_part = &channel->ch_part[PART_IN]; in channel_write_new_lines() local
1746 if (in_part->ch_bufref.br_buf == buf && in_part->ch_buf_append) in channel_write_new_lines()
1748 if (in_part->ch_fd == INVALID_FD) in channel_write_new_lines()
1751 for (lnum = in_part->ch_buf_bot; lnum < buf->b_ml.ml_line_count; in channel_write_new_lines()
1768 in_part->ch_buf_bot = lnum; in channel_write_new_lines()
2727 chanpart_T *in_part = &ch->ch_part[PART_IN]; in append_to_buffer() local
2729 if (in_part->ch_bufref.br_buf == buffer) in append_to_buffer()
2730 in_part->ch_buf_bot = buffer->b_ml.ml_line_count; in append_to_buffer()
3325 chanpart_T *in_part = &ch->ch_part[PART_IN]; in channel_fill_wfds() local
3327 if (in_part->ch_fd != INVALID_FD in channel_fill_wfds()
3328 && (in_part->ch_bufref.br_buf != NULL in channel_fill_wfds()
3329 || in_part->ch_writeque.wq_next != NULL)) in channel_fill_wfds()
3331 FD_SET((int)in_part->ch_fd, wfds); in channel_fill_wfds()
3332 if ((int)in_part->ch_fd >= maxfd) in channel_fill_wfds()
3333 maxfd = (int)in_part->ch_fd + 1; in channel_fill_wfds()
3350 chanpart_T *in_part = &ch->ch_part[PART_IN]; in channel_fill_poll_write() local
3352 if (in_part->ch_fd != INVALID_FD in channel_fill_poll_write()
3353 && (in_part->ch_bufref.br_buf != NULL in channel_fill_poll_write()
3354 || in_part->ch_writeque.wq_next != NULL)) in channel_fill_poll_write()
3356 in_part->ch_poll_idx = nfd; in channel_fill_poll_write()
3357 fds[nfd].fd = in_part->ch_fd; in channel_fill_poll_write()
3362 in_part->ch_poll_idx = -1; in channel_fill_poll_write()
4430 chanpart_T *in_part; in channel_poll_check() local
4451 in_part = &channel->ch_part[PART_IN]; in channel_poll_check()
4452 idx = in_part->ch_poll_idx; in channel_poll_check()
4530 chanpart_T *in_part; in channel_select_check() local
4551 in_part = &channel->ch_part[PART_IN]; in channel_select_check()
4552 if (ret > 0 && in_part->ch_fd != INVALID_FD in channel_select_check()
4553 && FD_ISSET(in_part->ch_fd, wfds)) in channel_select_check()
4556 FD_CLR(in_part->ch_fd, wfds); in channel_select_check()