solver_run.c

/*!
 * main routine for MPT solver examples
 */

#include "solver_run.h"

#include MPT_INCLUDE(types.h)
#include MPT_INCLUDE(client.h)
#include MPT_INCLUDE(message.h)
#include MPT_INCLUDE(config.h)

#include MPT_INCLUDE(notify.h)

#include MPT_INCLUDE(solver.h)

#ifdef __GLIBC__
# include <mcheck.h>
#else
# define mtrace()
#endif

static int dispatch_client(void *ptr, MPT_STRUCT(event) *ev)
{
	MPT_INTERFACE(client) *cl = ptr;
	if (!ev) {
		cl->_vptr->meta.unref((void *) cl);
		return 0;
	}
	return cl->_vptr->dispatch(cl, ev);
}

static int solver_standalone(MPT_INTERFACE(client) *c)
{
	int ret;
	
	/* setup standalone operation */
	if ((ret = c->_vptr->process(c, 0, 0)) < 0) {
		mpt_log(0, __func__, MPT_LOG(Error), "%s",
		        "solver client start failed");
		return 2;
	}
	/* execute standalone run */
	if (!(ret & MPT_EVENTFLAG(Default))) {
		return 0;
	}
	while ((ret = c->_vptr->dispatch(c, 0))) {
		if (ret < 0) {
			return 3;
		}
		if (ret & MPT_EVENTFLAG(Terminate)) {
			return 0;
		}
	}
	return 2;
}

extern int solver_run(MPT_INTERFACE(client) *c)
{
	MPT_STRUCT(notify) no = MPT_NOTIFY_INIT;
	MPT_INTERFACE(config) *cfg;
	MPT_STRUCT(dispatch) *disp;
	int ret;
	
	/* set solver client config */
	cfg = 0;
	if ((ret = c->_vptr->meta.convertable.convert((void *) c, MPT_ENUM(TypeConfigPtr), &cfg)) > 0
	    && cfg) {
		const char *path = "mpt.client";
		MPT_STRUCT(value) val = MPT_VALUE_INIT('s', &path);
		
		/* set global config root */
		if ((ret = cfg->_vptr->assign(cfg, 0, &val)) < 0) {
			mpt_log(0, __func__, MPT_LOG(Warning), "%s",
			        "failed to set client config root");
		}
		/* set solver client arguments */
		if ((ret = mpt_client_config(cfg, 0)) < 0) {
			dispatch_client(c, 0);
			return 1;
		}
	}
	/* global controller setup */
	ret = mpt_notify_config(&no, 0);
	
	/* standalone run */
	if (!no._fdused) {
		/* interactive file assignment */
		if (cfg && (ret = mpt_solver_require(cfg, 0)) < 0) {
			ret = 1;
		} else {
			ret = solver_standalone(c);
		}
		dispatch_client(c, 0);
	}
	/* register message dispatcher for notifier */
	else if (!(disp = mpt_notify_dispatch(&no))) {
		mpt_log(0, __func__, MPT_LOG(Error), "%s",
		        "failed to create dispatcher");
		dispatch_client(c, 0);
		ret = 2;
	}
	/* setup dispatcher for solver client */
	else if ((ret = mpt_dispatch_set(disp, MPT_MESGTYPE(Command), dispatch_client, c)) < 0) {
		mpt_log(0, __func__, MPT_LOG(Error), "%s",
		        "event setup failed");
		dispatch_client(c, 0);
		ret = 3;
	}
	/* execute event loop */
	else {
		mpt_dispatch_param(disp, 0);
		ret = mpt_loop(&no);
	}
	mpt_notify_fini(&no);
	
	return ret;
}