Function dm_get_cond

modules/aaa_diameter/dm_impl.c:109–141

};

static struct dm_cond *dm_get_cond(int type, diameter_reply_cb *cb, void *param)
{
	struct dm_cond *cond = shm_malloc(sizeof *cond);
	if (!cond) {
		LM_ERR("oom\n");
		return NULL;
	}
	memset(cond, 0, sizeof *cond);
	cond->ref = 1;
	cond->type = type;
	switch (type) {
	case DM_TYPE_EVENT:
		cond->sync.event.pid = process_no;
		cond->sync.event.fd = eventfd(0, 0);
		if (cond->sync.event.fd < 0) {
			LM_ERR("could not create event fd\n");
			shm_free(cond);
			return NULL;
		}
		break;
	case DM_TYPE_COND:
		init_mutex_cond(&cond->sync.cond.mutex, &cond->sync.cond.cond);
		break;
	case DM_TYPE_CB:
		if (!cb)
			LM_WARN("no callback specified\n");
		cond->sync.cb.f = cb;
		cond->sync.cb.p = param;
		break;
	}

	return cond;
}

int dm_init_reply_cond(int proc_rank)
{