Lines Matching refs:context
49 make_signal_socket (krb5_context context)
56 fn = kadm5_log_signal_socket(context);
60 krb5_err (context, 1, errno, "socket AF_UNIX");
66 krb5_err (context, 1, errno, "bind %s", addr.sun_path);
72 kadm5_log_signal_socket_info(context, 1, &ai);
76 krb5_err (context, 1, rk_SOCK_ERRNO, "socket AF=%d", ai->ai_family);
79 krb5_err (context, 1, rk_SOCK_ERRNO, "bind");
85 make_listen_socket (krb5_context context, const char *port_str)
93 krb5_err (context, 1, rk_SOCK_ERRNO, "socket AF_INET");
99 addr.sin_port = krb5_getportbyname (context,
108 krb5_errx (context, 1, "bad port `%s'", port_str);
112 addr.sin_port = krb5_getportbyname (context, IPROP_SERVICE,
116 krb5_err (context, 1, errno, "bind");
118 krb5_err (context, 1, errno, "listen");
123 make_listen6_socket (krb5_context context, const char *port_str)
131 krb5_err (context, 1, rk_SOCK_ERRNO, "socket AF_INET6");
137 addr.sin6_port = krb5_getportbyname (context,
146 krb5_errx (context, 1, "bad port `%s'", port_str);
150 addr.sin6_port = krb5_getportbyname (context, IPROP_SERVICE,
154 krb5_err (context, 1, errno, "bind6");
156 krb5_err (context, 1, errno, "listen6");
185 check_acl (krb5_context context, const char *name)
193 if (asprintf(&slavefile, "%s/slaves", hdb_db_dir(context)) == -1
197 fn = krb5_config_get_string_default(context,
243 slave_dead(krb5_context context, slave *s)
245 krb5_warnx(context, "slave %s dead", s->name);
256 remove_slave (krb5_context context, slave *s, slave **root)
265 krb5_auth_con_free (context, s->ac);
276 add_slave (krb5_context context, krb5_keytab keytab, slave **root,
288 krb5_warnx (context, "add_slave: no memory");
297 krb5_warn (context, rk_SOCK_ERRNO, "accept");
305 ret = krb5_sname_to_principal (context, hostname, IPROP_NAME,
308 krb5_warn (context, ret, "krb5_sname_to_principal");
312 ret = krb5_recvauth (context, &s->ac, &s->fd,
314 krb5_free_principal (context, server);
316 krb5_warn (context, ret, "krb5_recvauth");
319 ret = krb5_unparse_name (context, ticket->client, &s->name);
320 krb5_free_ticket (context, ticket);
322 krb5_warn (context, ret, "krb5_unparse_name");
325 if (check_acl (context, s->name)) {
326 krb5_warnx (context, "%s not in acl", s->name);
340 remove_slave(context, l, root);
342 krb5_warnx (context, "second connection from %s", s->name);
348 krb5_warnx (context, "connection from %s", s->name);
357 remove_slave(context, s, root);
366 prop_one (krb5_context context, HDB *db, hdb_entry_ex *entry, void *v)
373 ret = hdb_entry2value (context, &entry->entry, &data);
390 ret = krb5_write_priv_message (context, s->ac, &s->fd, &data);
396 send_complete (krb5_context context, slave *s,
405 ret = hdb_create (context, &db, database);
407 krb5_err (context, 1, ret, "hdb_create: %s", database);
408 ret = db->hdb_open (context, db, O_RDONLY, 0);
410 krb5_err (context, 1, ret, "db->open");
414 krb5_errx (context, 1, "krb5_storage_from_mem");
421 ret = krb5_write_priv_message(context, s->ac, &s->fd, &data);
424 krb5_warn (context, ret, "krb5_write_priv_message");
425 slave_dead(context, s);
429 ret = hdb_foreach (context, db, HDB_F_ADMIN_DATA, prop_one, s);
431 krb5_warn (context, ret, "hdb_foreach");
432 slave_dead(context, s);
436 (*db->hdb_close)(context, db);
437 (*db->hdb_destroy)(context, db);
441 krb5_errx (context, 1, "krb5_storage_from_mem");
450 ret = krb5_write_priv_message(context, s->ac, &s->fd, &data);
452 slave_dead(context, s);
453 krb5_warn (context, ret, "krb5_write_priv_message");
463 send_are_you_there (krb5_context context, slave *s)
473 krb5_warnx(context, "slave %s missing, sending AYT", s->name);
482 krb5_warnx (context, "are_you_there: krb5_data_alloc");
483 slave_dead(context, s);
489 ret = krb5_write_priv_message(context, s->ac, &s->fd, &data);
492 krb5_warn (context, ret, "are_you_there: krb5_write_priv_message");
493 slave_dead(context, s);
501 send_diffs (krb5_context context, slave *s, int log_fd,
514 krb5_warnx(context, "slave %s in sync already at version %ld",
524 krb5_warnx(context, "sending complete log to fresh slave %s",
526 return send_complete (context, s, database, current_version);
532 ret = kadm5_log_previous (context, sp, &ver, ×tamp, &op, &len);
534 krb5_err(context, 1, ret,
543 krb5_warnx(context,
547 return send_complete (context, s, database, current_version);
551 krb5_warnx(context,
559 krb5_warn (context, ret, "send_diffs: krb5_data_alloc");
560 slave_dead(context, s);
568 krb5_warnx (context, "send_diffs: krb5_storage_from_data");
569 slave_dead(context, s);
575 ret = krb5_write_priv_message(context, s->ac, &s->fd, &data);
579 krb5_warn (context, ret, "send_diffs: krb5_write_priv_message");
580 slave_dead(context, s);
591 process_msg (krb5_context context, slave *s, int log_fd,
599 ret = krb5_read_priv_message(context, s->ac, &s->fd, &out);
601 krb5_warn (context, ret, "error reading message from %s", s->name);
607 krb5_warnx (context, "process_msg: no memory");
612 krb5_warnx (context, "process_msg: client send too short command");
620 krb5_warnx (context, "process_msg: client send too I_HAVE data");
626 krb5_warnx (context, "Slave %s (version %lu) have later version "
634 krb5_warnx (context, "Slave claims to not have "
637 ret = send_diffs (context, s, log_fd, database, current_version);
645 krb5_warnx (context, "Ignoring command %d", tmp);
664 open_stats(krb5_context context)
673 asprintf(&statfile, "%s/slaves-stats", hdb_db_dir(context));
674 fn = krb5_config_get_string_default(context,
689 write_master_down(krb5_context context)
695 fp = open_stats(context);
698 krb5_format_time(context, t, str, sizeof(str), TRUE);
705 write_stats(krb5_context context, slave *slaves, uint32_t current_version)
712 fp = open_stats(context);
716 krb5_format_time(context, t, str, sizeof(str), TRUE);
740 ret = krb5_sockaddr2address (context,
744 krb5_free_address(context, &addr);
757 ret = krb5_format_time(context, slaves->seen, str, sizeof(str), TRUE);
811 krb5_context context;
823 optidx = krb5_program_setup(&context, argc, argv, args, num_args, NULL);
835 asprintf(&config_file, "%s/kdc.conf", hdb_db_dir(context));
842 krb5_err(context, 1, ret, "getting configuration files");
844 ret = krb5_set_config_files(context, files);
847 krb5_err(context, 1, ret, "reading configuration files");
851 krb5_errx (context, 1, "couldn't parse time: %s", slave_time_gone);
854 krb5_errx (context, 1, "couldn't parse time: %s", slave_time_missing);
861 krb5_openlog (context, "ipropd-master", &log_facility);
862 krb5_set_warn_dest(context, log_facility);
864 ret = krb5_kt_register(context, &hdb_kt_ops);
866 krb5_err(context, 1, ret, "krb5_kt_register");
868 ret = krb5_kt_resolve(context, keytab_str, &keytab);
870 krb5_err(context, 1, ret, "krb5_kt_resolve: %s", keytab_str);
877 ret = kadm5_init_with_skey_ctx (context,
884 krb5_err (context, 1, ret, "kadm5_init_with_password_ctx");
890 krb5_err (context, 1, errno, "open %s",
893 signal_fd = make_signal_socket (context);
894 listen_fd = make_listen_socket (context, port_str);
895 listen6_fd = make_listen6_socket (context, port_str);
899 krb5_warnx(context, "ipropd-master started at version: %lu",
912 krb5_errx (context, 1, "fd too large");
936 krb5_err (context, 1, errno, "select");
944 krb5_warnx(context,
951 send_diffs (context, p, log_fd, database, current_version);
966 krb5_warn (context, errno, "recvfrom");
974 krb5_warnx(context,
981 send_diffs (context, p, log_fd, database, current_version);
984 krb5_warnx(context,
996 if(process_msg (context, p, log_fd, database, current_version))
997 slave_dead(context, p);
999 slave_dead(context, p);
1001 send_are_you_there (context, p);
1005 add_slave (context, keytab, &slaves, listen6_fd);
1010 add_slave (context, keytab, &slaves, listen_fd);
1014 write_stats(context, slaves, current_version);
1018 krb5_warnx(context, "%s terminated", getprogname());
1021 krb5_warnx(context, "%s CPU time limit exceeded", getprogname());
1024 krb5_warnx(context, "%s unexpected exit reason: %ld",
1027 write_master_down(context);