Home | History | Annotate | Download | only in clvmd

Lines Matching refs:newfd

283 	struct local_client *newfd;
457 	newfd = malloc(sizeof(struct local_client));
458 	if (!newfd)
461 	newfd->fd = local_sock;
462 	newfd->removeme = 0;
463 	newfd->type = LOCAL_RENDEZVOUS;
464 	newfd->callback = local_rendezvous_callback;
465 	newfd->next = local_client_head.next;
466 	local_client_head.next = newfd;
523 	struct local_client *newfd;
531 		newfd = malloc(sizeof(struct local_client));
532 		if (!newfd) {
536 		newfd->fd = client_fd;
537 		newfd->type = LOCAL_SOCK;
538 		newfd->xid = 0;
539 		newfd->removeme = 0;
540 		newfd->callback = local_sock_callback;
541 		newfd->bits.localsock.replies = NULL;
542 		newfd->bits.localsock.expected_replies = 0;
543 		newfd->bits.localsock.cmd = NULL;
544 		newfd->bits.localsock.in_progress = FALSE;
545 		newfd->bits.localsock.sent_out = FALSE;
546 		newfd->bits.localsock.threadid = 0;
547 		newfd->bits.localsock.finished = 0;
548 		newfd->bits.localsock.pipe_client = NULL;
549 		newfd->bits.localsock.private = NULL;
550 		newfd->bits.localsock.all_success = 1;
551 		DEBUGLOG("Got new connection on fd %d\n", newfd->fd);
552 		*new_client = newfd;
750 					struct local_client *newfd = NULL;
757 							     &newfd);
785 					if (newfd) {
786 						newfd->next = thisfd->next;
787 						thisfd->next = newfd;
995 				struct local_client *newfd;
1003 				for (newfd = &local_client_head; newfd != NULL;
1004 				     newfd = newfd->next) {
1006 					    pipe_client == newfd) {
1010 						lastfd->next = newfd->next;
1011 						free_fd = newfd;
1012 						newfd->next = lastfd;
1016 					lastfd = newfd;
1033 		struct local_client *newfd;
1151 		newfd = malloc(sizeof(struct local_client));
1152 		if (!newfd) {
1168 		newfd->fd = comms_pipe[0];
1169 		newfd->removeme = 0;
1170 		newfd->type = THREAD_PIPE;
1171 		newfd->callback = local_pipe_callback;
1172 		newfd->next = thisfd->next;
1173 		newfd->bits.pipe.client = thisfd;
1174 		newfd->bits.pipe.threadid = 0;
1175 		thisfd->next = newfd;
1178 		thisfd->bits.localsock.pipe_client = newfd;
1183 		newfd->bits.pipe.threadid = thisfd->bits.localsock.threadid;