Lines Matching refs:commit
319 read_evfd(STATE_SYNC(commit).evfd);
321 ret = STATE_SYNC(commit).rq[0].cb(STATE_SYNC(commit).h, 0);
324 if (STATE_SYNC(commit).rq[1].cb) {
325 int fd = STATE_SYNC(commit).clientfd;
327 STATE_SYNC(commit).rq[0].cb =
328 STATE_SYNC(commit).rq[1].cb;
330 STATE_SYNC(commit).rq[1].cb = NULL;
332 STATE_SYNC(commit).clientfd = -1;
333 STATE_SYNC(commit).rq[0].cb(STATE_SYNC(commit).h, fd);
336 close(STATE_SYNC(commit).clientfd);
337 STATE_SYNC(commit).clientfd = -1;
454 STATE_SYNC(commit).h = nfct_open(CONFIG(netlink).subsys_id, 0);
455 if (STATE_SYNC(commit).h == NULL) {
456 dlog(LOG_ERR, "can't create handler to commit");
459 origin_register(STATE_SYNC(commit).h, CTD_ORIGIN_COMMIT);
461 STATE_SYNC(commit).evfd = create_evfd();
462 if (STATE_SYNC(commit).evfd == NULL) {
463 dlog(LOG_ERR, "can't create eventfd to commit");
466 if (register_fd(get_read_evfd(STATE_SYNC(commit).evfd),
470 STATE_SYNC(commit).clientfd = -1;
493 origin_unregister(STATE_SYNC(commit).h);
494 nfct_close(STATE_SYNC(commit).h);
495 destroy_evfd(STATE_SYNC(commit).evfd);
557 ret = STATE_SYNC(commit).rq[0].cb(STATE_SYNC(commit).h, fd);
559 dlog(LOG_NOTICE, "commit already in progress, skipping");
562 /* we've finished the commit. */
565 /* Keep open the client, we want synchronous commit. */
603 STATE_SYNC(commit).rq[0].cb = STATE_SYNC(external)->ct.commit;
604 STATE_SYNC(commit).rq[1].cb = NULL;
617 if (STATE_SYNC(commit).clientfd != -1) {
619 "commit still in progress");
636 if (STATE_SYNC(commit).clientfd != -1) {
638 "commit still in progress");
699 STATE_SYNC(commit).rq[0].cb = STATE_SYNC(external)->exp.commit;
700 STATE_SYNC(commit).rq[1].cb = NULL;
705 if (STATE_SYNC(commit).clientfd != -1) {
707 "commit still in progress");
720 STATE_SYNC(commit).rq[0].cb = STATE_SYNC(external)->ct.commit;
722 STATE_SYNC(commit).rq[1].cb =
723 STATE_SYNC(external)->exp.commit;
725 STATE_SYNC(commit).rq[1].cb = NULL;