Cross Reference: /src/lib/librumpclient/rumpclient.c

Lines Matching defs:clispc
117 static struct spclient clispc = {
198 			if ((rv = handshake_req(&clispc, HANDSHAKE_GUEST,
286 				pfd[0].fd = clispc.spc_fd;
588 	rv = syscall_req(&clispc, &omask, sysnum, data, dlen, &rdata);
717 	EV_SET(&kev[NSIG], clispc.spc_fd,
762 	if (clispc.spc_fd != -1)
763 		host_close(clispc.spc_fd);
764 	clispc.spc_fd = -1;
769 	putwait_locked(&clispc, &rw, &rhdr);
771 	pthread_mutex_lock(&clispc.spc_mtx);
772 	clispc.spc_reconnecting = 1;
773 	pthread_cond_broadcast(&clispc.spc_cv);
774 	clispc.spc_generation++;
775 	while (clispc.spc_istatus != SPCSTATUS_FREE) {
776 		clispc.spc_istatus = SPCSTATUS_WANTED;
777 		pthread_cond_wait(&rw.rw_cv, &clispc.spc_mtx);
779 	kickall(&clispc);
786 	clispc.spc_istatus = SPCSTATUS_FREE;
787 	pthread_mutex_unlock(&clispc.spc_mtx);
788 	unputwait_locked(&clispc, &rw);
790 	free(clispc.spc_buf);
791 	clispc.spc_off = 0;
827 	clispc.spc_fd = s;
828 	clispc.spc_state = SPCSTATE_RUNNING;
829 	clispc.spc_reconnecting = 0;
839 	TAILQ_INIT(&clispc.spc_respwait);
840 	pthread_mutex_init(&clispc.spc_mtx, NULL);
841 	pthread_cond_init(&clispc.spc_cv, NULL);
963 		sscanf(p, "%d,%d", &clispc.spc_fd, &holyfd);
972 	error = handshake_req(&clispc, hstype, NULL, 0, false);
974 		pthread_mutex_destroy(&clispc.spc_mtx);
975 		pthread_cond_destroy(&clispc.spc_cv);
976 		if (clispc.spc_fd != -1)
977 			host_close(clispc.spc_fd);
1008 	if ((rv = prefork_req(&clispc, &omask, &resp)) != 0) {
1018 	rpf->fork_spc = clispc;
1032 	osock = clispc.spc_fd;
1033 	memset(&clispc, 0, sizeof(clispc));
1034 	clispc.spc_fd = osock;
1050 	error = handshake_req(&clispc, HANDSHAKE_FORK, rpf->fork_auth,
1053 		pthread_mutex_destroy(&clispc.spc_mtx);
1054 		pthread_cond_destroy(&clispc.spc_cv);
1074 	clispc = rpf->fork_spc;
1097 		untilfd = MAX(clispc.spc_fd, holyfd);
1099 			if (fd == clispc.spc_fd || fd == holyfd)
1108 		if (fd == clispc.spc_fd) {
1109 			newfd = dupgood(clispc.spc_fd, 1);
1122 			EV_SET(&kev[0], clispc.spc_fd,
1133 			clispc.spc_fd = newfd;
1170 	    clispc.spc_fd, holyfd);
OpenGrok
