开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 嵌入式/单片机编程 > Windows CE > 查看源码
file_win32.c
资源名称：tcpmp.rar　[点击查看]
上传用户：wstnjxml
上传日期：2014-04-03
资源大小：7248k
文件大小：9k
源码类别：

Windows CE

开发平台：

C/C++

file_win32.c：源码内容
  1. /*****************************************************************************
  2.  *
  3.  * This program is free software ; you can redistribute it and/or modify
  4.  * it under the terms of the GNU General Public License as published by
  5.  * the Free Software Foundation; either version 2 of the License, or
  6.  * (at your option) any later version.
  7.  *
  8.  * This program is distributed in the hope that it will be useful,
  9.  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  10.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  11.  * GNU General Public License for more details.
  12.  *
  13.  * You should have received a copy of the GNU General Public License
  14.  * along with this program; if not, write to the Free Software
  15.  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307 USA
  16.  *
  17.  * $Id: file_win32.c 543 2006-01-07 22:06:24Z picard $
  18.  *
  19.  * The Core Pocket Media Player
  20.  * Copyright (c) 2004-2005 Gabor Kovacs
  21.  *
  22.  ****************************************************************************/
  24. #include "../common.h"
  26. #if defined(TARGET_WIN32) || defined(TARGET_WINCE)
  28. #ifndef STRICT
  29. #define STRICT
  30. #endif
  31. #define WIN32_LEAN_AND_MEAN
  32. #include <windows.h>
  34. #ifndef ERROR_INVALID_DRIVE_OBJECT
  35. #define ERROR_INVALID_DRIVE_OBJECT 4321L
  36. #endif
  38. #ifndef ERROR_DEVICE_NOT_AVAILABLE
  39. #define ERROR_DEVICE_NOT_AVAILABLE 4319L
  40. #endif
  42. #ifndef ERROR_DEVICE_REMOVED
  43. #define ERROR_DEVICE_REMOVED            1617L
  44. #endif
  46. typedef struct filestream
  47. {
  48. stream Stream;
  49. tchar_t URL[MAXPATH];
  50. HANDLE Handle;
  51. filepos_t Length;
  52. filepos_t Pos;
  53. bool_t Silent;
  54. bool_t Create;
  56. HANDLE Find;
  57. const tchar_t* Exts;
  58. bool_t ExtFilter;
  59. WIN32_FIND_DATA FindData;
  61. } filestream;
  63. static int Get(filestream* p, int No, void* Data, int Size)
  64. {
  65. int Result = ERR_INVALID_PARAM;
  66. switch (No)
  67. {
  68. case STREAM_URL: GETSTRING(p->URL); break;
  69. case STREAM_SILENT: GETVALUE(p->Silent,bool_t); break;
  70. case STREAM_LENGTH: GETVALUECOND(p->Length,int,p->Length>=0); break;
  71. case STREAM_CREATE: GETVALUE(p->Create,bool_t); break;
  72. }
  73. return Result;
  74. }
  76. static int Open(filestream* p, const tchar_t* URL, bool_t ReOpen)
  77. {
  78. if (p->Handle)
  79. CloseHandle(p->Handle);
  80. p->Handle = 0;
  81. p->Length = -1;
  82. if (!ReOpen)
  83. p->URL[0] = 0;
  84. else
  85. Sleep(200);
  87. if (URL && URL[0])
  88. {
  89. HANDLE Handle;
  91. Handle = CreateFile(URL,p->Create?GENERIC_WRITE:GENERIC_READ,
  92. FILE_SHARE_READ|FILE_SHARE_WRITE,NULL,p->Create?CREATE_ALWAYS:OPEN_EXISTING,
  93. FILE_ATTRIBUTE_NORMAL,NULL);
  95. if (Handle == INVALID_HANDLE_VALUE)
  96. {
  97. if (!ReOpen && !p->Silent)
  98. ShowError(0,ERR_ID,ERR_FILE_NOT_FOUND,URL);
  99. return ERR_FILE_NOT_FOUND;
  100. }
  102. tcscpy_s(p->URL,TSIZEOF(p->URL),URL);
  103. p->Handle = Handle;
  105. p->Length = GetFileSize(Handle,NULL);
  106. if (ReOpen)
  107. p->Pos = SetFilePointer(p->Handle,p->Pos,NULL,FILE_BEGIN);
  108. else
  109. {
  110. p->Pos = 0;
  112. #if defined(TARGET_WINCE)
  114. // wince shortcut handling
  116. if (p->Length < MAXPATH && !p->Create)
  117. {
  118. uint32_t Readed;
  119. char ShortCut[MAXPATH];
  120. tchar_t URL[MAXPATH];
  121. char* ch;
  123. if (ReadFile(p->Handle,ShortCut,p->Length,&Readed,NULL))
  124. {
  125. ShortCut[Readed] = 0;
  127. for (ch=ShortCut;*ch && *ch!='#';++ch)
  128. if (!IsDigit(*ch))
  129. break;
  131. if (ch[0] == '#' && ch[1]!=':')
  132. {
  133. char* Head = ++ch;
  134. char* Tail;
  136. if (*ch == '"')
  137. {
  138. Head++;
  139. ch = strchr(ch+1,'"');
  140. if (ch)
  141. *(ch++) = 0;
  142. }
  144. if (ch)
  145. {
  146. Tail = strchr(ch,13);
  147. if (Tail)
  148. {
  149. *Tail = 0;
  150. ch = Tail+1;
  151. }
  152. if (!strchr(ch,13))
  153. {
  154. ch = strchr(ch,10);
  155. if (!ch || !strchr(ch+1,10))
  156. {
  157. if (ch) *ch = 0;
  159. StrToTcs(URL,TSIZEOF(URL),Head);
  160. return Open(p,URL,0);
  161. }
  162. }
  163. }
  164. }
  166. p->Pos = SetFilePointer(p->Handle,0,NULL,FILE_BEGIN);
  167. }
  168. }
  169. #endif
  170. }
  171. }
  172. return ERR_NONE;
  173. }
  175. static int Set(filestream* p, int No, const void* Data, int Size)
  176. {
  177. int Result = ERR_INVALID_PARAM;
  178. switch (No)
  179. {
  180. case STREAM_SILENT: SETVALUE(p->Silent,bool_t,ERR_NONE); break;
  181. case STREAM_CREATE: SETVALUE(p->Create,bool_t,ERR_NONE); break;
  182. case STREAM_URL:
  183. Result = Open(p,(const tchar_t*)Data,0);
  184. break;
  185. }
  186. return Result;
  187. }
  189. static int Read(filestream* p,void* Data,int Size)
  190. {
  191. uint32_t Readed;
  192. DWORD Error;
  194. //Sleep(100); 
  196. //DEBUG_MSG3(-1,"FileRead: %08x %08x %d",p->Pos,SetFilePointer(p->Handle,0,NULL,FILE_CURRENT),Size);
  198. if (ReadFile(p->Handle,Data,Size,&Readed,NULL))
  199. {
  200. //DEBUG_MSG2(T("READ pos:%d len:%d"),p->Pos,Readed);
  201. p->Pos += Readed;
  202. return Readed;
  203. }
  205. Error = GetLastError();
  207. //DEBUG_MSG2(T("READ pos:%d error:%d"),p->Pos,Error);
  209. if (Error == ERROR_DEVICE_REMOVED || 
  210. Error == ERROR_DEVICE_NOT_AVAILABLE ||
  211. Error == ERROR_INVALID_HANDLE || 
  212. Error == ERROR_INVALID_DRIVE_OBJECT ||
  213. Error == ERROR_DEV_NOT_EXIST ||
  214. Error == ERROR_GEN_FAILURE)
  215. Open(p,p->URL,1);
  217. return -1;
  218. }
  220. static int ReadBlock(filestream* p,block* Block,int Ofs,int Size)
  221. {
  222. return Read(p,(char*)(Block->Ptr+Ofs),Size);
  223. }
  225. static int Seek(filestream* p,int Pos,int SeekMode)
  226. {
  227. int ReTry=3;
  228. int Result;
  229. DWORD Error;
  231. switch (SeekMode)
  232. {
  233. default:
  234. case SEEK_SET: SeekMode = FILE_BEGIN; break;
  235. case SEEK_CUR: SeekMode = FILE_CURRENT; break;
  236. case SEEK_END: SeekMode = FILE_END; break;
  237. }
  239. do
  240. {
  241. //DEBUG_MSG3(-1,"FileSeek: %08x %08x %d",SetFilePointer(p->Handle,0,NULL,FILE_CURRENT),Pos,SeekMode);
  243. Result = SetFilePointer(p->Handle,Pos,NULL,SeekMode);
  245. if (Result != -1)
  246. {
  247. p->Pos = Result;
  248. break;
  249. }
  251. Error = GetLastError();
  252. if (Error != ERROR_DEVICE_REMOVED && Error != ERROR_INVALID_HANDLE)
  253. break;
  255. Open(p,p->URL,1);
  256. }
  257. while (--ReTry>0);
  259. return Result;
  260. }
  262. static int Write(filestream* p,const void* Data,int Size)
  263. {
  264. DWORD Written;
  265. if (WriteFile(p->Handle,Data,Size,&Written,NULL))
  266. {
  267. p->Pos += Written;
  268. return Written;
  269. }
  270. return -1;
  271. }
  273. static int EnumDir(filestream* p,const tchar_t* URL,const tchar_t* Exts,bool_t ExtFilter,streamdir* Item)
  274. {
  275. if (URL)
  276. {
  277. DWORD Attrib;
  278. tchar_t Path[MAXPATH];
  280. p->Exts = Exts;
  281. p->ExtFilter = ExtFilter;
  283. if (p->Find != INVALID_HANDLE_VALUE)
  284. {
  285. FindClose(p->Find);
  286. p->Find = INVALID_HANDLE_VALUE;
  287. }
  289. stprintf_s(Path,TSIZEOF(Path),T("%s\*.*"),URL);
  291. Attrib = GetFileAttributes(URL);
  292. if (URL[0] && Attrib == (DWORD)-1)
  293. return ERR_FILE_NOT_FOUND;
  295. if (!(Attrib & FILE_ATTRIBUTE_DIRECTORY))
  296. return ERR_NOT_DIRECTORY;
  298. p->Find = FindFirstFile(Path, &p->FindData);
  299. }
  301. Item->FileName[0] = 0;
  302. Item->DisplayName[0] = 0;
  304. while (!Item->FileName[0] && p->Find != INVALID_HANDLE_VALUE)
  305. {
  306. if (p->FindData.cFileName[0]!='.') // skip unix/mac hidden files and . .. directory entries
  307. {
  308. FILETIME Local;
  310. tcscpy_s(Item->FileName,TSIZEOF(Item->FileName),p->FindData.cFileName);
  312. if (FileTimeToLocalFileTime(&p->FindData.ftLastWriteTime,&Local))
  313. Item->Date = ((int64_t)Local.dwHighDateTime << 32)|Local.dwLowDateTime;
  314. else
  315. Item->Date = -1;
  317. if (p->FindData.dwFileAttributes & FILE_ATTRIBUTE_DIRECTORY)
  318. Item->Size = -1;
  319. else
  320. {
  321. Item->Size = p->FindData.nFileSizeLow;
  322. Item->Type = CheckExts(Item->FileName,p->Exts);
  324. if (!Item->Type && p->ExtFilter)
  325. Item->FileName[0] = 0; // skip
  326. }
  327. }
  329. if (!FindNextFile(p->Find,&p->FindData))
  330. {
  331. FindClose(p->Find);
  332. p->Find = INVALID_HANDLE_VALUE;
  333. }
  334. }
  336. if (!Item->FileName[0])
  337. {
  338. if (p->Find != INVALID_HANDLE_VALUE)
  339. {
  340. FindClose(p->Find);
  341. p->Find = INVALID_HANDLE_VALUE;
  342. }
  343. return ERR_END_OF_FILE;
  344. }
  346. return ERR_NONE;
  347. }
  349. static int Create(filestream* p)
  350. {
  351. p->Stream.Get = (nodeget)Get,
  352. p->Stream.Set = (nodeset)Set,
  353. p->Stream.Read = Read;
  354. p->Stream.ReadBlock = ReadBlock;
  355. p->Stream.Write = Write;
  356. p->Stream.Seek = Seek;
  357. p->Stream.EnumDir = EnumDir;
  358. p->Find = INVALID_HANDLE_VALUE;
  359. return ERR_NONE;
  360. }
  362. static void Delete(filestream* p)
  363. {
  364. Open(p,NULL,0);
  365. if (p->Find != INVALID_HANDLE_VALUE)
  366. FindClose(p->Find);
  367. }
  369. static const nodedef File =
  370. {
  371. sizeof(filestream),
  372. FILE_ID,
  373. STREAM_CLASS,
  374. PRI_MINIMUM,
  375. (nodecreate)Create,
  376. (nodedelete)Delete,
  377. };
  379. void File_Init()
  380. {
  381. NodeRegisterClass(&File);
  382. }
  384. void File_Done()
  385. {
  386. NodeUnRegisterClass(FILE_ID);
  387. }
  389. stream* FileCreate(const tchar_t* Path)
  390. {
  391. // create fake stream
  392. filestream* p = (filestream*)malloc(sizeof(filestream));
  393. memset(p,0,sizeof(filestream));
  394. p->Stream.Class = FILE_ID;
  395. p->Stream.Enum = (nodeenum)StreamEnum;
  396. Create(p);
  397. return &p->Stream;
  398. }
  400. void FileRelease(stream* p)
  401. {
  402. if (p)
  403. {
  404. Delete((filestream*)p);
  405. free(p);
  406. }
  407. }
  409. bool_t FileExits(const tchar_t* Path)
  410. {
  411. return GetFileAttributes(Path) != (DWORD)-1;
  412. }
  414. int64_t FileDate(const tchar_t* Path)
  415. {
  416. int64_t Date = -1;
  417. HANDLE Find;
  418. SYSTEMTIME Time;
  419. WIN32_FIND_DATA FindData;
  421. Find = FindFirstFile(Path, &FindData);
  422. if (Find != INVALID_HANDLE_VALUE)
  423. {
  424. if (FileTimeToSystemTime(&FindData.ftLastWriteTime,&Time))
  425. Date = ((((((int64_t)Time.wYear*100+(int64_t)Time.wMonth)*100+(int64_t)Time.wDay)*100+
  426.        (int64_t)Time.wHour)*100+(int64_t)Time.wMinute)*100+(int64_t)Time.wSecond)*1000+(int64_t)Time.wMilliseconds;
  427. FindClose(Find);
  428. }
  429. return Date;
  430. }
  432. #endif