Lines Matching defs:queued_fds
95 stream->queued_fds = NULL;
573 if (server->queued_fds != NULL) {
574 uv__stream_queued_fds_t* queued_fds;
576 queued_fds = server->queued_fds;
579 server->accepted_fd = queued_fds->fds[0];
582 assert(queued_fds->offset > 0);
583 if (--queued_fds->offset == 0) {
584 uv__free(queued_fds);
585 server->queued_fds = NULL;
588 memmove(queued_fds->fds,
589 queued_fds->fds + 1,
590 queued_fds->offset * sizeof(*queued_fds->fds));
942 uv__stream_queued_fds_t* queued_fds;
945 queued_fds = stream->queued_fds;
946 if (queued_fds == NULL) {
948 queued_fds = uv__malloc((queue_size - 1) * sizeof(*queued_fds->fds) +
949 sizeof(*queued_fds));
950 if (queued_fds == NULL)
952 queued_fds->size = queue_size;
953 queued_fds->offset = 0;
954 stream->queued_fds = queued_fds;
957 } else if (queued_fds->size == queued_fds->offset) {
958 queue_size = queued_fds->size + 8;
959 queued_fds = uv__realloc(queued_fds,
960 (queue_size - 1) * sizeof(*queued_fds->fds) +
961 sizeof(*queued_fds));
967 if (queued_fds == NULL)
969 queued_fds->size = queue_size;
970 stream->queued_fds = queued_fds;
974 queued_fds->fds[queued_fds->offset++] = fd;
1504 uv__stream_queued_fds_t* queued_fds;
1545 if (handle->queued_fds != NULL) {
1546 queued_fds = handle->queued_fds;
1547 for (i = 0; i < queued_fds->offset; i++)
1548 uv__close(queued_fds->fds[i]);
1549 uv__free(handle->queued_fds);
1550 handle->queued_fds = NULL;