fstream некорректно работает в потоке созданном CreateThread

DWORD WINAPI threadProc(const LPVOID lpParam)
{
     // инициализация сокета, подключение к серверу, открытие файлов и другое
     int rlen = 1;
     while (rlen > 0) // пока функция recv получает какое-то кол-во байт
     {
 
         rlen = recv(sock, rbuf, MAX_RECV_BUF_SIZE, 0);
 
         // принимаем TCP пакеты, в каждом пакете может содержаться несколько сообщений разделенных '\n'
         // я достаю каждое сообщение из очередного принятого пакета и помещаю в вектор messages методом push_back
         // ...
         
         // вот собственно, код записи в файл
         for (std::vector<std::string>::iterator it = messages.begin(); it != messages.end(); ++it)
         {
              outfile << *it << "\n\n";
         }
 
          // ...
          // очистим вектор разобранных сообщений
          messages.clear();
      }
      
      // освобождение всех дескрипторов, закрытие файлов, сокетов и выход из потока
      return 0;
}
 
int main()
{
     // ...
     HANDLE hThread = CreateThread(NULL, 0, &threadProc, NULL, NULL, NULL);
     // ...
}

DWORD WINAPI threadProc(const LPVOID lpParam)
{
    flagRunningTelThread = true; // отметим, что поток начал свою работу
 
    WSAData wsa;
    SOCKADDR_IN telServ;
 
    if (WSAStartup(0x0202, &wsa) != 0)
    {
        return 0;
    }
 
    sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    if (sock <= 0)
    {
        WSACleanup();
        return 0;
    }
 
    telServ.sin_family = AF_INET;
    telServ.sin_port = htons(Review::settings_file.inputPort); // порт сервера телеметрии
    telServ.sin_addr.s_addr = inet_addr(Review::settings_file.inputIP.c_str()); // IP адрес сервера
 
    // узнаем сегодняшнюю дату
    QDate curDate = QDate::currentDate();
    curDate.toString("yyyy-MM-dd");
    std::string strCurDate(curDate.toString("yyyy-MM-dd").toLocal8Bit().constData());
    std::string curDateFileName = "\\data\\" + strCurDate + ".txt";
    std::string strPrivDate = strCurDate;
 
    // узнаем текущую директорию приложения
    std::string currentDir = getCurrentDir();
 
    if(fileExists(currentDir + curDateFileName)) // если файл с сегодняшней датой уже существует
    {
        outfile.open(currentDir + curDateFileName, std::ios_base::app); // откроем его для записи в конец
    }
    else
    {
        // иначе, создадим новый файл с сегодняшней датой и откроем его для записи
        outfile.open(currentDir + curDateFileName, std::ios_base::out);
    }
 
    if(!outfile.is_open()) // произошла ошибка
        return 0;
 
    const int MAX_RECV_BUF_SIZE = 1024;
 
    if (::connect(sock, (SOCKADDR *)&telServ, sizeof(telServ)) != SOCKET_ERROR)
    {
        int rlen = 1; // кол-во принятых байт функцией recv
        char rbuf[MAX_RECV_BUF_SIZE]; // принимаем данные порциями по 1024 байт
        int messageCount = 1; // счетчик полученных сообщений
 
        std::string sep = "\n";
        std::size_t sep_size = sep.size();
        std::string temp;
        std::string privMessagePart; // предыдущая часть сообщения
 
        while (rlen > 0) // пока функция recv получает какое-то кол-во байт
        {
            // проверим, не пора ли нам завершить свою работу
            if(flagRunningTelThread == false)
            {
                break;
            }
 
            rlen = recv(sock, rbuf, MAX_RECV_BUF_SIZE, 0);
            // получена новая порция данных
 
            // узнаем дату получения
            QDate curDate = QDate::currentDate();
            std::string strCurDate(curDate.toString("yyyy-MM-dd").toLocal8Bit().constData());
 
            // узнаем время получения с точностью до миллисекунд
            QTime curTime = QTime::currentTime();
            std::string strCurTime(curTime.toString("hh:mm:ss.zzz").toLocal8Bit().constData());
 
            if(strCurDate != strPrivDate) // если уже начался новый день
            {
                // закроем старый файл
                outfile.close();
 
                // создадим и откроем новый файл с датой нового (только что наступившего дня)
                std::string curDateFileName = "\\data\\" + strCurDate + ".txt";
                outfile.open(currentDir + curDateFileName, std::ios_base::app); // открываем для записи в конец файла
                if(!outfile.is_open())
                    return 0;
 
                // запомним текущий день
                strPrivDate = strCurDate;
 
                // теперь будем записывать в новый файл
            }
 
            // теперь необходимо извлечь из этих данных сообщение
 
            // преобразуем принятые данные в std::string, чтобы с ними было удобней работать
            std::string recvBuff(rbuf);
 
            std::string borderMessage; // полное сообщение, которое было разделено по двум пакетам данных
 
            std::vector<std::string> messages; // все полученные сообщения в очередном пакете данных
 
            int q = 0;
 
            // вот код разделения сообщений
            while (1)
            {
                temp = recvBuff.substr(0, recvBuff.find(sep));
 
                if (q == 0)
                {
                    borderMessage = privMessagePart + temp;
                    messages.push_back(borderMessage);
                }
                else
                {
                    if (temp.size() == recvBuff.size())
                    {
                        privMessagePart = temp;
                        break; // переходим к следующему пакету данных
                    }
                    else
                    {
                        messages.push_back(temp);
                    }
                }
 
                if (temp.size() != recvBuff.size())
                {
                    recvBuff = recvBuff.substr(temp.size() + sep_size);
                }
                ++q;
            }
 
            for (std::vector<std::string>::iterator it = messages.begin(); it != messages.end(); ++it)
            {
                // сформируем строку json сообщения
                std::string jsonStr = std::to_string(Telemetry::threadsCount) + ": {\"id\":" + std::to_string(messageCount) +
                ",\"timestamp\":\"" + strCurDate + " " + strCurTime +
                "\",\"message\":\"" + *it + "\"}";
 
                ++messageCount;
 
                outfile << jsonStr << "\n\n";
            }
            
            // перешлём полученные сообщения всем WebSocket клиентам
            server_instance.sendToAllClients(jsonStr); // эта функция по факту не выполняется, потому что я тестировал программку без подключеных клиентов
 
            // очистим вектор разобранных сообщений
            messages.clear();
           
 
        } // end while (rlen > 0)
    }
 
    closesocket(sock);
    WSACleanup();
    if(outfile.is_open()) // если файл все еще открыт
        outfile.close(); // закроем его
    return 0;
}

rlen = recv(sock, rbuf, MAX_RECV_BUF_SIZE, 0);
std::string recvBuff(rbuf);
// сформировал json строку
// jsonStr = ... + recvBuff ...
outfile << jsonStr << "\n\n";

hTelemetryThread = CreateThread(NULL, 0, &threadProc, NULL, THREAD_PRIORITY_NORMAL, NULL);
SetThreadPriority(hTelemetryThread, THREAD_PRIORITY_HIGHEST);
if(hTelemetryThread == NULL)
{
    // обработка ошибки
}

char allSymbols[] = "qwertyuiopasdfghjklzxcvbnmQWERTYUIOPASDFGHJKLZXCVBNM1234567890";
 
// ...
 
for (int i = 0; i < 1000; ++i)
{
     int delayTime = getRandomNumber(250, 1000); // интервал задержки (мсек) между отправками сообщений
     int messLength = getRandomNumber(25, 50); // длина очередного сообщения
     int messLength = 25; // если длина сообщения константа, то все нормально работает, сообщения записываются правильно
 
     // генерируем сообщение
     // если использовать такой способ генерации, то плохо записывается в файл
     int buffInd = 0;
     for (; buffInd < messLength; ++buffInd)
         sendBuff[buffInd] = allSymbols[getRandomNumber(0, strlen(allSymbols)-1)];
     sendBuff[buffInd] = '\n';
     sendBuff[buffInd + 1] = '\0';
 
     // если вместо генерации случайных сообщений, отправлять такую строку, то все нормально работает
     //wsprintfA(sendBuff, "%s %d\n", "message from server", i+1);
 
     // отправляем клиенту
     if ((slen = send(connSock, sendBuff, strlen(sendBuff), 0)) != strlen(sendBuff))
     {
         nstd::cout << "send() returned " << slen << ", but we need to send " << strlen(sendBuff) << " bytes! something went wrong" << std::endl;
         break;
     }
     Sleep(delayTime);
}