diff --git a/packages/ti/sdo/ipc/nsremote/NameServerMessageQ.c b/packages/ti/sdo/ipc/nsremote/NameServerMessageQ.c
index 156310be09419ece0053d20f0625eba6b1a90d2d..749e532a1efada5a3495df1fac1af611d45662cf 100644 (file)
/*
- * Copyright (c) 2012-2013, Texas Instruments Incorporated
+ * Copyright (c) 2012-2014, Texas Instruments Incorporated
* All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
*/
#define MAXNAMEINCHAR (NameServerMessageQ_maxNameLen / \
(xdc_target__bitsPerChar / 8))
-#define NAMEARRAYSZIE (((MAXNAMEINCHAR - 1) / sizeof(Bits32)) + 1)
+#define NAMEARRAYSIZE (((MAXNAMEINCHAR - 1) / sizeof(Bits32)) + 1)
+
+#define MESSAGEQ_INDEX 0
/* message sent to remote procId */
typedef struct NameServerMsg {
Bits32 requestStatus; /* status of request */
Bits32 reserved; /* reserved field */
/* name of NameServer instance */
- Bits32 instanceName[NAMEARRAYSZIE];
+ Bits32 instanceName[NAMEARRAYSIZE];
/* name of NameServer entry */
- Bits32 name[NAMEARRAYSZIE];
+ Bits32 name[NAMEARRAYSIZE];
} NameServerMsg;
/*
*/
Int NameServerMessageQ_Module_startup(Int phase)
{
- MessageQ_Params messageQParams;
+ MessageQ_Params2 messageQParams;
/* Ensure MessageQ and SyncSwi Module_startup() have completed */
if ((ti_sdo_ipc_MessageQ_Module_startupDone() == FALSE) ||
}
/* Create the message queue for NameServer using SyncSwi */
- MessageQ_Params_init(&messageQParams);
+ MessageQ_Params2_init(&messageQParams);
messageQParams.synchronizer = NameServerMessageQ_module->syncSwiHandle;
+ messageQParams.queueIndex = MESSAGEQ_INDEX;
NameServerMessageQ_module->msgHandle =
- (ti_sdo_ipc_MessageQ_Handle)MessageQ_create(NULL, &messageQParams);
+ (ti_sdo_ipc_MessageQ_Handle)MessageQ_create2(NULL, &messageQParams);
/* assert msgHandle is not null */
Assert_isTrue(NameServerMessageQ_module->msgHandle != NULL,
/* assert this is the first MessageQ created */
Assert_isTrue((MessageQ_getQueueId((MessageQ_Handle)
- NameServerMessageQ_module->msgHandle) & 0xffff) == 0,
+ NameServerMessageQ_module->msgHandle) & 0xffff) == MESSAGEQ_INDEX,
NameServerMessageQ_A_reservedMsgQueueId);
return (Startup_DONE);
Assert_isTrue(len < MAXNAMEINCHAR, NameServerMessageQ_A_nameIsTooLong);
/* copy the name of instance into putMsg */
- strncpy((Char *)msg->instanceName, instanceName, len);
+ strncpy((Char *)msg->instanceName, instanceName, MAXNAMEINCHAR - 1);
+ ((Char *)msg->instanceName) [MAXNAMEINCHAR - 1] = '0';
/* get the length of name */
len = strlen(name);
Assert_isTrue(len < MAXNAMEINCHAR, NameServerMessageQ_A_nameIsTooLong);
/* copy the name of nameserver entry into putMsg */
- strncpy((Char *)msg->name, name, len);
+ strncpy((Char *)msg->name, name, MAXNAMEINCHAR - 1);
+ ((Char *)msg->name) [MAXNAMEINCHAR - 1] = '0';
/* determine the queueId based upon the processor */
- queueId = (UInt32)obj->remoteProcId << 16;
+ queueId = MessageQ_openQueueId(MESSAGEQ_INDEX, obj->remoteProcId);
/* set the reply procId */
MessageQ_setReplyQueue(