Searched refs:conn (Results 1 - 25 of 90) sorted by relevance

1234

/sssd/src/sbus/
H A Dsssd_dbus_connection.c33 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 Dsbus_client.c32 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 Dsssd_dbus.h158 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 Dsssd_dbus_common_signals.c33 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 Dsssd_dbus_private.h31 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 Dsssd_dbus_common.c55 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 Dsssd_dbus_signals.c36 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 Dsssd_dbus_interface.c486 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 Dsssd_dbus_properties.c137 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 Dsssd_dbus_request.c38 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 Dproxy_client.c31 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 Dsssctl_systemd.c37 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 Dds.py56 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 Ddp_client.c32 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 Ddp_iface.c59 dp_register_sbus_interface(struct sbus_connection *conn, argument
62 return sbus_conn_register_iface_map(conn, dp_map, pvt);
H A Ddp_iface.h31 errno_t dp_register_sbus_interface(struct sbus_connection *conn,
/sssd/src/providers/ad/
H A Dad_domain_info.h31 struct sdap_id_conn_ctx *conn,
H A Dad_id.h42 struct sdap_id_conn_ctx **conn);
/sssd/src/monitor/
H A Dmonitor_sbus.c112 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 Dmonitor_interfaces.h39 int monitor_common_send_id(struct sbus_connection *conn,
/sssd/src/providers/ldap/
H A Dsdap_async_enum.h45 struct sdap_id_conn_ctx *conn);
H A Dsdap_async_ad.h52 struct sdap_id_conn_ctx *conn,
/sssd/src/responder/ifp/
H A Difp_private.h33 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 Difpsrv.c69 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 Dsbus_internal_tests.c33 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);

Completed in 1462 milliseconds

1234