mfplat: Read queue subscriber within the critical section.
[wine/zf.git] / dlls / kernel32 / lzexpand.c
blobb021a6012b97410fcd38f1c5fa9d63ecbb85a2da
1 /*
2 * LZ Decompression functions
4 * Copyright 1996 Marcus Meissner
6 * This library is free software; you can redistribute it and/or
7 * modify it under the terms of the GNU Lesser General Public
8 * License as published by the Free Software Foundation; either
9 * version 2.1 of the License, or (at your option) any later version.
11 * This library is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 * Lesser General Public License for more details.
16 * You should have received a copy of the GNU Lesser General Public
17 * License along with this library; if not, write to the Free Software
18 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
20 * NOTES
22 * The LZ (Lempel Ziv) decompression was used in win16 installation programs.
23 * It is a simple tabledriven decompression engine, the algorithm is not
24 * documented as far as I know. WINE does not contain a compressor for
25 * this format.
27 * The implementation is complete and there have been no reports of failures
28 * for some time.
30 * TODO:
32 * o Check whether the return values are correct
36 #include <string.h>
37 #include <ctype.h>
38 #include <sys/types.h>
39 #include <stdarg.h>
40 #include <stdio.h>
42 #include "windef.h"
43 #include "winbase.h"
44 #include "winnls.h"
45 #include "winternl.h"
46 #include "lzexpand.h"
48 #include "wine/debug.h"
50 WINE_DEFAULT_DEBUG_CHANNEL(file);
52 /* The readahead length of the decompressor. Reading single bytes
53 * using _lread() would be SLOW.
55 #define GETLEN 2048
57 #define LZ_MAGIC_LEN 8
58 #define LZ_HEADER_LEN 14
60 /* Format of first 14 byte of LZ compressed file */
61 struct lzfileheader {
62 BYTE magic[LZ_MAGIC_LEN];
63 BYTE compressiontype;
64 CHAR lastchar;
65 DWORD reallength;
67 static const BYTE LZMagic[LZ_MAGIC_LEN]={'S','Z','D','D',0x88,0xf0,0x27,0x33};
69 #define LZ_TABLE_SIZE 0x1000
71 struct lzstate {
72 HFILE realfd; /* the real filedescriptor */
73 CHAR lastchar; /* the last char of the filename */
75 DWORD reallength; /* the decompressed length of the file */
76 DWORD realcurrent; /* the position the decompressor currently is */
77 DWORD realwanted; /* the position the user wants to read from */
79 BYTE table[LZ_TABLE_SIZE]; /* the rotating LZ table */
80 UINT curtabent; /* CURrent TABle ENTry */
82 BYTE stringlen; /* length and position of current string */
83 DWORD stringpos; /* from stringtable */
86 WORD bytetype; /* bitmask within blocks */
88 BYTE *get; /* GETLEN bytes */
89 DWORD getcur; /* current read */
90 DWORD getlen; /* length last got */
93 #define MAX_LZSTATES 16
94 static struct lzstate *lzstates[MAX_LZSTATES];
96 #define LZ_MIN_HANDLE 0x400
97 #define IS_LZ_HANDLE(h) (((h) >= LZ_MIN_HANDLE) && ((h) < LZ_MIN_HANDLE+MAX_LZSTATES))
98 #define GET_LZ_STATE(h) (IS_LZ_HANDLE(h) ? lzstates[(h)-LZ_MIN_HANDLE] : NULL)
100 /* reads one compressed byte, including buffering */
101 #define GET(lzs,b) _lzget(lzs,&b)
102 #define GET_FLUSH(lzs) lzs->getcur=lzs->getlen;
104 static int
105 _lzget(struct lzstate *lzs,BYTE *b) {
106 if (lzs->getcur<lzs->getlen) {
107 *b = lzs->get[lzs->getcur++];
108 return 1;
109 } else {
110 int ret = _lread(lzs->realfd,lzs->get,GETLEN);
111 if (ret==HFILE_ERROR)
112 return HFILE_ERROR;
113 if (ret==0)
114 return 0;
115 lzs->getlen = ret;
116 lzs->getcur = 1;
117 *b = *(lzs->get);
118 return 1;
121 /* internal function, reads lzheader
122 * returns BADINHANDLE for non filedescriptors
123 * return 0 for file not compressed using LZ
124 * return UNKNOWNALG for unknown algorithm
125 * returns lzfileheader in *head
127 static INT read_header(HFILE fd,struct lzfileheader *head)
129 BYTE buf[LZ_HEADER_LEN];
131 if (_llseek(fd,0,SEEK_SET)==-1)
132 return LZERROR_BADINHANDLE;
134 /* We can't directly read the lzfileheader struct due to
135 * structure element alignment
137 if (_lread(fd,buf,LZ_HEADER_LEN) != LZ_HEADER_LEN)
138 return 0;
139 memcpy(head->magic,buf,LZ_MAGIC_LEN);
140 memcpy(&(head->compressiontype),buf+LZ_MAGIC_LEN,1);
141 memcpy(&(head->lastchar),buf+LZ_MAGIC_LEN+1,1);
143 /* FIXME: consider endianness on non-intel architectures */
144 memcpy(&(head->reallength),buf+LZ_MAGIC_LEN+2,4);
146 if (memcmp(head->magic,LZMagic,LZ_MAGIC_LEN))
147 return 0;
148 if (head->compressiontype!='A')
149 return LZERROR_UNKNOWNALG;
150 return 1;
154 /***********************************************************************
155 * LZStart (KERNEL32.@)
157 INT WINAPI LZStart(void)
159 TRACE("(void)\n");
160 return 1;
164 /***********************************************************************
165 * LZInit (KERNEL32.@)
167 * initializes internal decompression buffers, returns lzfiledescriptor.
168 * (return value the same as hfSrc, if hfSrc is not compressed)
169 * on failure, returns error code <0
170 * lzfiledescriptors range from 0x400 to 0x410 (only 16 open files per process)
172 * since _llseek uses the same types as libc.lseek, we just use the macros of
173 * libc
175 HFILE WINAPI LZInit( HFILE hfSrc )
178 struct lzfileheader head;
179 struct lzstate *lzs;
180 int i, ret;
182 TRACE("(%d)\n",hfSrc);
183 ret=read_header(hfSrc,&head);
184 if (ret<=0) {
185 _llseek(hfSrc,0,SEEK_SET);
186 return ret?ret:hfSrc;
188 for (i = 0; i < MAX_LZSTATES; i++) if (!lzstates[i]) break;
189 if (i == MAX_LZSTATES) return LZERROR_GLOBALLOC;
190 lzstates[i] = lzs = HeapAlloc( GetProcessHeap(), HEAP_ZERO_MEMORY, sizeof(*lzs) );
191 if(lzs == NULL) return LZERROR_GLOBALLOC;
193 lzs->realfd = hfSrc;
194 lzs->lastchar = head.lastchar;
195 lzs->reallength = head.reallength;
197 lzs->get = HeapAlloc( GetProcessHeap(), 0, GETLEN );
198 lzs->getlen = 0;
199 lzs->getcur = 0;
201 if(lzs->get == NULL) {
202 HeapFree(GetProcessHeap(), 0, lzs);
203 lzstates[i] = NULL;
204 return LZERROR_GLOBALLOC;
207 /* Yes, preinitialize with spaces */
208 memset(lzs->table,' ',LZ_TABLE_SIZE);
209 /* Yes, start 16 byte from the END of the table */
210 lzs->curtabent = 0xff0;
211 return LZ_MIN_HANDLE + i;
215 /***********************************************************************
216 * LZDone (KERNEL32.@)
218 void WINAPI LZDone(void)
220 TRACE("(void)\n");
224 /***********************************************************************
225 * GetExpandedNameA (KERNEL32.@)
227 * gets the full filename of the compressed file 'in' by opening it
228 * and reading the header
230 * "file." is being translated to "file"
231 * "file.bl_" (with lastchar 'a') is being translated to "file.bla"
232 * "FILE.BL_" (with lastchar 'a') is being translated to "FILE.BLA"
235 INT WINAPI GetExpandedNameA( LPSTR in, LPSTR out )
237 struct lzfileheader head;
238 HFILE fd;
239 OFSTRUCT ofs;
240 INT fnislowercased,ret,len;
241 LPSTR s,t;
243 TRACE("(%s)\n",in);
244 fd=OpenFile(in,&ofs,OF_READ);
245 if (fd==HFILE_ERROR)
246 return (INT)(INT16)LZERROR_BADINHANDLE;
247 strcpy(out,in);
248 ret=read_header(fd,&head);
249 if (ret<=0) {
250 /* not a LZ compressed file, so the expanded name is the same
251 * as the input name */
252 _lclose(fd);
253 return 1;
257 /* look for directory prefix and skip it. */
258 s=out;
259 while (NULL!=(t=strpbrk(s,"/\\:")))
260 s=t+1;
262 /* now mangle the basename */
263 if (!*s) {
264 /* FIXME: hmm. shouldn't happen? */
265 WARN("Specified a directory or what? (%s)\n",in);
266 _lclose(fd);
267 return 1;
269 /* see if we should use lowercase or uppercase on the last char */
270 fnislowercased=1;
271 t=s+strlen(s)-1;
272 while (t>=out) {
273 if (!isalpha(*t)) {
274 t--;
275 continue;
277 fnislowercased=islower(*t);
278 break;
280 if (isalpha(head.lastchar)) {
281 if (fnislowercased)
282 head.lastchar=tolower(head.lastchar);
283 else
284 head.lastchar=RtlUpperChar(head.lastchar);
287 /* now look where to replace the last character */
288 if (NULL!=(t=strchr(s,'.'))) {
289 if (t[1]=='\0') {
290 t[0]='\0';
291 } else {
292 len=strlen(t)-1;
293 if (t[len]=='_')
294 t[len]=head.lastchar;
296 } /* else no modification necessary */
297 _lclose(fd);
298 return 1;
302 /***********************************************************************
303 * GetExpandedNameW (KERNEL32.@)
305 INT WINAPI GetExpandedNameW( LPWSTR in, LPWSTR out )
307 INT ret;
308 DWORD len = WideCharToMultiByte( CP_ACP, 0, in, -1, NULL, 0, NULL, NULL );
309 char *xin = HeapAlloc( GetProcessHeap(), 0, len );
310 char *xout = HeapAlloc( GetProcessHeap(), 0, len+3 );
311 WideCharToMultiByte( CP_ACP, 0, in, -1, xin, len, NULL, NULL );
312 if ((ret = GetExpandedNameA( xin, xout )) > 0)
313 MultiByteToWideChar( CP_ACP, 0, xout, -1, out, lstrlenW(in)+4 );
314 HeapFree( GetProcessHeap(), 0, xin );
315 HeapFree( GetProcessHeap(), 0, xout );
316 return ret;
320 /***********************************************************************
321 * LZRead (KERNEL32.@)
323 INT WINAPI LZRead( HFILE fd, LPSTR vbuf, INT toread )
325 int howmuch;
326 BYTE b,*buf;
327 struct lzstate *lzs;
329 buf=(LPBYTE)vbuf;
330 TRACE("(%d,%p,%d)\n",fd,buf,toread);
331 howmuch=toread;
332 if (!(lzs = GET_LZ_STATE(fd))) return _lread(fd,buf,toread);
334 /* The decompressor itself is in a define, cause we need it twice
335 * in this function. (the decompressed byte will be in b)
337 #define DECOMPRESS_ONE_BYTE \
338 if (lzs->stringlen) { \
339 b = lzs->table[lzs->stringpos]; \
340 lzs->stringpos = (lzs->stringpos+1)&0xFFF; \
341 lzs->stringlen--; \
342 } else { \
343 if (!(lzs->bytetype&0x100)) { \
344 if (1!=GET(lzs,b)) \
345 return toread-howmuch; \
346 lzs->bytetype = b|0xFF00; \
348 if (lzs->bytetype & 1) { \
349 if (1!=GET(lzs,b)) \
350 return toread-howmuch; \
351 } else { \
352 BYTE b1,b2; \
354 if (1!=GET(lzs,b1)) \
355 return toread-howmuch; \
356 if (1!=GET(lzs,b2)) \
357 return toread-howmuch; \
358 /* Format: \
359 * b1 b2 \
360 * AB CD \
361 * where CAB is the stringoffset in the table\
362 * and D+3 is the len of the string \
363 */ \
364 lzs->stringpos = b1|((b2&0xf0)<<4); \
365 lzs->stringlen = (b2&0xf)+2; \
366 /* 3, but we use a byte already below ... */\
367 b = lzs->table[lzs->stringpos];\
368 lzs->stringpos = (lzs->stringpos+1)&0xFFF;\
370 lzs->bytetype>>=1; \
372 /* store b in table */ \
373 lzs->table[lzs->curtabent++]= b; \
374 lzs->curtabent &= 0xFFF; \
375 lzs->realcurrent++;
377 /* if someone has seeked, we have to bring the decompressor
378 * to that position
380 if (lzs->realcurrent!=lzs->realwanted) {
381 /* if the wanted position is before the current position
382 * I see no easy way to unroll ... We have to restart at
383 * the beginning. *sigh*
385 if (lzs->realcurrent>lzs->realwanted) {
386 /* flush decompressor state */
387 _llseek(lzs->realfd,LZ_HEADER_LEN,SEEK_SET);
388 GET_FLUSH(lzs);
389 lzs->realcurrent= 0;
390 lzs->bytetype = 0;
391 lzs->stringlen = 0;
392 memset(lzs->table,' ',LZ_TABLE_SIZE);
393 lzs->curtabent = 0xFF0;
395 while (lzs->realcurrent<lzs->realwanted) {
396 DECOMPRESS_ONE_BYTE;
400 while (howmuch) {
401 DECOMPRESS_ONE_BYTE;
402 lzs->realwanted++;
403 *buf++ = b;
404 howmuch--;
406 return toread;
407 #undef DECOMPRESS_ONE_BYTE
411 /***********************************************************************
412 * LZSeek (KERNEL32.@)
414 LONG WINAPI LZSeek( HFILE fd, LONG off, INT type )
416 struct lzstate *lzs;
417 LONG newwanted;
419 TRACE("(%d,%d,%d)\n",fd,off,type);
420 /* not compressed? just use normal _llseek() */
421 if (!(lzs = GET_LZ_STATE(fd))) return _llseek(fd,off,type);
422 newwanted = lzs->realwanted;
423 switch (type) {
424 case 1: /* SEEK_CUR */
425 newwanted += off;
426 break;
427 case 2: /* SEEK_END */
428 newwanted = lzs->reallength-off;
429 break;
430 default:/* SEEK_SET */
431 newwanted = off;
432 break;
434 if (newwanted>lzs->reallength)
435 return LZERROR_BADVALUE;
436 if (newwanted<0)
437 return LZERROR_BADVALUE;
438 lzs->realwanted = newwanted;
439 return newwanted;
443 /***********************************************************************
444 * LZCopy (KERNEL32.@)
446 * Copies everything from src to dest
447 * if src is a LZ compressed file, it will be uncompressed.
448 * will return the number of bytes written to dest or errors.
450 LONG WINAPI LZCopy( HFILE src, HFILE dest )
452 int usedlzinit = 0, ret, wret;
453 LONG len;
454 HFILE oldsrc = src, srcfd;
455 FILETIME filetime;
456 struct lzstate *lzs;
457 #define BUFLEN 1000
458 CHAR buf[BUFLEN];
459 /* we need that weird typedef, for i can't seem to get function pointer
460 * casts right. (Or they probably just do not like WINAPI in general)
462 typedef UINT (WINAPI *_readfun)(HFILE,LPVOID,UINT);
464 _readfun xread;
466 TRACE("(%d,%d)\n",src,dest);
467 if (!IS_LZ_HANDLE(src)) {
468 src = LZInit(src);
469 if ((INT)src <= 0) return 0;
470 if (src != oldsrc) usedlzinit=1;
473 /* not compressed? just copy */
474 if (!IS_LZ_HANDLE(src))
475 xread=_lread;
476 else
477 xread=(_readfun)LZRead;
478 len=0;
479 while (1) {
480 ret=xread(src,buf,BUFLEN);
481 if (ret<=0) {
482 if (ret==0)
483 break;
484 if (ret==-1)
485 return LZERROR_READ;
486 return ret;
488 len += ret;
489 wret = _lwrite(dest,buf,ret);
490 if (wret!=ret)
491 return LZERROR_WRITE;
494 /* Maintain the timestamp of source file to destination file */
495 srcfd = (!(lzs = GET_LZ_STATE(src))) ? src : lzs->realfd;
496 GetFileTime( LongToHandle(srcfd), NULL, NULL, &filetime );
497 SetFileTime( LongToHandle(dest), NULL, NULL, &filetime );
499 /* close handle */
500 if (usedlzinit)
501 LZClose(src);
502 return len;
503 #undef BUFLEN
506 /* reverses GetExpandedPathname */
507 static LPSTR LZEXPAND_MangleName( LPCSTR fn )
509 char *p;
510 char *mfn = HeapAlloc( GetProcessHeap(), 0, strlen(fn) + 3 ); /* "._" and \0 */
511 if(mfn == NULL) return NULL;
512 strcpy( mfn, fn );
513 if (!(p = strrchr( mfn, '\\' ))) p = mfn;
514 if ((p = strchr( p, '.' )))
516 p++;
517 if (strlen(p) < 3) strcat( p, "_" ); /* append '_' */
518 else p[strlen(p)-1] = '_'; /* replace last character */
520 else strcat( mfn, "._" ); /* append "._" */
521 return mfn;
525 /***********************************************************************
526 * LZOpenFileA (KERNEL32.@)
528 * Opens a file. If not compressed, open it as a normal file.
530 HFILE WINAPI LZOpenFileA( LPSTR fn, LPOFSTRUCT ofs, WORD mode )
532 HFILE fd,cfd;
533 BYTE ofs_cBytes = ofs->cBytes;
535 TRACE("(%s,%p,%d)\n",fn,ofs,mode);
536 /* 0x70 represents all OF_SHARE_* flags, ignore them for the check */
537 fd=OpenFile(fn,ofs,mode);
538 if (fd==HFILE_ERROR)
540 LPSTR mfn = LZEXPAND_MangleName(fn);
541 fd = OpenFile(mfn,ofs,mode);
542 HeapFree( GetProcessHeap(), 0, mfn );
544 if (fd==HFILE_ERROR)
545 ofs->cBytes = ofs_cBytes;
546 if ((mode&~0x70)!=OF_READ)
547 return fd;
548 if (fd==HFILE_ERROR)
549 return HFILE_ERROR;
550 cfd=LZInit(fd);
551 if ((INT)cfd <= 0) return fd;
552 return cfd;
556 /***********************************************************************
557 * LZOpenFileW (KERNEL32.@)
559 HFILE WINAPI LZOpenFileW( LPWSTR fn, LPOFSTRUCT ofs, WORD mode )
561 HFILE ret;
562 DWORD len = WideCharToMultiByte( CP_ACP, 0, fn, -1, NULL, 0, NULL, NULL );
563 LPSTR xfn = HeapAlloc( GetProcessHeap(), 0, len );
564 WideCharToMultiByte( CP_ACP, 0, fn, -1, xfn, len, NULL, NULL );
565 ret = LZOpenFileA(xfn,ofs,mode);
566 HeapFree( GetProcessHeap(), 0, xfn );
567 return ret;
571 /***********************************************************************
572 * LZClose (KERNEL32.@)
574 void WINAPI LZClose( HFILE fd )
576 struct lzstate *lzs;
578 TRACE("(%d)\n",fd);
579 if (!(lzs = GET_LZ_STATE(fd))) _lclose(fd);
580 else
582 HeapFree( GetProcessHeap(), 0, lzs->get );
583 CloseHandle( LongToHandle(lzs->realfd) );
584 lzstates[fd - LZ_MIN_HANDLE] = NULL;
585 HeapFree( GetProcessHeap(), 0, lzs );