axel_do主體部分，嘗試從多個連接select方式去讀取數據，如果讀取失敗或者連接超時就重新連接。

下面是代碼分析.

1. //下載的主循環
   
2. void axel_do( axel_t *axel )
   
3. {
   
4. ? ? ? ? fd_set fds[1];
   
5. ? ? ? ? int hifd, i;
   
6. ? ? ? ? long long int remaining,size;
   
7. ? ? ? ? struct timeval timeval[1];
   
8. ? ? ? ??
   
9. ? ? ? ? /* Create statefile if necessary? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? */
   
10. ? ? ? ? //如果到了保存狀態的時間，保存當前狀態到狀態文件
    
11. ? ? ? ? if( gettime() > axel->next_state )
    
12. ? ? ? ? {
    
13. ? ? ? ? ? ? ? ? //把連接的個數，當前下載量，每個連接當前的下載進度保存起來，
    
14. ? ? ? ? ? ? ? ? //如果狀態文件已經存在，就清空重寫，目的是只保存一份
    
15. ? ? ? ? ? ? ? ? //這樣的話，如果程序異常退出，下次開啟任務時，就能從狀態文件中
    
16. ? ? ? ? ? ? ? ? //重新加載最近的下載狀態(不是100%準確的狀態，因為保存狀態是有周期的),
    
17. ? ? ? ? ? ? ? ? //接著下載
    
18. ? ? ? ? ? ? ? ? save_state( axel );
    
19. ? ? ? ? ? ? ? ? //計算下一次狀態保存時間
    
20. ? ? ? ? ? ? ? ? axel->next_state = gettime() + axel->conf->save_state_interval;
    
21. ? ? ? ? }
    
22. ? ? ? ??
    
23. ? ? ? ? ? ? ? ? //采用多線程做連接，但是還是單線程select做傳輸
    
24. ? ? ? ? /* Wait for data on (one of) the connections? ? ? ? ? ? ? ? ? ? ? ? */
    
25. ? ? ? ? FD_ZERO( fds );
    
26. ? ? ? ? hifd = 0;
    
27. ? ? ? ? //經典的select方式，把有用的socket描述符加入到集合中
    
28. ? ? ? ? //而且，限于文件下載的特殊任務方式，基本上每個建立好的連接
    
29. ? ? ? ? //都不會太空，有恒定持續的數據傳輸，因此在這里select的效率并不弱于epoll
    
30. ? ? ? ? for( i = 0; i < axel->conf->num_connections; i ++ )
    
31. ? ? ? ? {
    
32. ? ? ? ? ? ? ? ? if( axel->conn[i].enabled )
    
33. ? ? ? ? ? ? ? ? ? ? ? ? FD_SET( axel->conn[i].fd, fds );
    
34. ? ? ? ? ? ? ? ? hifd = max( hifd, axel->conn[i].fd );
    
35. ? ? ? ? }
    
36. ? ? ? ? //沒有任何連接，等待重試
    
37. ? ? ? ? if( hifd == 0 )
    
38. ? ? ? ? {
    
39. ? ? ? ? ? ? ? ? /* No connections yet. Wait...? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? */
    
40. ? ? ? ? ? ? ? ? usleep( 100000 );
    
41. ? ? ? ? ? ? ? ? goto conn_check;
    
42. ? ? ? ? }
    
43. ? ? ? ? else
    
44. ? ? ? ? {
    
45. ? ? ? ? ? ? ? ? //超時0.1秒
    
46. ? ? ? ? ? ? ? ? timeval->tv_sec = 0;
    
47. ? ? ? ? ? ? ? ? timeval->tv_usec = 100000;
    
48. ? ? ? ? ? ? ? ? /* A select() error probably means it was interrupted
    
49. ? ? ? ? ? ? ? ?? ? by a signal, or that something else's very wrong...? ? ? ? */
    
50. ? ? ? ? ? ? ? ? //select等待數據到來
    
51. ? ? ? ? ? ? ? ? if( select( hifd + 1, fds, NULL, NULL, timeval ) == -1 )
    
52. ? ? ? ? ? ? ? ? {
    
53. ? ? ? ? ? ? ? ? ? ? ? ? //值位ready為-1，這樣，下載的主循環將退出，下載失敗
    
54. ? ? ? ? ? ? ? ? ? ? ? ? axel->ready = -1;
    
55. ? ? ? ? ? ? ? ? ? ? ? ? return;
    
56. ? ? ? ? ? ? ? ? }
    
57. ? ? ? ? }
    
58. ? ? ? ??
    
59. ? ? ? ? /* Handle connections which need attention? ? ? ? ? ? ? ? ? ? ? ? */
    
60. ? ? ? ? //循環讀取每個socket的數據
    
61. ? ? ? ? for( i = 0; i < axel->conf->num_connections; i ++ )
    
62. ? ? ? ? if( axel->conn[i].enabled ) {
    
63. ? ? ? ? //檢測，如果該socket有數據到來，就讀取
    
64. ? ? ? ? ? ? ? ? if( FD_ISSET( axel->conn[i].fd, fds ) )
    
65. ? ? ? ? {
    
66. ? ? ? ? ? ? ? ? //更新最后一次讀取數據的時間
    
67. ? ? ? ? ? ? ? ? axel->conn[i].last_transfer = gettime();
    
68. ? ? ? ? ? ? ? ? //嘗試讀取數據
    
69. ? ? ? ? ? ? ? ? size = read( axel->conn[i].fd, buffer, axel->conf->buffer_size );
    
70. ? ? ? ? ? ? ? ? //讀取失敗
    
71. ? ? ? ? ? ? ? ? if( size == -1 )
    
72. ? ? ? ? ? ? ? ? {
    
73. ? ? ? ? ? ? ? ? ? ? ? ? if( axel->conf->verbose )
    
74. ? ? ? ? ? ? ? ? ? ? ? ? {
    
75. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? axel_message( axel, _("Error on connection %i! "
    
76. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? "Connection closed"), i );
    
77. ? ? ? ? ? ? ? ? ? ? ? ? }
    
78. ? ? ? ? ? ? ? ? ? ? ? ? //關閉當前連接，并不等于放棄，還可能重新連接。。
    
79. ? ? ? ? ? ? ? ? ? ? ? ? axel->conn[i].enabled = 0;
    
80. ? ? ? ? ? ? ? ? ? ? ? ? conn_disconnect( &axel->conn[i] );
    
81. ? ? ? ? ? ? ? ? ? ? ? ? continue;
    
82. ? ? ? ? ? ? ? ? }//當前連接的數據讀取結束
    
83. ? ? ? ? ? ? ? ? else if( size == 0 )
    
84. ? ? ? ? ? ? ? ? {
    
85. ? ? ? ? ? ? ? ? ? ? ? ? if( axel->conf->verbose )
    
86. ? ? ? ? ? ? ? ? ? ? ? ? {
    
87. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? /* Only abnormal behaviour if:? ? ? ? ? ? ? ? */
    
88. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? if( axel->conn[i].currentbyte < axel->conn[i].lastbyte && axel->size != INT_MAX )
    
89. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? {
    
90. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? axel_message( axel, _("Connection %i unexpectedly closed"), i );
    
91. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? }
    
92. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? else
    
93. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? {
    
94. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? axel_message( axel, _("Connection %i finished"), i );
    
95. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? }
    
96. ? ? ? ? ? ? ? ? ? ? ? ? }
    
97. ? ? ? ? ? ? ? ? ? ? ? ? //如果是不支持并發分片下載(也就是說是單連接下載)，表明下載完成
    
98. ? ? ? ? ? ? ? ? ? ? ? ? if( !axel->conn[0].supported )
    
99. ? ? ? ? ? ? ? ? ? ? ? ? {
    
100. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? axel->ready = 1;
     
101. ? ? ? ? ? ? ? ? ? ? ? ? }
     
102. ? ? ? ? ? ? ? ? ? ? ? ? axel->conn[i].enabled = 0;
     
103. ? ? ? ? ? ? ? ? ? ? ? ? conn_disconnect( &axel->conn[i] );
     
104. ? ? ? ? ? ? ? ? ? ? ? ? continue;
     
105. ? ? ? ? ? ? ? ? }
     
106. ? ? ? ? ? ? ? ? /* remaining == Bytes to go? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? */
     
107. ? ? ? ? ? ? ? ? remaining = axel->conn[i].lastbyte - axel->conn[i].currentbyte + 1;
     
108. ? ? ? ? ? ? ? ? //需要填充的小于讀取的，下載完成
     
109. ? ? ? ? ? ? ? ? if( remaining < size )
     
110. ? ? ? ? ? ? ? ? {
     
111. ? ? ? ? ? ? ? ? ? ? ? ? if( axel->conf->verbose )
     
112. ? ? ? ? ? ? ? ? ? ? ? ? {
     
113. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? axel_message( axel, _("Connection %i finished"), i );
     
114. ? ? ? ? ? ? ? ? ? ? ? ? }
     
115. ? ? ? ? ? ? ? ? ? ? ? ? axel->conn[i].enabled = 0;
     
116. ? ? ? ? ? ? ? ? ? ? ? ? //關閉連接
     
117. ? ? ? ? ? ? ? ? ? ? ? ? conn_disconnect( &axel->conn[i] );
     
118. ? ? ? ? ? ? ? ? ? ? ? ? //修改需要的數據量大小，比如需要20字節，下載了30字節，那么就只要20字節
     
119. ? ? ? ? ? ? ? ? ? ? ? ? size = remaining;
     
120. ? ? ? ? ? ? ? ? ? ? ? ? /* Don't terminate, still stuff to write!? ? ? ? */
     
121. ? ? ? ? ? ? ? ? }
     
122. ? ? ? ? ? ? ? ? /* This should always succeed..? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? */
     
123. ? ? ? ? ? ? ? ? //調整偏移，寫文件
     
124. ? ? ? ? ? ? ? ? lseek( axel->outfd, axel->conn[i].currentbyte, SEEK_SET );
     
125. ? ? ? ? ? ? ? ? if( write( axel->outfd, buffer, size ) != size )
     
126. ? ? ? ? ? ? ? ? {
     
127. ? ? ? ? ? ? ? ? ? ? ? ? //寫失敗，退出
     
128. ? ? ? ? ? ? ? ? ? ? ? ? axel_message( axel, _("Write error!") );
     
129. ? ? ? ? ? ? ? ? ? ? ? ? axel->ready = -1;
     
130. ? ? ? ? ? ? ? ? ? ? ? ? return;
     
131. ? ? ? ? ? ? ? ? }
     
132. ? ? ? ? ? ? ? ? //修改偏移
     
133. ? ? ? ? ? ? ? ? axel->conn[i].currentbyte += size;
     
134. ? ? ? ? ? ? ? ? axel->bytes_done += size;
     
135. ? ? ? ? }
     
136. ? ? ? ? else //當前socket描述符不在select中，檢查超時
     
137. ? ? ? ? {
     
138. ? ? ? ? ? ? ? ? //傳輸超時，關閉連接
     
139. ? ? ? ? ? ? ? ? if( gettime() > axel->conn[i].last_transfer + axel->conf->connection_timeout )
     
140. ? ? ? ? ? ? ? ? {
     
141. ? ? ? ? ? ? ? ? ? ? ? ? if( axel->conf->verbose )
     
142. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? axel_message( axel, _("Connection %i timed out"), i );
     
143. ? ? ? ? ? ? ? ? ? ? ? ? conn_disconnect( &axel->conn[i] );
     
144. ? ? ? ? ? ? ? ? ? ? ? ? axel->conn[i].enabled = 0;
     
145. ? ? ? ? ? ? ? ? }
     
146. ? ? ? ? } }
     
147. ? ? ? ? //如果一切ok，就返回
     
148. ? ? ? ? if( axel->ready )
     
149. ? ? ? ? ? ? ? ? return;
     
150. ? ? ? ??
     
151. conn_check:
     
152. ? ? ? ? /* Look for aborted connections and attempt to restart them.? ? ? ? */
     
153. ? ? ? ? //檢查有問題的連接,如果未下載完，并且出錯了，重新啟動線程，開始傳輸
     
154. ? ? ? ? for( i = 0; i < axel->conf->num_connections; i ++ )
     
155. ? ? ? ? {
     
156. ? ? ? ? ? ? ? ? //連接無效并且未下載完
     
157. ? ? ? ? ? ? ? ? if( !axel->conn[i].enabled && axel->conn[i].currentbyte < axel->conn[i].lastbyte )
     
158. ? ? ? ? ? ? ? ? {
     
159. ? ? ? ? ? ? ? ? ? ? ? ? //狀態為0,表明setup_thread是成功執行了的，并且已經執行問，因此，連接的初始化沒問題，調用join回收
     
160. ? ? ? ? ? ? ? ? ? ? ? ? if( axel->conn[i].state == 0 )
     
161. ? ? ? ? ? ? ? ? ? ? ? ? {? ? ? ??
     
162. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? // Wait for termination of this thread
     
163. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? pthread_join(*(axel->conn[i].setup_thread), NULL);
     
164. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ??
     
165. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? conn_set( &axel->conn[i], axel->url->text );
     
166. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? axel->url = axel->url->next;
     
167. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? /* axel->conn[i].local_if = axel->conf->interfaces->text;
     
168. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? axel->conf->interfaces = axel->conf->interfaces->next; */
     
169. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? if( axel->conf->verbose >= 2 )
     
170. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? axel_message( axel, _("Connection %i downloading from %s:%i using interface %s"),
     
171. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?? ?? ?? ?? ? ? ?? ?? ? i, axel->conn[i].host, axel->conn[i].port, axel->conn[i].local_if );
     
172. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ??
     
173. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? //狀態設置為1，表示setup_thread開始執行，設置為0，表示setup_thread線程執行結束
     
174. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? axel->conn[i].state = 1;
     
175. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? if( pthread_create( axel->conn[i].setup_thread, NULL, setup_thread, &axel->conn[i] ) == 0 )
     
176. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? {
     
177. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? axel->conn[i].last_transfer = gettime();
     
178. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? }
     
179. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? else
     
180. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? {
     
181. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? axel_message( axel, _("pthread error!!!") );
     
182. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? axel->ready = -1;
     
183. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? }
     
184. ? ? ? ? ? ? ? ? ? ? ? ? }
     
185. ? ? ? ? ? ? ? ? ? ? ? ? else //setup_thread線程還未執行完，也就是說連接建立過程還未完成，需要檢查連接超時
     
186. ? ? ? ? ? ? ? ? ? ? ? ? {
     
187. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? //超時了，就取消她...
     
188. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? if( gettime() > axel->conn[i].last_transfer + axel->conf->reconnect_delay )
     
189. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? {
     
190. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? pthread_cancel( *axel->conn[i].setup_thread );
     
191. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? axel->conn[i].state = 0;
     
192. ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? }
     
193. ? ? ? ? ? ? ? ? ? ? ? ? }
     
194. ? ? ? ? ? ? ? ? }
     
195. ? ? ? ? }
     
196. 
     
197. ? ? ? ? /* Calculate current average speed and finish_time? ? ? ? ? ? ? ? */
     
198. ? ? ? ? //計算平均速度
     
199. ? ? ? ? axel->bytes_per_second = (int) ( (double) ( axel->bytes_done - axel->start_byte ) / ( gettime() - axel->start_time ) );
     
200. ? ? ? ? //估算結束時間
     
201. ? ? ? ? axel->finish_time = (int) ( axel->start_time + (double) ( axel->size - axel->start_byte ) / axel->bytes_per_second );
     
202. 
     
203. ? ? ? ? /* Check speed. If too high, delay for some time to slow things
     
204. ? ? ? ?? ? down a bit. I think a 5% deviation should be acceptable.? ? ? ? */
     
205. ? ? ? ? //速度調整
     
206. ? ? ? ? if( axel->conf->max_speed > 0 )
     
207. ? ? ? ? {
     
208. ? ? ? ? ? ? ? ? //如果超速了
     
209. ? ? ? ? ? ? ? ? if( (float) axel->bytes_per_second / axel->conf->max_speed > 1.05 )
     
210. ? ? ? ? ? ? ? ? ? ? ? ? axel->delay_time += 10000;
     
211. ? ? ? ? ? ? ? ? //速度太低，少休息會兒
     
212. ? ? ? ? ? ? ? ? else if( ( (float) axel->bytes_per_second / axel->conf->max_speed < 0.95 ) && ( axel->delay_time >= 10000 ) )
     
213. ? ? ? ? ? ? ? ? ? ? ? ? axel->delay_time -= 10000;
     
214. ? ? ? ? ? ? ? ? //速度太低，干脆不休息
     
215. ? ? ? ? ? ? ? ? else if( ( (float) axel->bytes_per_second / axel->conf->max_speed < 0.95 ) )
     
216. ? ? ? ? ? ? ? ? ? ? ? ? axel->delay_time = 0;
     
217. ? ? ? ? ? ? ? ? usleep( axel->delay_time );
     
218. ? ? ? ? }
     
219. ? ? ? ??
     
220. ? ? ? ? /* Ready?? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? */
     
221. ? ? ? ? //下載完了？
     
222. ? ? ? ? if( axel->bytes_done == axel->size )
     
223. ? ? ? ? ? ? ? ? axel->ready = 1;
     
224. }

轉載于:https://www.cnblogs.com/shepherd2012/archive/2012/08/06/2625670.html

總結

以上是生活随笔為你收集整理的Axel之 -axel_do剖析的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。