std::string dataname = plotdirectory() + plotname + ".dat";

FILE * df = fopen(dataname.c_str(), "w");

fclose(df);

std::cout << "---------- Initialized ------------" << std::endl;

graphchi_context &context = engine->get_context();

std::string dataname = plotdirectory() + plotname + ".dat";

FILE * df = fopen(dataname.c_str(), "a");

assert(df != NULL);

fprintf(df, "%lf %lf\n", context.runtime(), val);

fclose(df);

std::string plotfile = plotdirectory() + plotname + ".dat";

std::stringstream ss;

ss << "python2.6 ";

ss << plotdirectory() + "plotter.py " + plotfile + " lastsecs ";

ss << lookback_secs;

std::string cmd = ss.str();

logstream(LOG_DEBUG) << "Executing: " << cmd << std::endl;

system(cmd.c_str());

init_plot("edges");

init_plot("bufedges");

init_plot("updates");

init_plot("ingests");

init_plot("deltas");

initial_edges = engine->num_edges_safe();

addval(engine, "edges", (double)engine->num_edges_safe());

addval(engine, "bufedges", (double)engine->num_buffered_edges());

double rt = engine->get_context().runtime() - last_update_time;

if (last_update_time > 0) {

addval(engine, "ingests", (ingested_edges - last_edges) / rt);

addval(engine, "updates", (engine->num_updates() - last_updates) / rt);

addval(engine, "deltas", engine->get_context().last_deltasum);

}

if (last_update_time == 0) {

last_edges = ingested_edges;

last_update_time = engine->get_context().runtime();

last_updates = engine->num_updates();

}

drawplot("edges", 1800);

drawplot("bufedges", 1800);

drawplot("updates", 300);

drawplot("ingests", 500);

drawplot("deltas", 7200);