@@ -118,7 +118,7 @@ bool CMdUserApi::IsErrorRspInfo(const char* szSource, CThostFtdcRspInfoField *pR
118118 strcpy (pField->Text , pRspInfo->ErrorMsg );
119119 strcpy (pField->Source , szSource);
120120
121- m_msgQueue->Input_NoCopy (ResponeType::ResponeType_OnRtnError , m_msgQueue, m_pClass, bIsLast, 0 , pField, sizeof (ErrorField), nullptr , 0 , nullptr , 0 );
121+ m_msgQueue->Input_NoCopy (ResponseType::ResponseType_OnRtnError , m_msgQueue, m_pClass, bIsLast, 0 , pField, sizeof (ErrorField), nullptr , 0 , nullptr , 0 );
122122 }
123123 return bRet;
124124}
@@ -195,11 +195,11 @@ int CMdUserApi::_Init()
195195
196196 sprintf (pField->Message , " CopyFile:%s" , lpMsgBuf);
197197
198- m_msgQueue->Input_NoCopy (ResponeType::ResponeType_OnLog , m_msgQueue, m_pClass, true , 0 , pField, sizeof (LogField), nullptr , 0 , nullptr , 0 );
198+ m_msgQueue->Input_NoCopy (ResponseType::ResponseType_OnLog , m_msgQueue, m_pClass, true , 0 , pField, sizeof (LogField), nullptr , 0 , nullptr , 0 );
199199 }
200200#endif // KS_COPYFILE
201201
202- m_msgQueue->Input_NoCopy (ResponeType::ResponeType_OnConnectionStatus , m_msgQueue, m_pClass, ConnectionStatus::ConnectionStatus_Initialized, 0 , nullptr , 0 , nullptr , 0 , nullptr , 0 );
202+ m_msgQueue->Input_NoCopy (ResponseType::ResponseType_OnConnectionStatus , m_msgQueue, m_pClass, ConnectionStatus::ConnectionStatus_Initialized, 0 , nullptr , 0 , nullptr , 0 , nullptr , 0 );
203203
204204 m_pApi = CThostFtdcMdApi::CreateFtdcMdApi (pszPath, m_ServerInfo.IsUsingUdp , m_ServerInfo.IsMulticast );
205205 delete[] pszPath;
@@ -226,7 +226,7 @@ int CMdUserApi::_Init()
226226
227227 // 初始化连接
228228 m_pApi->Init ();
229- m_msgQueue->Input_NoCopy (ResponeType::ResponeType_OnConnectionStatus , m_msgQueue, m_pClass, ConnectionStatus::ConnectionStatus_Connecting, 0 , nullptr , 0 , nullptr , 0 , nullptr , 0 );
229+ m_msgQueue->Input_NoCopy (ResponseType::ResponseType_OnConnectionStatus , m_msgQueue, m_pClass, ConnectionStatus::ConnectionStatus_Connecting, 0 , nullptr , 0 , nullptr , 0 , nullptr , 0 );
230230 }
231231 else
232232 {
@@ -235,7 +235,7 @@ int CMdUserApi::_Init()
235235 pField->RawErrorID = 0 ;
236236 strncpy (pField->Text , " (Api==null)" , sizeof (Char256Type));
237237
238- m_msgQueue->Input_NoCopy (ResponeType::ResponeType_OnConnectionStatus , m_msgQueue, m_pClass, ConnectionStatus::ConnectionStatus_Disconnected, 0 , pField, sizeof (RspUserLoginField), nullptr , 0 , nullptr , 0 );
238+ m_msgQueue->Input_NoCopy (ResponseType::ResponseType_OnConnectionStatus , m_msgQueue, m_pClass, ConnectionStatus::ConnectionStatus_Disconnected, 0 , pField, sizeof (RspUserLoginField), nullptr , 0 , nullptr , 0 );
239239 }
240240
241241#ifdef KS_COPYFILE
@@ -262,7 +262,7 @@ void CMdUserApi::ReqUserLogin()
262262
263263int CMdUserApi::_ReqUserLogin (char type, void * pApi1, void * pApi2, double double1, double double2, void * ptr1, int size1, void * ptr2, int size2, void * ptr3, int size3)
264264{
265- m_msgQueue->Input_NoCopy (ResponeType::ResponeType_OnConnectionStatus , m_msgQueue, m_pClass, ConnectionStatus::ConnectionStatus_Logining, 0 , nullptr , 0 , nullptr , 0 , nullptr , 0 );
265+ m_msgQueue->Input_NoCopy (ResponseType::ResponseType_OnConnectionStatus , m_msgQueue, m_pClass, ConnectionStatus::ConnectionStatus_Logining, 0 , nullptr , 0 , nullptr , 0 , nullptr , 0 );
266266 return m_pApi->ReqUserLogin ((CThostFtdcReqUserLoginField*)ptr1, ++m_lRequestID);
267267}
268268
@@ -286,7 +286,7 @@ void CMdUserApi::Disconnect()
286286
287287 // 全清理,只留最后一个
288288 m_msgQueue->Clear ();
289- m_msgQueue->Input_NoCopy (ResponeType::ResponeType_OnConnectionStatus , m_msgQueue, m_pClass, ConnectionStatus::ConnectionStatus_Disconnected, 0 , nullptr , 0 , nullptr , 0 , nullptr , 0 );
289+ m_msgQueue->Input_NoCopy (ResponseType::ResponseType_OnConnectionStatus , m_msgQueue, m_pClass, ConnectionStatus::ConnectionStatus_Disconnected, 0 , nullptr , 0 , nullptr , 0 , nullptr , 0 );
290290 // 主动触发
291291 m_msgQueue->Process ();
292292 }
@@ -463,7 +463,7 @@ void CMdUserApi::UnsubscribeQuote(const string& szInstrumentIDs, const string& s
463463
464464void CMdUserApi::OnFrontConnected ()
465465{
466- m_msgQueue->Input_NoCopy (ResponeType::ResponeType_OnConnectionStatus , m_msgQueue, m_pClass, ConnectionStatus::ConnectionStatus_Connected, 0 , nullptr , 0 , nullptr , 0 , nullptr , 0 );
466+ m_msgQueue->Input_NoCopy (ResponseType::ResponseType_OnConnectionStatus , m_msgQueue, m_pClass, ConnectionStatus::ConnectionStatus_Connected, 0 , nullptr , 0 , nullptr , 0 , nullptr , 0 );
467467
468468 // 连接成功后自动请求登录
469469 ReqUserLogin ();
@@ -476,7 +476,7 @@ void CMdUserApi::OnFrontDisconnected(int nReason)
476476 pField->RawErrorID = nReason;
477477 GetOnFrontDisconnectedMsg (nReason, pField->Text );
478478
479- m_msgQueue->Input_NoCopy (ResponeType::ResponeType_OnConnectionStatus , m_msgQueue, m_pClass, ConnectionStatus::ConnectionStatus_Disconnected, 0 , pField, sizeof (RspUserLoginField), nullptr , 0 , nullptr , 0 );
479+ m_msgQueue->Input_NoCopy (ResponseType::ResponseType_OnConnectionStatus , m_msgQueue, m_pClass, ConnectionStatus::ConnectionStatus_Disconnected, 0 , pField, sizeof (RspUserLoginField), nullptr , 0 , nullptr , 0 );
480480}
481481
482482void CMdUserApi::OnRspUserLogin (CThostFtdcRspUserLoginField *pRspUserLogin, CThostFtdcRspInfoField *pRspInfo, int nRequestID, bool bIsLast)
@@ -492,8 +492,8 @@ void CMdUserApi::OnRspUserLogin(CThostFtdcRspUserLoginField *pRspUserLogin, CTho
492492
493493 sprintf (pField->SessionID , " %d:%d" , pRspUserLogin->FrontID , pRspUserLogin->SessionID );
494494
495- m_msgQueue->Input_NoCopy (ResponeType::ResponeType_OnConnectionStatus , m_msgQueue, m_pClass, ConnectionStatus::ConnectionStatus_Logined, 0 , pField, sizeof (RspUserLoginField), nullptr , 0 , nullptr , 0 );
496- m_msgQueue->Input_NoCopy (ResponeType::ResponeType_OnConnectionStatus , m_msgQueue, m_pClass, ConnectionStatus::ConnectionStatus_Done, 0 , nullptr , 0 , nullptr , 0 , nullptr , 0 );
495+ m_msgQueue->Input_NoCopy (ResponseType::ResponseType_OnConnectionStatus , m_msgQueue, m_pClass, ConnectionStatus::ConnectionStatus_Logined, 0 , pField, sizeof (RspUserLoginField), nullptr , 0 , nullptr , 0 );
496+ m_msgQueue->Input_NoCopy (ResponseType::ResponseType_OnConnectionStatus , m_msgQueue, m_pClass, ConnectionStatus::ConnectionStatus_Done, 0 , nullptr , 0 , nullptr , 0 , nullptr , 0 );
497497
498498 // 有可能断线了,本处是断线重连后重新订阅
499499 set<string> mapOld = m_setInstrumentIDs;// 记下上次订阅的合约
@@ -509,7 +509,7 @@ void CMdUserApi::OnRspUserLogin(CThostFtdcRspUserLoginField *pRspUserLogin, CTho
509509 pField->RawErrorID = pRspInfo->ErrorID ;
510510 strncpy (pField->Text , pRspInfo->ErrorMsg , sizeof (Char256Type));
511511
512- m_msgQueue->Input_NoCopy (ResponeType::ResponeType_OnConnectionStatus , m_msgQueue, m_pClass, ConnectionStatus::ConnectionStatus_Disconnected, 0 , pField, sizeof (RspUserLoginField), nullptr , 0 , nullptr , 0 );
512+ m_msgQueue->Input_NoCopy (ResponseType::ResponseType_OnConnectionStatus , m_msgQueue, m_pClass, ConnectionStatus::ConnectionStatus_Disconnected, 0 , pField, sizeof (RspUserLoginField), nullptr , 0 , nullptr , 0 );
513513 }
514514}
515515
@@ -660,11 +660,11 @@ void CMdUserApi::OnRtnDepthMarketData(CThostFtdcDepthMarketDataField *pDepthMark
660660#ifdef _REMOTE
661661 if (m_remoteQueue)
662662 {
663- m_remoteQueue->Input_Copy (ResponeType::ResponeType_OnRtnDepthMarketData , m_msgQueue, m_pClass, 0 , 0 , pField, pField->Size , nullptr , 0 , nullptr , 0 );
663+ m_remoteQueue->Input_Copy (ResponseType::ResponseType_OnRtnDepthMarketData , m_msgQueue, m_pClass, 0 , 0 , pField, pField->Size , nullptr , 0 , nullptr , 0 );
664664 }
665665#endif
666666
667- m_msgQueue->Input_NoCopy (ResponeType::ResponeType_OnRtnDepthMarketData , m_msgQueue, m_pClass, 0 , 0 , pField, pField->Size , nullptr , 0 , nullptr , 0 );
667+ m_msgQueue->Input_NoCopy (ResponseType::ResponseType_OnRtnDepthMarketData , m_msgQueue, m_pClass, 0 , 0 , pField, pField->Size , nullptr , 0 , nullptr , 0 );
668668 // 要关注一下其内的
669669 // }
670670}
@@ -704,5 +704,5 @@ void CMdUserApi::OnRtnForQuoteRsp(CThostFtdcForQuoteRspField *pForQuoteRsp)
704704 sprintf (pField->Symbol , " %s.%s" , pField->InstrumentID , pField->ExchangeID );
705705 strcpy (pField->QuoteID , pForQuoteRsp->ForQuoteSysID );
706706
707- m_msgQueue->Input_NoCopy (ResponeType::ResponeType_OnRtnQuoteRequest , m_msgQueue, m_pClass, 0 , 0 , pField, sizeof (QuoteRequestField), nullptr , 0 , nullptr , 0 );
707+ m_msgQueue->Input_NoCopy (ResponseType::ResponseType_OnRtnQuoteRequest , m_msgQueue, m_pClass, 0 , 0 , pField, sizeof (QuoteRequestField), nullptr , 0 , nullptr , 0 );
708708}
0 commit comments