88 static struct adist_host *adhost;  variable
217 		if (proto_recv(adhost->adh_remote, &adreq->adr_packet,  in recv_thread()
236 			    adhost->adh_directory, adhost->adh_trail_name);  in recv_thread()
247 			if (proto_recv(adhost->adh_remote, adreq->adr_data,  in recv_thread()
284 	if (adhost->adh_trail_fd != -1) {  in receiver_open()
286 		    filename, adhost->adh_trail_name);  in receiver_open()
296 	switch (trail_name_compare(filename, adhost->adh_trail_name)) {  in receiver_open()
298 		if (!trail_is_not_terminated(adhost->adh_trail_name)) {  in receiver_open()
300 			    adhost->adh_directory, adhost->adh_trail_name,  in receiver_open()
301 			    adhost->adh_directory, filename);  in receiver_open()
304 		if (renameat(adhost->adh_trail_dirfd, adhost->adh_trail_name,  in receiver_open()
305 		    adhost->adh_trail_dirfd, filename) == -1) {  in receiver_open()
308 			    adhost->adh_directory, adhost->adh_trail_name,  in receiver_open()
309 			    adhost->adh_directory, filename);  in receiver_open()
314 		    adhost->adh_directory, adhost->adh_trail_name,  in receiver_open()
315 		    adhost->adh_directory, filename);  in receiver_open()
319 		fd = openat(adhost->adh_trail_dirfd, filename,  in receiver_open()
324 			    adhost->adh_directory, filename);  in receiver_open()
329 		    adhost->adh_directory, filename);  in receiver_open()
333 		fd = openat(adhost->adh_trail_dirfd, filename,  in receiver_open()
338 			    adhost->adh_directory, filename);  in receiver_open()
343 		    adhost->adh_directory, filename);  in receiver_open()
352 	PJDLOG_VERIFY(strlcpy(adhost->adh_trail_name, filename,  in receiver_open()
353 	    sizeof(adhost->adh_trail_name)) < sizeof(adhost->adh_trail_name));  in receiver_open()
354 	adhost->adh_trail_fd = fd;  in receiver_open()
368 	if (adhost->adh_trail_fd == -1) {  in receiver_append()
375 		done = write(adhost->adh_trail_fd, data, size);  in receiver_append()
380 			    adhost->adh_directory, adhost->adh_trail_name);  in receiver_append()
385 		    adhost->adh_directory, adhost->adh_trail_name);  in receiver_append()
389 	    osize, adhost->adh_directory, adhost->adh_trail_name);  in receiver_append()
398 	if (adhost->adh_trail_fd == -1) {  in receiver_close()
404 	if (!trail_validate_name(adhost->adh_trail_name, filename)) {  in receiver_close()
406 		    adhost->adh_trail_name, filename);  in receiver_close()
410 	PJDLOG_VERIFY(close(adhost->adh_trail_fd) == 0);  in receiver_close()
411 	adhost->adh_trail_fd = -1;  in receiver_close()
413 	pjdlog_debug(1, "Closed file \"%s/%s\".", adhost->adh_directory,  in receiver_close()
414 	    adhost->adh_trail_name);  in receiver_close()
416 	if (strcmp(adhost->adh_trail_name, filename) == 0) {  in receiver_close()
421 	if (renameat(adhost->adh_trail_dirfd, adhost->adh_trail_name,  in receiver_close()
422 	    adhost->adh_trail_dirfd, filename) == -1) {  in receiver_close()
424 		    adhost->adh_trail_name, filename);  in receiver_close()
429 	    adhost->adh_directory, adhost->adh_trail_name,  in receiver_close()
430 	    adhost->adh_directory, filename);  in receiver_close()
431 	PJDLOG_VERIFY(strlcpy(adhost->adh_trail_name, filename,  in receiver_close()
432 	    sizeof(adhost->adh_trail_name)) < sizeof(adhost->adh_trail_name));  in receiver_close()
442 	if (adhost->adh_trail_fd == -1) {  in receiver_error()
447 	PJDLOG_VERIFY(close(adhost->adh_trail_fd) == 0);  in receiver_error()
448 	adhost->adh_trail_fd = -1;  in receiver_error()
450 	pjdlog_debug(1, "Closed file \"%s/%s\".", adhost->adh_directory,  in receiver_error()
451 	    adhost->adh_trail_name);  in receiver_error()
514 		if (proto_send(adhost->adh_remote, &adrep,  in send_thread()
549 	if (mkdir(adhost->adh_directory, 0700) == -1) {  in receiver_directory_create()
551 		    adhost->adh_directory);  in receiver_directory_create()
553 	if (chown(adhost->adh_directory, pw->pw_uid, pw->pw_gid) == -1) {  in receiver_directory_create()
556 		    adhost->adh_directory);  in receiver_directory_create()
557 		(void)rmdir(adhost->adh_directory);  in receiver_directory_create()
567 	adhost->adh_trail_dirfd = open(adhost->adh_directory,  in receiver_directory_open()
569 	if (adhost->adh_trail_dirfd == -1) {  in receiver_directory_open()
572 			adhost->adh_trail_dirfd = open(adhost->adh_directory,  in receiver_directory_open()
575 		if (adhost->adh_trail_dirfd == -1) {  in receiver_directory_open()
578 			    adhost->adh_directory);  in receiver_directory_open()
581 	adhost->adh_trail_dirfp = fdopendir(adhost->adh_trail_dirfd);  in receiver_directory_open()
582 	if (adhost->adh_trail_dirfp == NULL) {  in receiver_directory_open()
584 		    adhost->adh_directory);  in receiver_directory_open()
589 	if (stat(adhost->adh_directory, &sb) == -1) {  in receiver_directory_open()
595 			    adhost->adh_directory);  in receiver_directory_open()
598 	adhost->adh_trail_dirfp = opendir(adhost->adh_directory);  in receiver_directory_open()
599 	if (adhost->adh_trail_dirfp == NULL) {  in receiver_directory_open()
601 		    adhost->adh_directory);  in receiver_directory_open()
603 	adhost->adh_trail_dirfd = dirfd(adhost->adh_trail_dirfp);  in receiver_directory_open()
613 	PJDLOG_ASSERT(adhost->adh_trail_dirfp != NULL);  in receiver_connect()
615 	trail_last(adhost->adh_trail_dirfp, adhost->adh_trail_name,  in receiver_connect()
616 	    sizeof(adhost->adh_trail_name));  in receiver_connect()
618 	if (adhost->adh_trail_name[0] == '\0') {  in receiver_connect()
621 		if (fstatat(adhost->adh_trail_dirfd, adhost->adh_trail_name,  in receiver_connect()
624 			    adhost->adh_directory, adhost->adh_trail_name);  in receiver_connect()
629 			    adhost->adh_directory, adhost->adh_trail_name);  in receiver_connect()
634 	if (proto_send(adhost->adh_remote, &trail_size,  in receiver_connect()
639 	if (proto_send(adhost->adh_remote, adhost->adh_trail_name,  in receiver_connect()
640 	    sizeof(adhost->adh_trail_name)) == -1) {  in receiver_connect()
671 	adhost = adh;  in adist_receiver()
675 	descriptors_cleanup(adhost);  in adist_receiver()
681 	pjdlog_prefix_set("[%s] (%s) ", adhost->adh_name,  in adist_receiver()
682 	    role2str(adhost->adh_role));  in adist_receiver()
684 	setproctitle("%s (%s)", adhost->adh_name, role2str(adhost->adh_role));  in adist_receiver()
691 	if (proto_timeout(adhost->adh_remote, adcfg->adc_timeout) == -1)  in adist_receiver()
696 	adhost->adh_trail_fd = -1;  in adist_receiver()
700 	    role2str(adhost->adh_role), adhost->adh_name) != 0) {  in adist_receiver()
707 	error = pthread_create(&td, NULL, recv_thread, adhost);  in adist_receiver()
709 	error = pthread_create(&td, NULL, disk_thread, adhost);  in adist_receiver()
711 	(void)send_thread(adhost);  in adist_receiver()