/sssd/src/sbus/ |
H A D | sssd_dbus_connection.c | 33 static int sbus_auto_reconnect(struct sbus_connection *conn); 40 struct sbus_connection *conn; local 46 conn = talloc_get_type(data, struct sbus_connection); 48 dbus_conn = conn->dbus.conn; 49 DEBUG(SSSDBG_TRACE_ALL, "dbus conn: %p\n", dbus_conn); 51 if (conn->retries > 0) { 55 new_event = tevent_add_timer(ev, conn, tv, sbus_dispatch, conn); 63 (conn 123 struct sbus_connection *conn; local 153 struct sbus_connection *conn; local 215 sbus_conn_set_fns(struct sbus_connection *conn) argument 264 struct sbus_connection *conn; local 297 struct sbus_connection *conn; local 330 sbus_get_connection(struct sbus_connection *conn) argument 335 sbus_disconnect(struct sbus_connection *conn) argument 383 struct sbus_connection *conn; local 461 sbus_auto_reconnect(struct sbus_connection *conn) argument 485 sbus_reconnect_init(struct sbus_connection *conn, int max_retries, sbus_conn_reconn_callback_fn callback, void *pvt) argument 498 sbus_conn_disconnecting(struct sbus_connection *conn) argument 566 sbus_conn_send(struct sbus_connection *conn, DBusMessage *msg, int timeout_ms, DBusPendingCallNotifyFunction reply_handler, void *pvt, DBusPendingCall **pending) argument 585 sbus_conn_send_reply(struct sbus_connection *conn, DBusMessage *reply) argument 603 sbus_allow_uid(struct sbus_connection *conn, uid_t *uid) argument [all...] |
H A D | sbus_client.c | 32 struct sbus_connection *conn = NULL; local 66 ret = sbus_new_connection(mem_ctx, ev, server_address, &conn); 71 *_conn = conn; 75 talloc_free(conn);
|
H A D | sssd_dbus.h | 158 struct sbus_connection **conn); 178 DBusConnection *sbus_get_connection(struct sbus_connection *conn); 180 void sbus_disconnect(struct sbus_connection *conn); 189 int sbus_conn_register_iface(struct sbus_connection *conn, 199 errno_t sbus_conn_register_iface_map(struct sbus_connection *conn, 204 sbus_conn_register_nodes(struct sbus_connection *conn, 210 sbus_conn_reregister_paths(struct sbus_connection *conn); 251 bool sbus_conn_disconnecting(struct sbus_connection *conn); 257 void sbus_reconnect_init(struct sbus_connection *conn, 271 int sbus_conn_send(struct sbus_connection *conn, 293 struct sbus_connection *conn; member in struct:sbus_request 432 struct sbus_connection *conn; member in struct:sbus_incoming_signal [all...] |
H A D | sssd_dbus_common_signals.c | 33 hash_table_t *table = a_signal->conn->clients; 71 void sbus_register_common_signals(struct sbus_connection *conn, void *pvt) argument 77 if (signals_map[i].conn_type != conn->connection_type) { 82 ret = sbus_signal_listen(conn, signals_map[i].iface, 84 signals_map[i].handler_fn, conn);
|
H A D | sssd_dbus_private.h | 31 DBusConnection *conn; member in union:dbus_conn_pointer 81 struct sbus_connection *conn; member in struct:sbus_watch_ctx 108 sbus_new_request(struct sbus_connection *conn, struct sbus_interface *intf, 120 struct sbus_connection *conn, 136 struct sbus_connection *conn, 162 /* =Retrieve-conn-credentials=============================================== */ 165 struct sbus_connection *conn, 176 sbus_signal_handler(DBusConnection *conn, 184 void sbus_register_common_signals(struct sbus_connection *conn, void *pvt);
|
H A D | sssd_dbus_common.c | 55 DLIST_REMOVE(watch->conn->watch_list, watch); 73 /* conn may get freed inside a handle, save the data we need for later */ 74 type = watch->conn->type; 75 dbus_p = watch->conn->dbus; 81 dbus_connection_ref(dbus_p.conn); 102 dbus_connection_unref(dbus_p.conn); 115 struct sbus_connection *conn; local 120 conn = talloc_get_type(data, struct sbus_connection); 128 watch = fd_to_watch(conn->watch_list, fd); 131 watch = talloc_zero(conn, struc 314 struct sbus_connection *conn; local [all...] |
H A D | sssd_dbus_signals.c | 36 sbus_new_incoming_signal(struct sbus_connection *conn, argument 41 a_signal = talloc_zero(conn, struct sbus_incoming_signal); 47 a_signal->conn = conn; 166 sbus_signal_listen(struct sbus_connection *conn, argument 185 ret = sbus_incoming_signal_hash_add(conn->incoming_signals, iface, 200 dbus_bus_add_match(conn->dbus.conn, rule, &error); 226 struct sbus_connection *conn; local 237 conn [all...] |
H A D | sssd_dbus_interface.c | 486 struct sbus_connection *conn; local 489 conn = talloc_get_type(pvt, struct sbus_connection); 492 dbus_connection_unregister_object_path(conn->dbus.conn, path); 497 struct sbus_connection *conn, 501 sbus_opath_hash_delete_cb, conn); 737 struct sbus_connection *conn, 741 NULL, conn); 867 sbus_conn_register_path(struct sbus_connection *conn, argument 880 reg_path = sbus_opath_get_base_path(conn, pat 496 sbus_opath_hash_init(TALLOC_CTX *mem_ctx, struct sbus_connection *conn, hash_table_t **_table) argument 736 sbus_nodes_hash_init(TALLOC_CTX *mem_ctx, struct sbus_connection *conn, hash_table_t **_table) argument 919 sbus_conn_register_iface(struct sbus_connection *conn, struct sbus_vtable *iface_vtable, const char *object_path, void *handler_data) argument 974 sbus_conn_register_iface_map(struct sbus_connection *conn, struct sbus_iface_map *map, void *pvt) argument 992 sbus_conn_register_nodes(struct sbus_connection *conn, const char *path, sbus_nodes_fn nodes_fn, void *data) argument 1007 sbus_conn_reregister_paths(struct sbus_connection *conn) argument 1044 struct sbus_connection *conn; local [all...] |
H A D | sssd_dbus_properties.c | 137 sbus_subreq = sbus_new_request(sbus_req->conn, iface, sbus_req->message); 151 struct sbus_connection *conn; local 159 conn = talloc_get_type(pvt, struct sbus_connection); 173 iface = sbus_opath_hash_lookup_iface(conn->managed_paths, sbus_req->path, 226 struct sbus_connection *conn; local 234 conn = talloc_get_type(pvt, struct sbus_connection); 246 iface = sbus_opath_hash_lookup_iface(conn->managed_paths, sbus_req->path, 303 struct sbus_connection *conn; local 308 conn = talloc_get_type(pvt, struct sbus_connection); 321 iface = sbus_opath_hash_lookup_iface(conn [all...] |
H A D | sssd_dbus_request.c | 38 sbus_new_request(struct sbus_connection *conn, argument 44 dbus_req = talloc_zero(conn, struct sbus_request); 51 dbus_req->conn = conn; 98 sbus_conn_send_reply(dbus_req->conn, reply); 376 struct sbus_connection *conn; member in struct:sbus_get_sender_id_state 386 struct sbus_connection *conn, 402 state->conn = conn; 405 if (conn 384 sbus_get_sender_id_send(TALLOC_CTX *mem_ctx, struct tevent_context *ev, struct sbus_connection *conn, const char *sender) argument [all...] |
/sssd/src/providers/proxy/ |
H A D | proxy_client.c | 31 struct sbus_connection *conn; member in struct:proxy_client 40 struct sbus_connection *conn; local 49 conn = sbus_req->conn; 69 sbus_disconnect(proxy_cli->conn); 79 sbus_disconnect(conn); 99 init_ctx->conn = conn; 118 sbus_disconnect(proxy_cli->conn); 127 int proxy_client_init(struct sbus_connection *conn, voi argument [all...] |
/sssd/src/tools/sssctl/ |
H A D | sssctl_systemd.c | 37 DBusConnection *conn; local 42 conn = dbus_bus_get(DBUS_BUS_SYSTEM, &error); 46 conn = NULL; 52 return conn; 57 DBusConnection *conn = NULL; local 68 conn = sssctl_systemd_connect(); 69 if (conn == NULL) { 84 reply = dbus_connection_send_with_reply_and_block(conn, msg, 5000, &error); 110 if (conn != NULL) { 111 dbus_connection_unref(conn); [all...] |
/sssd/src/tests/intg/ |
H A D | ds.py | 56 conn = ldap.initialize(self.ldap_url) 57 conn.simple_bind_s(self.admin_dn, self.admin_pw) 58 return conn
|
/sssd/src/providers/data_provider/ |
H A D | dp_client.c | 32 struct sbus_connection *conn; member in struct:dp_client 139 sbus_disconnect(sbus_req->conn); 162 sbus_disconnect(dp_cli->conn); 166 errno_t dp_client_init(struct sbus_connection *conn, void *data) argument 182 dp_cli = talloc_zero(conn, struct dp_client); 185 talloc_free(conn); 190 dp_cli->conn = conn; 195 sbus_allow_uid(conn, &provider->uid); 211 ret = sbus_conn_register_iface(conn, [all...] |
H A D | dp_iface.c | 59 dp_register_sbus_interface(struct sbus_connection *conn, argument 62 return sbus_conn_register_iface_map(conn, dp_map, pvt);
|
H A D | dp_iface.h | 31 errno_t dp_register_sbus_interface(struct sbus_connection *conn,
|
/sssd/src/providers/ad/ |
H A D | ad_domain_info.h | 31 struct sdap_id_conn_ctx *conn,
|
H A D | ad_id.h | 42 struct sdap_id_conn_ctx **conn);
|
/sssd/src/monitor/ |
H A D | monitor_sbus.c | 112 int monitor_common_send_id(struct sbus_connection *conn, argument 140 retval = sbus_conn_send(conn, msg, 3000, 170 struct sbus_connection *conn; local 179 ret = sbus_client_init(mem_ctx, ev, sbus_address, &conn); 187 ret = sbus_conn_register_iface(conn, &mon_iface->vtable, MONITOR_PATH, pvt); 194 ret = monitor_common_send_id(conn, svc_name, svc_version); 200 *mon_conn = conn;
|
H A D | monitor_interfaces.h | 39 int monitor_common_send_id(struct sbus_connection *conn,
|
/sssd/src/providers/ldap/ |
H A D | sdap_async_enum.h | 45 struct sdap_id_conn_ctx *conn);
|
H A D | sdap_async_ad.h | 52 struct sdap_id_conn_ctx *conn,
|
/sssd/src/responder/ifp/ |
H A D | ifp_private.h | 33 struct sbus_connection *conn; member in struct:sysbus_ctx 46 errno_t ifp_register_sbus_interface(struct sbus_connection *conn, 49 void ifp_register_nodes(struct ifp_ctx *ctx, struct sbus_connection *conn);
|
H A D | ifpsrv.c | 69 static void ifp_dp_reconnect_init(struct sbus_connection *conn, argument 101 DBusConnection *conn = NULL; local 113 conn = dbus_bus_get(DBUS_BUS_SYSTEM, &dbus_error); 114 if (conn == NULL) { 121 dbus_connection_set_exit_on_disconnect(conn, FALSE); 123 ret = dbus_bus_request_name(conn, dbus_name, 139 ret = sbus_init_connection(system_bus, ev, conn, 141 &system_bus->conn); 148 ret = ifp_register_sbus_interface(system_bus->conn, pvt); 154 ifp_register_nodes(pvt, system_bus->conn); [all...] |
/sssd/src/tests/cmocka/ |
H A D | sbus_internal_tests.c | 33 struct sbus_connection *conn; member in struct:sbus_get_id_ctx 125 test_ctx->conn = talloc(test_ctx, struct sbus_connection); 126 assert_non_null(test_ctx->conn); 127 test_ctx->conn->connection_type = SBUS_CONN_TYPE_SYSBUS; 128 ret = sss_hash_create(test_ctx->conn, 32, &test_ctx->conn->clients); 175 test_ctx->conn, __FILE__); 184 test_ctx->conn, __FILE__); 215 test_ctx->conn, NULL);
|