关于处理积压文件的问题.

baiseqiji

大家好!麻烦各位大虾帮我看下,我写了个既做客户端又做服务端的程序,当作为客户端时一旦与服务端断开,就将从另一个客户端接受来的短信直接写入文件,到10条短信后将其转移到另一个目录,另一个线程负责处理那个目录下得所有积压文件.但是我在每产生一条短信调用SaveSmsFile时,调用10次,却只有一条短信入文件!实在不知道什么原因,麻烦各位了.我用的是AIX系统



void SaveSmsFile(char *nBuf_, char * length)
{

        time_t timer;
        struct tm *tmS;
        char str[30];
        int MaxValue, MinValue, tempnum;
        char len[5];

        pthread_mutex_lock(&g_mCRITICAL_SECTION);

        memset(len,0,sizeof(len));
        memset(str, 0, sizeof(str));
       memcpy(len,length,sizeof(len));

        char len[5];

        pthread_mutex_lock(&g_mCRITICAL_SECTION);

        memset(len,0,sizeof(len));
        memset(str, 0, sizeof(str));
       memcpy(len,length,sizeof(len));


        if (g_smsnum > 10)
        {

                if (smsfile != NULL)
                {
                        fclose(smsfile);
                        smsfile = NULL;
                        rename(g_filename, g_filename2);
                        remove(g_filename);

                        printf("file%s:%s\n", g_filename, g_filename2);

                }
                g_smsnum = 0;
                printf("333333333333\n");
        }
        if (smsfile == NULL)
        {
                MinValue = 10;
                MaxValue = 8000;
                timer = time(NULL);
                tmS = localtime(&timer);
                strftime(str, 20, "%Y%m%d%H%M%S", tmS);
                FileIndex++;
                srand((unsigned)time(NULL));
                tempnum = rand() % (MaxValue - MinValue) + MinValue + FileIndex;
                sprintf(g_filename2, "%s/data/SMSDAT/pushdat/%s%dsms.dat", getenv("HOME"), str, tempnum);

                printf("777777777777777777777777\n");

                if (access(g_filename, F_OK) == 0)      //文件是否存在
                {
                        printf("44444444444444444444\n");
                        rename(g_filename, g_filename2);
                        remove(g_filename);
                }
                smsfile = fopen(g_filename, "wb");
        }
        if (smsfile != NULL)
        {

                fwrite((char *)nBuf_, 1, atoi(len), smsfile);
                g_smsnum++;
                fflush(smsfile);
        }
        pthread_mutex_unlock(&g_mCRITICAL_SECTION);
}