论坛徽章:: 0

电梯直达

1楼 [收藏(0)] [报告]

发表于 2009-07-14 18:50 |只看该作者 |倒序浏览

我最近在设计短信收发的模块，其中的一个模块是向网关接口发送短信。其中一个线程负责向LIST容器中插入短信（尾部），另一个线程负责从LIST头部取出短信并与服务端进行通讯。不过在插入短信时malloc出错，请各位帮忙分析下，我现在将部分代码贴出。

/*插入LIST的线程*/
void *start_listinsert_thread(void *vag)
{

      SUBMIT *submit;
      int i;
      int j;
      int ret;

      pthread_detach(pthread_self());

      for (j = 0; j < 100000; j++)
      {

            for (i = 0; i < 100; i++)
            {
                     submit = NULL;
                     submit = (SUBMIT *) malloc(sizeof(SUBMIT));
                     if (submit == NULL)
                     {
                              perror("malloc()"

;
                              exit(1);
                     }

                     memset(submit, 0, sizeof(submit));
                     sprintf(submit->Msg_Content, "短信营业厅测试[%d]", i);
                     memcpy(submit->InData.GWId, "SX05", strlen("SX05"

);
memcpy(submit->FeeType, "1", strlen("1"

);
                     submit->Fee_terminal_type = 0;
                     htonl(submit->Fee_terminal_type);
                     submit->Msg_Fmt = 15;
                     htonl(submit->Msg_Fmt);

                     memcpy(submit->Fee_terminal_Id, "10086", strlen("10086"

);
memcpy(submit->Service_Id, "HELP", strlen("HELP"

);
memcpy(submit->Src_id, "11111", strlen("11111"

);
memcpy(submit->Dest_terminal_Id, "22222", strlen("22222"

);
                     submit->head.commandid = APP_SUBMIT;
                     htonl(submit->head.commandid);
                     submit->Msg_Length = strlen(submit->Msg_Content);
                     htonl(submit->Msg_Length);
                     submit->

k_total = 1;
memcpy(submit->LinkID, "hehhe", strlen("hehhe"

);

                     interface1(submit);

            }
            msleep(50);
      }
}

int interface1(SUBMIT * submit)
{
      int i;
      unsigned char tmp[MAXSIZE];
      int unicode_len;
      int gb_len;
      int ret;

      unicode_len =wgb2unicode((unsigned char *)submit->Msg_Content, tmp, strlen(submit->Msg_Content));
      if (unicode_len > 140)
      {
            printf("短信长度超过140\n"

;
            return -1;
      }

      try
      {
            Submit_list.push_back(submit);
      }
      catch(exception & e)
      {
            cout << "exception: " << e.what() << endl;

            msleep(10);
            return -1;
      }
}

/*负责连接并发送短信的线程*/
void *connect_thread(void *arg)
{
      char ip[IP_MAX];
      unsigned int sndport;
      SUBMIT *submit_tmp;
      SUBMIT submit_test;
      int socketid;
      int ret = 0;
      int len;
      int nSendTime = 0;
      int nSendAfterTime = 0;

      int start = time(NULL);
      int end;

      char filename[512];
      memset(filename, 0, sizeof(filename));
      strcpy(filename,"liqiang_log"

;
      pthread_detach(pthread_self());
      memset(ip, 0, sizeof(ip));

      ret = get_port("ifipcfg", ip, &sndport);
      printf("connect ip[%s] port[%d]\n", ip, sndport);
      if (ret == -1)
      {
            printf("获取IP或端口出错，请查看配置文件\n");
            exit(1);
      }
      else
      {
            printf("获取到ip:%s,端口:%d\n", ip, sndport);
      }

  loop:
      socketid = sndD_bind(ip, sndport);
      if (socketid < 0)
      {
            printf("连接失败\n");

            msleep(500);
            goto loop;
      }

      else
      {
            printf("连接成功\n");
      }

      printf("套接字号:[%d]\n", socketid);

      while (1)
      {

            pthread_mutex_lock(&submit_mutex);

            submit_tmp = NULL;

            submit_tmp = Submit_list.front();       //取出LIST头的数据

            if (submit_tmp != NULL)                      //判断LIST是否为空或到结尾
            {
                     nSendTime = getitime();
                     nSendAfterTime = nSendTime;

                     printf("短信内容:%s########\n", submit_tmp->Msg_Content);

                     /*发送请求给接口机 */
                     ret = Submit(socketid, submit_tmp);
                     if (ret < 0)
                     {
                              printf("发送失败 socket[%d]\n", socketid);
                              pthread_mutex_unlock(&submit_mutex);

                              /*关闭当前socket并重新链接 */
                              close(socketid);

                              goto loop;
                     }
                     else
                     {
                              my_log(filename,submit_tmp->Msg_Content);
                              Submit_list.pop_front();       //从队列中删除
                              free(submit_tmp);
                              pthread_mutex_unlock(&submit_mutex);

                     }
            }
            else
            {
                     pthread_mutex_unlock(&submit_mutex);

                     memset(&submit_test, 0, sizeof(submit_test));
                     end = time(NULL);
                     printf("#######%d########\n", end - start);
                     msleep(1);
                     nSendAfterTime = getitime();
                     if (nSendAfterTime - nSendTime > 50)
                     {
                              /*发送请求给接口机 */

                              submit_test.head.commandid = APP_ACTIVE_TEST;

                              ret = Submit(socketid, &submit_test);
                              if (ret < 0)
                              {
                                    /*关闭当前socket并重新链接 */
                                    close(socketid);
                                    goto loop;
                              }

                              nSendTime = nSendAfterTime;

                              printf("发送心跳检测数据包\n");;
                     }

                     else
                     {
                              msleep(10);
                     }
            }
            msleep(10);
      }
}