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

CI test

This commit is contained in:
emanuel 2021-05-17 16:55:05 +01:00
parent 6a4f8cba3c
commit d212396fe2
2 changed files with 18 additions and 38 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
test/spawn.sh
View File

@ -1,7 +1,9 @@
mkdir -p /tmp/itss
echo Spawning [facilities] echo Spawning [facilities]
nohup ../build/src/it2s-itss-facilities > /dev/null 2>&1 & nohup ../build/src/it2s-itss-facilities > /dev/null 2>&1 &
echo Running [tester] echo Running tester...
../build/test/./tester ../build/test/./tester
code=$? code=$?

52
test/tester.c
View File

@ -5,10 +5,6 @@
#include <itss-management/ManagementRequest.h> #include <itss-management/ManagementRequest.h>
#include <itss-management/ManagementReply.h> #include <itss-management/ManagementReply.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <dirent.h>
#include <pthread.h> #include <pthread.h>
#include <zmq.h> #include <zmq.h>
#include <unistd.h> #include <unistd.h>
@ -25,22 +21,16 @@ void hex2bin(char* hex, uint8_t** bin, uint16_t* bin_len) {
} }
int init(void* ctx) { int init(void* ctx) {
printf("Initializing management simulator \n"); printf("Simulating [management] ... \n"); fflush(stdout);
fflush(stdout);
void* management_socket = zmq_socket(ctx, ZMQ_REP); void* management_socket = zmq_socket(ctx, ZMQ_REP);
struct stat st = {0};
if (stat("/tmp/itss/", &st) == -1) {
mkdir("/tmp/itss", 0777);
}
int ra = zmq_bind(management_socket, "ipc:///tmp/itss/management"); zmq_bind(management_socket, "ipc:///tmp/itss/management");
uint8_t buffer[2048]; uint8_t buffer[2048];
// Ignore first request (set) // Ignore first request (set)
zmq_recv(management_socket, buffer, 2048, 0); zmq_recv(management_socket, buffer, 2048, 0);
printf(" - Received MREQ.set \n"); printf(" - Received MREQ.set \n"); fflush(stdout);
fflush(stdout);
int code = 0; int code = 0;
zmq_send(management_socket, &code, 1, 0); zmq_send(management_socket, &code, 1, 0);
@ -52,12 +42,10 @@ int init(void* ctx) {
asn_dec_rval_t dec = asn_decode(NULL, ATS_CANONICAL_OER, &asn_DEF_ManagementRequest, (void**) &mreq, buffer, 2048); asn_dec_rval_t dec = asn_decode(NULL, ATS_CANONICAL_OER, &asn_DEF_ManagementRequest, (void**) &mreq, buffer, 2048);
if (dec.code) { if (dec.code) {
rv = 1; rv = 1;
printf(" FAIL: MREQ decode error\n"); printf(" FAIL: MREQ decode error\n"); fflush(stdout);
fflush(stdout);
goto cleanup; goto cleanup;
} }
printf(" - Received MREQ.get\n"); printf(" - Received MREQ.get\n"); fflush(stdout);
fflush(stdout);
ManagementReply_t* mrep = calloc(1, sizeof(ManagementReply_t)); ManagementReply_t* mrep = calloc(1, sizeof(ManagementReply_t));
switch (mreq->present) { switch (mreq->present) {
@ -118,16 +106,14 @@ int init(void* ctx) {
case ManagementRequest_PR_set: case ManagementRequest_PR_set:
default: default:
rv = 1; rv = 1;
printf(" FAIL: MREQ. not GET (%d)\n", mreq->present); printf(" FAIL: MREQ. not GET (%d)\n", mreq->present); fflush(stdout);
fflush(stdout);
goto cleanup; goto cleanup;
} }
asn_enc_rval_t enc = oer_encode_to_buffer(&asn_DEF_ManagementReply, NULL, mrep, buffer, 256); asn_enc_rval_t enc = oer_encode_to_buffer(&asn_DEF_ManagementReply, NULL, mrep, buffer, 256);
zmq_send(management_socket, buffer, enc.encoded, 0); zmq_send(management_socket, buffer, enc.encoded, 0);
printf(" OK\n"); printf(" OK\n"); fflush(stdout);
fflush(stdout);
cleanup: cleanup:
ASN_STRUCT_FREE(asn_DEF_ManagementRequest, mreq); ASN_STRUCT_FREE(asn_DEF_ManagementRequest, mreq);
@ -142,7 +128,6 @@ int cam_gen(void* ctx) {
void* transport_socket = zmq_socket(ctx, ZMQ_REP); void* transport_socket = zmq_socket(ctx, ZMQ_REP);
int rv = zmq_bind(transport_socket, "ipc:///tmp/itss/transport"); int rv = zmq_bind(transport_socket, "ipc:///tmp/itss/transport");
printf("rv %d\n", rv); fflush(stdout);
uint8_t buffer[2048]; uint8_t buffer[2048];
zmq_recv(transport_socket, buffer, 2048, 0); zmq_recv(transport_socket, buffer, 2048, 0);
int code = 0; int code = 0;
@ -170,8 +155,7 @@ int cam_gen(void* ctx) {
int forward_up(void* ctx) { int forward_up(void* ctx) {
printf("Testing forwarding up:\n"); printf("Testing forwarding up:\n"); fflush(stdout);
fflush(stdout);
BTPDataIndication_t* bdi = calloc(1, sizeof(BTPDataIndication_t)); BTPDataIndication_t* bdi = calloc(1, sizeof(BTPDataIndication_t));
char* cam_hex = "02027dfddf4403ca4059bba5f38cc40dba9ffffffc2230eff200e11fc0078082a88a8337fee3fff600004dffea800618d08018efff14003ac68800c77ff8e002263460063bffd1000fb1a30031dffe2800958d30018efff840048c68800c77ffae002c63480063bffbd001a31a40031dfff28002d8cf0018c0"; char* cam_hex = "02027dfddf4403ca4059bba5f38cc40dba9ffffffc2230eff200e11fc0078082a88a8337fee3fff600004dffea800618d08018efff14003ac68800c77ff8e002263460063bffd1000fb1a30031dffe2800958d30018efff840048c68800c77ffae002c63480063bffbd001a31a40031dfff28002d8cf0018c0";
@ -199,12 +183,10 @@ int forward_up(void* ctx) {
zmq_send(facilities_socket, b_bdi_cam, enc.encoded+1, 0); zmq_send(facilities_socket, b_bdi_cam, enc.encoded+1, 0);
zmq_recv(facilities_socket, &code, 1, 0); zmq_recv(facilities_socket, &code, 1, 0);
if (code) { if (code) {
printf(" FAIL\n"); printf(" FAIL\n"); fflush(stdout);
fflush(stdout);
return 1; return 1;
} }
printf(" - Sent CAM BDI (%ldB)\n", bdi->data.size); printf(" - Sent CAM BDI (%ldB)\n", bdi->data.size); fflush(stdout);
fflush(stdout);
void* applications_socket = zmq_socket(ctx, ZMQ_REP); void* applications_socket = zmq_socket(ctx, ZMQ_REP);
@ -220,19 +202,15 @@ int forward_up(void* ctx) {
FacilitiesDataIndication_t* fdi = NULL; FacilitiesDataIndication_t* fdi = NULL;
asn_dec_rval_t dec = asn_decode(NULL, ATS_CANONICAL_OER, &asn_DEF_FacilitiesDataIndication, (void**) &fdi, buffer+1, 2047); asn_dec_rval_t dec = asn_decode(NULL, ATS_CANONICAL_OER, &asn_DEF_FacilitiesDataIndication, (void**) &fdi, buffer+1, 2047);
if (dec.code) { if (dec.code) {
printf(" FAIL\n"); printf(" FAIL\n"); fflush(stdout);
fflush(stdout);
return 1; return 1;
} }
printf(" - Received CAM FDI (%ldB)\n", fdi->data.size); printf(" - Received CAM FDI (%ldB)\n", fdi->data.size); fflush(stdout);
fflush(stdout);
if (fdi->data.size == bdi->data.size) { if (fdi->data.size == bdi->data.size) {
printf(" OK\n"); printf(" OK\n"); fflush(stdout);
fflush(stdout);
} else { } else {
printf(" FAIL\n"); printf(" FAIL\n"); fflush(stdout);
fflush(stdout);
return 1; return 1;
} }
@ -250,7 +228,7 @@ int main() {
if (rv) return 1; if (rv) return 1;
rv += forward_up(ctx); rv += forward_up(ctx);
rv += cam_gen(ctx); //rv += cam_gen(ctx);
return rv; return rv;
} }