Lines Matching refs:queued_fds
85 stream->queued_fds = NULL;
605 if (server->queued_fds != NULL) {
606 uv__stream_queued_fds_t* queued_fds;
608 queued_fds = server->queued_fds;
611 server->accepted_fd = queued_fds->fds[0];
614 assert(queued_fds->offset > 0);
615 if (--queued_fds->offset == 0) {
616 uv__free(queued_fds);
617 server->queued_fds = NULL;
620 memmove(queued_fds->fds,
621 queued_fds->fds + 1,
622 queued_fds->offset * sizeof(*queued_fds->fds));
975 uv__stream_queued_fds_t* queued_fds;
978 queued_fds = stream->queued_fds;
979 if (queued_fds == NULL) {
981 queued_fds = uv__malloc((queue_size - 1) * sizeof(*queued_fds->fds) +
982 sizeof(*queued_fds));
983 if (queued_fds == NULL)
985 queued_fds->size = queue_size;
986 queued_fds->offset = 0;
987 stream->queued_fds = queued_fds;
990 } else if (queued_fds->size == queued_fds->offset) {
991 queue_size = queued_fds->size + 8;
992 queued_fds = uv__realloc(queued_fds,
993 (queue_size - 1) * sizeof(*queued_fds->fds) +
994 sizeof(*queued_fds));
1000 if (queued_fds == NULL)
1002 queued_fds->size = queue_size;
1003 stream->queued_fds = queued_fds;
1007 queued_fds->fds[queued_fds->offset++] = fd;
1571 uv__stream_queued_fds_t* queued_fds;
1612 if (handle->queued_fds != NULL) {
1613 queued_fds = handle->queued_fds;
1614 for (i = 0; i < queued_fds->offset; i++)
1615 uv__close(queued_fds->fds[i]);
1616 uv__free(handle->queued_fds);
1617 handle->queued_fds = NULL;