2 Commits

Author SHA1 Message Date
c9370e53db New bug in SubscriptionDelete 2024-12-24 15:27:41 +08:00
2692cbfa14 New bug in SubscriptionCreate 2024-12-24 15:19:20 +08:00

View File

@ -318,6 +318,31 @@ 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;
}
int main(int argc, char *argv[]) {
// long connecthdl;