Searched defs:sbus_req (Results 1 - 25 of 29) sorted by relevance

12

/sssd-io/src/providers/data_provider/
H A Ddp_iface_backend.c31 errno_t dp_backend_is_online(struct sbus_request *sbus_req, argument
46 sbus_request_reply_error(sbus_req, SBUS_ERROR_UNKNOWN_DOMAIN,
58 iface_dp_backend_IsOnline_finish(sbus_req, online);
H A Ddp_target_autofs.c30 errno_t dp_autofs_handler(struct sbus_request *sbus_req, argument
42 data = talloc_zero(sbus_req, struct dp_autofs_data);
50 dp_req_with_reply(dp_cli, NULL, "AutoFS", key, sbus_req, DPT_AUTOFS,
H A Ddp_target_subdomains.c30 errno_t dp_subdomains_handler(struct sbus_request *sbus_req, argument
37 data = talloc_zero(sbus_req, struct dp_subdomains_data);
45 dp_req_with_reply(dp_cli, NULL, "Subdomains", key, sbus_req,
H A Ddp_target_hostid.c30 errno_t dp_host_handler(struct sbus_request *sbus_req, argument
43 data = talloc_zero(sbus_req, struct dp_hostid_data);
58 dp_req_with_reply(dp_cli, NULL, "HostID", key, sbus_req, DPT_HOSTID,
H A Ddp_reply_std.c70 struct sbus_request *sbus_req,
81 sbus_request_return_and_finish(sbus_req,
69 dp_req_reply_std(const char *request_name, struct sbus_request *sbus_req, struct dp_reply_std *reply) argument
H A Ddp_client.c90 dp_client_register(struct sbus_request *sbus_req, argument
125 error = sbus_error_new(sbus_req, SBUS_ERROR_NOT_FOUND,
130 return sbus_request_fail_and_finish(sbus_req, error);
135 ret = iface_dp_client_Register_finish(sbus_req);
139 sbus_disconnect(sbus_req->conn);
H A Ddp_target_sudo.c172 errno_t dp_sudo_handler(struct sbus_request *sbus_req, void *dp_cli) argument
180 data = talloc_zero(sbus_req, struct dp_sudo_data);
185 ret = dp_sudo_parse_message(data, sbus_req->message, &dp_flags,
194 dp_req_with_reply(dp_cli, NULL, name, key, sbus_req, DPT_SUDO,
H A Ddp_iface_failover.c179 errno_t dp_failover_list_services(struct sbus_request *sbus_req, argument
198 sbus_request_reply_error(sbus_req, SBUS_ERROR_UNKNOWN_DOMAIN,
235 services = talloc_zero_array(sbus_req, const char *, num_services);
267 iface_dp_failover_ListServices_finish(sbus_req, services, num_services);
271 errno_t dp_failover_active_server(struct sbus_request *sbus_req, argument
291 sbus_request_reply_error(sbus_req, SBUS_ERROR_NOT_FOUND,
302 sbus_request_reply_error(sbus_req, SBUS_ERROR_INTERNAL,
308 iface_dp_failover_ActiveServer_finish(sbus_req, server);
312 errno_t dp_failover_list_servers(struct sbus_request *sbus_req, argument
333 sbus_request_reply_error(sbus_req, SBUS_ERROR_NOT_FOUN
[all...]
H A Ddp_request_reply.c33 struct sbus_request *sbus_req,
38 sbus_request_return_and_finish(sbus_req, DBUS_TYPE_INVALID);
81 void dp_req_reply_error(struct sbus_request *sbus_req, argument
87 error = dp_req_reply_gen_error(sbus_req, req_name, ret);
91 talloc_free(sbus_req);
95 sbus_request_fail_and_finish(sbus_req, error);
113 talloc_free(item->sbus_req);
121 sbus_request_fail_and_finish(item->sbus_req, error);
140 reply_fn(request_name, item->sbus_req, output_data);
161 struct sbus_request *sbus_req,
32 dp_req_reply_default(const char *req_name, struct sbus_request *sbus_req, void **data) argument
173 _dp_req_with_reply(struct dp_client *dp_cli, const char *domain, const char *request_name, const char *custom_key, struct sbus_request *sbus_req, enum dp_targets target, enum dp_methods method, uint32_t dp_flags, void *request_data, dp_req_post_fn postprocess_fn, void *postprocess_data, dp_req_reply_fn reply_fn, const char *output_dtype) argument
256 dp_req_with_reply_step(struct data_provider *provider, struct dp_client *dp_cli, const char *domain, const char *request_name, const char *custom_key, struct sbus_request *sbus_req, enum dp_targets target, enum dp_methods method, uint32_t dp_flags, void *request_data, dp_req_post_fn postprocess_fn, void *postprocess_data, dp_req_reply_fn reply_fn, const char *output_dtype) argument
[all...]
H A Ddp_request_table.c58 struct sbus_request *sbus_req)
62 /* Attach to sbus_request so we ensure that this sbus_req is removed
65 item = talloc_zero(sbus_req, struct dp_sbus_req_item);
72 item->sbus_req = sbus_req;
120 struct sbus_request *sbus_req)
142 table_value->list = dp_sbus_req_item_new(table_value, sbus_req);
176 struct sbus_request *sbus_req)
180 item = dp_sbus_req_item_new(table_value, sbus_req);
193 struct sbus_request *sbus_req)
57 dp_sbus_req_item_new(struct dp_table_value *value, struct sbus_request *sbus_req) argument
117 dp_req_table_new_item(hash_table_t *table, const char *key, struct tevent_req *req, struct sbus_request *sbus_req) argument
174 dp_req_table_mod_item(hash_table_t *table, struct dp_table_value *table_value, struct sbus_request *sbus_req) argument
190 dp_req_table_add(hash_table_t *table, const char *key, struct tevent_req *req, struct sbus_request *sbus_req) argument
[all...]
H A Ddp_target_auth.c32 static void dp_pam_reply(struct sbus_request *sbus_req, argument
42 reply = dbus_message_new_method_return(sbus_req->message);
57 sbus_request_finish(sbus_req, reply);
63 struct sbus_request *sbus_req,
72 bret = dp_unpack_pam_request(sbus_req->message, mem_ctx, &pd, &dbus_error);
178 struct sbus_request *sbus_req; member in struct:dp_pam_handler_state
185 errno_t dp_pam_handler(struct sbus_request *sbus_req, void *sbus_data) argument
200 state = talloc_zero(sbus_req, struct dp_pam_handler_state);
206 ret = pam_data_create(state, sbus_req, provider->be_ctx, &pd);
213 state->sbus_req
62 pam_data_create(TALLOC_CTX *mem_ctx, struct sbus_request *sbus_req, struct be_ctx *be_ctx, struct pam_data **_pd) argument
310 dp_access_control_refresh_rules_handler(struct sbus_request *sbus_req, void *dp_cli) argument
[all...]
H A Ddp_private.h134 struct sbus_request *sbus_req,
138 struct sbus_request *sbus_req,
155 struct sbus_request *sbus_req; member in struct:dp_sbus_req_item
175 struct sbus_request *sbus_req);
190 void dp_req_reply_error(struct sbus_request *sbus_req,
198 struct sbus_request *sbus_req,
210 * If req_key is NULL, address of sbus_req is used.
215 #define dp_req_with_reply_pp(dp_cli, domain, req_name, req_key, sbus_req, \
228 _dp_req_with_reply(dp_cli, domain, req_name, req_key, sbus_req, \
234 #define dp_req_with_reply(dp_cli, domain, req_name, req_key, sbus_req, targe
[all...]
H A Ddp_target_id.c385 static errno_t dp_initgroups(struct sbus_request *sbus_req, argument
408 ret = sysdb_initgroups(sbus_req, domain, data->filter_value, &res);
417 ctx = create_initgr_ctx(sbus_req, data->domain, domain,
425 sbus_req, DPT_ID, DPM_ACCOUNT_HANDLER, dp_flags, data,
436 errno_t dp_get_account_info_handler(struct sbus_request *sbus_req, argument
448 data = talloc_zero(sbus_req, struct dp_id_data);
474 ret = dp_initgroups(sbus_req, dp_cli, key, dp_flags, data);
481 sbus_req, DPT_ID, DPM_ACCOUNT_HANDLER, dp_flags, data,
530 errno_t dp_get_account_domain_handler(struct sbus_request *sbus_req, argument
539 data = talloc_zero(sbus_req, struc
[all...]
/sssd-io/src/providers/proxy/
H A Dproxy_client.c36 static int proxy_client_register(struct sbus_request *sbus_req, argument
49 conn = sbus_req->conn;
73 iface_proxy_client_Register_finish(sbus_req);
/sssd-io/src/responder/ifp/
H A Difp_private.h88 struct sbus_request *sbus_req; member in struct:ifp_list_ctx
100 struct ifp_list_ctx *ifp_list_ctx_new(struct sbus_request *sbus_req,
H A Difp_cache.c211 int ifp_cache_list(struct sbus_request *sbus_req, argument
227 ret = ifp_cache_list_domains(sbus_req, ifp_ctx->rctx->domains, type,
230 error = sbus_error_new(sbus_req, DBUS_ERROR_FAILED,
233 return sbus_request_fail_and_finish(sbus_req, error);
236 iface_ifp_cache_List_finish(sbus_req, paths, num_paths);
241 int ifp_cache_list_by_domain(struct sbus_request *sbus_req, argument
261 error = sbus_error_new(sbus_req, DBUS_ERROR_FAILED, "Unknown domain");
262 return sbus_request_fail_and_finish(sbus_req, error);
265 ret = ifp_cache_get_cached_objects(sbus_req, type, domain,
268 error = sbus_error_new(sbus_req, DBUS_ERROR_FAILE
312 ifp_cache_object_store(struct sbus_request *sbus_req, struct sss_domain_info *domain, struct ldb_dn *dn) argument
329 ifp_cache_object_remove(struct sbus_request *sbus_req, struct sss_domain_info *domain, struct ldb_dn *dn) argument
[all...]
H A Difp_domains.c541 int ifp_domains_domain_is_online(struct sbus_request *sbus_req, argument
549 dom = get_domain_info_from_req(sbus_req, data);
551 sbus_request_reply_error(sbus_req, SBUS_ERROR_UNKNOWN_DOMAIN,
556 rdp_message_send_and_reply(sbus_req, ifp_ctx->rctx, dom, DP_PATH,
563 int ifp_domains_domain_list_services(struct sbus_request *sbus_req, argument
571 dom = get_domain_info_from_req(sbus_req, data);
573 sbus_request_reply_error(sbus_req, SBUS_ERROR_UNKNOWN_DOMAIN,
578 rdp_message_send_and_reply(sbus_req, ifp_ctx->rctx, dom, DP_PATH,
586 int ifp_domains_domain_active_server(struct sbus_request *sbus_req, argument
595 dom = get_domain_info_from_req(sbus_req, dat
610 ifp_domains_domain_list_servers(struct sbus_request *sbus_req, void *data, const char *service) argument
634 ifp_domains_domain_refresh_access_rules(struct sbus_request *sbus_req, void *data) argument
[all...]
H A Difpsrv_util.c358 struct ifp_list_ctx *ifp_list_ctx_new(struct sbus_request *sbus_req, argument
365 list_ctx = talloc_zero(sbus_req, struct ifp_list_ctx);
370 list_ctx->sbus_req = sbus_req;
/sssd-io/src/responder/common/data_provider/
H A Drdp_message.c234 void _rdp_message_send_and_reply(struct sbus_request *sbus_req, argument
248 rdp_message_send_and_reply_done, sbus_req,
255 talloc_free(sbus_req);
262 struct sbus_request *sbus_req; local
269 sbus_req = talloc_get_type(ptr, struct sbus_request);
271 ret = rdp_process_pending_call(sbus_req, pending, &reply);
282 sender = dbus_message_get_sender(sbus_req->message);
283 serial = dbus_message_get_serial(sbus_req->message);
299 sbus_request_finish(sbus_req, reply);
306 talloc_free(sbus_req);
[all...]
/sssd-io/src/responder/nss/
H A Dnss_iface.c184 int nss_memorycache_update_initgroups(struct sbus_request *sbus_req, argument
199 return iface_nss_memorycache_UpdateInitgroups_finish(sbus_req);
202 int nss_memorycache_invalidate_group_by_id(struct sbus_request *sbus_req, argument
214 return iface_nss_memorycache_InvalidateGroupById_finish(sbus_req);
/sssd-io/src/sbus/
H A Dsssd_dbus_properties.c47 static int sbus_properties_get(struct sbus_request *sbus_req, void *pvt);
48 static int sbus_properties_set(struct sbus_request *sbus_req, void *pvt);
49 static int sbus_properties_get_all(struct sbus_request *sbus_req, void *pvt);
129 sbus_properties_subreq(struct sbus_request *sbus_req, argument
137 sbus_subreq = sbus_new_request(sbus_req->conn, iface, sbus_req->message);
142 talloc_steal(sbus_subreq, sbus_req);
147 static int sbus_properties_get(struct sbus_request *sbus_req, void *pvt) argument
161 CHECK_SIGNATURE_OR_FAIL(sbus_req, error, fail, "ss");
163 bret = sbus_request_parse_or_finish(sbus_req,
220 sbus_properties_set(struct sbus_request *sbus_req, void *pvt) argument
299 sbus_properties_get_all(struct sbus_request *sbus_req, void *pvt) argument
[all...]
H A Dsssd_dbus_invokers.c35 sbus_invoke_get_basic(struct sbus_request *sbus_req, argument
46 handler_fn(sbus_req, sbus_req->intf->handler_data, value_ptr);
59 sbus_invoke_get_string(struct sbus_request *sbus_req, argument
70 handler_fn(sbus_req, sbus_req->intf->handler_data, &value);
79 sbus_invoke_get_array(struct sbus_request *sbus_req, argument
95 handler_fn(sbus_req, sbus_req->intf->handler_data, &values, &num_values);
121 struct sbus_request *sbus_req,
120 sbus_invoke_get_y(DBusMessageIter *iter, struct sbus_request *sbus_req, void *function_ptr) argument
130 sbus_invoke_get_b(DBusMessageIter *iter, struct sbus_request *sbus_req, void *function_ptr) argument
140 sbus_invoke_get_n(DBusMessageIter *iter, struct sbus_request *sbus_req, void *function_ptr) argument
150 sbus_invoke_get_q(DBusMessageIter *iter, struct sbus_request *sbus_req, void *function_ptr) argument
160 sbus_invoke_get_i(DBusMessageIter *iter, struct sbus_request *sbus_req, void *function_ptr) argument
170 sbus_invoke_get_u(DBusMessageIter *iter, struct sbus_request *sbus_req, void *function_ptr) argument
180 sbus_invoke_get_x(DBusMessageIter *iter, struct sbus_request *sbus_req, void *function_ptr) argument
190 sbus_invoke_get_t(DBusMessageIter *iter, struct sbus_request *sbus_req, void *function_ptr) argument
200 sbus_invoke_get_d(DBusMessageIter *iter, struct sbus_request *sbus_req, void *function_ptr) argument
210 sbus_invoke_get_s(DBusMessageIter *iter, struct sbus_request *sbus_req, void *function_ptr) argument
218 sbus_invoke_get_o(DBusMessageIter *iter, struct sbus_request *sbus_req, void *function_ptr) argument
226 sbus_invoke_get_ay(DBusMessageIter *iter, struct sbus_request *sbus_req, void *function_ptr) argument
234 sbus_invoke_get_an(DBusMessageIter *iter, struct sbus_request *sbus_req, void *function_ptr) argument
242 sbus_invoke_get_aq(DBusMessageIter *iter, struct sbus_request *sbus_req, void *function_ptr) argument
250 sbus_invoke_get_ai(DBusMessageIter *iter, struct sbus_request *sbus_req, void *function_ptr) argument
258 sbus_invoke_get_au(DBusMessageIter *iter, struct sbus_request *sbus_req, void *function_ptr) argument
266 sbus_invoke_get_ax(DBusMessageIter *iter, struct sbus_request *sbus_req, void *function_ptr) argument
274 sbus_invoke_get_at(DBusMessageIter *iter, struct sbus_request *sbus_req, void *function_ptr) argument
282 sbus_invoke_get_ad(DBusMessageIter *iter, struct sbus_request *sbus_req, void *function_ptr) argument
290 sbus_invoke_get_as(DBusMessageIter *iter, struct sbus_request *sbus_req, void *function_ptr) argument
298 sbus_invoke_get_ao(DBusMessageIter *iter, struct sbus_request *sbus_req, void *function_ptr) argument
306 sbus_invoke_get_aDOsasDE(DBusMessageIter *iter, struct sbus_request *sbus_req, void *function_ptr) argument
424 sbus_invoke_get(struct sbus_request *sbus_req, const char *type, sbus_get_invoker_fn invoker_fn, sbus_msg_handler_fn handler_fn) argument
478 sbus_invoke_get_all(struct sbus_request *sbus_req) argument
[all...]
H A Dsssd_dbus_request.c246 void sbus_request_reply_error(struct sbus_request *sbus_req, argument
255 error = sbus_error_new_va(sbus_req, error_name, fmt, ap);
261 talloc_free(sbus_req);
265 sbus_request_fail_and_finish(sbus_req, error);
H A Dsssd_dbus_introspect.c82 static int sbus_introspect(struct sbus_request *sbus_req, void *pvt);
369 sbus_introspect(struct sbus_request *sbus_req, void *pvt) argument
380 ret = sbus_opath_hash_lookup_supported(sbus_req, conn->managed_paths,
381 sbus_req->path, &list);
383 error = sbus_error_new(sbus_req, DBUS_ERROR_FAILED,
385 return sbus_request_fail_and_finish(sbus_req, error);
388 nodes = sbus_nodes_hash_lookup(sbus_req, conn->nodes_fns, sbus_req->path);
390 introspect = sbus_introspect_generate(sbus_req, sbus_req
[all...]
/sssd-io/src/tests/cmocka/data_provider/
H A Dtest_dp_request_table.c82 struct sbus_request *sbus_req; local
94 sbus_req = talloc(test_ctx, struct sbus_request);
95 assert_non_null(sbus_req);
97 ret = dp_req_table_add(test_ctx->table, key, req, sbus_req);
116 talloc_free(sbus_req);
148 struct sbus_request *sbus_req; local
166 sbus_req = talloc(test_ctx, struct sbus_request);
167 assert_non_null(sbus_req);
169 ret = dp_req_table_add(table, key, req, sbus_req);
178 assert_ptr_equal(tv->list->sbus_req, sbus_re
227 struct sbus_request *sbus_req[N]; local
[all...]

Completed in 34 milliseconds

12