myClient.c

@@ -318,83 +318,6 @@ void writeTest(long ConnectionHdl,u16 NodeHdlCount,long *NodeHdls,UA_Value *vari
 	return retval;
 }
 
-u32 SubscriptionCreate(long ConnectionHdl,bool PublishingEnable,u16 Priority,long *SubscriptionHdl,TIME *PublishingInterval){
-	UA_Client *c = (UA_Client*)ConnectionHdl;
-	UA_CreateSubscriptionRequest request = UA_CreateSubscriptionRequest_default();
-	request.requestedPublishingInterval=*PublishingInterval;
-	request.publishingEnabled=PublishingEnable;
-	request.priority=Priority;
-	UA_CreateSubscriptionResponse *response=malloc(sizeof(UA_CreateSubscriptionResponse));
-	*response = UA_Client_Subscriptions_create(c,request,NULL,NULL,NULL);
-	u32 retval=response[0].responseHeader.serviceResult;
-	if(retval!=UA_STATUSCODE_GOOD){
-		UA_CreateSubscriptionResponse_clear(&response[0]);
-		return retval;
-	}
-	printf("response[0].subscripstionId is %x\n",response[0].subscriptionId);
-	*SubscriptionHdl=(long *)response[0].subscriptionId;
-	UA_CreateSubscriptionResponse_clear(&response[0]);
-	return retval;
-}
-
-u32 UA_SubscriptionDelete(long ConnectionHdl,long SubscriptionHdl){
-	UA_Client *c = (UA_Client*)ConnectionHdl;
-	u32 retval=UA_Client_Subscriptions_deleteSingle(c,SubscriptionHdl);
-	return retval;
-}
-
-u32 SubscriptionHdlzu2[100];
-u32 MonItemHdlzu[100];
-UAMonitoredVariables MonVlaue[100];
-int MontNum=0;
-static void handler_DataChanged(UA_Client *client, UA_UInt32 subId,
-                                    void *subContext, UA_UInt32 monId,
-                                    void *monContext, UA_DataValue *value)
-{
-    UA_LOG_INFO(UA_Log_Stdout, UA_LOGCATEGORY_CLIENT, "Received Notification");
-
-    UA_NodeId *ptr = (UA_NodeId*)monContext;
-	SubscriptionHdlzu2[MontNum]=subId;
-	MonItemHdlzu[MontNum]=monId;
-	MonVlaue[MontNum].Values.data=value->value.data;
-	MonVlaue[MontNum].Values.type=value->value.type->typeId.identifier.numeric;
-	UA_DateTime now = UA_DateTime_nowMonotonic();
-	MonVlaue[MontNum].TimeStamps=now;
-	MonVlaue[MontNum].NewValuesCount=1;
-	//MonVlaue[MontNum].NodeQualityIDs[0]=0;
-    //UA_Int32 currentValue = *(UA_Int32*)(value->value.data);
-
-	MontNum++;
-}
-
-u32 MonitoredItemAddList(long ConnectionHdl,long SubscriptionHdl,u16 NodeHdlCount,
-							long *NodeHdls,UAMonitoringSyncMode SyncMode,
-							UANodeAdditionalInfo *NodeAddInfos,u32 *MonitoredItemHdls,u32 ErrorIDs[]){
-	UA_Client *c = (UA_Client*)ConnectionHdl;
-	u32 retval=0;
-	if(NodeHdlCount>MAX_ELEMENTS_MONITORLIST){
-		retval=0xA0000002;
-		return retval;
-	}
-	if(SyncMode==UAMS_ControllerSync){
-		for(int i=0;i<NodeHdlCount;i++){
-			UA_NodeId *NodeID=(UA_NodeId*)NodeHdls[i];
-			UA_MonitoredItemCreateRequest monRequest=UA_MonitoredItemCreateRequest_default(*NodeID);
-			monRequest.itemToMonitor.attributeId = NodeAddInfos[i].AttributeID;
-			UA_MonitoredItemCreateResult monResponse=
-			UA_Client_MonitoredItems_createDataChange(c,SubscriptionHdl,UA_TIMESTAMPSTORETURN_BOTH,
-														monRequest,NodeID,handler_DataChanged,NULL);
-		if(monResponse.statusCode!=UA_STATUSCODE_GOOD){
-			retval=monResponse.statusCode;
-		}
-		ErrorIDs[i]=monResponse.statusCode;
-		MonitoredItemHdls[i]=monResponse.monitoredItemId;
-		}
-	}
-	return retval;
-
-}
-
 int main(int argc, char *argv[]) {
 	
     // long connecthdl;