/* Initial value - on first iteration */

int initial_value(graphchi_context &info, vertex_info& myvertex) {

return 0;

}

/* Called before first "gather" */

int reset() {

return 0;

}

// Note: Unweighted version, edge value should also be passed

// "Gather"

int op_neighborval(graphchi_context &info, vertex_info& myvertex, vid_t nbid, int nbval) {

assert(nbval == (int) info.iteration - 1);

return nbval;

}

// "Sum"

int plus(int curval, int toadd) {

assert(curval == 0 || toadd == curval);

return toadd;

}

// "Apply"

int compute_vertexvalue(graphchi_context &ginfo, vertex_info& myvertex, int nbvalsum) {

return ginfo.iteration;

}

// "Scatter

int value_to_neighbor(graphchi_context &info, vertex_info& myvertex, vid_t nbid, int myval) {

assert(myval == (int) info.iteration);

return myval;

}

graphchi_init(argc, argv);

metrics m("test-functional");

std::string filename = get_option_string("file");

int niters = get_option_int("niters", 5);

std::string mode = get_option_string("mode", "semisync");

logstream(LOG_INFO) << "Running bulk sync smoke test." << std::endl;

run_functional_unweighted_synchronous<smoketest_program>(filename, niters, m);

logstream(LOG_INFO) << "Smoketest passed successfully! Your system is working!" << std::endl;

return 0;