TMS320C6678: 6678 udp组播（client）的例程

static void UDP_Recv_GDJ_Tsk(void)
{
    SOCKET          sudp = INVALID_SOCKET;
    char*           pBufPing = NULL,*pBufPong = NULL;
    HANDLE          hBuffer;
    int32_t         bytes;
    uint32_t        tsMsec, ts1Msec, startMsec, endMsec;
    uint32_t        ts, ts1, tn;
    uint32_t        totalBytes = 0;
    int32_t         counter = 0;
    float           lost_rate =0;
    struct timeval  timeout;
    struct sockaddr_in sin1,sin2;
    struct ip_mreq group;
    uint32_t FrameNum0 = 0;
    char flag_Firt= 1;

    int *pData;
    pData = GDJDATA_PING;
    Task_sleep(150);
//    Semaphore_pend(sem5_START_RECV_GDJ, BIOS_WAIT_FOREVER);
    printf( "3 UDP_Recv_GDJ_Tsk started\n");

    /* Allocate the file environment for this task */
    fdOpenSession(TaskSelf());

    /* 1 Create the main UDP listen socket */
    sudp = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
    if(sudp == INVALID_SOCKET) {
        printf( "Failed to create the receive socket \n");
        goto leave;
    }

    /* 2 Set Port = 65000, leaving IP address = Any */
    bzero(&sin1, sizeof(struct sockaddr_in));
    sin1.sin_family = AF_INET;
    sin1.sin_len    = sizeof(sin1);
    //sin1.sin_addr.s_addr    = inet_addr("224.0.0.88");
    sin1.sin_addr.s_addr    = inet_addr(INADDR_ANY);
    sin1.sin_port   = htons(65000);

    /* 3 Bind the socket */
    if(bind( sudp, (PSA) &sin1, sizeof(sin1)) < 0) {
        printf("Failed to bind the receive socket \n");
        goto leave;
    }

    /* Set a time out for the receive in case there is data loss.. time out is in seconds */
    timeout.tv_sec  = 5;    /* wait up to 5 seconds per packet */
    timeout.tv_usec = 0;
    if(setsockopt(sudp, SOL_SOCKET, SO_RCVTIMEO, &timeout, sizeof(timeout)) < 0) {
        printf( "Failed to set the sockopt for receive socket \n");
        goto leave;
    }
	//4 join multicast
    bzero(&group, sizeof(struct ip_mreq));
    group.imr_multiaddr.s_addr = inet_addr("224.0.0.88");//组播IP
    group.imr_interface.s_addr = inet_addr("192.168.172.110");//本机IP

    if(setsockopt(sudp, IPPROTO_IP, IP_ADD_MEMBERSHIP, &group, sizeof(group)) < 0) {
        printf("Failed to adding multicast group, %d\n", fdError());
        goto leave;
    }
    bzero(&sin2, sizeof(struct sockaddr_in));


    /* Allocate a working buffer */
    if(!(pBufPing = (char *)malloc(2048))) {
        printf("UDP_Send_ZT_Tsk Failed pBufPing buffer allocation\n");
        goto leave;
    }

    totalBytes = 0;
    int tmp;
    tmp=sizeof(sin2);
    for(;;){

        bytes = (int)recvncfrom(sudp, (void **)&pBufPing, 0, (PSA)&sin2, &tmp, &hBuffer);

    }


leave:
    if(pBufPing) {
        free(pBufPing);
    }
    if(pBufPong) {
        free(pBufPong);
    }
    if(sudp != INVALID_SOCKET)
       fdClose(sudp);
    UARTprintf(&uart0cfg,"leave : %d \n", fdError());
    TaskSleep(2000);
    fdCloseSession(TaskSelf());
    TaskDestroy(TaskSelf());
    return;
}