Commit f2f0313b authored by Danil Ruban's avatar Danil Ruban Committed by jperaldi

bugz #123365 fix sync inside VT

parent 94ddb56d
...@@ -289,7 +289,6 @@ static void ss_send_vtp_resp(struct VirtualTimeInfo_Type *virtualTime) ...@@ -289,7 +289,6 @@ static void ss_send_vtp_resp(struct VirtualTimeInfo_Type *virtualTime)
} }
req->tinfo.sfn = virtualTime->TimingInfo.SFN.v.Number;
req->tinfo.sfn = virtualTime->TimingInfo.SFN.v.Number; req->tinfo.sfn = virtualTime->TimingInfo.SFN.v.Number;
req->tinfo.sf = virtualTime->TimingInfo.Subframe.v.Number; req->tinfo.sf = virtualTime->TimingInfo.Subframe.v.Number;
...@@ -398,16 +397,6 @@ uint8_t ss_gNB_vtp_process_itti_msg(void) ...@@ -398,16 +397,6 @@ uint8_t ss_gNB_vtp_process_itti_msg(void)
ss_vtp_send_tinfo(TASK_VTP, &tinfo); ss_vtp_send_tinfo(TASK_VTP, &tinfo);
} }
} }
break;
case SS_VTP_PROXY_UPD:
{
LOG_A(GNB_APP, "[SS-VTP] VTP_Update receieved from proxy %s cmd: %d SFN: %d SF: %d\n",
ITTI_MSG_ORIGIN_NAME(received_msg), SS_VTP_PROXY_UPD(received_msg).cmd,
SS_VTP_PROXY_UPD(received_msg).tinfo.sfn, SS_VTP_PROXY_UPD(received_msg).tinfo.sf);
/** Send response here */
ss_vtp_send_tinfo(TASK_VTP, &SS_VTP_PROXY_UPD(received_msg).tinfo);
}
break; break;
case TERMINATE_MESSAGE: case TERMINATE_MESSAGE:
...@@ -469,6 +458,21 @@ int ss_gNB_vtp_init(void) ...@@ -469,6 +458,21 @@ int ss_gNB_vtp_init(void)
itti_mark_task_ready(TASK_VTP); itti_mark_task_ready(TASK_VTP);
return 0; return 0;
} }
static void ss_gNB_vt_ena(void) {
VtpCmdReq_t *req = (VtpCmdReq_t *)malloc(sizeof(VtpCmdReq_t));
req->header.preamble = 0xFEEDC0DE;
req->header.msg_id = SS_VTP_ENABLE;
req->header.length = sizeof(proxy_ss_header_t);
req->header.cell_id = SS_context.cellId;
req->tinfo.mu = -1;
req->tinfo.sfn = 0;
req->tinfo.sf = 0;
req->tinfo.slot = 0;
LOG_A(GNB_APP, "[SS-VTP] VT enable sent \n");
vtp_send_proxy((void *)req, sizeof(VtpCmdReq_t));
}
static void ss_gNB_wait_first_msg(void) static void ss_gNB_wait_first_msg(void)
{ {
const size_t size = 16 * 1024; const size_t size = 16 * 1024;
...@@ -481,7 +485,21 @@ static void ss_gNB_wait_first_msg(void) ...@@ -481,7 +485,21 @@ static void ss_gNB_wait_first_msg(void)
if (ret == MSG_SysVTEnquireTimingAck_userId || ret == -ACP_PEER_CONNECTED) if (ret == MSG_SysVTEnquireTimingAck_userId || ret == -ACP_PEER_CONNECTED)
{ {
LOG_A(GNB_APP, "[SS_VTP] First VT-ACK From Client Received (on-start) \n"); LOG_A(GNB_APP, "[SS_VTP] First VT-ACK From Client Received (on-start) \n");
struct VirtualTimeInfo_Type *virtualTime = NULL;
if (acpSysVTEnquireTimingAckDecSrv(ctx_vtp_g, buffer, msg_sz, &virtualTime) != 0)
{
LOG_E(GNB_APP, "[SS-VTP] acpVngProcessDecSrv failed \n");
break;
}
if (virtualTime->Enable) {
ss_gNB_vt_ena();
}
break; break;
_ss_log_vt(virtualTime, " => (enable message) ");
acpSysVTEnquireTimingAckFreeSrv(virtualTime);
} }
LOG_A(GNB_APP, "[SS_VTP] Waiting for First VT-ACK From Client(on-start) \n"); LOG_A(GNB_APP, "[SS_VTP] Waiting for First VT-ACK From Client(on-start) \n");
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment