Function watch_init

plugins/sql.c:1337–1369

First time we initialize counters and figure where we're up to */

/* First time we initialize counters and figure where we're up to */
static void watch_init(struct command *cmd,
		       struct table_desc *td,
		       const char *indexname,
		       u64 *max)
{
	struct json_out *params = json_out_new(NULL);
	const jsmntok_t *result, *valtok;
	const char *buf;
	u64 val;

	json_out_start(params, NULL, '{');
	json_out_addstr(params, "subsystem", td->waitname);
	json_out_addstr(params, "indexname", indexname);
	json_out_add(params, "nextvalue", false, "0");
	json_out_end(params, '}');

	result = jsonrpc_request_sync(tmpctx, cmd, "wait", take(params), &buf);

	valtok = json_get_member(buf, result, indexname);
	if (!valtok || !json_to_u64(buf, valtok, &val)) {
		plugin_err(cmd->plugin,
			   "Invalid wait reply for %s %s: '%.*s'",
			   td->name, indexname,
			   json_tok_full_len(result),
			   json_tok_full(buf, result));
	}

	if (max != NULL)
		*max = val;

	/* Place watch for when it increases */
	watch_for(sql_of(cmd->plugin), td, indexname, val + 1);
}

static struct command_result *refresh_tables(struct command *cmd,
					     struct db_query *dbq)