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()
463 pkgcloseserver(PKGserver server)  in pkgcloseserver()  argument
466 	if (server->fp != NULL)  in pkgcloseserver()
467 		(void) fclose(server->fp);  in pkgcloseserver()
468 	free(server->curbuf);  in pkgcloseserver()
469 	if (server->onetime) {  in pkgcloseserver()
472 		(void) pkgcmd(server, &cmd, sizeof (cmd), NULL, NULL, NULL);  in pkgcloseserver()
474 	(void) close(server->door);  in pkgcloseserver()
475 	if (server == current_server)  in pkgcloseserver()
477 	free(server);  in pkgcloseserver()
576 	void *server;  in pkgsync()  local
583 	server = pkgopenserver_i(root, sadmdir, B_FALSE, FLUSH_LOG);  in pkgsync()
588 	if (server == NULL)  in pkgsync()
593 	(void) pkgcmd(server, &cmd, sizeof (cmd), NULL, NULL, NULL);  in pkgsync()
594 	(void) pkgcloseserver(server);  in pkgsync()
599 pkgservercommitfile(VFP_T *a_vfp, PKGserver server)  in pkgservercommitfile()  argument
630 		if (pkgcmd(server, pcmd, sizeof (*pcmd) + len - 1,  in pkgservercommitfile()
639 	if (pkgcmd(server, pcmd, sizeof (*pcmd), NULL, NULL, NULL) != 0)  in pkgservercommitfile()
650 pkgopenfilter(PKGserver server, const char *filt)  in pkgopenfilter()  argument
659 	if (server->fp != NULL) {  in pkgopenfilter()
660 		(void) fclose(server->fp);  in pkgopenfilter()
661 		server->fp = NULL;  in pkgopenfilter()
671 	if (pkgcmd(server, pfcmd, len, NULL, NULL, &fd) != 0 || fd == -1) {  in pkgopenfilter()
677 	server->fp = fdopen(fd, "r");  in pkgopenfilter()
678 	if (server->fp == NULL) {  in pkgopenfilter()
687 pkgclosefilter(PKGserver server)  in pkgclosefilter()  argument
689 	if (server->fp != NULL) {  in pkgclosefilter()
690 		(void) fclose(server->fp);  in pkgclosefilter()
691 		server->fp = NULL;  in pkgclosefilter()
699 pkggetentry(PKGserver server, int *len, int *pathlen)  in pkggetentry()  argument
703 	if (server->fp == NULL)  in pkggetentry()
706 	if (feof(server->fp) || ferror(server->fp))  in pkggetentry()
709 	if (fread(num, sizeof (int), 2, server->fp) != 2)  in pkggetentry()
712 	if (num[0] > server->buflen) {  in pkggetentry()
713 		free(server->curbuf);  in pkggetentry()
714 		server->buflen = num[0];  in pkggetentry()
715 		server->curbuf = malloc(server->buflen);  in pkggetentry()
716 		if (server->curbuf == NULL)  in pkggetentry()
719 	if (fread(server->curbuf, 1, num[0], server->fp) != num[0])  in pkggetentry()
725 	return (server->curbuf);  in pkggetentry()
729 pkggetentry_named(PKGserver server, const char *path, int *len, int *pathlen)  in pkggetentry_named()  argument
740 	result = server->curbuf;  in pkggetentry_named()
741 	rlen = server->buflen;  in pkggetentry_named()
743 	if (pkgcmd(server, pcmd, sizeof (*pcmd) + pcmd->len,  in pkggetentry_named()
751 	if (result != server->curbuf) {  in pkggetentry_named()
752 		free(server->curbuf);  in pkggetentry_named()
753 		server->buflen = rlen;  in pkggetentry_named()
754 		server->curbuf = malloc(server->buflen);  in pkggetentry_named()
755 		if (server->curbuf == NULL)  in pkggetentry_named()
757 		(void) memcpy(server->curbuf, result, rlen);  in pkggetentry_named()
762 	return (server->curbuf);  in pkggetentry_named()