home *** CD-ROM | disk | FTP | other *** search
/ Fresh Fish 4 / FreshFish_May-June1994.bin / bbs / gnu / gs-2.6.1.4-src.lha / src / amiga / ghostscript-2.6.1 / zfile.c < prev    next >
Encoding:
C/C++ Source or Header  |  1994-01-28  |  21.2 KB  |  757 lines
  1. /* Copyright (C) 1989, 1992, 1993 Aladdin Enterprises.  All rights reserved.
  2.  
  3. This file is part of Ghostscript.
  4.  
  5. Ghostscript is distributed in the hope that it will be useful, but
  6. WITHOUT ANY WARRANTY.  No author or distributor accepts responsibility
  7. to anyone for the consequences of using it or for whether it serves any
  8. particular purpose or works at all, unless he says so in writing.  Refer
  9. to the Ghostscript General Public License for full details.
  10.  
  11. Everyone is granted permission to copy, modify and redistribute
  12. Ghostscript, but only under the conditions described in the Ghostscript
  13. General Public License.  A copy of this license is supposed to have been
  14. given to you along with Ghostscript so you can know your rights and
  15. responsibilities.  It should be in a file named COPYING.  Among other
  16. things, the copyright notice and this notice must be preserved on all
  17. copies.  */
  18.  
  19. /* zfile.c */
  20. /* Non-I/O file operators for Ghostscript */
  21. #include "memory_.h"
  22. #include "string_.h"
  23. #include "ghost.h"
  24. #include "gp.h"
  25. #include "errors.h"
  26. #include "oper.h"
  27. #include "alloc.h"
  28. #include "estack.h"            /* for filenameforall, file_close */
  29. #include "ilevel.h"            /* %names only work in Level 2 */
  30. #include "iutil.h"
  31. #include "save.h"            /* for restore */
  32. #include "stream.h"
  33. #include "filedev.h"            /* must come after stream.h */
  34. #include "files.h"            /* ditto */
  35. #include "store.h"
  36.  
  37. /* Import the file device table from zfiledev.c. */
  38. extern file_device *file_device_table[];
  39. #define fdev_default file_device_table[0]
  40.  
  41. /* Forward references: file name parsing. */
  42. /* Parsed file name type.  Note that the file name may be either a */
  43. /* Ghostscript string (no terminator) or a C string (null terminator). */
  44. typedef struct parsed_file_name_s {
  45.     file_device *fdev;
  46.     const char *fname;
  47.     uint len;
  48. } parsed_file_name;
  49. private int parse_file_name(P2(os_ptr, parsed_file_name *));
  50. private int parse_real_file_name(P3(os_ptr, parsed_file_name *,
  51.   const char *));
  52. private void free_real_file_name(P2(parsed_file_name *, const char *));
  53.  
  54. /* Forward references: file opening. */
  55. int file_open(P6(const byte *, uint, const char *, uint, ref *, stream **));
  56. stream *file_alloc_stream(P0());
  57. int file_open_stream(P6(const byte *, uint, const char *,
  58.   uint, stream **, fdev_proc_fopen_t));
  59. private void make_stream_file(P3(ref *, stream *, const char *));
  60.  
  61. /* Forward references: other. */
  62. private int file_close_file(P1(stream *));
  63.  
  64. /* Imported from gs.c */
  65. extern char **gs_lib_paths;        /* search path list, */
  66.                     /* terminated by a null pointer */
  67.  
  68. /*
  69.  * Since there can be many file objects referring to the same file/stream,
  70.  * we can't simply free a stream when we close it.  On the other hand,
  71.  * we don't want freed streams to clutter up memory needlessly.
  72.  * Our solution is to retain the freed streams, and reuse them.
  73.  * To prevent an old file object from being able to access a reused stream,
  74.  * we keep a serial number in each stream, and check it against a serial
  75.  * number stored in the file object (as the "size"); when we close a file,
  76.  * we increment its serial number.  If the serial number ever overflows,
  77.  * we leave it at zero, and do not reuse the stream.
  78.  * (This will never happen.)
  79.  *
  80.  * Storage management for this scheme is a little tricky.
  81.  * We maintain an invariant that says that a stream opened at a given
  82.  * save level always uses a stream structure allocated at that level.
  83.  * By doing this, we don't need to keep track separately of streams open
  84.  * at a level vs. streams allocated at a level; this simplifies things.
  85.  */
  86.  
  87. /*
  88.  * The chain of all streams allocated at the current level.
  89.  * We need this so that we can do the right thing for restore.
  90.  * Note that this chain includes both open and closed files.
  91.  */
  92. private ref file_list_ref;        /* t_file */
  93. #define file_list file_list_ref.value.pfile
  94.  
  95. /* File buffer sizes.  For real files, this is arbitrary, */
  96. /* since the C library does its own buffering in addition. */
  97. /* stdout and stderr use smaller buffers, */
  98. /* on the assumption that they are usually not real files. */
  99. /* The buffer size for type 1 encrypted files is NOT arbitrary: */
  100. /* it must be at most 512. */
  101. #define default_buffer_size 512
  102. const uint file_default_buffer_size = default_buffer_size;
  103.  
  104. /* An invalid file object */
  105. stream *invalid_file_entry;
  106.  
  107. /* Initialize the file table */
  108. private void
  109. zfile_init(void)
  110. {
  111.     invalid_file_entry =
  112.         (stream *)gs_malloc(1, sizeof(stream), "zfile_init");
  113.     s_disable(invalid_file_entry);
  114.     s_init_no_id(invalid_file_entry);
  115.  
  116.     /* Initialize the bookkeeping lists. */
  117.     
  118.     make_file(&file_list_ref, 0, 0, 0);
  119. }
  120.  
  121. /* <name_string> <access_string> file <file> */
  122. int
  123. zfile(register os_ptr op)
  124. {    char file_access[3];
  125.     parsed_file_name pname;
  126.     const byte *astr;
  127.     int code;
  128.     stream *s;
  129.     check_read_type(*op, t_string);
  130.     astr = op->value.const_bytes;
  131.     switch ( r_size(op) )
  132.        {
  133.     case 2:
  134.         if ( astr[1] != '+' )
  135.             return_error(e_invalidfileaccess);
  136.         file_access[1] = '+';
  137.         file_access[2] = 0;
  138.         break;
  139.     case 1:
  140.         file_access[1] = 0;
  141.         break;
  142.     default:
  143.         return_error(e_invalidfileaccess);
  144.        }
  145.     switch ( astr[0] )
  146.        {
  147.     case 'r': case 'w': case 'a':
  148.         break;
  149.     default:
  150.         return_error(e_invalidfileaccess);
  151.        }
  152.     file_access[0] = astr[0];
  153.     code = parse_file_name(op - 1, &pname);
  154.     if ( code < 0 )
  155.         return code;
  156.     if ( pname.fdev == NULL )
  157.         pname.fdev = fdev_default;
  158.     if ( pname.fname == NULL )        /* just a device */
  159.         code = (*pname.fdev->procs.open_device)(pname.fdev,
  160.                     file_access, &s);
  161.     else                    /* file */
  162.         code = (*pname.fdev->procs.open_file)(pname.fdev,
  163.                     pname.fname, pname.len,
  164.                     file_access, &s);
  165.     if ( code < 0 )
  166.         return code;
  167.     make_stream_file(op - 1, s, file_access);
  168.     pop(1);
  169.     return code;
  170. }
  171.  
  172. /* <file> closefile - */
  173. int
  174. zclosefile(register os_ptr op)
  175. {    stream *s;
  176.     check_file(s, op);
  177.     switch ( sclose(s) )
  178.     {
  179.     case 0:
  180.         pop(1);
  181.         return 0;
  182.     default:
  183.         return_error(e_ioerror);
  184.     }
  185. }
  186.  
  187. /* ------ Level 2 extensions ------ */
  188.  
  189. /* <string> deletefile - */
  190. int
  191. zdeletefile(register os_ptr op)
  192. {    parsed_file_name pname;
  193.     int code = parse_real_file_name(op, &pname, "deletefile");
  194.     if ( code < 0 )
  195.         return code;
  196.     code = (*pname.fdev->procs.delete_file)(pname.fdev, pname.fname);
  197.     free_real_file_name(&pname, "deletefile");
  198.     if ( code < 0 )
  199.         return code;
  200.     pop(1);
  201.     return 0;
  202. }
  203.  
  204. /* <template> <proc> <scratch> filenameforall - */
  205. /****** NOT CONVERTED FOR FILE DEVICES YET ******/
  206. private int file_continue(P1(os_ptr));
  207. private int file_cleanup(P1(os_ptr));
  208. int
  209. zfilenameforall(register os_ptr op)
  210. {    file_enum *pfen;
  211.     int code;
  212.     check_write_type(*op, t_string);
  213.     check_proc(op[-1]);
  214.     check_read_type(op[-2], t_string);
  215.     /* Push a mark, the pattern, the scratch string, the enumerator, */
  216.     /* and the procedure, and invoke the continuation. */
  217.     check_estack(7);
  218.     pfen = gp_enumerate_files_init((char *)op[-2].value.bytes, r_size(op - 2), &alloc_memory_procs);
  219.     if ( pfen == 0 )
  220.         return_error(e_VMerror);
  221.     mark_estack(es_for, file_cleanup);
  222.     *++esp = op[-2];
  223.     *++esp = *op;
  224.     ++esp;
  225.     make_tasv(esp, t_string, a_read+a_execute+a_executable, 0,
  226.           bytes, (byte *)pfen);
  227.     *++esp = op[-1];
  228.     pop(3);  op -= 3;
  229.     code = file_continue(op);
  230.     return (code == o_pop_estack ? o_push_estack : code);
  231. }
  232. /* Continuation operator for enumerating files */
  233. private int
  234. file_continue(register os_ptr op)
  235. {    es_ptr pscratch = esp - 2;
  236.     file_enum *pfen = (file_enum *)esp[-1].value.bytes;
  237.     uint len = r_size(pscratch);
  238.     uint code = gp_enumerate_files_next(pfen, (char *)pscratch->value.bytes, len);
  239.     if ( code == ~(uint)0 )        /* all done */
  240.        {    esp -= 4;        /* pop proc, pfen, scratch, mark */
  241.         return o_pop_estack;
  242.        }
  243.     else if ( code > len )        /* overran string */
  244.         return_error(e_rangecheck);
  245.     else
  246.        {    push(1);
  247.         ref_assign(op, pscratch);
  248.         r_set_size(op, code);
  249.         push_op_estack(file_continue);    /* come again */
  250.         *++esp = pscratch[2];    /* proc */
  251.         return o_push_estack;
  252.        }
  253. }
  254. /* Cleanup procedure for enumerating files */
  255. private int
  256. file_cleanup(os_ptr op)
  257. {    gp_enumerate_files_close((file_enum *)esp[4].value.bytes);
  258.     return 0;
  259. }
  260.  
  261. /* <string1> <string2> renamefile - */
  262. int
  263. zrenamefile(register os_ptr op)
  264. {    parsed_file_name pname1, pname2;
  265.     int code = parse_real_file_name(op - 1, &pname1, "renamefile(from)");
  266.     if ( code < 0 )
  267.         return code;
  268.     pname2.fname = 0;
  269.     code = parse_real_file_name(op, &pname2, "renamefile(to)");
  270.     if ( code < 0 || pname1.fdev != pname2.fdev ||
  271.          (code = (*pname1.fdev->procs.rename_file)(pname1.fdev,
  272.                      pname1.fname, pname2.fname)) < 0
  273.        )
  274.     {    if ( code >= 0 )
  275.             code = gs_note_error(e_invalidfileaccess);
  276.     }
  277.     free_real_file_name(&pname2, "renamefile(to)");
  278.     free_real_file_name(&pname1, "renamefile(from)");
  279.     if ( code < 0 )
  280.         return code;
  281.     pop(2);
  282.     return 0;
  283. }    
  284.  
  285. /* <file> status <open_bool> */
  286. /* <string> status <pages> <bytes> <ref_time> <creation_time> true */
  287. /* <string> status false */
  288. int
  289. zstatus(register os_ptr op)
  290. {    switch ( r_type(op) )
  291.        {
  292.     case t_file:
  293.         make_bool(op, (s_is_valid(fptr(op)) ? 1 : 0));
  294.         return 0;
  295.     case t_string:
  296.     {    parsed_file_name pname;
  297.         file_status fstat;
  298.         int code = parse_real_file_name(op, &pname, "status");
  299.         if ( code < 0 )
  300.             return 0;
  301.         if ( pname.fdev == fdev_default &&
  302.              gp_file_status(pname.fname, &fstat)
  303.            )
  304.         {    push(4);
  305.             make_int(op - 4, fstat.size_pages);
  306.             make_int(op - 3, fstat.size_bytes);
  307.             make_int(op - 2, fstat.time_referenced);
  308.             make_int(op - 1, fstat.time_created);
  309.             make_bool(op, 1);
  310.         }
  311.         else
  312.             make_bool(op, 0);
  313.         free_real_file_name(&pname, "status");
  314.     }    return 0;
  315.     default:
  316.         return_error(e_typecheck);
  317.     }
  318. }
  319.  
  320. /* ------ Ghostscript extensions ------ */
  321.  
  322. /* <string> findlibfile <found_string> <file> true */
  323. /* <string> findlibfile false */
  324. int
  325. zfindlibfile(register os_ptr op)
  326. {    int code;
  327. #define maxclen 200
  328.     byte cname[maxclen];
  329.     uint clen;
  330.     parsed_file_name pname;
  331.     stream *s;
  332.     check_ostack(2);
  333.     code = parse_file_name(op, &pname);
  334.     if ( code < 0 )
  335.         return code;
  336.     if ( pname.fdev == NULL )
  337.         pname.fdev = fdev_default;
  338.     if ( pname.fdev != fdev_default )
  339.     {    /* Non-OS devices don't have search paths (yet). */
  340.         code = (*pname.fdev->procs.open_file)(pname.fdev,
  341.                     pname.fname, pname.len, "r", &s);
  342.         if ( code < 0 )
  343.         {    push(1);
  344.             make_false(op);
  345.             return 0;
  346.         }
  347.         make_stream_file(op + 1, s, "r");
  348.     }
  349.     else
  350.     {    byte *cstr;
  351.         code = lib_file_open(pname.fname, pname.len, cname, maxclen,
  352.                      &clen, op + 1);
  353.         if ( code < 0 )
  354.         {    push(1);
  355.             make_false(op);
  356.             return 0;
  357.         }
  358.         cstr = (byte *)alloc(clen, 1, "findlibfile");
  359.         if ( cstr == 0 )
  360.             return_error(e_VMerror);
  361.         memcpy(cstr, cname, clen);
  362.         make_string(op, a_all, clen, cstr);
  363.     }
  364.     push(2);
  365.     make_true(op);
  366.     return 0;
  367. }
  368.  
  369. /* ------ Initialization procedure ------ */
  370.  
  371. op_def zfile_op_defs[] = {
  372.     {"1closefile", zclosefile},
  373.     {"1deletefile", zdeletefile},
  374.     {"2file", zfile},
  375.     {"3filenameforall", zfilenameforall},
  376.     {"1findlibfile", zfindlibfile},
  377.     {"2renamefile", zrenamefile},
  378.     {"1status", zstatus},
  379.         /* Internal operators */
  380.     {"0%file_continue", file_continue},
  381.     op_def_end(zfile_init)
  382. };
  383.  
  384. /* ------ Stream opening ------ */
  385.  
  386. /* Make a t_file reference to a stream. */
  387. private void
  388. make_stream_file(ref *pfile, stream *s, const char *access)
  389. {    uint attrs =
  390.         (access[1] == '+' ? a_write + a_read + a_execute : 0);
  391.     if ( access[0] == 'r' )
  392.     {    make_file(pfile, attrs | (a_read | a_execute), s->read_id, s);
  393.         s->write_id = 0;
  394.     }
  395.     else
  396.     {    make_file(pfile, attrs | a_write, s->write_id, s);
  397.         s->read_id = 0;
  398.     }
  399. }
  400.  
  401. /* Open an OS-level file (like fopen), using the search paths if necessary. */
  402. /* Note that it overwrites the file name; the 'const' on bname is a lie. */
  403. private FILE *
  404. lib_file_fopen(file_device *fdev, const char *bname,
  405.   const char *ignore_access)
  406. {    char fmode[3];            /* r, [b], null */
  407.     FILE *file;
  408.     int len = strlen(bname);
  409.     char **ppath;
  410.     strcpy(fmode, "r");
  411.     strcat(fmode, gp_fmode_binary_suffix);
  412.     file = (*fdev->procs.fopen)(fdev, bname, fmode);
  413.     if ( file )
  414.         return file;
  415.     if ( gp_file_name_is_absolute(bname, len) )
  416.         return 0;
  417.     /* Go through the list of search paths */
  418.     for ( ppath = gs_lib_paths; *ppath != 0; ppath++ )
  419.        {    char *path = *ppath;
  420.         for ( ; ; )
  421.            {    /* Find the end of the next path */
  422.             char *npath = path;
  423.             uint plen;
  424.             const char *cstr;
  425.             int up, i;
  426.             while ( *npath != 0 && *npath != gp_file_name_list_separator )
  427.                 npath++;
  428.             plen = npath - path;
  429.             cstr = gp_file_name_concat_string(path, plen,
  430.                               (const char *)bname,
  431.                               len);
  432.             /* Concatenate the prefix, combiner, and file name. */
  433.             up = plen + strlen(cstr);
  434. #define wbname ((char *)bname)        /* break const */
  435.             for ( i = len + 1; --i >= 0; )
  436.                 wbname[i + up] = wbname[i];
  437.             memcpy(wbname, (byte *)path, plen);
  438.             memcpy(wbname + plen, cstr, strlen(cstr));
  439.             file = (*fdev->procs.fopen)(fdev, bname, fmode);
  440.             if ( file )
  441.                 return file;
  442.             strcpy(wbname, wbname + up);
  443. #undef wbname
  444.             if ( !*npath ) break;
  445.             path = npath + 1;
  446.            }
  447.        }
  448.     return 0;
  449. }
  450. /* The startup code calls this to open @-files. */
  451. FILE *
  452. lib_fopen(const char *bname)
  453. {    return lib_file_fopen(fdev_default, bname, "r");
  454. }
  455.  
  456. /* Open a file stream on an OS file and create a file object, */
  457. /* using the search paths. */
  458. /* The startup code calls this to open the initialization file gs_init.ps. */
  459. int
  460. lib_file_open(const char *fname, uint len, byte *cname, uint max_clen,
  461.   uint *pclen, ref *pfile)
  462. {    stream *s;
  463.     int code = file_open_stream((const byte *)fname, len, "r",
  464.                     default_buffer_size, &s, lib_file_fopen);
  465.     char *bname;
  466.     uint blen;
  467.     if ( code < 0 ) return code;
  468.     /* Get the name from the stream buffer. */
  469.     bname = (char *)s->cbuf;
  470.     blen = strlen(bname);
  471.     if ( blen > max_clen )
  472.     {    sclose(s);
  473.         return_error(e_limitcheck);
  474.     }
  475.     memcpy(cname, bname, blen);
  476.     *pclen = blen;
  477.     make_stream_file(pfile, s, "r");
  478.     return 0;
  479. }
  480.  
  481. /* Open a file stream that reads a string. */
  482. /* (This is currently used only by gs_run_string.) */
  483. int
  484. file_read_string(const byte *str, uint len, ref *pfile)
  485. {    register stream *s = file_alloc_stream();
  486.     if ( s == 0 )
  487.         return_error(e_VMerror);
  488.     sread_string(s, str, len);
  489.     s->write_id = 0;
  490.     make_file(pfile, a_readonly, s->read_id, s);
  491.     s->save_close = s->procs.close;
  492.     s->procs.close = file_close_file;
  493.     return 0;
  494. }
  495.  
  496. /* Open a file stream, optionally on an OS file. */
  497. /* Return 0 if successful, error code if not. */
  498. /* On a successful return, the C file name is in the stream buffer. */
  499. /* If fname==0, set up the file entry, stream, and buffer, */
  500. /* but don't open an OS file or initialize the stream. */
  501. int
  502. file_open_stream(const byte *fname, uint len, const char *file_access,
  503.   uint buffer_size, stream **ps, fdev_proc_fopen_t fopen_proc)
  504. {    byte *buffer;
  505.     register stream *s;
  506.     if ( buffer_size == 0 )
  507.       buffer_size = default_buffer_size;
  508.     if ( len >= buffer_size )
  509.       return_error(e_limitcheck);    /* we copy the file name into the buffer */
  510.     /* Allocate the stream first, since it persists */
  511.     /* even after the file has been closed. */
  512.       s = file_alloc_stream();
  513.     if ( s == 0 )
  514.         return_error(e_VMerror);
  515.     /* Allocate the buffer. */
  516.     buffer = (byte *)alloc(buffer_size, 1, "file_open(buffer)");
  517.     if ( buffer == 0 )
  518.         return_error(e_VMerror);
  519.     if ( fname != 0 )
  520.        {    /* Copy the name (so we can terminate it with a zero byte.) */
  521.         char *file_name = (char *)buffer;
  522.         char fmode[4];        /* r/w/a, [+], [b], null */
  523.         FILE *file;
  524.         memcpy(file_name, fname, len);
  525.         file_name[len] = 0;        /* terminate string */
  526.         /* Open the file, always in binary mode. */
  527.         strcpy(fmode, file_access);
  528.         strcat(fmode, gp_fmode_binary_suffix);
  529.         /****** fdev_default IS QUESTIONABLE ******/
  530.         file = (*fopen_proc)(fdev_default, file_name, fmode);
  531.         if ( file == 0 )
  532.            {    alloc_free((char *)buffer, buffer_size, 1,
  533.                    "file_open(buffer)");
  534.             return_error(e_undefinedfilename);
  535.            }
  536.         /* Set up the stream. */
  537.         switch ( *file_access )
  538.         {
  539.         case 'a':
  540.             sappend_file(s, file, buffer, buffer_size);
  541.             break;
  542.         case 'r':
  543.             sread_file(s, file, buffer, buffer_size);
  544.             break;
  545.         case 'w':
  546.             swrite_file(s, file, buffer, buffer_size);
  547.         }
  548.         s->save_close = s->procs.close;
  549.         s->procs.close = file_close_file;
  550.        }
  551.     else                /* save the buffer and size */
  552.        {    s->cbuf = buffer;
  553.         s->bsize = s->cbsize = buffer_size;
  554.        }
  555.     *ps = s;
  556.     return 0;
  557. }
  558.  
  559. /* Open a file stream for a filter. */
  560. int
  561. filter_open(const char *file_access, uint buffer_size,
  562.   ref *pfile, const stream_procs _ds *procs, stream **ps)
  563. {    stream *s;
  564.     int code = file_open_stream((byte *)0, 0, file_access,
  565.                     buffer_size, &s, (fdev_proc_fopen_t)0);
  566.     if ( code < 0 )
  567.         return code;
  568.     s_std_init(s, s->cbuf, s->bsize, procs,
  569.            (*file_access == 'r' ? s_mode_read : s_mode_write));
  570.     s->file = 0;            /* not a file stream */
  571.     make_stream_file(pfile, s, file_access);
  572.     s->save_close = s->procs.close;
  573.     s->procs.close = file_close_file;
  574.     *ps = s;
  575.     return 0;
  576. }
  577.  
  578. /* ------ Stream closing ------ */
  579.  
  580. /* Finish closing a file stream by checking whether it is currentfile. */
  581. /* This replaces the close procedure for the std* streams, */
  582. /* which cannot actually be closed. */
  583. /* This is exported for zfiledev.c. */
  584. int
  585. file_close_finish(stream *s)
  586. {    check_close_current_file(s);
  587.     return 0;
  588. }
  589.  
  590. /* Close a file stream, but don't deallocate the buffer. */
  591. /* This replaces the close procedure for %lineedit and %statementedit. */
  592. /* (This is WRONG: these streams should allocate a new buffer each time */
  593. /* they are opened, but that would overstress the allocator right now.) */
  594. /* This is exported for zfiledev.c. */
  595. int
  596. file_close_disable(stream *s)
  597. {    int code = (*s->save_close)(s);
  598.     if ( code )
  599.         return code;
  600.     /* Increment the IDs to prevent further access. */
  601.     s->read_id = s->write_id = (s->read_id | s->write_id) + 1;
  602.     return file_close_finish(s);
  603. }
  604.  
  605. /* Close a file stream.  This replaces the close procedure in the stream */
  606. /* for normal (OS) files and for filters. */
  607. private int
  608. file_close_file(stream *s)
  609. {    stream *stemp = (s->strm_is_temp ? s->strm : 0);
  610.     int code = file_close_disable(s);
  611.     if ( code )
  612.         return code;
  613.     alloc_free((char *)s->cbuf, s->cbsize, 1,
  614.            "file_close(buffer)");
  615.     if ( stemp != 0 )
  616.         alloc_free((char *)stemp, 1, sizeof(stream),
  617.                "file_close(sub-stream)");
  618.     return 0;
  619. }
  620.  
  621. /* Close a file object. */
  622. int
  623. file_close(ref *pfile)
  624. {    if ( sclose(fptr(pfile)) )
  625.         return_error(e_ioerror);
  626.     return 0;
  627. }
  628.  
  629. /* ------ Internal routines ------ */
  630.  
  631. /* Parse a file name into device and individual name. */
  632. /* The device may be NULL, or the name may be NULL, but not both. */
  633. /* Note that %disk0 has name==NULL, whereas %disk0% just has len==0. */
  634. private int
  635. parse_file_name(os_ptr op, parsed_file_name *pfn)
  636. {    const byte *pname;
  637.     uint len, dlen;
  638.     const byte *pdelim;
  639.     file_device **pftab;
  640.  
  641.     check_read_type(*op, t_string);
  642.     len = r_size(op);
  643.     pname = op->value.const_bytes;
  644.     if ( len == 0 )
  645.         return_error(e_undefinedfilename);
  646.     if ( pname[0] != '%' )    /* no device */
  647.       { pfn->fdev = NULL;
  648.         pfn->fname = (const char *)pname;
  649.         pfn->len = len;
  650.         return 0;
  651.       }
  652.     pname++, len--;
  653.     pdelim = (const byte *)memchr(pname, '%', len);
  654.     if ( pdelim == NULL )    /* device only */
  655.         dlen = len;
  656.     else
  657.     {    dlen = pdelim - pname;
  658.         pdelim++, len--;
  659.     }
  660.     for ( pftab = file_device_table; *pftab != NULL; pftab++ )
  661.       { const char *dname = (*pftab)->dname;
  662.         if ( strlen(dname) == dlen && !memcmp(pname, dname, dlen) )
  663.           { pfn->fdev = *pftab;
  664.         pfn->fname = (const char *)pdelim;
  665.         pfn->len = len - dlen;
  666.         return 0;
  667.           }
  668.       }
  669.     return_error(e_undefinedfilename);
  670. }
  671.  
  672. /* Parse a real (non-device) file name and convert to a C string. */
  673. private int
  674. parse_real_file_name(os_ptr op, parsed_file_name *pfn, const char *cname)
  675. {    int code = parse_file_name(op, pfn);
  676.     const char *fname;
  677.     ref fnref;
  678.     uint len = pfn->len;
  679.     if ( code < 0 )
  680.         return code;
  681.     if ( pfn->fdev == NULL )     /* no device */
  682.         pfn->fdev = fdev_default;
  683.     if ( len == 0 )
  684.         return_error(e_invalidfileaccess); /* device only */
  685.     fnref.value.const_bytes = (const byte *)pfn->fname;
  686.     r_set_size(&fnref, len);
  687.     fname = ref_to_string(&fnref, cname);
  688.     if ( fname == 0 )
  689.         return_error(e_VMerror);
  690.     pfn->fname = fname;
  691.     pfn->len = len + 1;    /* null terminator */
  692.     return 0;
  693. }
  694.  
  695. /* Free a file name that was copied to a C string. */
  696. private void
  697. free_real_file_name(parsed_file_name *pfn, const char *cname)
  698. {    if ( pfn->fname != 0 )
  699.         alloc_free((char *)pfn->fname, pfn->len, 1, cname);
  700. }
  701.  
  702. /* Allocate and return a file stream. */
  703. /* Return 0 if the allocation failed. */
  704. /* The stream is initialized to an invalid state, so the caller need not */
  705. /* worry about cleaning up if a later step in opening the stream fails. */
  706. stream *
  707. file_alloc_stream(void)
  708. {    stream *s;
  709.     /* Look first for a free stream allocated at this level. */
  710.     s = file_list;
  711.     while ( s != 0 )
  712.     {    if ( !s_is_valid(s) && s->read_id != 0 /* i.e. !overflowed */ )
  713.         {    s->strm_is_temp = 0;    /* not a temp stream */
  714.             return s;
  715.         }
  716.         s = s->next;
  717.     }
  718.     s = (stream *)alloc(1, sizeof(stream), "file_open(stream)");
  719.     if ( s == 0 )
  720.         return 0;
  721.     s_init_ids(s);
  722.     s->strm_is_temp = 0;        /* not a temp stream */
  723.     /* Disable the stream now (in case we can't open the file, */
  724.     /* or a filter init procedure fails) so that `restore' won't */
  725.     /* crash when it tries to close open files. */
  726.     s_disable(s);
  727.     /* Add s to the list of files. */
  728.     if ( file_list != 0 )
  729.         file_list->prev = s;
  730.     s->next = file_list;
  731.     s->prev = 0;
  732.     file_list = s;
  733.     return s;
  734. }
  735.  
  736. /* ------ Memory management ------ */
  737.  
  738. /* Arrange to save the current file list at a save. */
  739. void
  740. file_save(void)
  741. {    ref_mark_old(&file_list_ref);
  742.     ref_save(&file_list_ref, "file_save");
  743.     make_file(&file_list_ref, 0, 0, 0);
  744. }
  745.  
  746. /* Close inaccessible files just before a restore. */
  747. void
  748. file_restore(const alloc_save *save)
  749. {    stream *s = file_list;
  750.     while ( s != 0 )
  751.     {    if ( s_is_valid(s) )
  752.             sclose(s);
  753.         s = s->next;
  754.     }
  755.     file_list = 0;
  756. }
  757.