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

Fix PCM enc

This commit is contained in:
emanuel 2022-03-14 16:45:54 +00:00
parent 9799900d27
commit a25d16f6c6
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/facilities.c
View File

@ -792,8 +792,7 @@ int main() {
for (int i = 0; i < facilities.zmq.n_responders; ++i) { for (int i = 0; i < facilities.zmq.n_responders; ++i) {
if (facilities.zmq.responders[i].revents) { if (facilities.zmq.responders[i].revents) {
rl = zmq_recv(facilities.zmq.responders[i].socket, buffer, ITSS_SDU_MAX_LEN, 0); rl = zmq_recv(facilities.zmq.responders[i].socket, buffer, ITSS_SDU_MAX_LEN, 0);
switch (buffer[0]) { /* source */
switch (buffer[0]) {
case ITSS_NETWORKING: case ITSS_NETWORKING:
networking_indication(&facilities, facilities.zmq.responders[i].socket, buffer+1, rl); networking_indication(&facilities, facilities.zmq.responders[i].socket, buffer+1, rl);
break; break;

3
src/pcm.c
View File

@ -107,6 +107,7 @@ static int pcm_check_handle_request(facilities_t* facilities, PCM_t* pcm, mc_nei
pcm_rep->pcm.chain->link.buf = malloc(8); pcm_rep->pcm.chain->link.buf = malloc(8);
pcm_rep->pcm.chain->link.size = 8; pcm_rep->pcm.chain->link.size = 8;
memcpy(pcm_rep->pcm.chain->link.buf, coordination->chain.link, 8); memcpy(pcm_rep->pcm.chain->link.buf, coordination->chain.link, 8);
pcm->pcm.chain->area.present = ChainGeoRegion_PR_circle;
} }
pthread_mutex_unlock(&facilities->coordination.lock); pthread_mutex_unlock(&facilities->coordination.lock);
@ -301,6 +302,7 @@ static int pcm_check_intersection_detected(facilities_t* facilities, PCM_t* pcm,
pcm_req->pcm.chain->link.buf = malloc(8); pcm_req->pcm.chain->link.buf = malloc(8);
pcm_req->pcm.chain->link.size = 8; pcm_req->pcm.chain->link.size = 8;
memcpy(pcm_req->pcm.chain->link.buf, coordination->chain.link, 8); memcpy(pcm_req->pcm.chain->link.buf, coordination->chain.link, 8);
pcm->pcm.chain->area.present = ChainGeoRegion_PR_circle;
} }
pthread_mutex_unlock(&facilities->coordination.lock); pthread_mutex_unlock(&facilities->coordination.lock);
@ -570,6 +572,7 @@ static int mk_pcm(facilities_t* facilities, uint8_t* pcm_uper, uint16_t* pcm_upe
pcm->pcm.chain->link.buf = malloc(8); pcm->pcm.chain->link.buf = malloc(8);
pcm->pcm.chain->link.size = 8; pcm->pcm.chain->link.size = 8;
memcpy(pcm->pcm.chain->link.buf, coordination->chain.link, 8); memcpy(pcm->pcm.chain->link.buf, coordination->chain.link, 8);
pcm->pcm.chain->area.present = ChainGeoRegion_PR_circle;
} }
if (facilities->station_type == StationType_roadSideUnit) { if (facilities->station_type == StationType_roadSideUnit) {