254 	PKGserver server;  in pkgopenserver_i()  local
289 	server = malloc(sizeof (*server));  in pkgopenserver_i()
291 	if (server == NULL)  in pkgopenserver_i()
294 	server->fp = NULL;  in pkgopenserver_i()
295 	server->onetime = readonly;  in pkgopenserver_i()
298 	server->door = open(pkgdoor, O_RDWR);  in pkgopenserver_i()
300 	if (server->door >= 0) {  in pkgopenserver_i()
301 		if (door_info(server->door, &di) == 0 && di.di_target >= 0) {  in pkgopenserver_i()
304 			server->buflen = 1024;  in pkgopenserver_i()
305 			server->curbuf = malloc(1024);  in pkgopenserver_i()
306 			if (server->curbuf == NULL ||  in pkgopenserver_i()
307 			    pkgcmd(server, &n, sizeof (n), NULL, NULL, NULL)) {  in pkgopenserver_i()
308 				pkgcloseserver(server);  in pkgopenserver_i()
311 			return (current_server = server);  in pkgopenserver_i()
314 		(void) close(server->door);  in pkgopenserver_i()
365 		server->onetime |= (mode == RUN_ONCE);  in pkgopenserver_i()
388 	free(server);  in pkgopenserver_i()
468 pkgcloseserver(PKGserver server)  in pkgcloseserver()  argument
471 	if (server->fp != NULL)  in pkgcloseserver()
472 		(void) fclose(server->fp);  in pkgcloseserver()
473 	free(server->curbuf);  in pkgcloseserver()
474 	if (server->onetime) {  in pkgcloseserver()
477 		(void) pkgcmd(server, &cmd, sizeof (cmd), NULL, NULL, NULL);  in pkgcloseserver()
479 	(void) close(server->door);  in pkgcloseserver()
480 	if (server == current_server)  in pkgcloseserver()
482 	free(server);  in pkgcloseserver()
582 	void *server;  in pkgsync()  local
589 	server = pkgopenserver_i(root, sadmdir, B_FALSE, FLUSH_LOG);  in pkgsync()
594 	if (server == NULL)  in pkgsync()
599 	(void) pkgcmd(server, &cmd, sizeof (cmd), NULL, NULL, NULL);  in pkgsync()
600 	(void) pkgcloseserver(server);  in pkgsync()
605 pkgservercommitfile(VFP_T *a_vfp, PKGserver server)  in pkgservercommitfile()  argument
636 		if (pkgcmd(server, pcmd, sizeof (*pcmd) + len - 1,  in pkgservercommitfile()
645 	if (pkgcmd(server, pcmd, sizeof (*pcmd), NULL, NULL, NULL) != 0)  in pkgservercommitfile()
656 pkgopenfilter(PKGserver server, const char *filt)  in pkgopenfilter()  argument
665 	if (server->fp != NULL) {  in pkgopenfilter()
666 		(void) fclose(server->fp);  in pkgopenfilter()
667 		server->fp = NULL;  in pkgopenfilter()
677 	if (pkgcmd(server, pfcmd, len, NULL, NULL, &fd) != 0 || fd == -1) {  in pkgopenfilter()
683 	server->fp = fdopen(fd, "r");  in pkgopenfilter()
684 	if (server->fp == NULL) {  in pkgopenfilter()
693 pkgclosefilter(PKGserver server)  in pkgclosefilter()  argument
695 	if (server->fp != NULL) {  in pkgclosefilter()
696 		(void) fclose(server->fp);  in pkgclosefilter()
697 		server->fp = NULL;  in pkgclosefilter()
705 pkggetentry(PKGserver server, int *len, int *pathlen)  in pkggetentry()  argument
709 	if (server->fp == NULL)  in pkggetentry()
712 	if (feof(server->fp) || ferror(server->fp))  in pkggetentry()
715 	if (fread(num, sizeof (int), 2, server->fp) != 2)  in pkggetentry()
718 	if (num[0] > server->buflen) {  in pkggetentry()
719 		free(server->curbuf);  in pkggetentry()
720 		server->buflen = num[0];  in pkggetentry()
721 		server->curbuf = malloc(server->buflen);  in pkggetentry()
722 		if (server->curbuf == NULL)  in pkggetentry()
725 	if (fread(server->curbuf, 1, num[0], server->fp) != num[0])  in pkggetentry()
731 	return (server->curbuf);  in pkggetentry()
735 pkggetentry_named(PKGserver server, const char *path, int *len, int *pathlen)  in pkggetentry_named()  argument
746 	result = server->curbuf;  in pkggetentry_named()
747 	rlen = server->buflen;  in pkggetentry_named()
749 	if (pkgcmd(server, pcmd, sizeof (*pcmd) + pcmd->len,  in pkggetentry_named()
757 	if (result != server->curbuf) {  in pkggetentry_named()
758 		free(server->curbuf);  in pkggetentry_named()
759 		server->buflen = rlen;  in pkggetentry_named()
760 		server->curbuf = malloc(server->buflen);  in pkggetentry_named()
761 		if (server->curbuf == NULL)  in pkggetentry_named()
763 		(void) memcpy(server->curbuf, result, rlen);  in pkggetentry_named()
768 	return (server->curbuf);  in pkggetentry_named()