在某些非固定写入数(C++)后，串行端口会导致死锁
在某些非固定写入数(C++)后，串行端口会导致死锁
提问于 2015-02-10 17:30:10
我一直在用C++编写一个串口应用程序，它可以处理通过虚拟串行端口到我为Arm微处理器编写的蓝牙堆栈的双向通信。
我非常确信，嵌入式方面是好的，因为在另一个主要接收微处理器数据的应用程序中，绝不会造成崩溃。在这个应用程序中，我将从C++串口应用程序向微处理器发送64字节块的二进制数据，并使用简单的协议来控制何时停止发送等等。
我处理这两个应用程序的方式非常相似，所以我想知道当我发送数据而不是接收数据时是否存在差异，这会导致问题。
代码是在Visual 2010中编写和调试的。
，我发现一件不寻常的事情是，这个应用程序工作在一个USB到串行有线连接，但死锁的虚拟com端口！同时调试uprocessor，这方面似乎没有任何问题，那么是什么导致了这个问题呢？。
编辑
Hacving更深入地查看了调用堆栈，挂起正在执行：
ntdll.dll!_ZwWriteFile@36() + 0x15字节
基本上是这样的：
初始化：
brate = CBR_112500;
com_name[0]='C';
com_name[1]='O';
com_name[2]='M';
com_name[3]=com_name[4]=com_name[5]=com_name[6]=0;
printf("Select COM Port: ");
scanf("%s", &com_name[3]);
if (Connect(com_name,brate)!=SLCONNECT_OK)
{
printf("\t\t\t\t....Could not open to port, exiting\r\n");
}连接：
在这里，我最初创建了第二个线程来处理读取，但确定这可能是死锁的原因。然后我删除线程并同步运行所有内容，但仍然存在相同的问题。
int Connect(const char *portname,int baudrate)
{
DCB dev_cont_block;
if (port_h != INVALID_HANDLE_VALUE)
{
return(SLCONNECT_ALREADY_CONNECTED);
}
if(strlen(portname)>4) // if COM10 or above use \\.\COM10
{
char *longportname;
int i;
longportname = (char *) malloc(strlen(portname)+5);
if(longportname != NULL)
{
longportname[0] = '\\';
longportname[1] = '\\';
longportname[2] = '.';
longportname[3] = '\\';
for(i=0;i<strlen(portname);i++)
longportname[4+i]=portname[i];
longportname[4+i] = 0;
port_h = CreateFile(longportname, GENERIC_READ | GENERIC_WRITE ,0,0,OPEN_EXISTING,FILE_ATTRIBUTE_NORMAL,0);
delete(longportname);
}
else
return(SLCONNECT_CONNECT_FAILED);
}
else
port_h = CreateFile(portname, GENERIC_READ | GENERIC_WRITE ,0,0,OPEN_EXISTING,FILE_ATTRIBUTE_NORMAL,0);
if (port_h==INVALID_HANDLE_VALUE)
{
return(SLCONNECT_CONNECT_FAILED);
}
if (GetCommState(port_h,&dev_cont_block))
{
dev_cont_block.BaudRate = baudrate;
dev_cont_block.ByteSize = 8;
dev_cont_block.StopBits = ONESTOPBIT;
dev_cont_block.fParity = FALSE;
dev_cont_block.Parity = NOPARITY;
dev_cont_block.fOutxCtsFlow = TRUE;
dev_cont_block.fOutxDsrFlow = FALSE;
dev_cont_block.fRtsControl = RTS_CONTROL_DISABLE;
if (!SetCommState(port_h, &dev_cont_block)) return(SLCONNECT_SETUP_PORT_FAILED);
}
else return(SLCONNECT_SETUP_PORT_FAILED);
PurgeComm(port_h,PURGE_TXABORT | PURGE_RXABORT | PURGE_TXCLEAR | PURGE_RXCLEAR);
keepLooping=1;
///_beginthread(Watcher,0,this);
//WatcherThread = (HANDLE)_beginthreadex(NULL, 0, Watcher, this, 0, NULL);
return(SLCONNECT_OK);
}主要应用程序
在这里，我等待用户命令启动，将其发送到uprocessor，等待响应，发送包，等待响应等，直到发送完整的二进制文件。
在这里，我省略了一些不相关的部分，比如如何处理文件的结尾，等等。
sendbuf[0] = 'x'; // The 'x' is just a placeholder
sendbuf[1] = 'x';
sendbuf[2] = 'x';
sendbuf[3] = 'x';
sendbuf[4] = 'x';
sendbuf[5] = 'x';
sendbuf[6] = 'x';
sendbuf[7] = 'x';
printf("Press 1 to begin Upgrade\r\n");
if(_getch() == '1')
{
Send('x');
Send('x');
Send('x');
Send('x');
Send('x');
Send('x');
Send('x');
Send('x');
Send('x');
Send('x');
Send('x');
Send('x');
if(Send('x') == SLSEND_OK )
{
printf("=> Note 'Set Firmware Mode'");
}
}
while(1)
{
while(true)
{
ClearCommError(port_h,&l_dwErrors, &l_ComStat);
if(l_ComStat.cbInQue)
{
ReadFile(port_h, &data, 1, &Received, NULL);
if(Received == 1)
{
Received = DllRxD(DataBuffer,64, data );
if(Received > 0)
{
if (DataBuffer[0] == 'x') //Note received
{
printf("\n\r=> Note ");
if(DataBuffer[3] == 'x' && DataBuffer[4] == 'x')
{
if(DataBuffer[5] == 'x')
{
if(DataBuffer[6] == 0x00)
{
printf("'Firmware Packet Received Sucessfully'");
result = 1;
break;
}
else
{
printf("'Error In Packet Message [0x0%d]'",(unsigned int)DataBuffer[6]);
result = -1;
break;
}
}
}
if(DataBuffer[3] =='x' && DataBuffer[4] == 'x')
{
if(DataBuffer[5] == 'x')
{
printf("Mode has changed to: Firmware Upgrade Mode");
result = 2;
break;
}
}
}
else
{
printf("=> ERRROR 'Unexpected Message'");
result = -2;
break;
}
}
}
}
}//while(true)
if(result == 1 || result == 2)
{
UpdateCRC('x', &crc);
UpdateCRC('x', &crc);
UpdateCRC('x', &crc);
UpdateCRC('x', &crc);
UpdateCRC('x', &crc);
UpdateCRC('x', &crc);
UpdateCRC('x', &crc);
UpdateCRC('x', &crc);
for (i = 0; i < 64; i++)
{
fread(&Packet[i],1,1,pFile);
if(feof(pFile))
Packet[i] = 0xFF;
if(Packet[i] == 'x')
{
UpdateCRC(Packet[i],&crc);
UpdateCRC(Packet[i],&crc);
}
else
UpdateCRC(Packet[i],&crc);
}
UpdateCRC('x', &crc);
UpdateCRC('x', &crc);
Send(x); //framing
Send(x);
Send('x');
Send('x');
Send('x');
Send('x');
Send('x');
Send('x');
for (i = 0; i < 64; i++)
{
if(Packet[i] == 'x')
{
Send(Packet[i]); **//this set of sends is where i receive the deadlock error message, it's not always the same place it happens though**
Send(Packet[i]);
}
else
Send(Packet[i]);
}
Send('x');
Send('x');
Send((crc >> 8));
if(Send((crc & 0xFF)) == SLSEND_OK)
{
printf("\n\r\t\t\t\t....Packet Sent (%u Bytes Total)",counter*64);
}发送
这是实际的发送函数。
int Send(unsigned char sdata)
{
unsigned long bytesWritten=0;
unsigned int rtn;
**//This is where the program stops in the source code i can view**
//Error received is "this is the next statement to execute when this thread returns from it's current function"
rtn = WriteFile(port_h,&sdata,1,&bytesWritten,NULL);
if (rtn)
return(SLSEND_OK);
else
return(SLSEND_UNKNOWN_ERROR);
}回答 2
Stack Overflow用户
发布于 2015-02-10 21:26:45
我对这一点一点也不精通。但我在串行口上玩过.
我不确定当我读你的代码时是否遗漏了什么东西，但我不知道你是为写还是读设置了超时。
另外，您如何处理数据终端就绪行？我有很多奇怪的事情都是因为..。
Stack Overflow用户
发布于 2015-02-11 04:47:07
dev_cont_block.fOutxCtsFlow =真；
如果该成员为fOutxCtsFlow，则监视CTS (清空到发送)信号以进行输出流量控制.如果此成员为TRUE，且CTS被关闭，则将暂停输出，直到再次发送CTS为止。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/28438045
复制相关文章
相似问题
腾讯云开发者
