Z991239-5890 #comment 优化客户感知实体日志

Module/mod_evtconverter/evtengine.cpp

@@ -1032,19 +1032,19 @@ static int build_ref(evt_engine_t *engine)
 {
 	int i;
 	evt_trigger_t *trigger;
-	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("after load engine->slot_ht->size = %d.", engine->slot_ht->size);
+	//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("after load engine->slot_ht->size = %d.", engine->slot_ht->size);
 	for (i = 0; i < engine->slot_ht->size; ++i) {
 		evt_slot_t *tpos;
 		struct hlist_node *pos;
 		hlist_for_each_entry(tpos, pos, &engine->slot_ht->buckets[i], evt_slot_t, hentry) {
-			DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)(
-				"tpos->key.code = %s, tpos->key.index_hash_code = %d, tpos->signal_state = %d.",
-				tpos->key.code, tpos->key.index_hash_code, tpos->signal_state);
+			//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)(
+			//	"tpos->key.code = %s, tpos->key.index_hash_code = %d, tpos->signal_state = %d.",
+			//	tpos->key.code, tpos->key.index_hash_code, tpos->signal_state);
 
 			int j;
 			for (j = 0; j < tpos->arr_reset->nelts; ++j) {
 				char *code = ARRAY_IDX(tpos->arr_reset, j, char*);
-				DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("code = %s.", code);
+				//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("code = %s.", code);
 				evt_slot_key_t key;
 				key.code = code;
 				key.index_hash_code = hash32_str(code, HASH32_STR_INIT);
@@ -1052,7 +1052,7 @@ static int build_ref(evt_engine_t *engine)
 				if (ref_slot) {
 					ARRAY_PUSH(ref_slot->arr_rref_reset, evt_slot_t*) = tpos;
 					ARRAY_PUSH(tpos->arr_ref_reset, evt_slot_t*) = ref_slot;
-					DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("build reset ref for slot %s->%s", tpos->key.code, code);
+					//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("build reset ref for slot %s->%s", tpos->key.code, code);
 				} 
 				else {
 					if (nIslog){
@@ -1065,12 +1065,12 @@ static int build_ref(evt_engine_t *engine)
 	}
 
 	list_for_each_entry(trigger, &engine->trigger_list, evt_trigger_t, entry) {
-		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)(
-			"trigger->log_type = %d, trigger->severity_level = %d, trigger->sys_code = %d, trigger->user_code = 0x%08x, trigger->delay_ms = %d, trigger->delay_timer_id = %d, trigger->msg = %s.",
-			trigger->log_type, trigger->severity_level, trigger->sys_code, trigger->user_code, trigger->delay_ms, trigger->delay_timer_id, trigger->msg);
+		//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)(
+		//	"trigger->log_type = %d, trigger->severity_level = %d, trigger->sys_code = %d, trigger->user_code = 0x%08x, trigger->delay_ms = %d, trigger->delay_timer_id = %d, trigger->msg = %s.",
+		//	trigger->log_type, trigger->severity_level, trigger->sys_code, trigger->user_code, trigger->delay_ms, trigger->delay_timer_id, trigger->msg);
 		evt_slot_rule_t *rule;
 		list_for_each_entry(rule, &trigger->slot_rule_list, evt_slot_rule_t, entry) {
-			DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("rule->positive = %d, rule->code = %s, rule->message = %s.",rule->positive, rule->code, rule->message);
+			//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("rule->positive = %d, rule->code = %s, rule->message = %s.",rule->positive, rule->code, rule->message);
 			evt_slot_key_t key;
 			key.code = rule->code;
 			key.index_hash_code = hash32_str(key.code, HASH32_STR_INIT);
@@ -1078,7 +1078,7 @@ static int build_ref(evt_engine_t *engine)
 			if (ref_slot) {
 				rule->ref_slot = ref_slot;
 				ARRAY_PUSH(ref_slot->arr_ref_trigger, evt_trigger_t*) = rule->parent;
-				DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("array push trigger.slot %s.", rule->code);
+				//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("array push trigger.slot %s.", rule->code);
 			} 
 			else {
 				if (nIslog){
@@ -1486,7 +1486,7 @@ static int load_filter_element(evt_engine_t* engine, evt_slot_t* slot, rvc_slotf
 	if (rc != 0) {
 		return rc;
 	}
-	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("filter->log_type = %d, filter->ent_id = %d, entity = %s, filter->severity = %d, filter->sys_code = %d, filter->user_code = 0x%08x, slotvar = %s.", filter->log_type, filter->ent_id, entity, filter->severity, filter->sys_code, filter->user_code, slotvar);
+	//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("filter->log_type = %d, filter->ent_id = %d, entity = %s, filter->severity = %d, filter->sys_code = %d, filter->user_code = 0x%08x, slotvar = %s.", filter->log_type, filter->ent_id, entity, filter->severity, filter->sys_code, filter->user_code, slotvar);
 	
 	if (slotvar) {
 		int i;
@@ -1562,7 +1562,7 @@ static int load_slot_arrays(evt_engine_t* engine, const char* ns, rvc_slot_t* tn
 		return Error_Unexpect;
 	}
 	else {
-		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("tnode->strCode == %s.", tnode->strCode);
+		//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("tnode->strCode == %s.", tnode->strCode);
 		code = parse_code(ns, tnode->strCode);
 		if (!code) {
 			if (nIslog) {
@@ -1578,7 +1578,7 @@ static int load_slot_arrays(evt_engine_t* engine, const char* ns, rvc_slot_t* tn
 	}
 
 	if (tnode->strTimeout) {
-		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("tnode->strTimeout == %s.", tnode->strTimeout);
+		//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("tnode->strTimeout == %s.", tnode->strTimeout);
 		evt_expire_t* expire = ZALLOC_T(evt_expire_t);
 		if (!expire) {
 			slot_free(slot);
@@ -1602,7 +1602,7 @@ static int load_slot_arrays(evt_engine_t* engine, const char* ns, rvc_slot_t* tn
 	}
 
 	if (tnode->strOneTrigger) {
-		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("tnode->strOneTrigger == %s.", tnode->strOneTrigger);
+		//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("tnode->strOneTrigger == %s.", tnode->strOneTrigger);
 		slot->once = parse_bool(tnode->strOneTrigger);
 	}
 	else {
@@ -1616,9 +1616,9 @@ static int load_slot_arrays(evt_engine_t* engine, const char* ns, rvc_slot_t* tn
 			if (rc != 0) {
 				break;
 			}
-			else {
-				DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("slot var name is %s, value is %s.", tnode->Vars[ivar].strName, tnode->Vars[ivar].strValue);
-			}
+			//else {
+			//	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("slot var name is %s, value is %s.", tnode->Vars[ivar].strName, tnode->Vars[ivar].strValue);
+			//}
 		}
 	}
 
@@ -1647,7 +1647,7 @@ static int load_slot_arrays(evt_engine_t* engine, const char* ns, rvc_slot_t* tn
 				else {
 					ARRAY_PUSH(slot->arr_reset, char*) = source;
 				}
-				DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("slot var reset source is %s.", tnode->Reset[ireset].strSource);
+				//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("slot var reset source is %s.", tnode->Reset[ireset].strSource);
 			}
 			else {
 				break;
@@ -1666,13 +1666,13 @@ static int load_slot_arrays(evt_engine_t* engine, const char* ns, rvc_slot_t* tn
 		return Error_Unexpect;
 	}
 
-	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("engine->slot_ht->size = %d, engine->slot_ht count = %d.", engine->slot_ht->size, htable_get_count(engine->slot_ht));
+	//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("engine->slot_ht->size = %d, engine->slot_ht count = %d.", engine->slot_ht->size, htable_get_count(engine->slot_ht));
 
-	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("slot->key.code = %s, slot->key.index_hash_code = %d.", slot->key.code, slot->key.index_hash_code);
+	//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("slot->key.code = %s, slot->key.index_hash_code = %d.", slot->key.code, slot->key.index_hash_code);
 
 	slot_add(engine->slot_ht, slot);
 
-	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("engine->slot_ht->size = %d, engine->slot_ht count = %d.", engine->slot_ht->size, htable_get_count(engine->slot_ht));
+	//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("engine->slot_ht->size = %d, engine->slot_ht count = %d.", engine->slot_ht->size, htable_get_count(engine->slot_ht));
 
 	return 0;
 }
@@ -1683,16 +1683,16 @@ static int load_slot_element_rule(evt_trigger_t* trigger, const char* ns, rvc_tr
 	evt_slot_rule_t* rule = ZALLOC_T(evt_slot_rule_t);
 
 	if (slot_elem->strCode) {
-		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Slot Code value is %s.", slot_elem->strCode);
+		//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Slot Code value is %s.", slot_elem->strCode);
 		rule->code = parse_code(ns, slot_elem->strCode);
-		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("after parse_code, rule->code is %s.", rule->code);
+		//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("after parse_code, rule->code is %s.", rule->code);
 	}
 	else {
 		goto on_error;
 	}
 
 	if (slot_elem->strPositive) {
-		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Slot Positive value is %s.", slot_elem->strPositive);
+		//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Slot Positive value is %s.", slot_elem->strPositive);
 		rule->positive = parse_bool(slot_elem->strPositive);
 		if (rule->positive == -1) {
 			if (nIslog) {
@@ -1706,7 +1706,7 @@ static int load_slot_element_rule(evt_trigger_t* trigger, const char* ns, rvc_tr
 	}
 
 	if (slot_elem->strMessage) {
-		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Slot Message value is %s.", slot_elem->strMessage);
+		//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Slot Message value is %s.", slot_elem->strMessage);
 		rule->message = _strdup(slot_elem->strMessage);
 	}
 	rule->parent = trigger;
@@ -1724,7 +1724,7 @@ static int load_sysvar_element_rule(evt_engine_t* engine, evt_trigger_t* trigger
 
 	if (sysvar_elem->strCode) {
 		char* code = sysvar_elem->strCode;
-		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("sysvar code is %s.", code);
+		//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("sysvar code is %s.", code);
 		evt_sysvar_key_t key;
 		key.code = code;
 		key.index_hash_code = hash32_str(code, HASH32_STR_INIT);
@@ -1747,7 +1747,7 @@ static int load_sysvar_element_rule(evt_engine_t* engine, evt_trigger_t* trigger
 	}
 
 	if (sysvar_elem->strPositive) {
-		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("sysvar Positive is %s.", sysvar_elem->strPositive);
+		//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("sysvar Positive is %s.", sysvar_elem->strPositive);
 		rule->positive = parse_bool(sysvar_elem->strPositive);
 	}
 	else {
@@ -1761,7 +1761,7 @@ static int load_sysvar_element_rule(evt_engine_t* engine, evt_trigger_t* trigger
 		for (int istate = 0; istate < states_arr_length; istate++) {
 			const char* state = sysvar_elem->strstates[istate];
 			if (state) {
-				DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("add sysvar state %s.", state);
+				//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("add sysvar state %s.", state);
 				ARRAY_PUSH(rule->arr_state, char*) = _strdup(state);
 			}
 			else {
@@ -1798,7 +1798,7 @@ static int load_trigger_arrays(evt_engine_t* engine, const char* ns, rvc_trigger
 	INIT_LIST_HEAD(&trigger->sysvar_list);
 
 	if (trigger_elem->strLogType) {
-		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("LogType value is %s.", trigger_elem->strLogType);
+		//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("LogType value is %s.", trigger_elem->strLogType);
 		trigger->log_type = parse_log_type(trigger_elem->strLogType);
 		if (trigger->log_type == -1) {
 			if (nIslog) {
@@ -1817,7 +1817,7 @@ static int load_trigger_arrays(evt_engine_t* engine, const char* ns, rvc_trigger
 	}
 
 	if (trigger_elem->strSeverityLevel) {
-		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("SeverityLevel value is %s.", trigger_elem->strSeverityLevel);
+		//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("SeverityLevel value is %s.", trigger_elem->strSeverityLevel);
 		trigger->severity_level = parse_severity(trigger_elem->strSeverityLevel);
 		if (trigger->severity_level == -1) {
 			if (nIslog) {
@@ -1838,7 +1838,7 @@ static int load_trigger_arrays(evt_engine_t* engine, const char* ns, rvc_trigger
 	}
 
 	if (trigger_elem->strSysError) {
-		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("SysError value is %s.", trigger_elem->strSysError);
+		//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("SysError value is %s.", trigger_elem->strSysError);
 		trigger->sys_code = parse_sys_code(trigger_elem->strSysError);
 		if (trigger->sys_code == -1) {
 			if (nIslog) {
@@ -1859,7 +1859,7 @@ static int load_trigger_arrays(evt_engine_t* engine, const char* ns, rvc_trigger
 	}
 
 	if (trigger_elem->strUserCode) {
-		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("UserCode value is %s.", trigger_elem->strUserCode);
+		//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("UserCode value is %s.", trigger_elem->strUserCode);
 		trigger->user_code = parse_usr_code(trigger_elem->strUserCode);
 	}
 	else {
@@ -1873,7 +1873,7 @@ static int load_trigger_arrays(evt_engine_t* engine, const char* ns, rvc_trigger
 	}
 
 	if (trigger_elem->strMessage) {
-		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Message value is %s.", trigger_elem->strMessage);
+		//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Message value is %s.", trigger_elem->strMessage);
 		trigger->msg = _strdup(trigger_elem->strMessage);
 	}
 
@@ -1917,8 +1917,8 @@ static int load_strategy_array(evt_engine_t* engine, slot_trigger_elem_t* peleme
 	const char* ns = pelement->slotns;
 	int rc = Error_Param;
 
-	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("ns = %s.", pelement->slotns);
-	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("pelement->islotarrlen = %d.", pelement->islotarrlen);
+	//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("ns = %s.", pelement->slotns);
+	//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("pelement->islotarrlen = %d.", pelement->islotarrlen);
 	for (int islot = 0; islot < pelement->islotarrlen; islot++) {
 		if (load_slot_arrays(engine, ns, &pelement->slotarr[islot]) != 0) {
 			if (nIslog) {
@@ -1928,7 +1928,7 @@ static int load_strategy_array(evt_engine_t* engine, slot_trigger_elem_t* peleme
 		}
 	}
 
-	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("pelement->itriggerarrlen = %d.", pelement->itriggerarrlen);
+	//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("pelement->itriggerarrlen = %d.", pelement->itriggerarrlen);
 	for (int itrigger = 0; itrigger < pelement->itriggerarrlen; itrigger++) {
 		if (load_trigger_arrays(engine, ns, &pelement->triggerarr[itrigger]) != 0) {
 			if (nIslog) {
@@ -1949,13 +1949,13 @@ int evt_engine_create(const evt_engine_callback_t *callback, evt_engine_t **p_en
 	evt_engine_t *engine = MALLOC_T(evt_engine_t);
 	
 	engine->filter_ht = htable_create(0);
-	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("engine->filter_ht->size = %d.", engine->filter_ht->size);
+	//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("engine->filter_ht->size = %d.", engine->filter_ht->size);
 	
 	engine->sysvar_ht = htable_create(0);
-	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("engine->sysvar_ht->size = %d.", engine->sysvar_ht->size);
+	//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("engine->sysvar_ht->size = %d.", engine->sysvar_ht->size);
 	
 	engine->slot_ht = htable_create(0);
-	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("engine->slot_ht->size = %d.", engine->slot_ht->size);
+	//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("engine->slot_ht->size = %d.", engine->slot_ht->size);
 	
 	INIT_LIST_HEAD(&engine->trigger_list);
 	spinlock_init(&engine->lock);
@@ -2000,7 +2000,6 @@ int evt_engine_load(evt_engine_t* engine, int* indexarr, int icount, slot_trigge
 		}
 	}
 
-	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("################################################");
 	rc = build_ref(engine);
 	if (rc != 0) {
 		if (nIslog) {
@@ -2136,15 +2135,14 @@ int evt_engine_start(evt_engine_t *engine)
 			int kk;
 			for (kk = 0; kk < slot->arr_filter->nelts; ++kk) {
 				evt_filter_t *filter = ARRAY_IDX(slot->arr_filter, kk, evt_filter_t*);
-				DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("filter->log_type = %d, filter->ent_id = %d, entity = %s, filter->severity = %d, filter->sys_code = %d, filter->user_code = 0x%08x.", filter->log_type, filter->ent_id, filter->entity, filter->severity, filter->sys_code, filter->user_code);
-				if (filter->content_to_var) {
-					DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("filter->content_to_var->name = %s, filter->content_to_var->current_value = %s, filter->content_to_var->init_value = %s.", filter->content_to_var->name, filter->content_to_var->current_value, filter->content_to_var->init_value);
-				}
-				if ((filter->owner)) {
-					DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("filter->owner->key.code = %s.", filter->owner->key.code);
-				}
+				//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("filter->log_type = %d, filter->ent_id = %d, entity = %s, filter->severity = %d, filter->sys_code = %d, filter->user_code = 0x%08x.", filter->log_type, filter->ent_id, filter->entity, filter->severity, filter->sys_code, filter->user_code);
+				//if (filter->content_to_var) {
+				//	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("filter->content_to_var->name = %s, filter->content_to_var->current_value = %s, filter->content_to_var->init_value = %s.", filter->content_to_var->name, filter->content_to_var->current_value, filter->content_to_var->init_value);
+				//}
+				//if ((filter->owner)) {
+				//	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("filter->owner->key.code = %s.", filter->owner->key.code);
+				//}
 				
-
 				rc = engine->cb.subscribe_log(engine, &filter->key.listen_id, 
 					(LogTypeEnum)filter->log_type, filter->entity, (SeverityLevelEnum)filter->severity, (ErrorCodeEnum)filter->sys_code, filter->user_code, filter->content_to_var ? false : true, engine->cb.user_data);
 				
@@ -2168,7 +2166,7 @@ int evt_engine_start(evt_engine_t *engine)
 		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("subscribe started!");
 	}
 
-	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("################################################");
+	//DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("################################################");
 	
 	return rc;
 }