schedule.cpp

#include "ocelot.h"
#include "config.h"
#include "db.h"
#include "worker.h"
#include "events.h"
#include "schedule.h"


schedule::schedule(connection_mother * mother_obj, worker* worker_obj, config* conf_obj, mysql * db_obj) : mother(mother_obj), work(worker_obj), conf(conf_obj), db(db_obj) {
	counter = 0;
	last_opened_connections = 0;
	
	next_reap_peers = time(NULL) + conf->reap_peers_interval + 40;
}
//---------- Schedule - gets called every schedule_interval seconds
void schedule::handle(ev::timer &watcher, int events_flags) {
	
	if(counter % 20 == 0) {
		time_t rawtime;
		struct tm * timeinfo;
		char buffer [80];

		time ( &rawtime );
		timeinfo = localtime ( &rawtime );

		strftime (buffer,80,"%Y-%m-%d %X",timeinfo);
		std::cout << buffer << " Schedule run #" << counter << " - open: " << mother->get_open_connections() << ", opened: " 
		<< mother->get_opened_connections() << ", speed: "
		<< ((mother->get_opened_connections()-last_opened_connections)/conf->schedule_interval) << "/s" << std::endl;
	}

	if ((work->get_status() == CLOSING) && db->all_clear()) {
		std::cout << "all clear, shutting down" << std::endl;
		exit(0);
	}

	last_opened_connections = mother->get_opened_connections();
	
	db->flush();

	time_t cur_time = time(NULL);

	if(cur_time > next_reap_peers) {
		work->reap_peers();
		next_reap_peers = cur_time + conf->reap_peers_interval;
	}

	counter++;
}