MCU: TM4C1294NCPDT
TI-RTOS: v2.01.00.36
NDK: v2.23.01.01
CCS: v6.0.1.0040
SYS/BIOS 6.4..02.27 GA Release Note
===============================================================
Hi all
I want to create two sockets in a .c file. But how to create them in order to ensure these two sockets can be normal communication it?
/*
* ======== udpEcho.c ========
*/
/* XDCtools Header files */
#include <xdc/std.h>
#include <xdc/cfg/global.h>
#include <xdc/runtime/Error.h>
#include <xdc/runtime/Memory.h>
#include <xdc/runtime/System.h>
/* BIOS Header files */
#include <ti/sysbios/BIOS.h>
#include <ti/sysbios/knl/Clock.h>
#include <ti/sysbios/knl/Task.h>
/* NDK Header files */
#include <ti/ndk/inc/netmain.h>
#include <ti/ndk/inc/_stack.h>
/* TI-RTOS Header files */
#include <ti/drivers/GPIO.h>
/* Example/Board Header files */
#include "Board.h"
#define UDPPORT 1000
/*
* ======== udpHandler ========
* Echo back all UDP data received.
*
* Since we are using UDP, the same socket is used for all incoming requests.
*/
Void udpHandler(UArg arg0, UArg arg1)
{
SOCKET lSocket;
struct sockaddr_in sLocalAddr;
struct sockaddr_in client_addr;
struct timeval to;
fd_set readfds;
int addrlen = sizeof(client_addr);
int status;
HANDLE hBuffer;
IPN LocalAddress = 0;
int nbytes;
bool flag = true;
char *buffer;
fdOpenSession(TaskSelf());
lSocket = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
if (lSocket < 0) {
System_printf("udpHandler: socket failed\n");
Task_exit();
return;
}
memset((char *)&sLocalAddr, 0, sizeof(sLocalAddr));
sLocalAddr.sin_family = AF_INET;
sLocalAddr.sin_len = sizeof(sLocalAddr);
sLocalAddr.sin_addr.s_addr = LocalAddress;
sLocalAddr.sin_port = htons(arg0);
status = bind(lSocket, (struct sockaddr *)&sLocalAddr, sizeof(sLocalAddr));
if (status < 0) {
System_printf("udpHandler: bind failed: returned: %d, error: %d\n",
status, fdError());
fdClose(lSocket);
Task_exit();
return;
}
/* Give user time to connect with udpSendReceive client app */
to.tv_sec = 30;
to.tv_usec = 0;
if (setsockopt( lSocket, SOL_SOCKET, SO_SNDTIMEO, &to, sizeof( to ) ) < 0) {
System_printf("udpHandler: setsockopt SO_SNDTIMEO failed\n");
fdClose(lSocket);
Task_exit();
return;
}
if (setsockopt( lSocket, SOL_SOCKET, SO_RCVTIMEO, &to, sizeof( to ) ) < 0) {
System_printf("udpHandler: setsockopt SO_RCVTIMEO failed\n");
fdClose(lSocket);
Task_exit();
return;
}
/* Loop while we receive data */
while (flag) {
/*
* Wait for the reply. Timeout after TIMEOUT seconds (assume UDP
* packet dropped)
*/
FD_ZERO(&readfds);
FD_SET(lSocket, &readfds);
if (fdSelect(0, &readfds, NULL, NULL, NULL) != 1) {
status = fdError();
System_printf("timed out waiting for client\n", status);
continue;
}
nbytes = recvncfrom(lSocket, (void **)&buffer, MSG_WAITALL,
(struct sockaddr *)&client_addr, &addrlen, &hBuffer);
if (nbytes >= 0) {
/* Echo the data back */
sendto(lSocket, (char *)buffer, nbytes, 0,
(struct sockaddr *)&client_addr, sizeof(client_addr));
recvncfree( hBuffer );
}
else {
status = fdError();
if (status == EWOULDBLOCK) {
System_printf("udpHandler: Waiting for client to send UDP data\n");
continue;
}
else {
System_printf(
"udpHandler: recvfrom failed: returned: %d, error: %d\n",
nbytes, status);
fdClose(lSocket);
flag = false;
}
}
}
System_printf("udpHandler stop, lSocket = 0x%x\n", lSocket);
if (lSocket) {
fdClose(lSocket);
}
fdCloseSession(TaskSelf());
/*
* Since deleteTerminatedTasks is set in the cfg file,
* the Task will be deleted when the idle task runs.
*/
Task_exit();
}
/*
* ======== netOpenHook ========
*/
void netOpenHook()
{
Task_Handle taskHandle;
Task_Params taskParams;
Error_Block eb;
/* Make sure Error_Block is initialized */
Error_init(&eb);
/*
* Create the Task that handles UDP "connections."
* arg0 will be the port that this task listens to.
*/
Task_Params_init(&taskParams);
taskParams.stackSize = 1024;
taskParams.priority = 1;
taskParams.arg0 = UDPPORT;
taskHandle = Task_create((Task_FuncPtr)udpHandler, &taskParams, &eb);
if (taskHandle == NULL) {
System_printf("main: Failed to create udpHandler Task\n");
}
}
/*
* ======== main ========
*/
int main(void)
{
/* Call board init functions */
Board_initGeneral();
Board_initGPIO();
Board_initEMAC();
/* Turn on user LED */
GPIO_write(Board_LED0, Board_LED_ON);
System_printf("Starting the UDP Echo example\nSystem provider is set to "
"SysMin. Halt the target to view any SysMin contents in"
" ROV.\n");
/* SysMin will only print to the console when you call flush or exit */
System_flush();
/* Start BIOS */
BIOS_start();
return (0);
}
Should I how to modify it?
I look forward to your reply!
Regards
Lewis
