← Back to branch summary

~xnox/ubuntu/quantal/lvm2/merge95

« back to all changes in this revision

Viewing changes to daemons/dmeventd/libdevmapper-event.c

  • Committer: Dmitrijs Ledkovs
  • Date: 2012-08-15 09:45:58 UTC
  • Revision ID: dmitrijs.ledkovs@canonical.com-20120815094558-1fugetlxzs49g6g9
quilt push

Show diffs side-by-side

added added

removed removed

Lines of Context:
daemons/dmeventd/libdevmapper-event.c
344
344
        return bytes == size;
345
345
}
346
346
 
347
 
int daemon_talk(struct dm_event_fifos *fifos,
 
347
int dm_event_daemon_talk(struct dm_event_fifos *fifos,
348
348
                struct dm_event_daemon_message *msg, int cmd,
349
349
                const char *dso_name, const char *dev_name,
350
350
                enum dm_event_mask evmask, uint32_t timeout)
467
467
        return ret;
468
468
}
469
469
 
470
 
int init_fifos(struct dm_event_fifos *fifos)
 
470
int dm_event_daemon_init_fifos(struct dm_event_fifos *fifos)
471
471
{
472
472
        /* FIXME? Is fifo the most suitable method? Why not share
473
473
           comms/daemon code with something else e.g. multipath? */
514
514
        if (!_start_daemon(dmeventd_path, fifos))
515
515
                return_0;
516
516
 
517
 
        return init_fifos(fifos);
 
517
        return dm_event_daemon_init_fifos(fifos);
518
518
}
519
519
 
520
 
void fini_fifos(struct dm_event_fifos *fifos)
 
520
void dm_event_daemon_fini_fifos(struct dm_event_fifos *fifos)
521
521
{
522
522
        if (flock(fifos->server, LOCK_UN))
523
523
                log_error("flock unlock %s", fifos->server_path);
596
596
                return -ESRCH;
597
597
        }
598
598
 
599
 
        ret = daemon_talk(&fifos, msg, DM_EVENT_CMD_HELLO, NULL, NULL, 0, 0);
 
599
        ret = dm_event_daemon_talk(&fifos, msg, DM_EVENT_CMD_HELLO, NULL, NULL, 0, 0);
600
600
 
601
601
        dm_free(msg->data);
602
602
        msg->data = 0;
603
603
 
604
604
        if (!ret)
605
 
                ret = daemon_talk(&fifos, msg, cmd, dso_name, dev_name, evmask, timeout);
 
605
                ret = dm_event_daemon_talk(&fifos, msg, cmd, dso_name, dev_name, evmask, timeout);
606
606
 
607
607
        /* what is the opposite of init? */
608
 
        fini_fifos(&fifos);
 
608
        dm_event_daemon_fini_fifos(&fifos);
609
609
 
610
610
        return ret;
611
611
}
814
814
        char *p;
815
815
        struct dm_event_daemon_message msg = { 0, 0, NULL };
816
816
 
817
 
        if (daemon_talk(fifos, &msg, DM_EVENT_CMD_HELLO, NULL, NULL, 0, 0))
 
817
        if (dm_event_daemon_talk(fifos, &msg, DM_EVENT_CMD_HELLO, NULL, NULL, 0, 0))
818
818
                return 0;
819
819
        p = msg.data;
820
820
        *version = 0;