TiagoRG
/
it2s-itss-facilities
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Test CI

This commit is contained in:
emanuel 2021-05-17 15:57:32 +01:00
parent 22afa8a522
commit 4ed977f69f
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/config.c
View File

@ -219,12 +219,16 @@ int facilities_config(void* facilities_s) {
uint8_t b_oer[128]; uint8_t b_oer[128];
asn_enc_rval_t enc = asn_encode_to_buffer(NULL, ATS_CANONICAL_OER, &asn_DEF_ManagementRequest, mreq_set, b_oer, 128); asn_enc_rval_t enc = asn_encode_to_buffer(NULL, ATS_CANONICAL_OER, &asn_DEF_ManagementRequest, mreq_set, b_oer, 128);
if (enc.encoded != -1) { if (enc.encoded != -1) {
printf("Sending MReq get\n");
fflush(stdout);
void* management_socket = zmq_socket(facilities->zmq.ctx, ZMQ_REQ); void* management_socket = zmq_socket(facilities->zmq.ctx, ZMQ_REQ);
zmq_connect(management_socket, facilities->zmq.management_address); zmq_connect(management_socket, facilities->zmq.management_address);
zmq_send(management_socket, b_oer, enc.encoded, 0); zmq_send(management_socket, b_oer, enc.encoded, 0);
uint8_t code; uint8_t code;
zmq_recv(management_socket, &code, 1, 0); zmq_recv(management_socket, &code, 1, 0);
zmq_close(management_socket); zmq_close(management_socket);
printf("OK\n");
fflush(stdout);
} }
ASN_STRUCT_FREE(asn_DEF_ManagementRequest, mreq_set); ASN_STRUCT_FREE(asn_DEF_ManagementRequest, mreq_set);
@ -316,8 +320,12 @@ int facilities_config(void* facilities_s) {
uint8_t buffer[256]; uint8_t buffer[256];
enc = oer_encode_to_buffer(&asn_DEF_ManagementRequest, NULL, mreq, buffer, 256); enc = oer_encode_to_buffer(&asn_DEF_ManagementRequest, NULL, mreq, buffer, 256);
printf("Sending MReq get\n");
fflush(stdout);
zmq_send(management_socket, buffer, enc.encoded, 0); zmq_send(management_socket, buffer, enc.encoded, 0);
zmq_recv(management_socket, buffer, 256, 0); zmq_recv(management_socket, buffer, 256, 0);
printf("OK\n");
fflush(stdout);
ManagementReply_t* mrep = calloc(1, sizeof(ManagementReply_t)); ManagementReply_t* mrep = calloc(1, sizeof(ManagementReply_t));
oer_decode(NULL, &asn_DEF_ManagementReply, (void**) &mrep, buffer, 256); oer_decode(NULL, &asn_DEF_ManagementReply, (void**) &mrep, buffer, 256);