ftpd.c 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784
  1. #include <string.h>
  2. #include <stdlib.h>
  3. #include <rtthread.h>
  4. #include <dfs_posix.h>
  5. #include <lwip/sockets.h>
  6. #define FTP_PORT 21
  7. #define FTP_SRV_ROOT "/"
  8. #define FTP_MAX_CONNECTION 2
  9. #define FTP_USER "rtt"
  10. #define FTP_PASSWORD "demo"
  11. #define FTP_WELCOME_MSG "220-= welcome on RT-Thread FTP server =-\r\n220 \r\n"
  12. #define FTP_BUFFER_SIZE 1024
  13. struct ftp_session
  14. {
  15. rt_bool_t is_anonymous;
  16. int sockfd;
  17. struct sockaddr_in remote;
  18. /* pasv data */
  19. char pasv_active;
  20. int pasv_sockfd;
  21. unsigned short pasv_port;
  22. size_t offset;
  23. /* current directory */
  24. char currentdir[256];
  25. struct ftp_session* next;
  26. };
  27. static struct ftp_session* session_list = NULL;
  28. int ftp_process_request(struct ftp_session* session, char * buf);
  29. int ftp_get_filesize(char *filename);
  30. struct ftp_session* ftp_new_session()
  31. {
  32. struct ftp_session* session;
  33. session = (struct ftp_session*)rt_malloc(sizeof(struct ftp_session));
  34. session->next = session_list;
  35. session_list = session;
  36. return session;
  37. }
  38. void ftp_close_session(struct ftp_session* session)
  39. {
  40. struct ftp_session* list;
  41. if (session_list == session)
  42. {
  43. session_list = session_list->next;
  44. session->next = NULL;
  45. }
  46. else
  47. {
  48. list = session_list;
  49. while (list->next != session) list = list->next;
  50. list->next = session->next;
  51. session->next = NULL;
  52. }
  53. rt_free(session);
  54. }
  55. int ftp_get_filesize(char * filename)
  56. {
  57. int pos;
  58. int end;
  59. int fd;
  60. fd = open(filename, O_RDONLY, 0);
  61. if (fd < 0) return -1;
  62. pos = lseek(fd, 0, SEEK_CUR);
  63. end = lseek(fd, 0, SEEK_END);
  64. lseek (fd, pos, SEEK_SET);
  65. close(fd);
  66. return end;
  67. }
  68. rt_bool_t is_absolute_path(char* path)
  69. {
  70. #ifdef _WIN32
  71. if (path[0] == '\\' ||
  72. (path[1] == ':' && path[2] == '\\'))
  73. return RT_TRUE;
  74. #else
  75. if (path[0] == '/') return RT_TRUE;
  76. #endif
  77. return RT_FALSE;
  78. }
  79. int build_full_path(struct ftp_session* session, char* path, char* new_path, size_t size)
  80. {
  81. if (is_absolute_path(path) == RT_TRUE)
  82. strcpy(new_path, path);
  83. else
  84. {
  85. rt_sprintf(new_path, "%s/%s", session->currentdir, path);
  86. }
  87. return 0;
  88. }
  89. void ftpd_thread_entry(void* parameter)
  90. {
  91. int numbytes;
  92. int sockfd, maxfdp1;
  93. struct sockaddr_in local;
  94. fd_set readfds, tmpfds;
  95. struct ftp_session* session;
  96. rt_uint32_t addr_len = sizeof(struct sockaddr);
  97. char * buffer = (char *) rt_malloc(FTP_BUFFER_SIZE);
  98. local.sin_port=htons(FTP_PORT);
  99. local.sin_family=PF_INET;
  100. local.sin_addr.s_addr=INADDR_ANY;
  101. FD_ZERO(&readfds);
  102. FD_ZERO(&tmpfds);
  103. sockfd=socket(AF_INET, SOCK_STREAM, 0);
  104. if(sockfd < 0)
  105. {
  106. rt_kprintf("create socket failed\n");
  107. return ;
  108. }
  109. bind(sockfd, (struct sockaddr *)&local, addr_len);
  110. listen(sockfd, FTP_MAX_CONNECTION);
  111. FD_SET(sockfd, &readfds);
  112. for(;;)
  113. {
  114. /* get maximum fd */
  115. maxfdp1 = sockfd + 1;
  116. session = session_list;
  117. while (session != RT_NULL)
  118. {
  119. if (maxfdp1 < session->sockfd + 1)
  120. maxfdp1 = session->sockfd + 1;
  121. FD_SET(session->sockfd, &readfds);
  122. session = session->next;
  123. }
  124. tmpfds=readfds;
  125. if (select(maxfdp1, &tmpfds, 0, 0, 0) == 0) continue;
  126. if(FD_ISSET(sockfd, &tmpfds))
  127. {
  128. int com_socket;
  129. struct sockaddr_in remote;
  130. com_socket = accept(sockfd, (struct sockaddr*)&remote, &addr_len);
  131. if(com_socket == -1)
  132. {
  133. rt_kprintf("Error on accept()\nContinuing...\n");
  134. continue;
  135. }
  136. else
  137. {
  138. rt_kprintf("Got connection from %s\n", inet_ntoa(remote.sin_addr));
  139. send(com_socket, FTP_WELCOME_MSG, strlen(FTP_WELCOME_MSG), 0);
  140. FD_SET(com_socket, &readfds);
  141. /* new session */
  142. session = ftp_new_session();
  143. if (session != NULL)
  144. {
  145. strcpy(session->currentdir, FTP_SRV_ROOT);
  146. session->sockfd = com_socket;
  147. session->remote = remote;
  148. }
  149. }
  150. }
  151. {
  152. struct ftp_session* next;
  153. session = session_list;
  154. while (session != NULL)
  155. {
  156. next = session->next;
  157. if (FD_ISSET(session->sockfd, &tmpfds))
  158. {
  159. numbytes=recv(session->sockfd, buffer, FTP_BUFFER_SIZE, 0);
  160. if(numbytes==0 || numbytes==-1)
  161. {
  162. rt_kprintf("Client %s disconnected\n", inet_ntoa(session->remote.sin_addr));
  163. FD_CLR(session->sockfd, &readfds);
  164. closesocket(session->sockfd);
  165. ftp_close_session(session);
  166. }
  167. else
  168. {
  169. buffer[numbytes]=0;
  170. if(ftp_process_request(session, buffer)==-1)
  171. {
  172. rt_kprintf("Client %s disconnected\r\n", inet_ntoa(session->remote.sin_addr));
  173. closesocket(session->sockfd);
  174. ftp_close_session(session);
  175. }
  176. }
  177. }
  178. session = next;
  179. }
  180. }
  181. }
  182. // rt_free(buffer);
  183. }
  184. int do_list(char* directory, int sockfd)
  185. {
  186. DIR* dirp;
  187. struct dirent* entry;
  188. char line_buffer[256], line_length;
  189. #ifdef _WIN32
  190. struct _stat s;
  191. #else
  192. struct stat s;
  193. #endif
  194. dirp = opendir(directory);
  195. if (dirp == NULL)
  196. {
  197. line_length = rt_sprintf(line_buffer, "500 Internal Error\r\n");
  198. send(sockfd, line_buffer, line_length, 0);
  199. return -1;
  200. }
  201. while (1)
  202. {
  203. entry = readdir(dirp);
  204. if (entry == NULL) break;
  205. rt_sprintf(line_buffer, "%s/%s", directory, entry->d_name);
  206. #ifdef _WIN32
  207. if (_stat(line_buffer, &s) ==0)
  208. #else
  209. if (stat(line_buffer, &s) == 0)
  210. #endif
  211. {
  212. if (s.st_mode & S_IFDIR)
  213. line_length = rt_sprintf(line_buffer, "drw-r--r-- 1 admin admin %d Jan 1 2000 %s\r\n", 0, entry->d_name);
  214. else
  215. line_length = rt_sprintf(line_buffer, "-rw-r--r-- 1 admin admin %d Jan 1 2000 %s\r\n", s.st_size, entry->d_name);
  216. send(sockfd, line_buffer, line_length, 0);
  217. }
  218. }
  219. closedir(dirp);
  220. return 0;
  221. }
  222. int do_simple_list(char* directory, int sockfd)
  223. {
  224. DIR* dirp;
  225. struct dirent* entry;
  226. char line_buffer[256], line_length;
  227. dirp = opendir(directory);
  228. if (dirp == NULL)
  229. {
  230. line_length = rt_sprintf(line_buffer, "500 Internal Error\r\n");
  231. send(sockfd, line_buffer, line_length, 0);
  232. return -1;
  233. }
  234. while (1)
  235. {
  236. entry = readdir(dirp);
  237. if (entry == NULL) break;
  238. line_length = rt_sprintf(line_buffer, "%s\r\n", entry->d_name);
  239. send(sockfd, line_buffer, line_length, 0);
  240. }
  241. closedir(dirp);
  242. return 0;
  243. }
  244. int str_begin_with(char* src, char* match)
  245. {
  246. while (*match)
  247. {
  248. /* check source */
  249. if (*src == 0) return -1;
  250. if (*match != *src) return -1;
  251. match ++; src ++;
  252. }
  253. return 0;
  254. }
  255. int ftp_process_request(struct ftp_session* session, char *buf)
  256. {
  257. int fd;
  258. struct timeval tv;
  259. fd_set readfds;
  260. char filename[256];
  261. int numbytes;
  262. char *sbuf;
  263. char *parameter_ptr, *ptr;
  264. rt_uint32_t addr_len = sizeof(struct sockaddr_in);
  265. struct sockaddr_in local, pasvremote;
  266. sbuf =(char *)rt_malloc(FTP_BUFFER_SIZE);
  267. tv.tv_sec=3, tv.tv_usec=0;
  268. local.sin_family=PF_INET;
  269. local.sin_addr.s_addr=INADDR_ANY;
  270. /* remove \r\n */
  271. ptr = buf;
  272. while (*ptr)
  273. {
  274. if (*ptr == '\r' || *ptr == '\n') *ptr = 0;
  275. ptr ++;
  276. }
  277. /* get request parameter */
  278. parameter_ptr = strchr(buf, ' '); if (parameter_ptr != NULL) parameter_ptr ++;
  279. // debug:
  280. rt_kprintf("%s requested: \"%s\"\n", inet_ntoa(session->remote.sin_addr), buf);
  281. //
  282. //-----------------------
  283. if(str_begin_with(buf, "USER")==0)
  284. {
  285. rt_kprintf("%s sent login \"%s\"\n", inet_ntoa(session->remote.sin_addr), parameter_ptr);
  286. // login correct
  287. if(strcmp(parameter_ptr, "anonymous") == 0)
  288. {
  289. session->is_anonymous = RT_TRUE;
  290. rt_sprintf(sbuf, "331 Anonymous login OK send e-mail address for password.\r\n", parameter_ptr);
  291. send(session->sockfd, sbuf, strlen(sbuf), 0);
  292. }
  293. else if (strcmp(parameter_ptr, FTP_USER) == 0)
  294. {
  295. session->is_anonymous = RT_FALSE;
  296. rt_sprintf(sbuf, "331 Password required for %s\r\n", parameter_ptr);
  297. send(session->sockfd, sbuf, strlen(sbuf), 0);
  298. }
  299. else
  300. {
  301. // incorrect login
  302. rt_sprintf(sbuf, "530 Login incorrect. Bye.\r\n");
  303. send(session->sockfd, sbuf, strlen(sbuf), 0);
  304. rt_free(sbuf);
  305. return -1;
  306. }
  307. return 0;
  308. }
  309. else if(str_begin_with(buf, "PASS")==0)
  310. {
  311. rt_kprintf("%s sent password \"%s\"\n", inet_ntoa(session->remote.sin_addr), parameter_ptr);
  312. if (strcmp(parameter_ptr, FTP_PASSWORD)==0 ||
  313. session->is_anonymous == RT_TRUE)
  314. {
  315. // password correct
  316. rt_sprintf(sbuf, "230 User logged in\r\n");
  317. send(session->sockfd, sbuf, strlen(sbuf), 0);
  318. rt_free(sbuf);
  319. return 0;
  320. }
  321. // incorrect password
  322. rt_sprintf(sbuf, "530 Login or Password incorrect. Bye!\r\n");
  323. send(session->sockfd, sbuf, strlen(sbuf), 0);
  324. rt_free(sbuf);
  325. return -1;
  326. }
  327. else if(str_begin_with(buf, "LIST")==0 )
  328. {
  329. memset(sbuf,0,FTP_BUFFER_SIZE);
  330. rt_sprintf(sbuf, "150 Opening Binary mode connection for file list.\r\n");
  331. send(session->sockfd, sbuf, strlen(sbuf), 0);
  332. do_list(session->currentdir, session->pasv_sockfd);
  333. closesocket(session->pasv_sockfd);
  334. session->pasv_active = 0;
  335. rt_sprintf(sbuf, "226 Transfert Complete.\r\n");
  336. send(session->sockfd, sbuf, strlen(sbuf), 0);
  337. }
  338. else if(str_begin_with(buf, "NLST")==0 )
  339. {
  340. memset(sbuf, 0, FTP_BUFFER_SIZE);
  341. rt_sprintf(sbuf, "150 Opening Binary mode connection for file list.\r\n");
  342. send(session->sockfd, sbuf, strlen(sbuf), 0);
  343. do_simple_list(session->currentdir, session->pasv_sockfd);
  344. closesocket(session->pasv_sockfd);
  345. session->pasv_active = 0;
  346. rt_sprintf(sbuf, "226 Transfert Complete.\r\n");
  347. send(session->sockfd, sbuf, strlen(sbuf), 0);
  348. }
  349. else if(str_begin_with(buf, "PWD")==0 || str_begin_with(buf, "XPWD")==0)
  350. {
  351. rt_sprintf(sbuf, "257 \"%s\" is current directory.\r\n", session->currentdir);
  352. send(session->sockfd, sbuf, strlen(sbuf), 0);
  353. }
  354. else if(str_begin_with(buf, "TYPE")==0)
  355. {
  356. // Ignore it
  357. if(strcmp(parameter_ptr, "I")==0)
  358. {
  359. rt_sprintf(sbuf, "200 Type set to binary.\r\n");
  360. send(session->sockfd, sbuf, strlen(sbuf), 0);
  361. }
  362. else
  363. {
  364. rt_sprintf(sbuf, "200 Type set to ascii.\r\n");
  365. send(session->sockfd, sbuf, strlen(sbuf), 0);
  366. }
  367. }
  368. else if(str_begin_with(buf, "PASV")==0)
  369. {
  370. int dig1, dig2;
  371. int sockfd;
  372. char optval='1';
  373. session->pasv_port = 10000;
  374. session->pasv_active = 1;
  375. local.sin_port=htons(session->pasv_port);
  376. local.sin_addr.s_addr=INADDR_ANY;
  377. dig1 = (int)(session->pasv_port/256);
  378. dig2 = session->pasv_port % 256;
  379. FD_ZERO(&readfds);
  380. if((sockfd=socket(PF_INET, SOCK_STREAM, 0))==-1)
  381. {
  382. rt_sprintf(sbuf, "425 Can't open data connection.\r\n");
  383. send(session->sockfd, sbuf, strlen(sbuf), 0);
  384. goto err1;
  385. }
  386. if(setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &optval, sizeof(optval))==-1)
  387. {
  388. rt_sprintf(sbuf, "425 Can't open data connection.\r\n");
  389. send(session->sockfd, sbuf, strlen(sbuf), 0);
  390. goto err1;
  391. }
  392. if(bind(sockfd, (struct sockaddr *)&local, addr_len)==-1)
  393. {
  394. rt_sprintf(sbuf, "425 Can't open data connection.\r\n");
  395. send(session->sockfd, sbuf, strlen(sbuf), 0);
  396. goto err1;
  397. }
  398. if(listen(sockfd, 1)==-1)
  399. {
  400. rt_sprintf(sbuf, "425 Can't open data connection.\r\n");
  401. send(session->sockfd, sbuf, strlen(sbuf), 0);
  402. goto err1;
  403. }
  404. rt_kprintf("Listening %d seconds @ port %d\n", tv.tv_sec, session->pasv_port);
  405. rt_sprintf(sbuf, "227 Entering passive mode (%d,%d,%d,%d,%d,%d)\r\n", 127, 0, 0, 1, dig1, dig2);
  406. send(session->sockfd, sbuf, strlen(sbuf), 0);
  407. FD_SET(sockfd, &readfds);
  408. select(0, &readfds, 0, 0, &tv);
  409. if(FD_ISSET(sockfd, &readfds))
  410. {
  411. if((session->pasv_sockfd = accept(sockfd, (struct sockaddr*)&pasvremote, &addr_len))==-1)
  412. {
  413. rt_sprintf(sbuf, "425 Can't open data connection.\r\n");
  414. send(session->sockfd, sbuf, strlen(sbuf), 0);
  415. goto err1;
  416. }
  417. else
  418. {
  419. rt_kprintf("Got Data(PASV) connection from %s\n", inet_ntoa(pasvremote.sin_addr));
  420. session->pasv_active = 1;
  421. closesocket(sockfd);
  422. }
  423. }
  424. else
  425. {
  426. err1:
  427. closesocket(session->pasv_sockfd);
  428. session->pasv_active = 0;
  429. rt_free(sbuf);
  430. return 0;
  431. }
  432. }
  433. else if (str_begin_with(buf, "RETR")==0)
  434. {
  435. int file_size;
  436. strcpy(filename, buf + 5);
  437. build_full_path(session, parameter_ptr, filename, 256);
  438. file_size = ftp_get_filesize(filename);
  439. if (file_size == -1)
  440. {
  441. rt_sprintf(sbuf, "550 \"%s\" : not a regular file\r\n", filename);
  442. send(session->sockfd, sbuf, strlen(sbuf), 0);
  443. session->offset=0;
  444. rt_free(sbuf);
  445. return 0;
  446. }
  447. fd = open(filename, O_RDONLY, 0);
  448. if (fd < 0)
  449. {
  450. rt_free(sbuf);
  451. return 0;
  452. }
  453. if(session->offset>0 && session->offset < file_size)
  454. {
  455. lseek(fd, session->offset, SEEK_SET);
  456. rt_sprintf(sbuf, "150 Opening binary mode data connection for partial \"%s\" (%d/%d bytes).\r\n",
  457. filename, file_size - session->offset, file_size);
  458. }
  459. else
  460. {
  461. rt_sprintf(sbuf, "150 Opening binary mode data connection for \"%s\" (%d bytes).\r\n", filename, file_size);
  462. }
  463. send(session->sockfd, sbuf, strlen(sbuf), 0);
  464. while((numbytes = read(fd, sbuf, FTP_BUFFER_SIZE))>0)
  465. {
  466. send(session->pasv_sockfd, sbuf, numbytes, 0);
  467. }
  468. rt_sprintf(sbuf, "226 Finished.\r\n");
  469. send(session->sockfd, sbuf, strlen(sbuf), 0);
  470. closesocket(session->pasv_sockfd);
  471. }
  472. else if (str_begin_with(buf, "STOR")==0)
  473. {
  474. if(session->is_anonymous == RT_TRUE)
  475. {
  476. rt_sprintf(sbuf, "550 Permission denied.\r\n");
  477. send(session->sockfd, sbuf, strlen(sbuf), 0);
  478. rt_free(sbuf);
  479. return 0;
  480. }
  481. build_full_path(session, parameter_ptr, filename, 256);
  482. fd = open(filename, O_WRONLY | O_CREAT | O_TRUNC, 0);
  483. if(fd < 0)
  484. {
  485. rt_sprintf(sbuf, "550 Cannot open \"%s\" for writing.\r\n", filename);
  486. send(session->sockfd, sbuf, strlen(sbuf), 0);
  487. rt_free(sbuf);
  488. return 0;
  489. }
  490. rt_sprintf(sbuf, "150 Opening binary mode data connection for \"%s\".\r\n", filename);
  491. send(session->sockfd, sbuf, strlen(sbuf), 0);
  492. FD_ZERO(&readfds);
  493. FD_SET(session->pasv_sockfd, &readfds);
  494. rt_kprintf("Waiting %d seconds for data...\n", tv.tv_sec);
  495. while(select(session->pasv_sockfd+1, &readfds, 0, 0, &tv)>0 )
  496. {
  497. if((numbytes=recv(session->pasv_sockfd, sbuf, FTP_BUFFER_SIZE, 0))>0)
  498. {
  499. write(fd, sbuf, numbytes);
  500. }
  501. else if(numbytes==0)
  502. {
  503. close(fd);
  504. closesocket(session->pasv_sockfd);
  505. rt_sprintf(sbuf, "226 Finished.\r\n");
  506. send(session->sockfd, sbuf, strlen(sbuf), 0);
  507. break;
  508. }
  509. else if(numbytes==-1)
  510. {
  511. close(fd);
  512. closesocket(session->pasv_sockfd);
  513. rt_free(sbuf);
  514. return -1;
  515. }
  516. }
  517. closesocket(session->pasv_sockfd);
  518. }
  519. else if(str_begin_with(buf, "SIZE")==0)
  520. {
  521. int file_size;
  522. build_full_path(session, parameter_ptr, filename, 256);
  523. file_size = ftp_get_filesize(filename);
  524. if( file_size == -1)
  525. {
  526. rt_sprintf(sbuf, "550 \"%s\" : not a regular file\r\n", filename);
  527. send(session->sockfd, sbuf, strlen(sbuf), 0);
  528. }
  529. else
  530. {
  531. rt_sprintf(sbuf, "213 %d\r\n", file_size);
  532. send(session->sockfd, sbuf, strlen(sbuf), 0);
  533. }
  534. }
  535. else if(str_begin_with(buf, "MDTM")==0)
  536. {
  537. rt_sprintf(sbuf, "550 \"/\" : not a regular file\r\n");
  538. send(session->sockfd, sbuf, strlen(sbuf), 0);
  539. }
  540. else if(str_begin_with(buf, "SYST")==0)
  541. {
  542. rt_sprintf(sbuf, "215 %s\r\n", "RT-Thread RTOS");
  543. send(session->sockfd, sbuf, strlen(sbuf), 0);
  544. }
  545. else if(str_begin_with(buf, "CWD")==0)
  546. {
  547. build_full_path(session, parameter_ptr, filename, 256);
  548. rt_sprintf(sbuf, "250 Changed to directory \"%s\"\r\n", filename);
  549. send(session->sockfd, sbuf, strlen(sbuf), 0);
  550. strcpy(session->currentdir, filename);
  551. rt_kprintf("Changed to directory %s", filename);
  552. }
  553. else if(str_begin_with(buf, "CDUP")==0)
  554. {
  555. rt_sprintf(filename, "%s/%s", session->currentdir, "..");
  556. rt_sprintf(sbuf, "250 Changed to directory \"%s\"\r\n", filename);
  557. send(session->sockfd, sbuf, strlen(sbuf), 0);
  558. strcpy(session->currentdir, filename);
  559. rt_kprintf("Changed to directory %s", filename);
  560. }
  561. else if(str_begin_with(buf, "PORT")==0)
  562. {
  563. int i;
  564. int portcom[6];
  565. char tmpip[100];
  566. i=0;
  567. portcom[i++]=atoi(strtok(parameter_ptr, ".,;()"));
  568. for(;i<6;i++)
  569. portcom[i]=atoi(strtok(0, ".,;()"));
  570. rt_sprintf(tmpip, "%d.%d.%d.%d", portcom[0], portcom[1], portcom[2], portcom[3]);
  571. FD_ZERO(&readfds);
  572. if((session->pasv_sockfd=socket(AF_INET, SOCK_STREAM, 0))==-1)
  573. {
  574. rt_sprintf(sbuf, "425 Can't open data connection.\r\n");
  575. send(session->sockfd, sbuf, strlen(sbuf), 0);
  576. closesocket(session->pasv_sockfd);
  577. session->pasv_active = 0;
  578. rt_free(sbuf);
  579. return 0;
  580. }
  581. pasvremote.sin_addr.s_addr=inet_addr(tmpip);
  582. pasvremote.sin_port=htons(portcom[4] * 256 + portcom[5]);
  583. pasvremote.sin_family=PF_INET;
  584. if(connect(session->pasv_sockfd, (struct sockaddr *)&pasvremote, addr_len)==-1)
  585. {
  586. // is it only local address?try using gloal ip addr
  587. pasvremote.sin_addr=session->remote.sin_addr;
  588. if(connect(session->pasv_sockfd, (struct sockaddr *)&pasvremote, addr_len)==-1)
  589. {
  590. rt_sprintf(sbuf, "425 Can't open data connection.\r\n");
  591. send(session->sockfd, sbuf, strlen(sbuf), 0);
  592. closesocket(session->pasv_sockfd);
  593. rt_free(sbuf);
  594. return 0;
  595. }
  596. }
  597. session->pasv_active=1;
  598. session->pasv_port = portcom[4] * 256 + portcom[5];
  599. rt_kprintf("Connected to Data(PORT) %s @ %d\n", tmpip, portcom[4] * 256 + portcom[5]);
  600. rt_sprintf(sbuf, "200 Port Command Successful.\r\n");
  601. send(session->sockfd, sbuf, strlen(sbuf), 0);
  602. }
  603. else if(str_begin_with(buf, "REST")==0)
  604. {
  605. if(atoi(parameter_ptr)>=0)
  606. {
  607. session->offset=atoi(parameter_ptr);
  608. rt_sprintf(sbuf, "350 Send RETR or STOR to start transfert.\r\n");
  609. send(session->sockfd, sbuf, strlen(sbuf), 0);
  610. }
  611. }
  612. else if(str_begin_with(buf, "MKD")==0)
  613. {
  614. if (session->is_anonymous == RT_TRUE)
  615. {
  616. rt_sprintf(sbuf, "550 Permission denied.\r\n");
  617. send(session->sockfd, sbuf, strlen(sbuf), 0);
  618. rt_free(sbuf);
  619. return 0;
  620. }
  621. build_full_path(session, parameter_ptr, filename, 256);
  622. if(mkdir(filename, 0) == -1)
  623. {
  624. rt_sprintf(sbuf, "550 File \"%s\" exists.\r\n", filename);
  625. send(session->sockfd, sbuf, strlen(sbuf), 0);
  626. }
  627. else
  628. {
  629. rt_sprintf(sbuf, "257 directory \"%s\" successfully created.\r\n", filename);
  630. send(session->sockfd, sbuf, strlen(sbuf), 0);
  631. }
  632. }
  633. else if(str_begin_with(buf, "DELE")==0)
  634. {
  635. if (session->is_anonymous == RT_TRUE)
  636. {
  637. rt_sprintf(sbuf, "550 Permission denied.\r\n");
  638. send(session->sockfd, sbuf, strlen(sbuf), 0);
  639. rt_free(sbuf);
  640. return 0;
  641. }
  642. build_full_path(session, parameter_ptr, filename, 256);
  643. if(unlink(filename)==0)
  644. rt_sprintf(sbuf, "250 Successfully deleted file \"%s\".\r\n", filename);
  645. else
  646. {
  647. rt_sprintf(sbuf, "550 Not such file or directory: %s.\r\n", filename);
  648. }
  649. send(session->sockfd, sbuf, strlen(sbuf), 0);
  650. }
  651. else if(str_begin_with(buf, "RMD")==0)
  652. {
  653. if (session->is_anonymous == RT_TRUE)
  654. {
  655. rt_sprintf(sbuf, "550 Permission denied.\r\n");
  656. send(session->sockfd, sbuf, strlen(sbuf), 0);
  657. rt_free(sbuf);
  658. return 0;
  659. }
  660. build_full_path(session, parameter_ptr, filename, 256);
  661. if(unlink(filename) == -1)
  662. {
  663. rt_sprintf(sbuf, "550 Directory \"%s\" doesn't exist.\r\n", filename);
  664. send(session->sockfd, sbuf, strlen(sbuf), 0);
  665. }
  666. else
  667. {
  668. rt_sprintf(sbuf, "257 directory \"%s\" successfully deleted.\r\n", filename);
  669. send(session->sockfd, sbuf, strlen(sbuf), 0);
  670. }
  671. }
  672. else if(str_begin_with(buf, "QUIT")==0)
  673. {
  674. rt_sprintf(sbuf, "221 Bye!\r\n");
  675. send(session->sockfd, sbuf, strlen(sbuf), 0);
  676. rt_free(sbuf);
  677. return -1;
  678. }
  679. else
  680. {
  681. rt_sprintf(sbuf, "502 Not Implemented.\r\n");
  682. send(session->sockfd, sbuf, strlen(sbuf), 0);
  683. }
  684. rt_free(sbuf);
  685. return 0;
  686. }
  687. void ftpd_start()
  688. {
  689. rt_thread_t tid;
  690. tid = rt_thread_create("ftpd",
  691. ftpd_thread_entry, RT_NULL,
  692. 4096, 30, 5);
  693. if (tid != RT_NULL) rt_thread_startup(tid);
  694. }
  695. #ifdef RT_USING_FINSH
  696. #include <finsh.h>
  697. FINSH_FUNCTION_EXPORT(ftpd_start, start ftp server)
  698. #endif