commandqueue.cpp

来自「一个支持FTP,SFTP的客户端程序」· C++ 代码 · 共 930 行 · 第 1/2 页

CPP
930 行
字号
12
		}
		else
		{
			BOOL res = m_pFileZillaApi->FileTransfer(TransferFile);
			if (res==FZ_REPLY_WOULDBLOCK)
			{
				m_CommandList.push_back(command);
				return TRUE;
			}
			else if (res==FZ_REPLY_OK)
				return TRUE;
			else
				return FALSE;
		}
	}
}

void CCommandQueue::Cancel()
{
	CMainFrame *pMainFrame=DYNAMIC_DOWNCAST(CMainFrame,AfxGetMainWnd());

	bool didWaitForRetry = false;
	if (m_nRetryCount > 0)
	{
		didWaitForRetry = true;
		CString str;
		if (!m_CommandList.empty() && m_CommandList.front().id == FZ_COMMAND_CONNECT)
		{
			str.LoadString(IDS_ERRORMSG_CANTCONNECT);
			pMainFrame->GetStatusPane()->ShowStatus(str, FZ_LOG_ERROR);
		}
		str.LoadString(IDS_ERRORMSG_INTERRUPTED);
		pMainFrame->GetStatusPane()->ShowStatus(str, FZ_LOG_ERROR);
		m_nRetryCount = 0;
	}
	else
	{
		m_pFileZillaApi->Cancel();
	}

	if (m_CommandList.empty())
		return;


	t_command firstCommand = m_CommandList.front();
	m_CommandList.pop_front();
	while (!m_CommandList.empty())
	{
		t_command command = m_CommandList.front();
		m_CommandList.pop_front();
		if (command.id == FZ_COMMAND_FILETRANSFER)
			pMainFrame->GetQueuePane()->GetListCtrl()->ProcessReply(FZ_REPLY_ERROR|FZ_REPLY_CANCEL);
		else if (command.id == FZ_COMMAND_LIST)
			((CFtpListCtrl *)pMainFrame->GetFtpPane()->GetListCtrl())->ListComplete(FALSE, command.path, command.param1);
	}

	if (!didWaitForRetry)
		m_CommandList.push_back(firstCommand);
}


BOOL CCommandQueue::Disconnect()
{
	t_command command;
	command.id = FZ_COMMAND_DISCONNECT;
	if (!m_CommandList.empty())
	{
		m_CommandList.push_back(command);
		return TRUE;
	}
	else
	{
		if (m_pFileZillaApi->IsConnected()==FZ_REPLY_NOTCONNECTED)
			return TRUE;
		int res=m_pFileZillaApi->Disconnect();
		if (res==FZ_REPLY_WOULDBLOCK)
		{
			m_CommandList.push_back(command);
			return TRUE;
		}
		else if (res==FZ_REPLY_NOTCONNECTED)
			return TRUE;
		else
			return FALSE;
	}
}

BOOL CCommandQueue::IsConnected()
{
	return m_pFileZillaApi->IsConnected()==FZ_REPLY_OK;
}

BOOL CCommandQueue::Command(CString commandStr, BOOL bAddToQueue /*=FALSE*/)
{
	t_command command;
	command.id = FZ_COMMAND_CUSTOMCOMMAND;
	command.param1 = commandStr;
	if (!m_CommandList.empty() && !bAddToQueue) //Don't queue direct commands
		return FALSE;
	else if (!m_CommandList.empty())
	{
		m_CommandList.push_back(command);
		return TRUE;
	}
	else
	{
		int res=m_pFileZillaApi->CustomCommand(commandStr);
		if (res==FZ_REPLY_WOULDBLOCK)
		{
			m_CommandList.push_back(command);
			return TRUE;
		}
		else if (res==FZ_REPLY_OK)
			return TRUE;
		else
			return FALSE;
	}
}

BOOL CCommandQueue::Delete(CString FileName, const CServerPath &path /*=CServerPath()*/)
{
	t_command command;
	command.id = FZ_COMMAND_DELETE;
	command.param1 = FileName;
	command.path = path;
	if (!m_CommandList.empty())
	{
		m_CommandList.push_back(command);
		return TRUE;
	}
	else
	{
		int res = m_pFileZillaApi->Delete(FileName, path);
		if (res==FZ_REPLY_WOULDBLOCK)
		{
			m_CommandList.push_back(command);
			return TRUE;
		}
		else if (res==FZ_REPLY_OK)
			return TRUE;
		else
			return FALSE;
	}
}

BOOL CCommandQueue::RemoveDir(CString DirName, const CServerPath &path /*=CServerPath()*/)
{
	t_command command;
	command.id = FZ_COMMAND_REMOVEDIR;
	command.param1 = DirName;
	command.path = path;
	if (!m_CommandList.empty())
	{
		m_CommandList.push_back(command);
		return TRUE;
	}
	else
	{
		int res=m_pFileZillaApi->RemoveDir(DirName, path);
		if (res==FZ_REPLY_WOULDBLOCK)
		{
			m_CommandList.push_back(command);
			return TRUE;
		}
		else if (res==FZ_REPLY_OK)
			return TRUE;
		else
			return FALSE;
	}
}

BOOL CCommandQueue::MakeDir(const CServerPath &path /*=CServerPath()*/)
{
	t_command command;
	command.id = FZ_COMMAND_MAKEDIR;
	command.path = path;
	if (!m_CommandList.empty())
	{
		m_CommandList.push_back(command);
		return TRUE;
	}
	else
	{
		int res = m_pFileZillaApi->MakeDir(path);
		if (res == FZ_REPLY_WOULDBLOCK)
		{
			m_CommandList.push_back(command);
			return TRUE;
		}
		else if (res == FZ_REPLY_OK)
			return TRUE;
		else
			return FALSE;
	}
}

BOOL CCommandQueue::Rename(CString oldName, CString newName, const CServerPath &path /*=CServerPath()*/, const CServerPath &newPath /*=CServerPath()*/)
{
	t_command command;
	command.id = FZ_COMMAND_RENAME;
	command.param1 = oldName;
	command.param2 = newName;
	command.path = path;
	command.newPath = newPath;
	if (!m_CommandList.empty())
	{
		m_CommandList.push_back(command);
		return TRUE;
	}
	else
	{
		int res=m_pFileZillaApi->Rename(oldName, newName, path, newPath);
		if (res==FZ_REPLY_WOULDBLOCK)
		{
			m_CommandList.push_back(command);
			return TRUE;
		}
		else if (res==FZ_REPLY_OK)
			return TRUE;
		else
			return FALSE;
	}
}

void CCommandQueue::OnRetryTimer()
{
	if (m_nRetryCount > 0 && m_nRetryCount <= COptions::GetOptionVal(OPTION_NUMRETRIES))
	{
		if (m_CommandList.empty())
		{
			m_nRetryCount = 0;
			CMainFrame *pMainFrame = DYNAMIC_DOWNCAST(CMainFrame, AfxGetMainWnd());
			pMainFrame->GetStatusPane()->ShowStatus("No command to retry", FZ_LOG_INFO);
			return;
		}
		else if (!m_RetryServerList.StillWait(m_CommandList.front().server))
		{
			m_nRetryCount *= -1;
			int res = m_pFileZillaApi->Connect(m_CommandList.front().server);
			if (res==FZ_REPLY_WOULDBLOCK)
			{
				m_RetryServerList.AddServer(m_CommandList.front().server);
				return;
			}
			else if (res == FZ_REPLY_OK)
			{
				CString title;
				CString str;
				if (m_CommandList.front().server.name!="")
					str = m_CommandList.front().server.name + _T(" (") + m_CommandList.front().server.host + _T(")");
				else
					str = m_CommandList.front().server.host;
				title.Format(IDS_TITLE_CONNECTED, str);
				SetWindowText( _T("FileZilla - ") + title);
				return;
			}
			else
			{
				m_CommandList.pop_front();
				
				while (!m_CommandList.empty())
				{
					t_command command = m_CommandList.front();
					int res = m_pFileZillaApi->Command(&command);
					if (res==FZ_REPLY_WOULDBLOCK)
					{
						if (command.id==FZ_COMMAND_CONNECT)
						{
							m_RetryServerList.AddServer(command.server);
							CString title;
							CString str;
							if (command.server.name!="")
								str=command.server.name + _T(" (") + command.server.host + _T(")");
							else
								str=command.server.host;
							title.Format(IDS_TITLE_CONNECTED, str);
							SetWindowText( _T("FileZilla - ") + title);							
						}
						return;
					}
					else
					{
						m_CommandList.pop_front();
						CMainFrame *pMainFrame = DYNAMIC_DOWNCAST(CMainFrame, AfxGetMainWnd());
						if (command.id == FZ_COMMAND_FILETRANSFER)
						{
							pMainFrame->GetQueuePane()->GetListCtrl()->ProcessReply(FZ_REPLY_ERROR);
							break;
						}
						else if (command.id==FZ_COMMAND_LIST)
						{
							if (res != FZ_REPLY_OK)
								((CFtpListCtrl *)pMainFrame->GetFtpPane()->GetListCtrl())->ListComplete(FALSE, command.path, command.param1);
							else
								((CFtpListCtrl *)pMainFrame->GetFtpPane()->GetListCtrl())->ListComplete(TRUE, command.path, command.param1);
						}
					}
				}
				if (!IsConnected() && !IsBusy())
					SetWindowText(GetVersionString());
			}
		}
	}
}

BOOL CCommandQueue::GetLastServer(t_server &server, CServerPath &path)
{
	t_server server2;
	BOOL bAskForPassword = FALSE;
	if (m_pLastServer)
		server2 = *m_pLastServer;
	else
	{
		server2.host=COptions::GetOption(OPTION_LASTSERVERHOST);
		server2.port=COptions::GetOptionVal(OPTION_LASTSERVERPORT);
		server2.user=COptions::GetOption(OPTION_LASTSERVERUSER);
		server2.account = COptions::GetOption(OPTION_LASTSERVERACCOUNT);
		server2.nUTF8=COptions::GetOptionVal(OPTION_LASTSERVERUTF8);
		server2.bDontRememberPass=COptions::GetOptionVal(OPTION_LASTSERVERDONTREMEMBERPASS);
		if (!server2.bDontRememberPass)
		{
			if (_ttoi(COptions::GetOption(OPTION_RUNINSECUREMODE)))
				bAskForPassword=TRUE;
			else
				server2.pass=CCrypt::decrypt(COptions::GetOption(OPTION_LASTSERVERPASS));
		}
		server2.fwbypass=COptions::GetOptionVal(OPTION_LASTSERVERFWBYPASS);
		server2.nServerType=COptions::GetOptionVal(OPTION_LASTSERVERTYPE);
		server2.name=COptions::GetOption(OPTION_LASTSERVERNAME);
		
		if (server2.host=="")
			return FALSE;
		if (server2.port<1 || server2.port>65535)
			return FALSE;	
	}
	BOOL bUseGSS = FALSE;
	if (COptions::GetOptionVal(OPTION_USEGSS))
	{
		USES_CONVERSION;
		
		CString GssServers = COptions::GetOption(OPTION_GSSSERVERS);
		hostent *fullname = gethostbyname(T2CA(server2.host));
		CString host;
		if (fullname)
			host = fullname->h_name;
		else
			host = server2.host;
		host.MakeLower();
		int i;
		while ((i=GssServers.Find( _T(";") ))!=-1)
		{
			if (("."+GssServers.Left(i))==host.Right(GssServers.Left(i).GetLength()+1) || GssServers.Left(i)==host)
			{
				bUseGSS=TRUE;
				break;
			}
			GssServers=GssServers.Mid(i+1);
		}
	}
	if (server2.bDontRememberPass && server2.pass=="")
		bAskForPassword = TRUE;
	if (bAskForPassword && !bUseGSS)
	{
		CEnterSomething dlg(IDS_INPUTDIALOGTITLE_INPUTPASSWORD,IDS_INPUTDIALOGTEXT_INPUTPASSWORD,'*');
		if (dlg.DoModal()==IDOK)
			server2.pass=dlg.m_String;
		else
			return FALSE;
	}	
	server = server2;

	CServerPath path2;
	
	if (m_pLastServerPath)
		path2=*m_pLastServerPath;
	else
	{
		if (!path2.SetSafePath(COptions::GetOption(OPTION_LASTSERVERPATH)))
			path2=CServerPath();
	}

	server.nPasv = COptions::GetOptionVal(OPTION_LASTSERVERTRANSFERMODE);

	path = path2;
	return TRUE;
}

void CCommandQueue::OutputRetryMessage()
{
	if (m_CommandList.empty())
		return;
	CMainFrame *pMainFrame=DYNAMIC_DOWNCAST(CMainFrame,AfxGetMainWnd());
	CString status;
	
	if (m_nRetryCount<COptions::GetOptionVal(OPTION_NUMRETRIES))
		status.Format(IDS_STATUSMSG_WAITINGTORETRY_LEFT,COptions::GetOptionVal(OPTION_NUMRETRIES)-m_nRetryCount+1);
	else
		status.Format(IDS_STATUSMSG_WAITINGTORETRY);
	pMainFrame->GetStatusPane()->ShowStatus(status,0);
}

void CCommandQueue::SetLastServerPath(const CServerPath &path)
{
	if (!m_pLastServerPath)
		m_pLastServerPath=new CServerPath;
	*m_pLastServerPath=path;
}

BOOL CCommandQueue::Chmod(int nValue, CString filename, CServerPath path /*=CServerPath()*/, BOOL bAddToQueue /*=FALSE*/)
{
	if (!m_CommandList.empty() && !bAddToQueue) //Don't queue direct commands
		return FALSE;
	
	t_command command;
	command.id = FZ_COMMAND_CHMOD;
	command.param1 = filename;
	command.path = path;
	command.param4 = nValue;
	if (!m_CommandList.empty())
	{
		m_CommandList.push_back(command);
		return TRUE;
	}
	else
	{
		int res=m_pFileZillaApi->Chmod(nValue, filename, path);
		if (res==FZ_REPLY_WOULDBLOCK)
		{
			m_CommandList.push_back(command);
			return TRUE;
		}
		else if (res == FZ_REPLY_OK)
			return TRUE;
		else
			return FALSE;
	}
}

BOOL CCommandQueue::IsLocked() const
{
	return m_bLocked;
}

void CCommandQueue::SetLock(BOOL bLock)
{
	m_bLocked=bLock;
}

void CCommandQueue::SetWindowText(LPCTSTR lpszWindowText)
{
	CMainFrame *pMainFrame = reinterpret_cast<CMainFrame *>(AfxGetMainWnd());
	pMainFrame->SetRedraw(FALSE);
	pMainFrame->SetWindowText(lpszWindowText);
	pMainFrame->SetRedraw(TRUE);
	pMainFrame->RedrawWindow(0, 0, RDW_FRAME | RDW_INVALIDATE | RDW_UPDATENOW);
}

BOOL CCommandQueue::IsListInQueue() const
{
	for (std::list<t_command>::const_iterator iter = m_CommandList.begin(); iter != m_CommandList.end(); iter++)
		if (iter->id == FZ_COMMAND_LIST)
			return TRUE;

	return FALSE;
}
12

commandqueue.cpp - 源码说明

本页面展示了「一个支持FTP,SFTP的客户端程序」中的 commandqueue.cpp 源码文件，采用 C++ 编程语言编写，共 930 行代码。您可以在线阅读完整代码内容，也可以返回资源详情页下载完整源码包进行本地学习和开发。

虫虫开发者社区收录了大量与FTP相关的技术资源，包括源代码、技术文档、电路图等，是电子工程师和嵌入式开发者的专业学习平台。

⌨️ 快捷键说明

复制代码Ctrl + C
搜索代码Ctrl + F
全屏模式F11
增大字号Ctrl + =
减小字号Ctrl + -
显示快捷键?