Compare commits
1 Commits
main
...
NodeGetInf
| Author | SHA1 | Date | |
|---|---|---|---|
| a340e3fb02 |
683
myClient.c
683
myClient.c
@ -22,485 +22,244 @@
|
|||||||
// return flag;
|
// return flag;
|
||||||
// }
|
// }
|
||||||
|
|
||||||
void saveUA_ReferenceDescriptionToUAReferenceDescription(int j,UA_ReferenceDescription *ref,UAReferenceDescription *BrowseResult){
|
u32 UA_NodeGetInformation(long ConnectionHdl,UANodeID NodeID,UANodeInformation *NodeInfo,u32 ErrorIDs[]){
|
||||||
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;
|
|
||||||
UA_NodeId *NodeID=malloc(sizeof(UA_NodeId)*NodeIDCount);
|
|
||||||
if(NodeIDCount>MAX_ELEMENTS_NODELIST){
|
|
||||||
retval=0xA0000002;
|
|
||||||
return retval;
|
|
||||||
}
|
|
||||||
|
|
||||||
for(i=0;i<NodeIDCount;i++){
|
|
||||||
printf("\nNdeIDs[i].IdentifierType=%d,NodeIDs[i].NamespaceIndex=%d,NodeIDs[i].Identifier.length=%d, NodeIDs[i].Identifier.data=%s\n",
|
|
||||||
NodeIDs[i].IdentifierType, NodeIDs[i].NamespaceIndex, NodeIDs[i].Identifier.length ,NodeIDs[i].Identifier.data );
|
|
||||||
|
|
||||||
if(NodeIDs[i].IdentifierType>=0&&NodeIDs[i].IdentifierType<4){
|
|
||||||
switch(NodeIDs[i].IdentifierType){
|
|
||||||
case 0:NodeID[i]=UA_NODEID_NUMERIC(NodeIDs[i].NamespaceIndex,NodeIDs[i].Identifier.data);break;
|
|
||||||
case 1:NodeID[i]=UA_NODEID_STRING(NodeIDs[i].NamespaceIndex,NodeIDs[i].Identifier.data);break;
|
|
||||||
case 2:NodeID[i].identifierType=4;
|
|
||||||
NodeID[i].identifier.string.data=NodeIDs[i].Identifier.data;
|
|
||||||
NodeID[i].identifier.string.length=NodeIDs[i].Identifier.length;
|
|
||||||
NodeID[i].namespaceIndex=NodeIDs[i].NamespaceIndex;break;
|
|
||||||
case 3:NodeID[i]=UA_NODEID_BYTESTRING(NodeIDs[i].NamespaceIndex,NodeIDs[i].Identifier.data);break;
|
|
||||||
}
|
|
||||||
ErrorIDs[i]=0;
|
|
||||||
}else{
|
|
||||||
ErrorIDs[i]=0xA0000301;
|
|
||||||
retval=ErrorIDs[i];
|
|
||||||
}
|
|
||||||
// NodeID[i].identifier.string.data=NodeIDs[i].Identifier.data;
|
|
||||||
// NodeID[i].identifier.string.length=NodeIDs[i].Identifier.length;
|
|
||||||
// NodeID[i].namespaceIndex=NodeIDs[i].NamespaceIndex;
|
|
||||||
NodeHdls[i]=&NodeID[i];
|
|
||||||
//UA_NodeId *NodeID1=malloc(sizeof(UA_NodeId)*NodeIDCount);
|
|
||||||
//UA_NodeId_delete(&NodeID[i]);
|
|
||||||
}
|
|
||||||
|
|
||||||
return retval;
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
u32 UA_ReadList(long ConnectionHdl,u16 NodeHdlCount,long *NodeHdls,UANodeAdditionalInfo *NodeAddInfos,UA_Value *variables,u32 ErrorIDs[]){
|
|
||||||
UA_Client *c = (UA_Client*)ConnectionHdl;
|
UA_Client *c = (UA_Client*)ConnectionHdl;
|
||||||
int i;
|
if (c == NULL) {
|
||||||
u32 retval;
|
fprintf(stderr, "Invalid UA_Client pointer\n");
|
||||||
UA_ReadValueId item[NodeHdlCount];
|
return UA_STATUSCODE_BADUNEXPECTEDERROR; // 返回错误码
|
||||||
if(NodeHdlCount>MAX_ELEMENTS_NODELIST){
|
|
||||||
retval=0xA0000002;
|
|
||||||
}
|
}
|
||||||
else
|
u32 retval,ret=0;
|
||||||
{
|
|
||||||
for(i=0;i<NodeHdlCount;i++){
|
|
||||||
UA_ReadValueId_init(&item[i]);
|
|
||||||
item[i].nodeId = *(UA_NodeId*)NodeHdls[i];
|
|
||||||
//item[i].nodeId.identifier.numeric = NodeHdls[i];//zjy 20240910
|
|
||||||
item[i].attributeId = NodeAddInfos[i].AttributeID;
|
|
||||||
//item[i].nodeId.namespaceIndex = 1;
|
|
||||||
printf("------------#2------NodeHdls[i] = %ld ,item[i].nodeId = %d,item[i].attributeId=%d,item[i].nodeId.namespaceIndex=%d-\n",
|
|
||||||
NodeHdls[i],item[i].nodeId.identifier.string.length,item[i].attributeId,item[i].nodeId.namespaceIndex);
|
|
||||||
}
|
|
||||||
UA_ReadRequest request;
|
|
||||||
UA_ReadRequest_init(&request);
|
|
||||||
request.nodesToRead = &item[0];
|
|
||||||
request.nodesToReadSize = 1;
|
|
||||||
UA_ReadResponse response = UA_Client_Service_read(c, request);
|
|
||||||
retval = response.responseHeader.serviceResult;
|
|
||||||
if(retval == UA_STATUSCODE_GOOD)
|
|
||||||
{
|
|
||||||
printf("------------#3---------------\n");
|
|
||||||
if(response.resultsSize==NodeHdlCount)
|
|
||||||
{
|
|
||||||
printf("------------#4---------------\n");
|
|
||||||
for (i = 0; i < NodeHdlCount; i++)
|
|
||||||
{
|
|
||||||
ErrorIDs[i]=response.results[i].status;
|
|
||||||
}
|
|
||||||
retval = 0 ;
|
|
||||||
for(i=0;i<NodeHdlCount;i++)
|
|
||||||
{
|
|
||||||
if(ErrorIDs[i]==UA_STATUSCODE_GOOD)
|
|
||||||
{
|
|
||||||
printf("------------#5---------------\n");
|
|
||||||
UA_DataValue res = response.results[i];
|
|
||||||
if(!res.hasValue)
|
|
||||||
{
|
|
||||||
printf("------------#6---------------\n");
|
|
||||||
UA_ReadResponse_clear(&response);
|
|
||||||
retval = UA_STATUSCODE_BADUNEXPECTEDERROR;
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
if(NodeAddInfos[i].AttributeID == UA_ATTRIBUTEID_VALUE)
|
|
||||||
{
|
|
||||||
//UA_Variant *out=malloc(sizeof(UA_Variant));
|
|
||||||
UA_Variant out;
|
|
||||||
//memcpy(&out, &res.value, sizeof(UA_Variant));
|
|
||||||
//UA_Variant_init(&res.value);
|
|
||||||
//variables[i].data =res.value.data;
|
|
||||||
long temp ;
|
|
||||||
memcpy(&temp,res.value.data,8);
|
|
||||||
variables[i].data = (void *)temp;
|
|
||||||
|
|
||||||
variables[i].type=res.value.type->typeId.identifier.numeric;
|
printf("\n\n %s \n\n",NodeID.Identifier.data);
|
||||||
|
|
||||||
}
|
//UA_NodeId NODEID=UA_NODEID_STRING(NodeID.NamespaceIndex,NodeID.Identifier.data);
|
||||||
else if(NodeAddInfos[i].AttributeID == UA_ATTRIBUTEID_NODECLASS)
|
UA_NodeId NODEID=UA_NODEID_NUMERIC(NodeID.NamespaceIndex,atoll(NodeID.Identifier.data));
|
||||||
{
|
|
||||||
//UA_NodeClass *out1;
|
// NODEID.namespaceIndex = NodeID.NamespaceIndex;
|
||||||
//memcpy(out1, (UA_NodeClass*)res.value.data, sizeof(UA_NodeClass));
|
// if(NodeID.IdentifierType>=0&&NodeID.IdentifierType<4){
|
||||||
memcpy(variables[i].data,res.value.data,8);
|
// switch(NodeID.IdentifierType){
|
||||||
variables[i].type=UA_TYPES_NODECLASS;
|
// case 0:NODEID.identifierType=0;
|
||||||
}
|
// case 1:NODEID.identifierType=3;
|
||||||
else if(UA_Variant_isScalar(&res.value))
|
// case 2:NODEID.identifierType=4;
|
||||||
{
|
// case 3:NODEID.identifierType=5;
|
||||||
//memcpy(&variables[i].data, &res.value.data, res.value.type->memSize);
|
// }
|
||||||
//UA_free(res.value.data);
|
// ret=0;
|
||||||
//res.value.data = 0;
|
// }else{
|
||||||
variables[i].type=res.value.type->typeId.identifier.numeric;
|
// ret=0xA0000301;
|
||||||
}
|
// }
|
||||||
else
|
// NODEID.identifier.string = UA_STRING(NodeID.Identifier.data);
|
||||||
{
|
UA_NodeClass outNodeClass;
|
||||||
retval = UA_STATUSCODE_BADUNEXPECTEDERROR;
|
UA_NodeClass_init(&outNodeClass);
|
||||||
}
|
retval=UA_Client_readNodeClassAttribute(c,NODEID,&outNodeClass);
|
||||||
|
if(retval!=0){
|
||||||
}
|
ErrorIDs[0]=retval;
|
||||||
UA_free(res.value.data); //????? need or not
|
ret=retval;
|
||||||
}
|
|
||||||
} //end for
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
|
|
||||||
retval = UA_STATUSCODE_BADUNEXPECTEDERROR;
|
|
||||||
}
|
|
||||||
}//end if(retval == UA_STATUSCODE_GOOD)
|
|
||||||
// printf("------------#f8 --------------\n");
|
|
||||||
// UA_ReadResponse_clear(&response);
|
|
||||||
}
|
|
||||||
|
|
||||||
return retval;
|
|
||||||
}
|
|
||||||
|
|
||||||
u32 UA_WriteList(long ConnectionHdl,u16 NodeHdlCount,long *NodeHdls,UANodeAdditionalInfo *NodeAddInfos,UA_Value *variables,u32 ErrorIDs[]){
|
|
||||||
UA_Client *c = (UA_Client*)ConnectionHdl;
|
|
||||||
int i;
|
|
||||||
UA_StatusCode retval=0;
|
|
||||||
if(NodeHdlCount>MAX_ELEMENTS_NODELIST){
|
|
||||||
retval=0xA0000002;
|
|
||||||
return retval;
|
|
||||||
}
|
}
|
||||||
//UA_NodeId NODEid= UA_NODEID_STRING(1, "A1.the anwser2");
|
u32 temp =outNodeClass;
|
||||||
//UA_Client_writeValueAttribute(c,NODEid,&in);
|
NodeInfo->NodeClass=temp;
|
||||||
UA_WriteValue wValue[NodeHdlCount];
|
UA_NodeClass_clear(&outNodeClass);
|
||||||
for(i=0;i<NodeHdlCount;i++){
|
|
||||||
UA_WriteValue_init(&wValue[i]);
|
UA_QualifiedName outBrowseName;
|
||||||
wValue[i].nodeId = *(UA_NodeId*)NodeHdls[i];
|
UA_QualifiedName_init(&outBrowseName);
|
||||||
//wValue[i].nodeId = NODEid;
|
retval=UA_Client_readBrowseNameAttribute(c,NODEID,&outBrowseName);
|
||||||
wValue[i].attributeId = NodeAddInfos[i].AttributeID;
|
if(retval!=0){
|
||||||
if(NodeAddInfos[i].AttributeID == UA_ATTRIBUTEID_VALUE){
|
fprintf(stderr, "Failed to read BrowseName: %s\n", UA_StatusCode_name(retval));
|
||||||
UA_Variant in;
|
ErrorIDs[1]=retval;
|
||||||
UA_Variant_init(&in);
|
ret=retval;
|
||||||
UA_Variant_setScalar(&in,variables[i].data,&UA_TYPES[variables[i].type-1]);
|
return ret;
|
||||||
wValue[i].value.value = in;
|
|
||||||
wValue[i].value.hasValue = true;
|
|
||||||
}
|
|
||||||
else{
|
|
||||||
UA_Variant_setScalar(&wValue[i].value.value, (void*)(uintptr_t)variables[i].data, &UA_TYPES[variables[i].type-1]);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
UA_WriteRequest wReq;
|
NodeInfo->BrowseName.NamespaceIndex=outBrowseName.namespaceIndex;
|
||||||
UA_WriteRequest_init(&wReq);
|
NodeInfo->BrowseName.Name.length=outBrowseName.name.length;
|
||||||
wReq.nodesToWrite = &wValue[0];
|
NodeInfo->BrowseName.Name.data=outBrowseName.name.data;
|
||||||
wReq.nodesToWriteSize = NodeHdlCount;
|
printf("\n\n %s \n\n",outBrowseName.name.data);
|
||||||
|
UA_QualifiedName_clear(&outBrowseName);
|
||||||
|
|
||||||
UA_WriteResponse wResp = UA_Client_Service_write(c, wReq);
|
UA_LocalizedText outDisplayName;
|
||||||
|
UA_LocalizedText_init(&outDisplayName);
|
||||||
retval = wResp.responseHeader.serviceResult;
|
retval=UA_Client_readDisplayNameAttribute(c,NODEID,&outDisplayName);
|
||||||
if(retval==UA_STATUSCODE_GOOD){
|
if(retval!=0){
|
||||||
if(wResp.resultsSize==NodeHdlCount){
|
ErrorIDs[2]=retval;
|
||||||
for(i=0;i<NodeHdlCount;i++){
|
ret=retval;
|
||||||
ErrorIDs[i]=wResp.results[i];
|
|
||||||
}
|
|
||||||
}else{
|
|
||||||
retval=UA_STATUSCODE_BADUNEXPECTEDERROR;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
UA_WriteRequest_clear(&wResp);
|
NodeInfo->DisplayName.Locale=outDisplayName.locale.data;
|
||||||
return retval;
|
NodeInfo->DisplayName.Text.length=outDisplayName.text.length;
|
||||||
}
|
NodeInfo->DisplayName.Text.data=outDisplayName.text.data;
|
||||||
|
UA_LocalizedText_clear(&outDisplayName);
|
||||||
|
|
||||||
void readTest(long ConnectionHdl,u16 NodeHdlCount,long *NodeHdls,UA_Value *variables,u32 ErrorIDs[])
|
UA_LocalizedText outDescription;
|
||||||
{
|
UA_LocalizedText_init(&outDescription);
|
||||||
UA_Client *c = (UA_Client*)ConnectionHdl;
|
retval=UA_Client_readDescriptionAttribute(c,NODEID,&outDescription);
|
||||||
int i;
|
if(retval!=0){
|
||||||
u32 retval;
|
ErrorIDs[3]=retval;
|
||||||
UA_ReadValueId item[NodeHdlCount];
|
ret=retval;
|
||||||
if(NodeHdlCount>MAX_ELEMENTS_NODELIST){
|
|
||||||
retval=0xA0000002;
|
|
||||||
}
|
}
|
||||||
else
|
NodeInfo->Description.Locale=outDescription.locale.data;
|
||||||
{
|
NodeInfo->Description.Text.length=outDescription.text.length;
|
||||||
for(i=0;i<NodeHdlCount;i++){
|
NodeInfo->Description.Text.data=outDescription.text.data;
|
||||||
UA_ReadValueId_init(&item[i]);
|
UA_LocalizedText_clear(&outDescription);
|
||||||
item[i].nodeId = *(UA_NodeId*)NodeHdls[i];
|
|
||||||
//item[i].nodeId.identifier.numeric = NodeHdls[i];//zjy 20240910
|
|
||||||
item[i].attributeId = 1;
|
|
||||||
//item[i].nodeId.namespaceIndex = 1;
|
|
||||||
printf("------------#2------NodeHdls[i] = %ld ,item[i].nodeId = %d,item[i].attributeId=%d,item[i].nodeId.namespaceIndex=%d-\n",
|
|
||||||
NodeHdls[i],item[i].nodeId.identifier.string.length,item[i].attributeId,item[i].nodeId.namespaceIndex);
|
|
||||||
}
|
|
||||||
UA_ReadRequest request;
|
|
||||||
UA_ReadRequest_init(&request);
|
|
||||||
request.nodesToRead = &item[0];
|
|
||||||
request.nodesToReadSize = 1;
|
|
||||||
UA_ReadResponse response = UA_Client_Service_read(c, request);
|
|
||||||
retval = response.responseHeader.serviceResult;
|
|
||||||
if(retval == UA_STATUSCODE_GOOD)
|
|
||||||
{
|
|
||||||
printf("------------#3---------------\n");
|
|
||||||
printf("%d\n",response.resultsSize);
|
|
||||||
if(response.resultsSize==NodeHdlCount)
|
|
||||||
{
|
|
||||||
printf("------------#4---------------\n");
|
|
||||||
for (i = 0; i < NodeHdlCount; i++)
|
|
||||||
{
|
|
||||||
ErrorIDs[i]=response.results[i].status;
|
|
||||||
}
|
|
||||||
retval = 0 ;
|
|
||||||
for(i=0;i<NodeHdlCount;i++)
|
|
||||||
{
|
|
||||||
if(ErrorIDs[i]==UA_STATUSCODE_GOOD)
|
|
||||||
{
|
|
||||||
printf("------------#5---------------\n");
|
|
||||||
UA_DataValue res = response.results[i];
|
|
||||||
if(!res.hasValue)
|
|
||||||
{
|
|
||||||
printf("------------#6---------------\n");
|
|
||||||
UA_ReadResponse_clear(&response);
|
|
||||||
retval = UA_STATUSCODE_BADUNEXPECTEDERROR;
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
memcpy(variables[i].data,res.value.data,8);
|
|
||||||
variables[i].type=UA_TYPES_NODECLASS;
|
|
||||||
}
|
|
||||||
UA_free(res.value.data); //????? need or not
|
|
||||||
}
|
|
||||||
} //end for
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
|
|
||||||
retval = UA_STATUSCODE_BADUNEXPECTEDERROR;
|
UA_UInt32 outWriteMask;
|
||||||
}
|
UA_UInt32_init(&outWriteMask);
|
||||||
}
|
retval=UA_Client_readWriteMaskAttribute(c,NODEID,&outWriteMask);
|
||||||
}
|
if(retval!=0){
|
||||||
}
|
ErrorIDs[4]=retval;
|
||||||
|
ret=retval;
|
||||||
void writeTest(long ConnectionHdl,u16 NodeHdlCount,long *NodeHdls,UA_Value *variables,u32 ErrorIDs[]){
|
|
||||||
UA_Client *c = (UA_Client*)ConnectionHdl;
|
|
||||||
int i;
|
|
||||||
UA_StatusCode retval=0;
|
|
||||||
if(NodeHdlCount>MAX_ELEMENTS_NODELIST){
|
|
||||||
retval=0xA0000002;
|
|
||||||
return retval;
|
|
||||||
}
|
}
|
||||||
//UA_NodeId NODEid= UA_NODEID_STRING(1, "A1.the anwser2");
|
NodeInfo->WriteMask=outWriteMask;
|
||||||
//UA_Client_writeValueAttribute(c,NODEid,&in);
|
UA_UInt32_clear(&outWriteMask);
|
||||||
UA_WriteValue wValue[NodeHdlCount];
|
|
||||||
for(i=0;i<NodeHdlCount;i++){
|
UA_UInt32 outUserWriteMask;
|
||||||
UA_WriteValue_init(&wValue[i]);
|
UA_UInt32_init(&outUserWriteMask);
|
||||||
wValue[i].nodeId = *(UA_NodeId*)NodeHdls[i];
|
retval=UA_Client_readUserWriteMaskAttribute(c,NODEID,&outUserWriteMask);
|
||||||
//wValue[i].nodeId = NODEid;
|
if(retval!=0){
|
||||||
wValue[i].attributeId = 1;
|
ErrorIDs[5]=retval;
|
||||||
UA_Variant_setScalar(&wValue[i].value.value, (void*)(uintptr_t)variables[i].data, &UA_TYPES[variables[i].type-1]);
|
ret=retval;
|
||||||
}
|
}
|
||||||
UA_WriteRequest wReq;
|
NodeInfo->UserWriteMask=outUserWriteMask;
|
||||||
UA_WriteRequest_init(&wReq);
|
UA_UInt32_clear(&outUserWriteMask);
|
||||||
wReq.nodesToWrite = &wValue[0];
|
|
||||||
wReq.nodesToWriteSize = NodeHdlCount;
|
|
||||||
|
|
||||||
UA_WriteResponse wResp = UA_Client_Service_write(c, wReq);
|
UA_Boolean outIsAbstract;
|
||||||
|
UA_Boolean_init(&outIsAbstract);
|
||||||
retval = wResp.responseHeader.serviceResult;
|
retval=UA_Client_readIsAbstractAttribute(c,NODEID,&outIsAbstract);
|
||||||
if(retval==UA_STATUSCODE_GOOD){
|
if(retval!=0){
|
||||||
if(wResp.resultsSize==NodeHdlCount){
|
ErrorIDs[6]=retval;
|
||||||
for(i=0;i<NodeHdlCount;i++){
|
//ret=retval;
|
||||||
ErrorIDs[i]=wResp.results[i];
|
|
||||||
}
|
|
||||||
}else{
|
|
||||||
retval=UA_STATUSCODE_BADUNEXPECTEDERROR;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
UA_WriteRequest_clear(&wResp);
|
NodeInfo->IsAbstract=outIsAbstract;
|
||||||
return retval;
|
UA_Boolean_clear(&outIsAbstract);
|
||||||
}
|
|
||||||
|
|
||||||
u32 SubscriptionCreate(long ConnectionHdl,bool PublishingEnable,u16 Priority,long *SubscriptionHdl,TIME *PublishingInterval){
|
UA_Boolean outSymmetric;
|
||||||
UA_Client *c = (UA_Client*)ConnectionHdl;
|
UA_Boolean_init(&outSymmetric);
|
||||||
UA_CreateSubscriptionRequest request = UA_CreateSubscriptionRequest_default();
|
retval=UA_Client_readSymmetricAttribute(c,NODEID,&outSymmetric);
|
||||||
request.requestedPublishingInterval=*PublishingInterval;
|
if(retval!=0){
|
||||||
request.publishingEnabled=PublishingEnable;
|
ErrorIDs[7]=retval;
|
||||||
request.priority=Priority;
|
//ret=retval;
|
||||||
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);
|
NodeInfo->Symmetric=outSymmetric;
|
||||||
*SubscriptionHdl=(long *)response[0].subscriptionId;
|
UA_Boolean_clear(&outSymmetric);
|
||||||
UA_CreateSubscriptionResponse_clear(&response[0]);
|
|
||||||
return retval;
|
|
||||||
}
|
|
||||||
|
|
||||||
u32 UA_SubscriptionDelete(long ConnectionHdl,long SubscriptionHdl){
|
UA_LocalizedText outInverseName;
|
||||||
UA_Client *c = (UA_Client*)ConnectionHdl;
|
UA_LocalizedText_init(&outInverseName);
|
||||||
u32 retval=UA_Client_Subscriptions_deleteSingle(c,SubscriptionHdl);
|
retval=UA_Client_readInverseNameAttribute(c,NODEID,&outInverseName);
|
||||||
return retval;
|
if(retval!=0){
|
||||||
}
|
ErrorIDs[8]=retval;
|
||||||
|
//ret=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){
|
NodeInfo->InverseName.length=outInverseName.text.length;
|
||||||
for(int i=0;i<NodeHdlCount;i++){
|
NodeInfo->InverseName.data=outInverseName.text.data;
|
||||||
UA_NodeId *NodeID=(UA_NodeId*)NodeHdls[i];
|
UA_LocalizedText_clear(&outInverseName);
|
||||||
UA_MonitoredItemCreateRequest monRequest=UA_MonitoredItemCreateRequest_default(*NodeID);
|
|
||||||
monRequest.itemToMonitor.attributeId = NodeAddInfos[i].AttributeID;
|
UA_Boolean outContainsNoLoops;
|
||||||
UA_MonitoredItemCreateResult monResponse=
|
UA_Boolean_init(&outContainsNoLoops);
|
||||||
UA_Client_MonitoredItems_createDataChange(c,SubscriptionHdl,UA_TIMESTAMPSTORETURN_BOTH,
|
retval=UA_Client_readContainsNoLoopsAttribute(c,NODEID,&outContainsNoLoops);
|
||||||
monRequest,NodeID,handler_DataChanged,NULL);
|
if(retval!=0){
|
||||||
if(monResponse.statusCode!=UA_STATUSCODE_GOOD){
|
ErrorIDs[9]=retval;
|
||||||
retval=monResponse.statusCode;
|
//ret=retval;
|
||||||
}
|
|
||||||
ErrorIDs[i]=monResponse.statusCode;
|
|
||||||
MonitoredItemHdls[i]=monResponse.monitoredItemId;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
return retval;
|
NodeInfo->ContainsNoLoops=outContainsNoLoops;
|
||||||
|
UA_Boolean_clear(&outContainsNoLoops);
|
||||||
|
|
||||||
}
|
UA_Byte outEventNotifier;
|
||||||
|
UA_Byte_init(&outEventNotifier);
|
||||||
|
retval=UA_Client_readEventNotifierAttribute(c,NODEID,&outEventNotifier);
|
||||||
|
if(retval!=0){
|
||||||
|
ErrorIDs[10]=retval;
|
||||||
|
//ret=retval;
|
||||||
|
}
|
||||||
|
NodeInfo->EventNotifier=outEventNotifier;
|
||||||
|
UA_Byte_clear(&outEventNotifier);
|
||||||
|
|
||||||
u32 Browse(long ConnectionHdl,UABrowseDescription BrowseDescription,u32 ContinuationPointIn,u16 *BrowseResultCount,UAReferenceDescription *BrowseResult,u32 ContinuationPointOut){
|
UA_NodeId outDataType;
|
||||||
UA_Client *c = (UA_Client*)ConnectionHdl;
|
UA_NodeId_init(&outDataType);
|
||||||
UA_StatusCode retval;
|
retval=UA_Client_readDataTypeAttribute(c,NODEID,&outDataType);
|
||||||
if(ContinuationPointIn==0){
|
if(retval!=0){
|
||||||
UA_BrowseRequest bReq;
|
ErrorIDs[11]=retval;
|
||||||
UA_BrowseRequest_init(&bReq);
|
ret=retval;
|
||||||
bReq.requestedMaxReferencesPerNode = 0;
|
}
|
||||||
bReq.nodesToBrowse = UA_BrowseDescription_new();
|
NodeInfo->DataType.NamespaceIndex=outDataType.namespaceIndex;
|
||||||
bReq.nodesToBrowseSize = 1;
|
NodeInfo->DataType.IdentifierType=outDataType.identifierType;
|
||||||
switch(BrowseDescription.StartingNodeID.IdentifierType){
|
NodeInfo->DataType.Identifier.length=outDataType.identifier.string.length;
|
||||||
case 0:bReq.nodesToBrowse[0].nodeId=UA_NODEID_NUMERIC(BrowseDescription.StartingNodeID.NamespaceIndex,BrowseDescription.StartingNodeID.Identifier.data);break;
|
NodeInfo->DataType.Identifier.data=outDataType.identifier.string.data;
|
||||||
case 1:bReq.nodesToBrowse[0].nodeId=UA_NODEID_STRING(BrowseDescription.StartingNodeID.NamespaceIndex,BrowseDescription.StartingNodeID.Identifier.data);break;
|
UA_NodeId_clear(&outDataType);
|
||||||
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);
|
UA_Int32 outValueRank;
|
||||||
retval = bResp.responseHeader.serviceResult;
|
UA_Int32_init(&outValueRank);
|
||||||
if(retval == UA_STATUSCODE_GOOD) {
|
retval=UA_Client_readValueRankAttribute(c,NODEID,&outValueRank);
|
||||||
if(bResp.results[0].referencesSize<=MAX_ELEMENTS_NODELIST){
|
if(retval!=0){
|
||||||
*BrowseResultCount=bResp.results[0].referencesSize;
|
ErrorIDs[12]=retval;
|
||||||
for(size_t j = 0; j < bResp.results[0].referencesSize; ++j){
|
ret=retval;
|
||||||
UA_ReferenceDescription *ref = &bResp.results[0].references[j];
|
}
|
||||||
saveUA_ReferenceDescriptionToUAReferenceDescription(j,ref,BrowseResult);
|
NodeInfo->ValueRank=outValueRank;
|
||||||
}
|
UA_Int32_clear(&outValueRank);
|
||||||
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;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
UA_UInt32 outArrayDimensions[MAX_ELEMENTS_ARRAYDIMENSION];
|
||||||
|
//UA_UInt32_init(*outArrayDimensions);
|
||||||
|
int size;
|
||||||
|
retval=UA_Client_readArrayDimensionsAttribute(c,NODEID,&size,outArrayDimensions);
|
||||||
|
if(retval!=0){
|
||||||
|
ErrorIDs[13]=retval;
|
||||||
|
ret=retval;
|
||||||
|
}
|
||||||
|
for(int i=0;i<MAX_ELEMENTS_ARRAYDIMENSION;i++){
|
||||||
|
NodeInfo->ArrayDimension[i]=outArrayDimensions[i];
|
||||||
}
|
}
|
||||||
|
|
||||||
return retval;
|
|
||||||
|
UA_Byte outAccessLevel;
|
||||||
|
UA_Byte_init(&outAccessLevel);
|
||||||
|
retval=UA_Client_readAccessLevelAttribute(c,NODEID,&outAccessLevel);
|
||||||
|
if(retval!=0){
|
||||||
|
ErrorIDs[14]=retval;
|
||||||
|
ret=retval;
|
||||||
|
}
|
||||||
|
NodeInfo->AccessLevel=outAccessLevel;
|
||||||
|
|
||||||
|
UA_Byte outUserAccessLevel;
|
||||||
|
UA_Byte_init(&outUserAccessLevel);
|
||||||
|
retval=UA_Client_readUserAccessLevelAttribute(c,NODEID,&outUserAccessLevel);
|
||||||
|
if(retval!=0){
|
||||||
|
ErrorIDs[15]=retval;
|
||||||
|
ret=retval;
|
||||||
|
}
|
||||||
|
NodeInfo->UserAccessLevel=outUserAccessLevel;
|
||||||
|
|
||||||
|
UA_Double outMinSamplingInterval;
|
||||||
|
UA_Double_init(&outMinSamplingInterval);
|
||||||
|
retval=UA_Client_readMinimumSamplingIntervalAttribute(c,NODEID,&outMinSamplingInterval);
|
||||||
|
if(retval!=0){
|
||||||
|
ErrorIDs[16]=retval;
|
||||||
|
ret=retval;
|
||||||
|
}
|
||||||
|
NodeInfo->MinimumSamplingInterval=outMinSamplingInterval;
|
||||||
|
|
||||||
|
UA_Boolean outHistorizing;
|
||||||
|
UA_Boolean_init(&outHistorizing);
|
||||||
|
retval=UA_Client_readHistorizingAttribute(c,NODEID,&outHistorizing);
|
||||||
|
if(retval!=0){
|
||||||
|
ErrorIDs[17]=retval;
|
||||||
|
ret=retval;
|
||||||
|
}
|
||||||
|
NodeInfo->Historizing=outHistorizing;
|
||||||
|
|
||||||
|
UA_Boolean outExecutable;
|
||||||
|
UA_Boolean_init(&outExecutable);
|
||||||
|
retval=UA_Client_readExecutableAttribute(c,NODEID,&outExecutable);
|
||||||
|
if(retval!=0){
|
||||||
|
ErrorIDs[18]=retval;
|
||||||
|
//ret=retval;
|
||||||
|
}
|
||||||
|
NodeInfo->Executable=outExecutable;
|
||||||
|
|
||||||
|
UA_Boolean outUserExecutable;
|
||||||
|
UA_Boolean_init(&outUserExecutable);
|
||||||
|
retval=UA_Client_readUserExecutableAttribute(c,NODEID,&outUserExecutable);
|
||||||
|
if(retval!=0){
|
||||||
|
ErrorIDs[19]=retval;
|
||||||
|
//ret=retval;
|
||||||
|
}
|
||||||
|
NodeInfo->UserExecutable=outUserExecutable;
|
||||||
|
|
||||||
|
return ret;
|
||||||
}
|
}
|
||||||
|
|
||||||
int main(int argc, char *argv[]) {
|
int main(int argc, char *argv[]) {
|
||||||
@ -545,12 +304,12 @@ int main(int argc, char *argv[]) {
|
|||||||
(int)ref->displayName.text.length, ref->displayName.text.data);
|
(int)ref->displayName.text.length, ref->displayName.text.data);
|
||||||
}
|
}
|
||||||
|
|
||||||
printf("\n%lld\n\n",ref->nodeId.nodeId.identifier.numeric);
|
printf("%lld",ref->nodeId.nodeId.identifier.numeric);
|
||||||
|
|
||||||
nodes[j].Identifier.length = ref->nodeId.nodeId.identifier.string.length;
|
nodes[j].Identifier.length = ref->nodeId.nodeId.identifier.string.length;
|
||||||
if(nodes[j].Identifier.length > 0) {
|
if(nodes[j].Identifier.length > 0) {
|
||||||
nodes[j].Identifier.data = (u8*)malloc(nodes[j].Identifier.length);
|
nodes[j].Identifier.data = (u8*)malloc(nodes[j].Identifier.length);
|
||||||
snprintf(nodes[j].Identifier.data, 64, "%lld", (long long)ref->nodeId.nodeId.identifier.numeric);
|
snprintf(nodes[j].Identifier.data, nodes[j].Identifier.length, "%lld", (long long)ref->nodeId.nodeId.identifier.numeric);
|
||||||
|
|
||||||
}
|
}
|
||||||
nodes[j].IdentifierType = ref->nodeId.nodeId.identifierType;
|
nodes[j].IdentifierType = ref->nodeId.nodeId.identifierType;
|
||||||
@ -560,17 +319,9 @@ int main(int argc, char *argv[]) {
|
|||||||
}
|
}
|
||||||
UA_BrowseRequest_clear(&bReq);
|
UA_BrowseRequest_clear(&bReq);
|
||||||
UA_BrowseResponse_clear(&bResp);
|
UA_BrowseResponse_clear(&bResp);
|
||||||
u16 count;
|
|
||||||
UABrowseDescription browseDes;
|
UANodeInformation *nodeinfo = (UANodeInformation*)malloc(sizeof(UANodeInformation));
|
||||||
browseDes.Direction = 1;
|
UA_NodeGetInformation(hdl,nodes[1],nodeinfo,errors);
|
||||||
browseDes.StartingNodeID = nodes[0];
|
|
||||||
browseDes.ResultMask = 31;
|
|
||||||
browseDes.IncludeSubtypes = true;
|
|
||||||
browseDes.ReferenceTypeID.Identifier.length == NULL;
|
|
||||||
browseDes.NodeClass = 511;
|
|
||||||
UAReferenceDescription *browseResult = (UAReferenceDescription*)malloc(MAX_ELEMENTS_NODELIST * sizeof(UAReferenceDescription));
|
|
||||||
u32 resultOut;
|
|
||||||
Browse(hdl,browseDes,0,&count,browseResult,resultOut);
|
|
||||||
|
|
||||||
/* Clean up */
|
/* Clean up */
|
||||||
UA_Client_disconnect(client);
|
UA_Client_disconnect(client);
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user