WebSVN - Projects - Blame - Rev 222 - /DUBwise/trunk/shared/src/MKWatchDog.java

Rev	Author	Line No.	Line
206	ligi	1	/**************************************
		2	*
		3	* WatchDog for MK-Connection
		4	*
		5	* Author: Marcus -LiGi- Bueschleb
		6	*
		7	* see README for further Infos
		8	*
		9	*
		10
		11	**************************************/
		12	package org.ligi.ufo;
		13
		14	public class MKWatchDog
		15	implements Runnable,DUBwiseDefinitions
		16	{
		17	MKCommunicator mk=null;
		18
		19	int debug_data_count_buff=-123;
		20
		21	public MKWatchDog(MKCommunicator _mk)
		22	{
		23
		24	mk=_mk;
		25	new Thread( this ).start(); // fire up main Thread
		26	}
		27
		28
		29	public int act_paramset=0;
		30	int conn_check_timeout=0;
		31
		32
		33	public byte resend_timeout=0;
		34	int last_count=0;
		35
		36
219	ligi	37	public boolean resend_check(int ref_count)
		38	{
		39	if (( last_count!=ref_count)\|\|(resend_timeout<0))
		40	{
		41	if (resend_timeout<0) mk.stats.resend_count++;
		42	last_count=ref_count;
		43	resend_timeout=20;
		44	return true;
		45	}
		46	else
		47	resend_timeout--;
		48
		49	return false;
		50	}
		51
206	ligi	52	//#ifdef android
		53	// public final static int BASE_SLEEP=50;
		54	//#else
219	ligi	55	public final static int BASE_SLEEP=10;
206	ligi	56	//#endif
		57
		58	public void run()
		59	{
		60	mk.log("starting Watchdog");
		61	// get all params
		62	int act_debug_name=0;
219	ligi	63	// int sleeper=BASE_SLEEP;
206	ligi	64	while(true)
		65	{
		66	try {
219	ligi	67	Thread.sleep(BASE_SLEEP);
		68	// sleeper=BASE_SLEEP;
206	ligi	69	if (mk.connected&&(!mk.force_disconnect))
		70	{
		71
		72	mk.log("watchdog pre main loop");
219	ligi	73	if (mk.init_bootloader)
206	ligi	74	{
		75	mk.jump_bootloader();
219	ligi	76	mk.init_bootloader=false;
206	ligi	77	}
219	ligi	78	else if ( mk.version.major==-1 )
206	ligi	79	mk.get_version();
		80	else if (mk.ufo_prober.is_navi()&&(mk.error_str==null))
		81	mk.get_error_str();
		82
		83	else if (mk.ufo_prober.is_mk()&&(mk.params.last_parsed_paramset==-1))
		84	{
		85	mk.get_params(0xFF-1);
219	ligi	86	Thread.sleep(150);
		87
206	ligi	88	act_paramset=0; // warning - if dropped problem
		89	}
		90	else switch (mk.user_intent)
		91	{
		92	case USER_INTENT_PARAMS:
		93
		94	if ((act_paramset<5))
		95	{
		96
		97	if (resend_timeout==0) {
		98	mk.get_params(act_paramset);
213	ligi	99	resend_timeout=120;
206	ligi	100	}
		101
		102	if(mk.params.field[act_paramset]!=null)
		103	{
		104	mk.get_params(++act_paramset);
213	ligi	105	resend_timeout=120;
206	ligi	106	}
		107	else
		108	resend_timeout--;
		109	/*
		110	// act_paramset++;
		111	else
		112	mk.get_params(act_paramset);
		113
		114	sleeper+=1200;
		115	*/
		116	}
		117	break;
		118	case USER_INTENT_RAWDEBUG:
		119	if (act_debug_name<32)
		120	{
		121
		122	if (resend_timeout==0) {
		123	mk.get_debug_name(act_debug_name);
		124	resend_timeout=50;
		125	}
		126
		127
		128	//sleeper+=100;
		129	if (mk.debug_data.got_name[act_debug_name])
		130	{
		131	mk.get_debug_name(++act_debug_name);
		132	resend_timeout=50;
		133	}
		134	else
		135	resend_timeout--;
		136
		137	}
216	ligi	138	else
		139	if (!(mk.debug_data.got_name[0]))
		140	act_debug_name=0;
206	ligi	141
		142	break;
		143
		144	case USER_INTENT_RCDATA:
219	ligi	145	if ( resend_check(mk.stats.stick_data_count) )
		146	mk.trigger_rcdata();
206	ligi	147	break;
219	ligi	148
		149	case USER_INTENT_EXTERNAL_CONTROL:
		150	if (resend_check(mk.stats.external_control_confirm_frame_count))
222	ligi	151	{
219	ligi	152	mk.send_extern_control();
222	ligi	153	mk.send_extern_control();
		154	mk.send_extern_control();
		155	mk.send_extern_control();
		156	}
219	ligi	157
		158	break;
		159
206	ligi	160
		161	case USER_INTENT_LCD:
219	ligi	162	if (resend_check(mk.stats.lcd_data_count))
206	ligi	163	mk.LCD.trigger_LCD();
219	ligi	164
206	ligi	165	break;
		166
		167	default:
		168	// mk.log("uncactched intent " +mk.root.canvas.user_intent );
		169	break;
		170	}
		171
		172	// if ((!mk.ufo_prober.is_incompatible()))
		173	{
		174
		175	mk.log("watchdog after main loop");
		176	if (debug_data_count_buff==mk.stats.debug_data_count)
		177	{
		178	mk.log("timeout:" +conn_check_timeout );
		179	conn_check_timeout++;
		180	if (conn_check_timeout==100)
		181	{
		182	mk.log("disconnecting");
		183	mk.close_connections(false);
		184	conn_check_timeout=0;
		185	}
		186	debug_data_count_buff=mk.stats.debug_data_count;
		187	}
		188	else
		189	conn_check_timeout=0;
		190
		191
		192
		193	/*else if ((mk.root.canvas.user_intent==USER_INTENT_RAWDEBUG) \|\| (mk.root.canvas.user_intent==USER_INTENT_GRAPH) )
		194	{
		195	mk.trigger_debug();
		196	try { Thread.sleep(100); }
		197	catch (Exception e) { }
		198	}
		199	*/
		200
		201
		202
		203
		204
		205
		206	/*
		207
		208
		209	if (debug_data_count_buff==mk.debug_data_count)
		210	{
		211	// mk.close_connections(false);
		212	}
		213
		214	*/
		215
		216	/*if (mk.version.major==-1)
		217	mk.get_version();
		218	else
		219	*/
		220	/*for ( int cnt=0;cnt<5;cnt++)
		221	if (mk.params.field[cnt]==null)
		222	{
		223	mk.get_params(cnt+1);
		224	break;
		225	}*/
		226	/*
		227	for (int c=0;c<32;c++)
		228	if (!mk.debug_data.got_name[c])
		229	{
		230	mk.get_debug_name(c);
		231	break;
		232	}
		233	*/
		234
		235
		236	}
		237
		238	}
		239
		240
		241	} // 3000
		242	catch (Exception e) {
		243	mk.log("err in watchdog:");
		244	mk.log(e.toString());
		245
		246	}
		247	}
		248
		249
		250	// mk.log("watchdog quit");
		251	}
		252
		253
		254	}

Subversion Repositories Projects

(root)/DUBwise/trunk/shared/src/MKWatchDog.java - Rev 222