get

myClient.c

@@ -22,6 +22,33 @@
 // 	return flag;
 // }
 
+void saveUA_ReferenceDescriptionToUAReferenceDescription(int j,UA_ReferenceDescription *ref,UAReferenceDescription *BrowseResult){
+	memcpy(BrowseResult[j].BrowseName.data,ref->browseName.name.data,ref->browseName.name.length);
+	BrowseResult[j].BrowseName.length=ref->browseName.name.length;
+	memcpy(BrowseResult[j].DisplayName.Locale,ref->displayName.locale.data,ref->displayName.locale.length);
+	memcpy(BrowseResult[j].DisplayName.Text.data,ref->displayName.text.data,ref->displayName.text.length);
+	BrowseResult[j].IsForward=ref->isForward;
+	BrowseResult[j].NodeClass=ref->nodeClass;
+	BrowseResult[j].NodeID.ID.NamespaceIndex=ref->nodeId.nodeId.namespaceIndex;
+	BrowseResult[j].NodeID.ID.IdentifierType=ref->nodeId.nodeId.identifierType;
+	BrowseResult[j].NodeID.ID.Identifier.length=ref->nodeId.nodeId.identifier.string.length;
+	BrowseResult[j].NodeID.ID.Identifier.data=ref->nodeId.nodeId.identifier.string.data;
+	BrowseResult[j].NodeID.NamespaceURI.length=ref->nodeId.namespaceUri.length;
+	memcpy(BrowseResult[j].NodeID.NamespaceURI.data,ref->nodeId.namespaceUri.data,ref->nodeId.namespaceUri.length);
+	BrowseResult[j].NodeID.ServerIndex=ref->nodeId.serverIndex;
+	BrowseResult[j].ReferenceTypeID.NamespaceIndex=ref->referenceTypeId.namespaceIndex;
+	BrowseResult[j].ReferenceTypeID.IdentifierType=ref->referenceTypeId.identifierType;
+	BrowseResult[j].ReferenceTypeID.Identifier.length=ref->referenceTypeId.identifier.string.length;
+	//memcpy(BrowseResult[j].ReferenceTypeID.Identifier.data,ref->referenceTypeId.identifier.string.data,ref->referenceTypeId.identifier.string.length);
+	BrowseResult[j].TypeDefinition.ID.NamespaceIndex=ref->typeDefinition.nodeId.namespaceIndex;
+	BrowseResult[j].TypeDefinition.ID.IdentifierType=ref->typeDefinition.nodeId.identifierType;
+	BrowseResult[j].TypeDefinition.ID.Identifier.length=ref->typeDefinition.nodeId.identifier.string.length;
+	memcpy(BrowseResult[j].TypeDefinition.ID.Identifier.data,ref->typeDefinition.nodeId.identifier.string.data,ref->typeDefinition.nodeId.identifier.string.length);
+	BrowseResult[j].TypeDefinition.NamespaceURI.length=ref->typeDefinition.namespaceUri.length;
+	memcpy(BrowseResult[j].TypeDefinition.NamespaceURI.data,ref->typeDefinition.namespaceUri.data,ref->typeDefinition.namespaceUri.length);
+	BrowseResult[j].TypeDefinition.ServerIndex=ref->typeDefinition.serverIndex;
+}
+
 u32 UA_NodeGetHandleList(long ConnectionHdl,u16 NodeIDCount,UANodeID *NodeIDs,long *NodeHdls,u32 ErrorIDs[]){
 	int i;
 	u32 retval=0;
@@ -337,6 +364,198 @@ u32 SubscriptionCreate(long ConnectionHdl,bool PublishingEnable,u16 Priority,lon
 	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;
+
+}
+
+u32 Browse(long ConnectionHdl,UABrowseDescription BrowseDescription,u32 ContinuationPointIn,u16 *BrowseResultCount,UAReferenceDescription *BrowseResult,u32 ContinuationPointOut){
+	UA_Client *c = (UA_Client*)ConnectionHdl;
+	UA_StatusCode retval;
+	if(ContinuationPointIn==0){
+		UA_BrowseRequest bReq;
+		UA_BrowseRequest_init(&bReq);
+		bReq.requestedMaxReferencesPerNode = 0;
+		bReq.nodesToBrowse = UA_BrowseDescription_new();
+		bReq.nodesToBrowseSize = 1;
+		switch(BrowseDescription.StartingNodeID.IdentifierType){
+			case 0:bReq.nodesToBrowse[0].nodeId=UA_NODEID_NUMERIC(BrowseDescription.StartingNodeID.NamespaceIndex,BrowseDescription.StartingNodeID.Identifier.data);break;
+			case 1:bReq.nodesToBrowse[0].nodeId=UA_NODEID_STRING(BrowseDescription.StartingNodeID.NamespaceIndex,BrowseDescription.StartingNodeID.Identifier.data);break;
+			case 2:bReq.nodesToBrowse[0].nodeId.identifierType=4;
+					bReq.nodesToBrowse[0].nodeId.identifier.string.data=BrowseDescription.StartingNodeID.Identifier.data;
+					bReq.nodesToBrowse[0].nodeId.identifier.string.length=BrowseDescription.StartingNodeID.Identifier.length;
+					bReq.nodesToBrowse[0].nodeId.namespaceIndex=BrowseDescription.StartingNodeID.NamespaceIndex;break;
+			case 3:bReq.nodesToBrowse[0].nodeId=UA_NODEID_BYTESTRING(BrowseDescription.StartingNodeID.NamespaceIndex,BrowseDescription.StartingNodeID.Identifier.data);break;
+			default:retval=UA_STATUSCODE_BADUNEXPECTEDERROR;
+		}
+		if(BrowseDescription.ReferenceTypeID.Identifier.length!=NULL)
+			bReq.nodesToBrowse[0].referenceTypeId=UA_NODEID_NUMERIC(0,BrowseDescription.ReferenceTypeID.Identifier.length);
+		if(BrowseDescription.ResultMask==1||BrowseDescription.ResultMask==2||BrowseDescription.ResultMask==4||BrowseDescription.ResultMask==8||BrowseDescription.ResultMask==16)
+		 	bReq.nodesToBrowse[0].resultMask = BrowseDescription.ResultMask;
+		if(BrowseDescription.Direction==2||BrowseDescription.Direction==1||BrowseDescription.Direction==0)
+		 	bReq.nodesToBrowse[0].browseDirection = BrowseDescription.Direction;
+		if(BrowseDescription.IncludeSubtypes==0||BrowseDescription.IncludeSubtypes==1)
+		 	bReq.nodesToBrowse[0].includeSubtypes = BrowseDescription.IncludeSubtypes;
+		if(BrowseDescription.NodeClass!=NULL)
+		 	bReq.nodesToBrowse[0].nodeClassMask = BrowseDescription.NodeClass;
+
+		UA_BrowseResponse bResp = UA_Client_Service_browse(c, bReq);
+		retval = bResp.responseHeader.serviceResult;
+		if(retval == UA_STATUSCODE_GOOD) {
+			if(bResp.results[0].referencesSize<=MAX_ELEMENTS_NODELIST){
+				*BrowseResultCount=bResp.results[0].referencesSize;
+				for(size_t j = 0; j < bResp.results[0].referencesSize; ++j){
+					UA_ReferenceDescription *ref = &bResp.results[0].references[j];
+					saveUA_ReferenceDescriptionToUAReferenceDescription(j,ref,BrowseResult);
+				}
+				ContinuationPointOut=0;
+			}else if(bResp.results[0].referencesSize>MAX_ELEMENTS_NODELIST){
+				*BrowseResultCount=MAX_ELEMENTS_NODELIST;
+				UA_ReferenceDescription *ref1=malloc(sizeof(UA_ReferenceDescription)*(bResp.results[0].referencesSize-MAX_ELEMENTS_NODELIST+1));
+				for(size_t j = 0; j < MAX_ELEMENTS_NODELIST; ++j){
+					UA_ReferenceDescription *ref = &bResp.results[0].references[j];
+					saveUA_ReferenceDescriptionToUAReferenceDescription(j,ref,BrowseResult);
+				}
+				for(size_t j=MAX_ELEMENTS_NODELIST+1;j<=bResp.results[0].referencesSize;j++){
+					ref1[j-MAX_ELEMENTS_NODELIST]=bResp.results[0].references[j];
+				}
+				ref1[0].browseName.namespaceIndex=bResp.results[0].referencesSize-MAX_ELEMENTS_NODELIST;
+				ContinuationPointOut=(u32 *)ref1;
+			}
+
+		}
+		//UA_BrowseRequest_clear(&bReq);
+    	//UA_BrowseResponse_clear(&bResp);
+	}else{
+		UA_ReferenceDescription *ref=(UA_ReferenceDescription *)ContinuationPointOut;
+		if(ref[0].browseName.namespaceIndex<=MAX_ELEMENTS_NODELIST){
+			for(size_t j = 1; j < ref[0].browseName.namespaceIndex+1; ++j){
+				saveUA_ReferenceDescriptionToUAReferenceDescription(j,ref,BrowseResult);
+			}
+			ContinuationPointOut=0;
+		}else if(ref[0].browseName.namespaceIndex>MAX_ELEMENTS_NODELIST){
+			UA_ReferenceDescription *ref1=malloc(sizeof(UA_ReferenceDescription)*(ref[0].browseName.namespaceIndex-MAX_ELEMENTS_NODELIST+1));
+			for(size_t j = 1; j < MAX_ELEMENTS_NODELIST+1; ++j){
+				saveUA_ReferenceDescriptionToUAReferenceDescription(j,ref,BrowseResult);
+			}
+			for(size_t j=MAX_ELEMENTS_NODELIST+1;j<=ref[0].browseName.namespaceIndex;j++){
+				ref1[j-MAX_ELEMENTS_NODELIST]=ref[j];
+			}
+			ref1[0].browseName.namespaceIndex=ref[0].browseName.namespaceIndex-MAX_ELEMENTS_NODELIST;
+			ContinuationPointOut=(u32 *)ref1;
+		}
+
+	}
+
+	return retval;
+}
+
+
+u32 UA_MethodGetHandleList(long ConnectionHdl,u16 NodeIDCount,UANodeID *ObjectNodeIDs,UANodeID *MethodNodeIDs,long *MethodHdls,u32 ErrorIDs[]){
+	UA_Client *c = (UA_Client*)ConnectionHdl;
+	u32 retval=0;
+	if(NodeIDCount>MAX_ELEMENTS_METHOD){
+		retval=0xA0000002;
+		return retval;
+	}
+	UA_CallRequest *request=malloc(sizeof(UA_CallRequest));
+	UA_CallRequest_init(request);
+	UA_CallMethodRequest *item = (UA_CallMethodRequest*)malloc(sizeof(UA_CallMethodRequest) * NodeIDCount);
+	for(int i = 0;i<NodeIDCount;i++){
+
+		UA_CallMethodRequest_init(&item[i]);
+
+		switch(ObjectNodeIDs[i].IdentifierType){
+			case 0:item[i].objectId=UA_NODEID_NUMERIC(ObjectNodeIDs[i].NamespaceIndex,ObjectNodeIDs[i].Identifier.data);break;
+			case 1:item[i].objectId=UA_NODEID_STRING(ObjectNodeIDs[i].NamespaceIndex,ObjectNodeIDs[i].Identifier.data);break;
+			case 2:item[i].objectId.identifierType=4;
+					item[i].objectId.identifier.string.data=ObjectNodeIDs[i].Identifier.data;
+					item[i].objectId.identifier.string.length=ObjectNodeIDs[i].Identifier.length;
+					item[i].objectId.namespaceIndex=ObjectNodeIDs[i].NamespaceIndex;break;
+			case 3:item[i].objectId=UA_NODEID_BYTESTRING(ObjectNodeIDs[i].NamespaceIndex,ObjectNodeIDs[i].Identifier.data);break;
+			default:ErrorIDs[i]==0xA0000301;retval=ErrorIDs[i];break;
+		}
+		switch(MethodNodeIDs[i].IdentifierType){
+			case 0:item[i].methodId=UA_NODEID_NUMERIC(MethodNodeIDs[i].NamespaceIndex,MethodNodeIDs[i].Identifier.data);break;
+			case 1:item[i].methodId=UA_NODEID_STRING(MethodNodeIDs[i].NamespaceIndex,MethodNodeIDs[i].Identifier.data);break;
+			case 2:item[i].methodId.identifierType=4;
+					item[i].methodId.identifier.string.data=MethodNodeIDs[i].Identifier.data;
+					item[i].methodId.identifier.string.length=MethodNodeIDs[i].Identifier.length;
+					item[i].methodId.namespaceIndex=MethodNodeIDs[i].NamespaceIndex;break;
+			case 3:item[i].methodId=UA_NODEID_BYTESTRING(MethodNodeIDs[i].NamespaceIndex,MethodNodeIDs[i].Identifier.data);break;
+			default:ErrorIDs[i]==0xA0000301;retval=ErrorIDs[i];break;
+		}
+		//UA_CallMethodRequest_clear(&item);
+		
+
+		//UA_CallRequest_clear(request);
+		
+		MethodHdls[i]=(long *)&item[i];
+		printf("%lld\n",MethodHdls[i]);
+		ErrorIDs[i]=0;
+	}
+	request->methodsToCall = &item;
+	request->methodsToCallSize = NodeIDCount;
+
+	return retval;
+}
+
+
+
+
 int main(int argc, char *argv[]) {
 	
     // long connecthdl;
@@ -395,18 +614,16 @@ int main(int argc, char *argv[]) {
     UA_BrowseRequest_clear(&bReq);
     UA_BrowseResponse_clear(&bResp);
 
-	UA_NodeGetHandleList(hdl,4,nodes,nodeHdls,errors);
+	UANodeID ObjectNodeIDs[4];
-    UA_Value *variables = (UA_Value*)malloc(4 * sizeof(UA_Value));
+	UANodeID MethodNodeIDs[1];
-	readTest(hdl,4,nodeHdls,variables,errors);
+	long MethodHdls[4];
-    for (int i = 0; i < 4; i++)
+	u32 ErrorIDs[1];
-    {
+	UA_MethodGetHandleList(hdl,4,nodes,MethodNodeIDs,MethodHdls,ErrorIDs);
-        printf("%d\n",variables[i].type);
+	printf("1111\n");
-    }
+	printf("%lld\n",MethodHdls[1]);
-    
+	
-
     /* Clean up */
     UA_Client_disconnect(client);
     UA_Client_delete(client);
 	
-	
 }