Function plugin_hook_db_sync

lightningd/plugin_hook.c:463–538

}

void plugin_hook_db_sync(struct db *db)
{
	struct plugin_hook *hook = &db_write_hook;
	struct jsonrpc_request *req;
	struct plugin_hook_request *ph_req;
	void *ret;
	struct plugin **plugin_arr;
	struct plugins *plugins;
	size_t i;
	size_t num_live_hooks;
	const char **changes = db_changes(db);

	/* Common fast path */
	if (tal_count(hook->hooks) == 0)
		return;

	/* Could still have no non-NULL ones, if a plugin was removed. */
	plugin_arr = tal_arr(NULL, struct plugin *, 0);
	for (i = 0; i < tal_count(hook->hooks); ++i) {
		if (hook->hooks[i])
			tal_arr_expand(&plugin_arr, hook->hooks[i]->plugin);
	}
	num_live_hooks = tal_count(plugin_arr);
	if (num_live_hooks == 0) {
		tal_free(plugin_arr);
		return;
	}

	plugins = plugin_arr[0]->plugins;
	ph_req = notleak(tal(hook->hooks, struct plugin_hook_request));
	ph_req->hook = hook;
	ph_req->db = db;
	ph_req->cb_arg = &num_live_hooks;

	for (i = 0; i < num_live_hooks; ++i) {
		/* Create an object for this plugin.  */
		struct db_write_hook_req *dwh_req;
		dwh_req = tal(ph_req, struct db_write_hook_req);
		dwh_req->plugin = plugin_arr[i];
		dwh_req->ph_req = ph_req;
		dwh_req->num_hooks = &num_live_hooks;

		/* FIXME: id_prefix from caller? */
		/* FIXME: do IO logging for this! */
		req = jsonrpc_request_start(NULL, hook->name, NULL,
					    NULL, NULL,
					    db_hook_response,
					    dwh_req);

		json_add_num(req->stream, "data_version",
			     db_data_version_get(db));

		json_array_start(req->stream, "writes");
		for (size_t j = 0; j < tal_count(changes); j++)
			json_add_string(req->stream, NULL, changes[j]);
		json_array_end(req->stream);
		jsonrpc_request_end(req);