Test CI
This commit is contained in:
parent
69c53c51c3
commit
66cf83efe0
|
|
@ -24,9 +24,6 @@ test:
|
||||||
stage: test
|
stage: test
|
||||||
extends: .dependencies
|
extends: .dependencies
|
||||||
script:
|
script:
|
||||||
- pacman -Sy it2s-itss-management-git --noconfirm
|
|
||||||
- sed -i 's/type = "realtime"/type = "fixed"/g' /etc/it2s/itss.toml
|
|
||||||
- nohup /usr/bin/it2s-itss-management &
|
|
||||||
- cd test
|
- cd test
|
||||||
- sh spawn.sh
|
- sh spawn.sh
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -219,16 +219,12 @@ 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);
|
||||||
|
|
||||||
|
|
@ -320,12 +316,8 @@ 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);
|
||||||
|
|
|
||||||
|
|
@ -464,9 +464,6 @@ void* tx(void* fc) {
|
||||||
int main() {
|
int main() {
|
||||||
int rv = 0;
|
int rv = 0;
|
||||||
|
|
||||||
printf("facilities starting...");
|
|
||||||
fflush(stdout);
|
|
||||||
|
|
||||||
syslog_info("[facilities] starting");
|
syslog_info("[facilities] starting");
|
||||||
|
|
||||||
facilities_t facilities;
|
facilities_t facilities;
|
||||||
|
|
|
||||||
|
|
@ -225,7 +225,7 @@ int main() {
|
||||||
|
|
||||||
void* ctx = zmq_ctx_new();
|
void* ctx = zmq_ctx_new();
|
||||||
|
|
||||||
//rv += init(ctx);
|
rv += init(ctx);
|
||||||
if (rv) return 1;
|
if (rv) return 1;
|
||||||
|
|
||||||
rv += forward_up(ctx);
|
rv += forward_up(ctx);
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue