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