250 	PKGserver server;  in pkgopenserver_i()  local
285 	server = malloc(sizeof (*server));  in pkgopenserver_i()
287 	if (server == NULL)  in pkgopenserver_i()
290 	server->fp = NULL;  in pkgopenserver_i()
291 	server->onetime = readonly;  in pkgopenserver_i()
294 	server->door = open(pkgdoor, O_RDWR);  in pkgopenserver_i()
296 	if (server->door >= 0) {  in pkgopenserver_i()
297 		if (door_info(server->door, &di) == 0 && di.di_target >= 0) {  in pkgopenserver_i()
300 			server->buflen = 1024;  in pkgopenserver_i()
301 			server->curbuf = malloc(1024);  in pkgopenserver_i()
302 			if (server->curbuf == NULL ||  in pkgopenserver_i()
303 			    pkgcmd(server, &n, sizeof (n), NULL, NULL, NULL)) {  in pkgopenserver_i()
304 				pkgcloseserver(server);  in pkgopenserver_i()
307 			return (current_server = server);  in pkgopenserver_i()
310 		(void) close(server->door);  in pkgopenserver_i()
361 		server->onetime |= (mode == RUN_ONCE);  in pkgopenserver_i()
384 	free(server);  in pkgopenserver_i()
464 pkgcloseserver(PKGserver server)  in pkgcloseserver()  argument
467 	if (server->fp != NULL)  in pkgcloseserver()
468 		(void) fclose(server->fp);  in pkgcloseserver()
469 	free(server->curbuf);  in pkgcloseserver()
470 	if (server->onetime) {  in pkgcloseserver()
473 		(void) pkgcmd(server, &cmd, sizeof (cmd), NULL, NULL, NULL);  in pkgcloseserver()
475 	(void) close(server->door);  in pkgcloseserver()
476 	if (server == current_server)  in pkgcloseserver()
478 	free(server);  in pkgcloseserver()
577 	void *server;  in pkgsync()  local
584 	server = pkgopenserver_i(root, sadmdir, B_FALSE, FLUSH_LOG);  in pkgsync()
589 	if (server == NULL)  in pkgsync()
594 	(void) pkgcmd(server, &cmd, sizeof (cmd), NULL, NULL, NULL);  in pkgsync()
595 	(void) pkgcloseserver(server);  in pkgsync()
600 pkgservercommitfile(VFP_T *a_vfp, PKGserver server)  in pkgservercommitfile()  argument
631 		if (pkgcmd(server, pcmd, sizeof (*pcmd) + len - 1,  in pkgservercommitfile()
640 	if (pkgcmd(server, pcmd, sizeof (*pcmd), NULL, NULL, NULL) != 0)  in pkgservercommitfile()
651 pkgopenfilter(PKGserver server, const char *filt)  in pkgopenfilter()  argument
660 	if (server->fp != NULL) {  in pkgopenfilter()
661 		(void) fclose(server->fp);  in pkgopenfilter()
662 		server->fp = NULL;  in pkgopenfilter()
672 	if (pkgcmd(server, pfcmd, len, NULL, NULL, &fd) != 0 || fd == -1) {  in pkgopenfilter()
678 	server->fp = fdopen(fd, "r");  in pkgopenfilter()
679 	if (server->fp == NULL) {  in pkgopenfilter()
688 pkgclosefilter(PKGserver server)  in pkgclosefilter()  argument
690 	if (server->fp != NULL) {  in pkgclosefilter()
691 		(void) fclose(server->fp);  in pkgclosefilter()
692 		server->fp = NULL;  in pkgclosefilter()
700 pkggetentry(PKGserver server, int *len, int *pathlen)  in pkggetentry()  argument
704 	if (server->fp == NULL)  in pkggetentry()
707 	if (feof(server->fp) || ferror(server->fp))  in pkggetentry()
710 	if (fread(num, sizeof (int), 2, server->fp) != 2)  in pkggetentry()
713 	if (num[0] > server->buflen) {  in pkggetentry()
714 		free(server->curbuf);  in pkggetentry()
715 		server->buflen = num[0];  in pkggetentry()
716 		server->curbuf = malloc(server->buflen);  in pkggetentry()
717 		if (server->curbuf == NULL)  in pkggetentry()
720 	if (fread(server->curbuf, 1, num[0], server->fp) != num[0])  in pkggetentry()
726 	return (server->curbuf);  in pkggetentry()
730 pkggetentry_named(PKGserver server, const char *path, int *len, int *pathlen)  in pkggetentry_named()  argument
741 	result = server->curbuf;  in pkggetentry_named()
742 	rlen = server->buflen;  in pkggetentry_named()
744 	if (pkgcmd(server, pcmd, sizeof (*pcmd) + pcmd->len,  in pkggetentry_named()
752 	if (result != server->curbuf) {  in pkggetentry_named()
753 		free(server->curbuf);  in pkggetentry_named()
754 		server->buflen = rlen;  in pkggetentry_named()
755 		server->curbuf = malloc(server->buflen);  in pkggetentry_named()
756 		if (server->curbuf == NULL)  in pkggetentry_named()
758 		(void) memcpy(server->curbuf, result, rlen);  in pkggetentry_named()
763 	return (server->curbuf);  in pkggetentry_named()