| 1319 | } |
| 1320 | |
| 1321 | static void watch_for(struct sql *sql, |
| 1322 | struct table_desc *td, |
| 1323 | const char *indexname, |
| 1324 | u64 next_index) |
| 1325 | { |
| 1326 | struct out_req *req; |
| 1327 | |
| 1328 | req = jsonrpc_request_start(sql->waitcmd, "wait", wait_done, |
| 1329 | plugin_broken_cb, td); |
| 1330 | json_add_string(req->js, "subsystem", td->waitname); |
| 1331 | json_add_string(req->js, "indexname", indexname); |
| 1332 | json_add_u64(req->js, "nextvalue", next_index); |
| 1333 | send_outreq(req); |
| 1334 | } |
| 1335 | |
| 1336 | /* First time we initialize counters and figure where we're up to */ |
| 1337 | static void watch_init(struct command *cmd, |
no test coverage detected