imap连接原型

hechengjin

nsImapIncomingServer 维护imap连接队列 和任务队列

1. nsImapIncomingServer
   
2. 
   
3. nsCOMArray<nsIImapUrl> m_urlQueue;    任务队列
   
4. nsCOMArray<nsIImapProtocol> m_connectionCache;  //imap连接线程队列
   
5. 
   
6. 
   
7. GetImapConnection(nsIImapUrl * aImapUrl,..)
   
8. {
   
9.         1.从缓存中取可用连接
   
10.         connection = m_connectionCache[i];
    
11.         2.没有可用连接，且连接数少于最大连接数，则创建新连接
    
12.         CreateProtocolInstance(nsIImapProtocol ** aImapConnection)
    
13.         3.如果找不到可用连接，则放到队列中
    
14.         m_urlQueue.AppendObject(aImapUrl);  //GetImapConnectionAndLoadUrl
    
15. }

复制代码

hechengjin

1. 
   
2. 5.关于任务执行(
   
3. a.内部保持一个任务队列，下一个要执行的命令就从这里取  ??
   
4. b.自身可以产生新任务，且可向上层发送
   
5. c.任务支持优先级
   
6. )
   
7. 
   
8. 6.线程根据要执行的任务分类(
   
9. a.T1(类型1):邮件同步线程，如：同步邮件头512封，下载邮件体512封，再同步邮件头512封，再下载邮件体512封.... 直到所有邮件都下载完。
   
10. 邮件夹有一定的优先级，且点击的优先下,处理好中断，且从最新的邮件开始下。
    
11. 新邮件的下载也放这里，注意优先级会提升
    
12. b.T2(类型2): 处理本地相关操作任务，如：已读未读  星标  邮件上载 邮件复制、移动等。
    
13. 对于批量操作用时较长时，要细分任务粒度，且相关交互操作优先级提升
    
14. c.T3(类型3): 定时任务执行线程：如：定期更新邮件夹目录，定期同步邮件变动。
    
15. d.T4(类型4)：邮件体下载线程：针对点击的邮件优先处理，如果没下载完或这个邮件比较大，又切换到读其它的邮件，直接放弃该任务，直接进行下一个任务的下载。
    
16. e.处理好相关同步，如a和d，已下载中的邮件，不要重复下载
    
17. )
    
18. 
    
19. 问题：
    
20. 1.imap连接内部会产生新任务吗？
    
21. 2.多个imap连接都产生同一个新任务如何处理？
    
22. ImapThreadMainLoop
    
23. ProcessCurrentURL
    
24. ProcessSelectedStateURL   
    
25. 如：
    
26. 同步某邮件夹的更新的任务(ProcessMailboxUpdate)，发现新邮件需要接收
    
27. FetchMessage(idsToFetch, kFlags, fetchModifier);
    
28. 则直接进行这项操作
    
29. 
    
30. ----------------
    
31. 加载任务后的处理流程
    
32. NS_IMETHODIMP nsImapProtocol::LoadImapUrl(nsIURI * aURL, nsISupports * aConsumer)
    
33. {
    
34. //1.本地能处理的任务直接处理返回
    
35. if (TryToRunUrlLocally(aURL, aConsumer))  
    
36.       return NS_OK;
    
37. //2.设置运行的Url
    
38. SetupWithUrl(aURL.)
    
39.         {
    
40.         m_runningUrl = do_QueryInterface(aURL, &rv);
    
41.         }
    
42.         //3.获取url的执行动作
    
43.         m_runningUrl->GetImapAction(&imapAction);
    
44.         m_needNoop = (imapAction == nsIImapUrl::nsImapSelectFolder || imapAction == nsIImapUrl::nsImapDeleteAllMsgs);
    
45. }
    
46. 
    
47. 线程函数中处理要运行的Url
    
48. ProcessSelectedStateURL(){
    
49.         case nsIImapUrl::nsImapSelectFolder:
    
50.                 ProcessMailboxUpdate(true);
    
51. }
    
52. 
    
53. ProcessMailboxUpdate(..)
    
54. {
    
55.         needFolderSync
    
56.         FetchMessage("1:*", kFlags);
    
57. }
    
58. FetchMessage(...)
    
59. {
    
60.         SendData(protocolString);
    
61.         ParseIMAPandCheckForNewMail(protocolString);
    
62. }
    
63. ParseIMAPandCheckForNewMail(..){
    
64.         GetServerStateParser().ParseIMAPServerResponse(commandString, aIgnoreBadAndNOResponses);
    
65. }
    
66. 
    
67. nsImapServerResponseParser.cpp
    
68. ParseIMAPServerResponse(..){
    
69. response_data();
    
70. }
    
71. response_data()
    
72. {
    
73. mailbox_data();
    
74. numeric_mailbox_data();
    
75. }
    
76. numeric_mailbox_data()
    
77. {
    
78. msg_fetch();
    
79. }
    
80. msg_fetch()
    
81. {
    
82. }
    
83. 
    
84. //下面这些操作什么时候触发
    
85. case nsIImapUrl::nsImapSaveMessageToDisk:  // nsImapService::SaveMessageToDisk
    
86.       case nsIImapUrl::nsImapMsgFetch:  //nsImapService::GetHeaders
    
87.       case nsIImapUrl::nsImapMsgFetchPeek:
    
88.       case nsIImapUrl::nsImapMsgDownloadForOffline:  //上层指定要下载的邮件触发  nsImapService::DownloadMessagesForOffline(const nsACString &messageIds
    
89.       case nsIImapUrl::nsImapMsgPreview:
    
90. 
    
91. 一个自动处理离线下载的管理器
    
92. nsAutoSyncState::DownloadMessagesForOffline(nsIArray *aMessagesList)
    
93. nsAutoSyncManager::TimerCallback
    
94. {
    
95. autoSyncStateObj->ProcessExistingHeaders(kNumberOfHeadersToProcess, &leftToProcess);
    
96. }
    
97. --------------
    
98. 任务的产生(粒度)
    
99. 线程的分类管理

复制代码

hechengjin

1. nsImapIncomingServer
   
2. 
   
3. nsCOMArray<nsIImapUrl> m_urlQueue;    任务队列
   
4. nsCOMArray<nsIImapProtocol> m_connectionCache;  //imap连接线程队列
   
5. 
   
6. 
   
7. GetImapConnection(nsIImapUrl * aImapUrl,..)
   
8. {
   
9.         1.从缓存中取可用连接
   
10.         connection = m_connectionCache[i];
    
11.         2.没有可用连接，且连接数少于最大连接数，则创建新连接
    
12.         CreateProtocolInstance(nsIImapProtocol ** aImapConnection)
    
13.         3.如果找不到可用连接，则放到队列中
    
14.         m_urlQueue.AppendObject(aImapUrl);  //GetImapConnectionAndLoadUrl
    
15. }
    
16. 
    
17. 
    
18. 获取连接以后加载执行任务
    
19. rv = aProtocol->LoadImapUrl(mailnewsurl, aConsumer);
    
20. 
    
21. 
    
22. nsImapIncomingServer调用nsIImapService为了构建nsIImapUrl，然后再转回来调用nsImapIncomingServer，然后是nsImapProtocol
    
23. 
    
24. ---------相关难点-----
    
25. 多个imap线程连接之间，如何进行分开不重复执行相关任务，
    
26. imap线程内部永远不会自动产生新任务？
    
27. 不需要时移除掉此连接 imapServer->RemoveConnection(this);
    
28. 
    
29. 可自动获取上层的任务
    
30. rv = m_imapServerSink->LoadNextQueuedUrl(this, &anotherUrlRun);
    
31. 
    
32. LoadImapUrl的调用
    
33. nsImapIncomingServer下
    
34. GetImapConnectionAndLoadUrl   ---- nsImapMockChannel::ReadFromImapConnection  OnCacheEntryAvailable  AsyncOpen
    
35. RetryUrl
    
36. LoadNextQueuedUrl
    
37. 
    
38. 
    
39. 是否可共用连接的判断 ：
    
40. in selected state can only run url with matching foldername  //选择状态下只能是同一邮件夹下的相关任务可以共用
    
41. 
    
42. 
    
43. //头收完后，邮件体是如何触发收取的？
    
44. HeaderFetchCompleted()
    
45. nsImapMailFolder::ParseMsgHdrs(nsIImapProtocol *aProtocol, nsIImapHeaderXferInfo *aHdrXferInfo){
    
46. }
    
47. 
    
48. 
    
49.         !nsImapProtocol::LoadImapUrl(nsIURI * aURL, nsISupports * aConsumer) 行 2205        C++
    
50. >        !nsImapIncomingServer::LoadNextQueuedUrl(nsIImapProtocol * aProtocol, bool * aResult) 行 575        C++
    
51.         !`anonymous namespace'::SyncRunnable2<nsIImapMailFolderSink,unsigned int,nsIImapUrl *>::Run() 行 147        C++   ---界面点击触发，不点不触发？
    
52. 
    
53. 
    
54. 
    
55.         >        !nsImapProtocol::LoadImapUrl(nsIURI * aURL, nsISupports * aConsumer) 行 2205        C++
    
56.         !nsImapIncomingServer::LoadNextQueuedUrl(nsIImapProtocol * aProtocol, bool * aResult) 行 575        C++
    
57.         !`anonymous namespace'::SyncRunnable2<nsIImapMailFolderSink,unsigned int,nsIImapUrl *>::Run() 行 147        C++  //nsImapMsgDownloadForOffline = 268435506,
    
58. 
    
59. 
    
60.         nsImapMsgDownloadForOffline  邮件头下载完后，调用自动同步 HeaderFetchCompleted -> nsAutoSyncState
    
61.                  !nsImapService::DownloadMessagesForOffline(const nsACString & messageIds, nsIMsgFolder * aFolder, nsIUrlListener * aUrlListener, nsIMsgWindow * aMsgWindow) 行 3255        C++
    
62.         !nsAutoSyncState::DownloadMessagesForOffline(nsIArray * aMessagesList) 行 651        C++
    
63.         !nsAutoSyncManager::DownloadMessagesForOffline(nsIAutoSyncState * aAutoSyncStateObj, unsigned int aSizeLimit) 行 982        C++
    
64.         !nsAutoSyncManager::OnDownloadQChanged(nsIAutoSyncState * aAutoSyncStateObj) 行 1206        C++
    
65.         !nsAutoSyncState::PlaceIntoDownloadQ(const nsTArray<unsigned int> & aMsgKeyList) 行 154        C++
    
66. >        !nsImapMailFolder::HeaderFetchCompleted(nsIImapProtocol * aProtocol) 行 5901        C++
    
67. 
    

复制代码