Bram Moolenaar | edf3f97 | 2016-08-29 22:49:24 +0200 | [diff] [blame] | 1 | /* vi:set ts=8 sts=4 sw=4 noet: |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 2 | * |
| 3 | * VIM - Vi IMproved by Bram Moolenaar |
| 4 | * |
| 5 | * Do ":help uganda" in Vim to read copying and usage conditions. |
| 6 | * Do ":help credits" in Vim to see a list of people who contributed. |
| 7 | * See README.txt for an overview of the Vim source code. |
| 8 | */ |
| 9 | |
| 10 | /* |
| 11 | * memfile.c: Contains the functions for handling blocks of memory which can |
| 12 | * be stored in a file. This is the implementation of a sort of virtual memory. |
| 13 | * |
| 14 | * A memfile consists of a sequence of blocks. The blocks numbered from 0 |
| 15 | * upwards have been assigned a place in the actual file. The block number |
| 16 | * is equal to the page number in the file. The |
| 17 | * blocks with negative numbers are currently in memory only. They can be |
| 18 | * assigned a place in the file when too much memory is being used. At that |
| 19 | * moment they get a new, positive, number. A list is used for translation of |
| 20 | * negative to positive numbers. |
| 21 | * |
| 22 | * The size of a block is a multiple of a page size, normally the page size of |
| 23 | * the device the file is on. Most blocks are 1 page long. A Block of multiple |
| 24 | * pages is used for a line that does not fit in a single page. |
| 25 | * |
| 26 | * Each block can be in memory and/or in a file. The block stays in memory |
| 27 | * as long as it is locked. If it is no longer locked it can be swapped out to |
| 28 | * the file. It is only written to the file if it has been changed. |
| 29 | * |
| 30 | * Under normal operation the file is created when opening the memory file and |
| 31 | * deleted when closing the memory file. Only with recovery an existing memory |
| 32 | * file is opened. |
| 33 | */ |
| 34 | |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 35 | #include "vim.h" |
| 36 | |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 37 | /* |
| 38 | * Some systems have the page size in statfs.f_bsize, some in stat.st_blksize |
| 39 | */ |
| 40 | #ifdef HAVE_ST_BLKSIZE |
| 41 | # define STATFS stat |
| 42 | # define F_BSIZE st_blksize |
| 43 | # define fstatfs(fd, buf, len, nul) mch_fstat((fd), (buf)) |
| 44 | #else |
| 45 | # ifdef HAVE_SYS_STATFS_H |
| 46 | # include <sys/statfs.h> |
| 47 | # define STATFS statfs |
| 48 | # define F_BSIZE f_bsize |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 49 | # endif |
| 50 | #endif |
| 51 | |
| 52 | /* |
| 53 | * for Amiga Dos 2.0x we use Flush |
| 54 | */ |
| 55 | #ifdef AMIGA |
| 56 | # ifdef FEAT_ARP |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 57 | extern int dos2; // this is in os_amiga.c |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 58 | # endif |
| 59 | # ifdef SASC |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 60 | # include <ios1.h> // for chkufb() |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 61 | # endif |
| 62 | #endif |
| 63 | |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 64 | #define MEMFILE_PAGE_SIZE 4096 // default page size |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 65 | |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 66 | static long_u total_mem_used = 0; // total memory used for memfiles |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 67 | |
Bram Moolenaar | 92b8b2d | 2016-01-29 22:36:45 +0100 | [diff] [blame] | 68 | static void mf_ins_hash(memfile_T *, bhdr_T *); |
| 69 | static void mf_rem_hash(memfile_T *, bhdr_T *); |
| 70 | static bhdr_T *mf_find_hash(memfile_T *, blocknr_T); |
| 71 | static void mf_ins_used(memfile_T *, bhdr_T *); |
| 72 | static void mf_rem_used(memfile_T *, bhdr_T *); |
| 73 | static bhdr_T *mf_release(memfile_T *, int); |
| 74 | static bhdr_T *mf_alloc_bhdr(memfile_T *, int); |
| 75 | static void mf_free_bhdr(bhdr_T *); |
| 76 | static void mf_ins_free(memfile_T *, bhdr_T *); |
| 77 | static bhdr_T *mf_rem_free(memfile_T *); |
| 78 | static int mf_read(memfile_T *, bhdr_T *); |
| 79 | static int mf_write(memfile_T *, bhdr_T *); |
Bram Moolenaar | 8767f52 | 2016-07-01 17:17:39 +0200 | [diff] [blame] | 80 | static int mf_write_block(memfile_T *mfp, bhdr_T *hp, off_T offset, unsigned size); |
Bram Moolenaar | 92b8b2d | 2016-01-29 22:36:45 +0100 | [diff] [blame] | 81 | static int mf_trans_add(memfile_T *, bhdr_T *); |
| 82 | static void mf_do_open(memfile_T *, char_u *, int); |
| 83 | static void mf_hash_init(mf_hashtab_T *); |
| 84 | static void mf_hash_free(mf_hashtab_T *); |
| 85 | static void mf_hash_free_all(mf_hashtab_T *); |
| 86 | static mf_hashitem_T *mf_hash_find(mf_hashtab_T *, blocknr_T); |
| 87 | static void mf_hash_add_item(mf_hashtab_T *, mf_hashitem_T *); |
| 88 | static void mf_hash_rem_item(mf_hashtab_T *, mf_hashitem_T *); |
| 89 | static int mf_hash_grow(mf_hashtab_T *); |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 90 | |
| 91 | /* |
| 92 | * The functions for using a memfile: |
| 93 | * |
| 94 | * mf_open() open a new or existing memfile |
| 95 | * mf_open_file() open a swap file for an existing memfile |
| 96 | * mf_close() close (and delete) a memfile |
| 97 | * mf_new() create a new block in a memfile and lock it |
| 98 | * mf_get() get an existing block and lock it |
| 99 | * mf_put() unlock a block, may be marked for writing |
| 100 | * mf_free() remove a block |
| 101 | * mf_sync() sync changed parts of memfile to disk |
| 102 | * mf_release_all() release as much memory as possible |
| 103 | * mf_trans_del() may translate negative to positive block number |
| 104 | * mf_fullname() make file name full path (use before first :cd) |
| 105 | */ |
| 106 | |
| 107 | /* |
| 108 | * Open an existing or new memory block file. |
| 109 | * |
| 110 | * fname: name of file to use (NULL means no file at all) |
| 111 | * Note: fname must have been allocated, it is not copied! |
| 112 | * If opening the file fails, fname is freed. |
| 113 | * flags: flags for open() call |
| 114 | * |
| 115 | * If fname != NULL and file cannot be opened, fail. |
| 116 | * |
| 117 | * return value: identifier for this memory block file. |
| 118 | */ |
| 119 | memfile_T * |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 120 | mf_open(char_u *fname, int flags) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 121 | { |
| 122 | memfile_T *mfp; |
Bram Moolenaar | 8767f52 | 2016-07-01 17:17:39 +0200 | [diff] [blame] | 123 | off_T size; |
Bram Moolenaar | a03dbed | 2013-05-23 22:27:03 +0200 | [diff] [blame] | 124 | #if defined(STATFS) && defined(UNIX) && !defined(__QNX__) && !defined(__minix) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 125 | # define USE_FSTATFS |
| 126 | struct STATFS stf; |
| 127 | #endif |
| 128 | |
Bram Moolenaar | c799fe2 | 2019-05-28 23:08:19 +0200 | [diff] [blame] | 129 | if ((mfp = ALLOC_ONE(memfile_T)) == NULL) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 130 | return NULL; |
| 131 | |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 132 | if (fname == NULL) // no file for this memfile, use memory only |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 133 | { |
| 134 | mfp->mf_fname = NULL; |
| 135 | mfp->mf_ffname = NULL; |
| 136 | mfp->mf_fd = -1; |
| 137 | } |
| 138 | else |
| 139 | { |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 140 | mf_do_open(mfp, fname, flags); // try to open the file |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 141 | |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 142 | // if the file cannot be opened, return here |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 143 | if (mfp->mf_fd < 0) |
| 144 | { |
| 145 | vim_free(mfp); |
| 146 | return NULL; |
| 147 | } |
| 148 | } |
| 149 | |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 150 | mfp->mf_free_first = NULL; // free list is empty |
| 151 | mfp->mf_used_first = NULL; // used list is empty |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 152 | mfp->mf_used_last = NULL; |
Bram Moolenaar | 3a2a60c | 2023-05-27 18:02:55 +0100 | [diff] [blame] | 153 | mfp->mf_dirty = MF_DIRTY_NO; |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 154 | mfp->mf_used_count = 0; |
Bram Moolenaar | b05b10a | 2011-03-22 18:10:45 +0100 | [diff] [blame] | 155 | mf_hash_init(&mfp->mf_hash); |
| 156 | mf_hash_init(&mfp->mf_trans); |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 157 | mfp->mf_page_size = MEMFILE_PAGE_SIZE; |
Bram Moolenaar | a8ffcbb | 2010-06-21 06:15:46 +0200 | [diff] [blame] | 158 | #ifdef FEAT_CRYPT |
| 159 | mfp->mf_old_key = NULL; |
| 160 | #endif |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 161 | |
| 162 | #ifdef USE_FSTATFS |
| 163 | /* |
| 164 | * Try to set the page size equal to the block size of the device. |
| 165 | * Speeds up I/O a lot. |
| 166 | * When recovering, the actual block size will be retrieved from block 0 |
| 167 | * in ml_recover(). The size used here may be wrong, therefore |
| 168 | * mf_blocknr_max must be rounded up. |
| 169 | */ |
| 170 | if (mfp->mf_fd >= 0 |
| 171 | && fstatfs(mfp->mf_fd, &stf, sizeof(struct statfs), 0) == 0 |
| 172 | && stf.F_BSIZE >= MIN_SWAP_PAGE_SIZE |
| 173 | && stf.F_BSIZE <= MAX_SWAP_PAGE_SIZE) |
| 174 | mfp->mf_page_size = stf.F_BSIZE; |
| 175 | #endif |
| 176 | |
| 177 | if (mfp->mf_fd < 0 || (flags & (O_TRUNC|O_EXCL)) |
Bram Moolenaar | 8767f52 | 2016-07-01 17:17:39 +0200 | [diff] [blame] | 178 | || (size = vim_lseek(mfp->mf_fd, (off_T)0L, SEEK_END)) <= 0) |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 179 | mfp->mf_blocknr_max = 0; // no file or empty file |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 180 | else |
| 181 | mfp->mf_blocknr_max = (blocknr_T)((size + mfp->mf_page_size - 1) |
| 182 | / mfp->mf_page_size); |
| 183 | mfp->mf_blocknr_min = -1; |
| 184 | mfp->mf_neg_count = 0; |
| 185 | mfp->mf_infile_count = mfp->mf_blocknr_max; |
Bram Moolenaar | fe265ff | 2007-05-11 18:15:45 +0000 | [diff] [blame] | 186 | |
| 187 | /* |
| 188 | * Compute maximum number of pages ('maxmem' is in Kbyte): |
| 189 | * 'mammem' * 1Kbyte / page-size-in-bytes. |
| 190 | * Avoid overflow by first reducing page size as much as possible. |
| 191 | */ |
| 192 | { |
| 193 | int shift = 10; |
| 194 | unsigned page_size = mfp->mf_page_size; |
| 195 | |
| 196 | while (shift > 0 && (page_size & 1) == 0) |
| 197 | { |
| 198 | page_size = page_size >> 1; |
| 199 | --shift; |
| 200 | } |
| 201 | mfp->mf_used_count_max = (p_mm << shift) / page_size; |
| 202 | if (mfp->mf_used_count_max < 10) |
| 203 | mfp->mf_used_count_max = 10; |
| 204 | } |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 205 | |
| 206 | return mfp; |
| 207 | } |
| 208 | |
| 209 | /* |
| 210 | * Open a file for an existing memfile. Used when updatecount set from 0 to |
| 211 | * some value. |
| 212 | * If the file already exists, this fails. |
| 213 | * "fname" is the name of file to use (NULL means no file at all) |
| 214 | * Note: "fname" must have been allocated, it is not copied! If opening the |
| 215 | * file fails, "fname" is freed. |
| 216 | * |
| 217 | * return value: FAIL if file could not be opened, OK otherwise |
| 218 | */ |
| 219 | int |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 220 | mf_open_file(memfile_T *mfp, char_u *fname) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 221 | { |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 222 | mf_do_open(mfp, fname, O_RDWR|O_CREAT|O_EXCL); // try to open the file |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 223 | |
| 224 | if (mfp->mf_fd < 0) |
| 225 | return FAIL; |
| 226 | |
Bram Moolenaar | 3a2a60c | 2023-05-27 18:02:55 +0100 | [diff] [blame] | 227 | mfp->mf_dirty = MF_DIRTY_YES; |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 228 | return OK; |
| 229 | } |
| 230 | |
| 231 | /* |
Bram Moolenaar | 945e2db | 2010-06-05 17:43:32 +0200 | [diff] [blame] | 232 | * Close a memory file and delete the associated file if 'del_file' is TRUE. |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 233 | */ |
| 234 | void |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 235 | mf_close(memfile_T *mfp, int del_file) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 236 | { |
| 237 | bhdr_T *hp, *nextp; |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 238 | |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 239 | if (mfp == NULL) // safety check |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 240 | return; |
| 241 | if (mfp->mf_fd >= 0) |
| 242 | { |
| 243 | if (close(mfp->mf_fd) < 0) |
Bram Moolenaar | 12f3c1b | 2021-12-05 21:46:34 +0000 | [diff] [blame] | 244 | emsg(_(e_close_error_on_swap_file)); |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 245 | } |
| 246 | if (del_file && mfp->mf_fname != NULL) |
| 247 | mch_remove(mfp->mf_fname); |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 248 | // free entries in used list |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 249 | for (hp = mfp->mf_used_first; hp != NULL; hp = nextp) |
| 250 | { |
=?UTF-8?q?Dundar=20G=C3=B6c?= | d5cec1f | 2022-01-29 15:19:23 +0000 | [diff] [blame] | 251 | total_mem_used -= (long_u)hp->bh_page_count * mfp->mf_page_size; |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 252 | nextp = hp->bh_next; |
| 253 | mf_free_bhdr(hp); |
| 254 | } |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 255 | while (mfp->mf_free_first != NULL) // free entries in free list |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 256 | vim_free(mf_rem_free(mfp)); |
Bram Moolenaar | b05b10a | 2011-03-22 18:10:45 +0100 | [diff] [blame] | 257 | mf_hash_free(&mfp->mf_hash); |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 258 | mf_hash_free_all(&mfp->mf_trans); // free hashtable and its items |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 259 | vim_free(mfp->mf_fname); |
| 260 | vim_free(mfp->mf_ffname); |
| 261 | vim_free(mfp); |
| 262 | } |
| 263 | |
| 264 | /* |
| 265 | * Close the swap file for a memfile. Used when 'swapfile' is reset. |
| 266 | */ |
| 267 | void |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 268 | mf_close_file( |
| 269 | buf_T *buf, |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 270 | int getlines) // get all lines into memory? |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 271 | { |
| 272 | memfile_T *mfp; |
| 273 | linenr_T lnum; |
| 274 | |
| 275 | mfp = buf->b_ml.ml_mfp; |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 276 | if (mfp == NULL || mfp->mf_fd < 0) // nothing to close |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 277 | return; |
| 278 | |
| 279 | if (getlines) |
| 280 | { |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 281 | // get all blocks in memory by accessing all lines (clumsy!) |
Bram Moolenaar | 47b8b15 | 2007-02-07 02:41:57 +0000 | [diff] [blame] | 282 | mf_dont_release = TRUE; |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 283 | for (lnum = 1; lnum <= buf->b_ml.ml_line_count; ++lnum) |
| 284 | (void)ml_get_buf(buf, lnum, FALSE); |
Bram Moolenaar | 47b8b15 | 2007-02-07 02:41:57 +0000 | [diff] [blame] | 285 | mf_dont_release = FALSE; |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 286 | // TODO: should check if all blocks are really in core |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 287 | } |
| 288 | |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 289 | if (close(mfp->mf_fd) < 0) // close the file |
Bram Moolenaar | 12f3c1b | 2021-12-05 21:46:34 +0000 | [diff] [blame] | 290 | emsg(_(e_close_error_on_swap_file)); |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 291 | mfp->mf_fd = -1; |
| 292 | |
| 293 | if (mfp->mf_fname != NULL) |
| 294 | { |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 295 | mch_remove(mfp->mf_fname); // delete the swap file |
Bram Moolenaar | d23a823 | 2018-02-10 18:45:26 +0100 | [diff] [blame] | 296 | VIM_CLEAR(mfp->mf_fname); |
| 297 | VIM_CLEAR(mfp->mf_ffname); |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 298 | } |
| 299 | } |
| 300 | |
| 301 | /* |
| 302 | * Set new size for a memfile. Used when block 0 of a swapfile has been read |
| 303 | * and the size it indicates differs from what was guessed. |
| 304 | */ |
| 305 | void |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 306 | mf_new_page_size(memfile_T *mfp, unsigned new_size) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 307 | { |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 308 | // Correct the memory used for block 0 to the new size, because it will be |
| 309 | // freed with that size later on. |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 310 | total_mem_used += new_size - mfp->mf_page_size; |
| 311 | mfp->mf_page_size = new_size; |
| 312 | } |
| 313 | |
| 314 | /* |
| 315 | * get a new block |
| 316 | * |
| 317 | * negative: TRUE if negative block number desired (data block) |
| 318 | */ |
| 319 | bhdr_T * |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 320 | mf_new(memfile_T *mfp, int negative, int page_count) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 321 | { |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 322 | bhdr_T *hp; // new bhdr_T |
| 323 | bhdr_T *freep; // first block in free list |
Bram Moolenaar | 17e7919 | 2007-05-06 14:15:36 +0000 | [diff] [blame] | 324 | char_u *p; |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 325 | |
| 326 | /* |
| 327 | * If we reached the maximum size for the used memory blocks, release one |
| 328 | * If a bhdr_T is returned, use it and adjust the page_count if necessary. |
| 329 | */ |
| 330 | hp = mf_release(mfp, page_count); |
| 331 | |
| 332 | /* |
| 333 | * Decide on the number to use: |
| 334 | * If there is a free block, use its number. |
| 335 | * Otherwise use mf_block_min for a negative number, mf_block_max for |
| 336 | * a positive number. |
| 337 | */ |
| 338 | freep = mfp->mf_free_first; |
| 339 | if (!negative && freep != NULL && freep->bh_page_count >= page_count) |
| 340 | { |
| 341 | /* |
| 342 | * If the block in the free list has more pages, take only the number |
| 343 | * of pages needed and allocate a new bhdr_T with data |
| 344 | * |
Bram Moolenaar | 17e7919 | 2007-05-06 14:15:36 +0000 | [diff] [blame] | 345 | * If the number of pages matches and mf_release() did not return a |
| 346 | * bhdr_T, use the bhdr_T from the free list and allocate the data |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 347 | * |
Bram Moolenaar | 17e7919 | 2007-05-06 14:15:36 +0000 | [diff] [blame] | 348 | * If the number of pages matches and mf_release() returned a bhdr_T, |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 349 | * just use the number and free the bhdr_T from the free list |
| 350 | */ |
| 351 | if (freep->bh_page_count > page_count) |
| 352 | { |
| 353 | if (hp == NULL && (hp = mf_alloc_bhdr(mfp, page_count)) == NULL) |
| 354 | return NULL; |
| 355 | hp->bh_bnum = freep->bh_bnum; |
| 356 | freep->bh_bnum += page_count; |
| 357 | freep->bh_page_count -= page_count; |
| 358 | } |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 359 | else if (hp == NULL) // need to allocate memory for this block |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 360 | { |
=?UTF-8?q?Dundar=20G=C3=B6c?= | d5cec1f | 2022-01-29 15:19:23 +0000 | [diff] [blame] | 361 | if ((p = alloc((size_t)mfp->mf_page_size * page_count)) == NULL) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 362 | return NULL; |
| 363 | hp = mf_rem_free(mfp); |
| 364 | hp->bh_data = p; |
| 365 | } |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 366 | else // use the number, remove entry from free list |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 367 | { |
| 368 | freep = mf_rem_free(mfp); |
| 369 | hp->bh_bnum = freep->bh_bnum; |
| 370 | vim_free(freep); |
| 371 | } |
| 372 | } |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 373 | else // get a new number |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 374 | { |
| 375 | if (hp == NULL && (hp = mf_alloc_bhdr(mfp, page_count)) == NULL) |
| 376 | return NULL; |
| 377 | if (negative) |
| 378 | { |
| 379 | hp->bh_bnum = mfp->mf_blocknr_min--; |
| 380 | mfp->mf_neg_count++; |
| 381 | } |
| 382 | else |
| 383 | { |
| 384 | hp->bh_bnum = mfp->mf_blocknr_max; |
| 385 | mfp->mf_blocknr_max += page_count; |
| 386 | } |
| 387 | } |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 388 | hp->bh_flags = BH_LOCKED | BH_DIRTY; // new block is always dirty |
Bram Moolenaar | 3a2a60c | 2023-05-27 18:02:55 +0100 | [diff] [blame] | 389 | mfp->mf_dirty = MF_DIRTY_YES; |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 390 | hp->bh_page_count = page_count; |
| 391 | mf_ins_used(mfp, hp); |
| 392 | mf_ins_hash(mfp, hp); |
| 393 | |
| 394 | /* |
| 395 | * Init the data to all zero, to avoid reading uninitialized data. |
| 396 | * This also avoids that the passwd file ends up in the swap file! |
| 397 | */ |
Bram Moolenaar | 945e2db | 2010-06-05 17:43:32 +0200 | [diff] [blame] | 398 | (void)vim_memset((char *)(hp->bh_data), 0, |
| 399 | (size_t)mfp->mf_page_size * page_count); |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 400 | |
| 401 | return hp; |
| 402 | } |
| 403 | |
| 404 | /* |
Bram Moolenaar | a8ffcbb | 2010-06-21 06:15:46 +0200 | [diff] [blame] | 405 | * Get existing block "nr" with "page_count" pages. |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 406 | * |
| 407 | * Note: The caller should first check a negative nr with mf_trans_del() |
| 408 | */ |
| 409 | bhdr_T * |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 410 | mf_get(memfile_T *mfp, blocknr_T nr, int page_count) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 411 | { |
| 412 | bhdr_T *hp; |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 413 | // doesn't exist |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 414 | if (nr >= mfp->mf_blocknr_max || nr <= mfp->mf_blocknr_min) |
| 415 | return NULL; |
| 416 | |
| 417 | /* |
| 418 | * see if it is in the cache |
| 419 | */ |
| 420 | hp = mf_find_hash(mfp, nr); |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 421 | if (hp == NULL) // not in the hash list |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 422 | { |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 423 | if (nr < 0 || nr >= mfp->mf_infile_count) // can't be in the file |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 424 | return NULL; |
| 425 | |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 426 | // could check here if the block is in the free list |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 427 | |
| 428 | /* |
| 429 | * Check if we need to flush an existing block. |
| 430 | * If so, use that block. |
| 431 | * If not, allocate a new block. |
| 432 | */ |
| 433 | hp = mf_release(mfp, page_count); |
Bram Moolenaar | b67ba03 | 2023-04-22 21:14:26 +0100 | [diff] [blame] | 434 | if (hp == NULL && page_count > 0) |
| 435 | hp = mf_alloc_bhdr(mfp, page_count); |
| 436 | if (hp == NULL) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 437 | return NULL; |
| 438 | |
| 439 | hp->bh_bnum = nr; |
| 440 | hp->bh_flags = 0; |
| 441 | hp->bh_page_count = page_count; |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 442 | if (mf_read(mfp, hp) == FAIL) // cannot read the block! |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 443 | { |
| 444 | mf_free_bhdr(hp); |
| 445 | return NULL; |
| 446 | } |
| 447 | } |
| 448 | else |
| 449 | { |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 450 | mf_rem_used(mfp, hp); // remove from list, insert in front below |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 451 | mf_rem_hash(mfp, hp); |
| 452 | } |
| 453 | |
| 454 | hp->bh_flags |= BH_LOCKED; |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 455 | mf_ins_used(mfp, hp); // put in front of used list |
| 456 | mf_ins_hash(mfp, hp); // put in front of hash list |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 457 | |
| 458 | return hp; |
| 459 | } |
| 460 | |
| 461 | /* |
| 462 | * release the block *hp |
| 463 | * |
| 464 | * dirty: Block must be written to file later |
| 465 | * infile: Block should be in file (needed for recovery) |
| 466 | * |
| 467 | * no return value, function cannot fail |
| 468 | */ |
| 469 | void |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 470 | mf_put( |
| 471 | memfile_T *mfp, |
| 472 | bhdr_T *hp, |
| 473 | int dirty, |
| 474 | int infile) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 475 | { |
| 476 | int flags; |
| 477 | |
| 478 | flags = hp->bh_flags; |
| 479 | |
| 480 | if ((flags & BH_LOCKED) == 0) |
RestorerZ | 68ebcee | 2023-05-31 17:12:14 +0100 | [diff] [blame] | 481 | iemsg(e_block_was_not_locked); |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 482 | flags &= ~BH_LOCKED; |
| 483 | if (dirty) |
| 484 | { |
| 485 | flags |= BH_DIRTY; |
Bram Moolenaar | 3a2a60c | 2023-05-27 18:02:55 +0100 | [diff] [blame] | 486 | if (mfp->mf_dirty != MF_DIRTY_YES_NOSYNC) |
| 487 | mfp->mf_dirty = MF_DIRTY_YES; |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 488 | } |
| 489 | hp->bh_flags = flags; |
| 490 | if (infile) |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 491 | mf_trans_add(mfp, hp); // may translate negative in positive nr |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 492 | } |
| 493 | |
| 494 | /* |
| 495 | * block *hp is no longer in used, may put it in the free list of memfile *mfp |
| 496 | */ |
| 497 | void |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 498 | mf_free(memfile_T *mfp, bhdr_T *hp) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 499 | { |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 500 | vim_free(hp->bh_data); // free the memory |
| 501 | mf_rem_hash(mfp, hp); // get *hp out of the hash list |
| 502 | mf_rem_used(mfp, hp); // get *hp out of the used list |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 503 | if (hp->bh_bnum < 0) |
| 504 | { |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 505 | vim_free(hp); // don't want negative numbers in free list |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 506 | mfp->mf_neg_count--; |
| 507 | } |
| 508 | else |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 509 | mf_ins_free(mfp, hp); // put *hp in the free list |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 510 | } |
| 511 | |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 512 | /* |
| 513 | * Sync the memory file *mfp to disk. |
| 514 | * Flags: |
| 515 | * MFS_ALL If not given, blocks with negative numbers are not synced, |
| 516 | * even when they are dirty! |
| 517 | * MFS_STOP Stop syncing when a character becomes available, but sync at |
| 518 | * least one block. |
| 519 | * MFS_FLUSH Make sure buffers are flushed to disk, so they will survive a |
| 520 | * system crash. |
| 521 | * MFS_ZERO Only write block 0. |
| 522 | * |
| 523 | * Return FAIL for failure, OK otherwise |
| 524 | */ |
| 525 | int |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 526 | mf_sync(memfile_T *mfp, int flags) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 527 | { |
| 528 | int status; |
| 529 | bhdr_T *hp; |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 530 | int got_int_save = got_int; |
| 531 | |
Bram Moolenaar | 3a2a60c | 2023-05-27 18:02:55 +0100 | [diff] [blame] | 532 | if (mfp->mf_fd < 0) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 533 | { |
Bram Moolenaar | 3a2a60c | 2023-05-27 18:02:55 +0100 | [diff] [blame] | 534 | // there is no file, nothing to do |
| 535 | mfp->mf_dirty = MF_DIRTY_NO; |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 536 | return FAIL; |
| 537 | } |
| 538 | |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 539 | // Only a CTRL-C while writing will break us here, not one typed |
| 540 | // previously. |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 541 | got_int = FALSE; |
| 542 | |
| 543 | /* |
| 544 | * sync from last to first (may reduce the probability of an inconsistent |
| 545 | * file) If a write fails, it is very likely caused by a full filesystem. |
| 546 | * Then we only try to write blocks within the existing file. If that also |
| 547 | * fails then we give up. |
| 548 | */ |
| 549 | status = OK; |
| 550 | for (hp = mfp->mf_used_last; hp != NULL; hp = hp->bh_prev) |
| 551 | if (((flags & MFS_ALL) || hp->bh_bnum >= 0) |
| 552 | && (hp->bh_flags & BH_DIRTY) |
| 553 | && (status == OK || (hp->bh_bnum >= 0 |
| 554 | && hp->bh_bnum < mfp->mf_infile_count))) |
| 555 | { |
| 556 | if ((flags & MFS_ZERO) && hp->bh_bnum != 0) |
| 557 | continue; |
| 558 | if (mf_write(mfp, hp) == FAIL) |
| 559 | { |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 560 | if (status == FAIL) // double error: quit syncing |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 561 | break; |
| 562 | status = FAIL; |
| 563 | } |
| 564 | if (flags & MFS_STOP) |
| 565 | { |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 566 | // Stop when char available now. |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 567 | if (ui_char_avail()) |
| 568 | break; |
| 569 | } |
| 570 | else |
| 571 | ui_breakcheck(); |
| 572 | if (got_int) |
| 573 | break; |
| 574 | } |
| 575 | |
| 576 | /* |
| 577 | * If the whole list is flushed, the memfile is not dirty anymore. |
| 578 | * In case of an error this flag is also set, to avoid trying all the time. |
| 579 | */ |
| 580 | if (hp == NULL || status == FAIL) |
Bram Moolenaar | 3a2a60c | 2023-05-27 18:02:55 +0100 | [diff] [blame] | 581 | mfp->mf_dirty = MF_DIRTY_NO; |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 582 | |
| 583 | if ((flags & MFS_FLUSH) && *p_sws != NUL) |
| 584 | { |
| 585 | #if defined(UNIX) |
| 586 | # ifdef HAVE_FSYNC |
| 587 | /* |
| 588 | * most Unixes have the very useful fsync() function, just what we need. |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 589 | */ |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 590 | if (STRCMP(p_sws, "fsync") == 0) |
| 591 | { |
Bram Moolenaar | a787019 | 2019-02-14 12:56:36 +0100 | [diff] [blame] | 592 | if (vim_fsync(mfp->mf_fd)) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 593 | status = FAIL; |
| 594 | } |
| 595 | else |
| 596 | # endif |
Jonas Sortie Termansen | 8bb5eaf | 2024-11-04 20:32:27 +0100 | [diff] [blame] | 597 | # ifdef HAVE_SYNC |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 598 | sync(); |
Jonas Sortie Termansen | 8bb5eaf | 2024-11-04 20:32:27 +0100 | [diff] [blame] | 599 | # else |
| 600 | fflush(NULL); |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 601 | # endif |
| 602 | #endif |
| 603 | #ifdef VMS |
| 604 | if (STRCMP(p_sws, "fsync") == 0) |
| 605 | { |
Bram Moolenaar | a787019 | 2019-02-14 12:56:36 +0100 | [diff] [blame] | 606 | if (vim_fsync(mfp->mf_fd)) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 607 | status = FAIL; |
| 608 | } |
| 609 | #endif |
Bram Moolenaar | 4f97475 | 2019-02-17 17:44:42 +0100 | [diff] [blame] | 610 | #ifdef MSWIN |
Bram Moolenaar | 0bd4051 | 2018-09-21 14:48:53 +0200 | [diff] [blame] | 611 | if (_commit(mfp->mf_fd)) |
| 612 | status = FAIL; |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 613 | #endif |
| 614 | #ifdef AMIGA |
Bram Moolenaar | 5a6404c | 2006-11-01 17:12:57 +0000 | [diff] [blame] | 615 | # if defined(__AROS__) || defined(__amigaos4__) |
Bram Moolenaar | a787019 | 2019-02-14 12:56:36 +0100 | [diff] [blame] | 616 | if (vim_fsync(mfp->mf_fd) != 0) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 617 | status = FAIL; |
| 618 | # else |
| 619 | /* |
| 620 | * Flush() only exists for AmigaDos 2.0. |
| 621 | * For 1.3 it should be done with close() + open(), but then the risk |
| 622 | * is that the open() may fail and lose the file.... |
| 623 | */ |
| 624 | # ifdef FEAT_ARP |
| 625 | if (dos2) |
| 626 | # endif |
| 627 | # ifdef SASC |
| 628 | { |
| 629 | struct UFB *fp = chkufb(mfp->mf_fd); |
| 630 | |
| 631 | if (fp != NULL) |
| 632 | Flush(fp->ufbfh); |
| 633 | } |
| 634 | # else |
| 635 | # if defined(_DCC) || defined(__GNUC__) || defined(__MORPHOS__) |
| 636 | { |
Bram Moolenaar | 89f3727 | 2006-09-26 11:48:34 +0000 | [diff] [blame] | 637 | # if defined(__GNUC__) && !defined(__MORPHOS__) && defined(__libnix__) |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 638 | // Have function (in libnix at least), |
| 639 | // but ain't got no prototype anywhere. |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 640 | extern unsigned long fdtofh(int filedescriptor); |
| 641 | # endif |
Bram Moolenaar | 89f3727 | 2006-09-26 11:48:34 +0000 | [diff] [blame] | 642 | # if !defined(__libnix__) |
| 643 | fflush(NULL); |
| 644 | # else |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 645 | BPTR fh = (BPTR)fdtofh(mfp->mf_fd); |
| 646 | |
| 647 | if (fh != 0) |
| 648 | Flush(fh); |
Bram Moolenaar | 89f3727 | 2006-09-26 11:48:34 +0000 | [diff] [blame] | 649 | # endif |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 650 | } |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 651 | # else // assume Manx |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 652 | Flush(_devtab[mfp->mf_fd].fd); |
| 653 | # endif |
| 654 | # endif |
| 655 | # endif |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 656 | #endif // AMIGA |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 657 | } |
| 658 | |
| 659 | got_int |= got_int_save; |
| 660 | |
| 661 | return status; |
| 662 | } |
| 663 | |
| 664 | /* |
Bram Moolenaar | c32840f | 2006-01-14 21:23:38 +0000 | [diff] [blame] | 665 | * For all blocks in memory file *mfp that have a positive block number set |
| 666 | * the dirty flag. These are blocks that need to be written to a newly |
| 667 | * created swapfile. |
| 668 | */ |
| 669 | void |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 670 | mf_set_dirty(memfile_T *mfp) |
Bram Moolenaar | c32840f | 2006-01-14 21:23:38 +0000 | [diff] [blame] | 671 | { |
| 672 | bhdr_T *hp; |
| 673 | |
| 674 | for (hp = mfp->mf_used_last; hp != NULL; hp = hp->bh_prev) |
| 675 | if (hp->bh_bnum > 0) |
| 676 | hp->bh_flags |= BH_DIRTY; |
Bram Moolenaar | 3a2a60c | 2023-05-27 18:02:55 +0100 | [diff] [blame] | 677 | mfp->mf_dirty = MF_DIRTY_YES; |
Bram Moolenaar | c32840f | 2006-01-14 21:23:38 +0000 | [diff] [blame] | 678 | } |
| 679 | |
| 680 | /* |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 681 | * insert block *hp in front of hashlist of memfile *mfp |
| 682 | */ |
| 683 | static void |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 684 | mf_ins_hash(memfile_T *mfp, bhdr_T *hp) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 685 | { |
Bram Moolenaar | b05b10a | 2011-03-22 18:10:45 +0100 | [diff] [blame] | 686 | mf_hash_add_item(&mfp->mf_hash, (mf_hashitem_T *)hp); |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 687 | } |
| 688 | |
| 689 | /* |
| 690 | * remove block *hp from hashlist of memfile list *mfp |
| 691 | */ |
| 692 | static void |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 693 | mf_rem_hash(memfile_T *mfp, bhdr_T *hp) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 694 | { |
Bram Moolenaar | b05b10a | 2011-03-22 18:10:45 +0100 | [diff] [blame] | 695 | mf_hash_rem_item(&mfp->mf_hash, (mf_hashitem_T *)hp); |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 696 | } |
| 697 | |
| 698 | /* |
| 699 | * look in hash lists of memfile *mfp for block header with number 'nr' |
| 700 | */ |
| 701 | static bhdr_T * |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 702 | mf_find_hash(memfile_T *mfp, blocknr_T nr) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 703 | { |
Bram Moolenaar | b05b10a | 2011-03-22 18:10:45 +0100 | [diff] [blame] | 704 | return (bhdr_T *)mf_hash_find(&mfp->mf_hash, nr); |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 705 | } |
| 706 | |
| 707 | /* |
| 708 | * insert block *hp in front of used list of memfile *mfp |
| 709 | */ |
| 710 | static void |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 711 | mf_ins_used(memfile_T *mfp, bhdr_T *hp) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 712 | { |
| 713 | hp->bh_next = mfp->mf_used_first; |
| 714 | mfp->mf_used_first = hp; |
| 715 | hp->bh_prev = NULL; |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 716 | if (hp->bh_next == NULL) // list was empty, adjust last pointer |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 717 | mfp->mf_used_last = hp; |
| 718 | else |
| 719 | hp->bh_next->bh_prev = hp; |
| 720 | mfp->mf_used_count += hp->bh_page_count; |
=?UTF-8?q?Dundar=20G=C3=B6c?= | d5cec1f | 2022-01-29 15:19:23 +0000 | [diff] [blame] | 721 | total_mem_used += (long_u)hp->bh_page_count * mfp->mf_page_size; |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 722 | } |
| 723 | |
| 724 | /* |
| 725 | * remove block *hp from used list of memfile *mfp |
| 726 | */ |
| 727 | static void |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 728 | mf_rem_used(memfile_T *mfp, bhdr_T *hp) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 729 | { |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 730 | if (hp->bh_next == NULL) // last block in used list |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 731 | mfp->mf_used_last = hp->bh_prev; |
| 732 | else |
| 733 | hp->bh_next->bh_prev = hp->bh_prev; |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 734 | if (hp->bh_prev == NULL) // first block in used list |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 735 | mfp->mf_used_first = hp->bh_next; |
| 736 | else |
| 737 | hp->bh_prev->bh_next = hp->bh_next; |
| 738 | mfp->mf_used_count -= hp->bh_page_count; |
=?UTF-8?q?Dundar=20G=C3=B6c?= | d5cec1f | 2022-01-29 15:19:23 +0000 | [diff] [blame] | 739 | total_mem_used -= (long_u)hp->bh_page_count * mfp->mf_page_size; |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 740 | } |
| 741 | |
| 742 | /* |
| 743 | * Release the least recently used block from the used list if the number |
| 744 | * of used memory blocks gets to big. |
| 745 | * |
| 746 | * Return the block header to the caller, including the memory block, so |
| 747 | * it can be re-used. Make sure the page_count is right. |
Bram Moolenaar | bc56336 | 2015-06-09 18:35:25 +0200 | [diff] [blame] | 748 | * |
| 749 | * Returns NULL if no block is released. |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 750 | */ |
| 751 | static bhdr_T * |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 752 | mf_release(memfile_T *mfp, int page_count) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 753 | { |
| 754 | bhdr_T *hp; |
| 755 | int need_release; |
| 756 | buf_T *buf; |
| 757 | |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 758 | // don't release while in mf_close_file() |
Bram Moolenaar | 47b8b15 | 2007-02-07 02:41:57 +0000 | [diff] [blame] | 759 | if (mf_dont_release) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 760 | return NULL; |
| 761 | |
| 762 | /* |
| 763 | * Need to release a block if the number of blocks for this memfile is |
| 764 | * higher than the maximum or total memory used is over 'maxmemtot' |
| 765 | */ |
| 766 | need_release = ((mfp->mf_used_count >= mfp->mf_used_count_max) |
| 767 | || (total_mem_used >> 10) >= (long_u)p_mmt); |
| 768 | |
| 769 | /* |
| 770 | * Try to create a swap file if the amount of memory used is getting too |
| 771 | * high. |
| 772 | */ |
| 773 | if (mfp->mf_fd < 0 && need_release && p_uc) |
| 774 | { |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 775 | // find for which buffer this memfile is |
Bram Moolenaar | 2932359 | 2016-07-24 22:04:11 +0200 | [diff] [blame] | 776 | FOR_ALL_BUFFERS(buf) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 777 | if (buf->b_ml.ml_mfp == mfp) |
| 778 | break; |
| 779 | if (buf != NULL && buf->b_may_swap) |
| 780 | ml_open_file(buf); |
| 781 | } |
| 782 | |
| 783 | /* |
| 784 | * don't release a block if |
| 785 | * there is no file for this memfile |
| 786 | * or |
| 787 | * the number of blocks for this memfile is lower than the maximum |
| 788 | * and |
| 789 | * total memory used is not up to 'maxmemtot' |
| 790 | */ |
| 791 | if (mfp->mf_fd < 0 || !need_release) |
| 792 | return NULL; |
| 793 | |
| 794 | for (hp = mfp->mf_used_last; hp != NULL; hp = hp->bh_prev) |
| 795 | if (!(hp->bh_flags & BH_LOCKED)) |
| 796 | break; |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 797 | if (hp == NULL) // not a single one that can be released |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 798 | return NULL; |
| 799 | |
| 800 | /* |
| 801 | * If the block is dirty, write it. |
| 802 | * If the write fails we don't free it. |
| 803 | */ |
| 804 | if ((hp->bh_flags & BH_DIRTY) && mf_write(mfp, hp) == FAIL) |
| 805 | return NULL; |
| 806 | |
| 807 | mf_rem_used(mfp, hp); |
| 808 | mf_rem_hash(mfp, hp); |
| 809 | |
| 810 | /* |
| 811 | * If a bhdr_T is returned, make sure that the page_count of bh_data is |
| 812 | * right |
| 813 | */ |
| 814 | if (hp->bh_page_count != page_count) |
| 815 | { |
Bram Moolenaar | b67ba03 | 2023-04-22 21:14:26 +0100 | [diff] [blame] | 816 | VIM_CLEAR(hp->bh_data); |
| 817 | if (page_count > 0) |
| 818 | hp->bh_data = alloc((size_t)mfp->mf_page_size * page_count); |
| 819 | if (hp->bh_data == NULL) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 820 | { |
| 821 | vim_free(hp); |
| 822 | return NULL; |
| 823 | } |
| 824 | hp->bh_page_count = page_count; |
| 825 | } |
| 826 | return hp; |
| 827 | } |
| 828 | |
| 829 | /* |
| 830 | * release as many blocks as possible |
| 831 | * Used in case of out of memory |
| 832 | * |
| 833 | * return TRUE if any memory was released |
| 834 | */ |
| 835 | int |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 836 | mf_release_all(void) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 837 | { |
| 838 | buf_T *buf; |
| 839 | memfile_T *mfp; |
| 840 | bhdr_T *hp; |
| 841 | int retval = FALSE; |
| 842 | |
Bram Moolenaar | 2932359 | 2016-07-24 22:04:11 +0200 | [diff] [blame] | 843 | FOR_ALL_BUFFERS(buf) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 844 | { |
| 845 | mfp = buf->b_ml.ml_mfp; |
| 846 | if (mfp != NULL) |
| 847 | { |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 848 | // If no swap file yet, may open one |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 849 | if (mfp->mf_fd < 0 && buf->b_may_swap) |
| 850 | ml_open_file(buf); |
| 851 | |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 852 | // only if there is a swapfile |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 853 | if (mfp->mf_fd >= 0) |
| 854 | { |
| 855 | for (hp = mfp->mf_used_last; hp != NULL; ) |
| 856 | { |
| 857 | if (!(hp->bh_flags & BH_LOCKED) |
| 858 | && (!(hp->bh_flags & BH_DIRTY) |
| 859 | || mf_write(mfp, hp) != FAIL)) |
| 860 | { |
| 861 | mf_rem_used(mfp, hp); |
| 862 | mf_rem_hash(mfp, hp); |
| 863 | mf_free_bhdr(hp); |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 864 | hp = mfp->mf_used_last; // re-start, list was changed |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 865 | retval = TRUE; |
| 866 | } |
| 867 | else |
| 868 | hp = hp->bh_prev; |
| 869 | } |
| 870 | } |
| 871 | } |
| 872 | } |
| 873 | return retval; |
| 874 | } |
| 875 | |
| 876 | /* |
Bram Moolenaar | b67ba03 | 2023-04-22 21:14:26 +0100 | [diff] [blame] | 877 | * Allocate a block header and a block of memory for it. |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 878 | */ |
| 879 | static bhdr_T * |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 880 | mf_alloc_bhdr(memfile_T *mfp, int page_count) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 881 | { |
| 882 | bhdr_T *hp; |
| 883 | |
Yegappan Lakshmanan | e857598 | 2023-01-14 12:32:28 +0000 | [diff] [blame] | 884 | if ((hp = ALLOC_ONE(bhdr_T)) == NULL) |
| 885 | return NULL; |
| 886 | |
Bram Moolenaar | b67ba03 | 2023-04-22 21:14:26 +0100 | [diff] [blame] | 887 | if ((hp->bh_data = alloc((size_t)mfp->mf_page_size * page_count)) == NULL) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 888 | { |
Yegappan Lakshmanan | e857598 | 2023-01-14 12:32:28 +0000 | [diff] [blame] | 889 | vim_free(hp); // not enough memory |
| 890 | return NULL; |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 891 | } |
Yegappan Lakshmanan | e857598 | 2023-01-14 12:32:28 +0000 | [diff] [blame] | 892 | hp->bh_page_count = page_count; |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 893 | return hp; |
| 894 | } |
| 895 | |
| 896 | /* |
Bram Moolenaar | b67ba03 | 2023-04-22 21:14:26 +0100 | [diff] [blame] | 897 | * Free a block header and the block of memory for it. |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 898 | */ |
| 899 | static void |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 900 | mf_free_bhdr(bhdr_T *hp) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 901 | { |
| 902 | vim_free(hp->bh_data); |
| 903 | vim_free(hp); |
| 904 | } |
| 905 | |
| 906 | /* |
Bram Moolenaar | b67ba03 | 2023-04-22 21:14:26 +0100 | [diff] [blame] | 907 | * Insert entry *hp in the free list. |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 908 | */ |
| 909 | static void |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 910 | mf_ins_free(memfile_T *mfp, bhdr_T *hp) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 911 | { |
| 912 | hp->bh_next = mfp->mf_free_first; |
| 913 | mfp->mf_free_first = hp; |
| 914 | } |
| 915 | |
| 916 | /* |
| 917 | * remove the first entry from the free list and return a pointer to it |
| 918 | * Note: caller must check that mfp->mf_free_first is not NULL! |
| 919 | */ |
| 920 | static bhdr_T * |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 921 | mf_rem_free(memfile_T *mfp) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 922 | { |
| 923 | bhdr_T *hp; |
| 924 | |
| 925 | hp = mfp->mf_free_first; |
| 926 | mfp->mf_free_first = hp->bh_next; |
| 927 | return hp; |
| 928 | } |
| 929 | |
| 930 | /* |
| 931 | * read a block from disk |
| 932 | * |
| 933 | * Return FAIL for failure, OK otherwise |
| 934 | */ |
| 935 | static int |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 936 | mf_read(memfile_T *mfp, bhdr_T *hp) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 937 | { |
Bram Moolenaar | 8767f52 | 2016-07-01 17:17:39 +0200 | [diff] [blame] | 938 | off_T offset; |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 939 | unsigned page_size; |
| 940 | unsigned size; |
| 941 | |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 942 | if (mfp->mf_fd < 0) // there is no file, can't read |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 943 | return FAIL; |
| 944 | |
| 945 | page_size = mfp->mf_page_size; |
Bram Moolenaar | 8767f52 | 2016-07-01 17:17:39 +0200 | [diff] [blame] | 946 | offset = (off_T)page_size * hp->bh_bnum; |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 947 | size = page_size * hp->bh_page_count; |
Bram Moolenaar | 8767f52 | 2016-07-01 17:17:39 +0200 | [diff] [blame] | 948 | if (vim_lseek(mfp->mf_fd, offset, SEEK_SET) != offset) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 949 | { |
Bram Moolenaar | 9a846fb | 2022-01-01 21:59:18 +0000 | [diff] [blame] | 950 | PERROR(_(e_seek_error_in_swap_file_read)); |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 951 | return FAIL; |
| 952 | } |
Bram Moolenaar | 540fc6f | 2010-12-17 16:27:16 +0100 | [diff] [blame] | 953 | if ((unsigned)read_eintr(mfp->mf_fd, hp->bh_data, size) != size) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 954 | { |
Bram Moolenaar | 9a846fb | 2022-01-01 21:59:18 +0000 | [diff] [blame] | 955 | PERROR(_(e_read_error_in_swap_file)); |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 956 | return FAIL; |
| 957 | } |
Bram Moolenaar | a8ffcbb | 2010-06-21 06:15:46 +0200 | [diff] [blame] | 958 | |
| 959 | #ifdef FEAT_CRYPT |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 960 | // Decrypt if 'key' is set and this is a data block. And when changing the |
| 961 | // key. |
Bram Moolenaar | 4a8c2cf | 2015-12-19 15:28:18 +0100 | [diff] [blame] | 962 | if (*mfp->mf_buffer->b_p_key != NUL || mfp->mf_old_key != NULL) |
Bram Moolenaar | a8ffcbb | 2010-06-21 06:15:46 +0200 | [diff] [blame] | 963 | ml_decrypt_data(mfp, hp->bh_data, offset, size); |
| 964 | #endif |
| 965 | |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 966 | return OK; |
| 967 | } |
| 968 | |
| 969 | /* |
| 970 | * write a block to disk |
| 971 | * |
| 972 | * Return FAIL for failure, OK otherwise |
| 973 | */ |
| 974 | static int |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 975 | mf_write(memfile_T *mfp, bhdr_T *hp) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 976 | { |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 977 | off_T offset; // offset in the file |
| 978 | blocknr_T nr; // block nr which is being written |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 979 | bhdr_T *hp2; |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 980 | unsigned page_size; // number of bytes in a page |
| 981 | unsigned page_count; // number of pages written |
| 982 | unsigned size; // number of bytes written |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 983 | |
Bram Moolenaar | b58a4b9 | 2019-05-27 23:36:21 +0200 | [diff] [blame] | 984 | if (mfp->mf_fd < 0 && !mfp->mf_reopen) |
| 985 | // there is no file and there was no file, can't write |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 986 | return FAIL; |
| 987 | |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 988 | if (hp->bh_bnum < 0) // must assign file block number |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 989 | if (mf_trans_add(mfp, hp) == FAIL) |
| 990 | return FAIL; |
| 991 | |
| 992 | page_size = mfp->mf_page_size; |
| 993 | |
| 994 | /* |
| 995 | * We don't want gaps in the file. Write the blocks in front of *hp |
| 996 | * to extend the file. |
| 997 | * If block 'mf_infile_count' is not in the hash list, it has been |
| 998 | * freed. Fill the space in the file with data from the current block. |
| 999 | */ |
| 1000 | for (;;) |
| 1001 | { |
Bram Moolenaar | b58a4b9 | 2019-05-27 23:36:21 +0200 | [diff] [blame] | 1002 | int attempt; |
| 1003 | |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1004 | nr = hp->bh_bnum; |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 1005 | if (nr > mfp->mf_infile_count) // beyond end of file |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1006 | { |
| 1007 | nr = mfp->mf_infile_count; |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 1008 | hp2 = mf_find_hash(mfp, nr); // NULL caught below |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1009 | } |
| 1010 | else |
| 1011 | hp2 = hp; |
| 1012 | |
Bram Moolenaar | 8767f52 | 2016-07-01 17:17:39 +0200 | [diff] [blame] | 1013 | offset = (off_T)page_size * nr; |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 1014 | if (hp2 == NULL) // freed block, fill with dummy data |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1015 | page_count = 1; |
| 1016 | else |
| 1017 | page_count = hp2->bh_page_count; |
| 1018 | size = page_size * page_count; |
Bram Moolenaar | b58a4b9 | 2019-05-27 23:36:21 +0200 | [diff] [blame] | 1019 | |
| 1020 | for (attempt = 1; attempt <= 2; ++attempt) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1021 | { |
Bram Moolenaar | b58a4b9 | 2019-05-27 23:36:21 +0200 | [diff] [blame] | 1022 | if (mfp->mf_fd >= 0) |
| 1023 | { |
| 1024 | if (vim_lseek(mfp->mf_fd, offset, SEEK_SET) != offset) |
| 1025 | { |
Bram Moolenaar | 9a846fb | 2022-01-01 21:59:18 +0000 | [diff] [blame] | 1026 | PERROR(_(e_seek_error_in_swap_file_write)); |
Bram Moolenaar | b58a4b9 | 2019-05-27 23:36:21 +0200 | [diff] [blame] | 1027 | return FAIL; |
| 1028 | } |
| 1029 | if (mf_write_block(mfp, |
| 1030 | hp2 == NULL ? hp : hp2, offset, size) == OK) |
| 1031 | break; |
| 1032 | } |
| 1033 | |
| 1034 | if (attempt == 1) |
| 1035 | { |
| 1036 | // If the swap file is on a network drive, and the network |
| 1037 | // gets disconnected and then re-connected, we can maybe fix it |
| 1038 | // by closing and then re-opening the file. |
| 1039 | if (mfp->mf_fd >= 0) |
| 1040 | close(mfp->mf_fd); |
| 1041 | mfp->mf_fd = mch_open_rw((char *)mfp->mf_fname, mfp->mf_flags); |
| 1042 | mfp->mf_reopen = (mfp->mf_fd < 0); |
| 1043 | } |
| 1044 | if (attempt == 2 || mfp->mf_fd < 0) |
| 1045 | { |
| 1046 | // Avoid repeating the error message, this mostly happens when |
| 1047 | // the disk is full. We give the message again only after a |
| 1048 | // successful write or when hitting a key. We keep on trying, |
| 1049 | // in case some space becomes available. |
| 1050 | if (!did_swapwrite_msg) |
Bram Moolenaar | 9a846fb | 2022-01-01 21:59:18 +0000 | [diff] [blame] | 1051 | emsg(_(e_write_error_in_swap_file)); |
Bram Moolenaar | b58a4b9 | 2019-05-27 23:36:21 +0200 | [diff] [blame] | 1052 | did_swapwrite_msg = TRUE; |
| 1053 | return FAIL; |
| 1054 | } |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1055 | } |
Bram Moolenaar | b58a4b9 | 2019-05-27 23:36:21 +0200 | [diff] [blame] | 1056 | |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1057 | did_swapwrite_msg = FALSE; |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 1058 | if (hp2 != NULL) // written a non-dummy block |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1059 | hp2->bh_flags &= ~BH_DIRTY; |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 1060 | // appended to the file |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1061 | if (nr + (blocknr_T)page_count > mfp->mf_infile_count) |
| 1062 | mfp->mf_infile_count = nr + page_count; |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 1063 | if (nr == hp->bh_bnum) // written the desired block |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1064 | break; |
| 1065 | } |
| 1066 | return OK; |
| 1067 | } |
| 1068 | |
| 1069 | /* |
Bram Moolenaar | a8ffcbb | 2010-06-21 06:15:46 +0200 | [diff] [blame] | 1070 | * Write block "hp" with data size "size" to file "mfp->mf_fd". |
| 1071 | * Takes care of encryption. |
| 1072 | * Return FAIL or OK. |
| 1073 | */ |
| 1074 | static int |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 1075 | mf_write_block( |
| 1076 | memfile_T *mfp, |
| 1077 | bhdr_T *hp, |
Bram Moolenaar | 8767f52 | 2016-07-01 17:17:39 +0200 | [diff] [blame] | 1078 | off_T offset UNUSED, |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 1079 | unsigned size) |
Bram Moolenaar | a8ffcbb | 2010-06-21 06:15:46 +0200 | [diff] [blame] | 1080 | { |
| 1081 | char_u *data = hp->bh_data; |
| 1082 | int result = OK; |
| 1083 | |
| 1084 | #ifdef FEAT_CRYPT |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 1085 | // Encrypt if 'key' is set and this is a data block. |
Bram Moolenaar | a8ffcbb | 2010-06-21 06:15:46 +0200 | [diff] [blame] | 1086 | if (*mfp->mf_buffer->b_p_key != NUL) |
| 1087 | { |
| 1088 | data = ml_encrypt_data(mfp, data, offset, size); |
| 1089 | if (data == NULL) |
| 1090 | return FAIL; |
| 1091 | } |
| 1092 | #endif |
| 1093 | |
Bram Moolenaar | 540fc6f | 2010-12-17 16:27:16 +0100 | [diff] [blame] | 1094 | if ((unsigned)write_eintr(mfp->mf_fd, data, size) != size) |
Bram Moolenaar | a8ffcbb | 2010-06-21 06:15:46 +0200 | [diff] [blame] | 1095 | result = FAIL; |
| 1096 | |
| 1097 | #ifdef FEAT_CRYPT |
| 1098 | if (data != hp->bh_data) |
| 1099 | vim_free(data); |
| 1100 | #endif |
| 1101 | |
| 1102 | return result; |
| 1103 | } |
| 1104 | |
| 1105 | /* |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1106 | * Make block number for *hp positive and add it to the translation list |
| 1107 | * |
| 1108 | * Return FAIL for failure, OK otherwise |
| 1109 | */ |
| 1110 | static int |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 1111 | mf_trans_add(memfile_T *mfp, bhdr_T *hp) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1112 | { |
| 1113 | bhdr_T *freep; |
| 1114 | blocknr_T new_bnum; |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1115 | NR_TRANS *np; |
| 1116 | int page_count; |
| 1117 | |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 1118 | if (hp->bh_bnum >= 0) // it's already positive |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1119 | return OK; |
| 1120 | |
Bram Moolenaar | c799fe2 | 2019-05-28 23:08:19 +0200 | [diff] [blame] | 1121 | if ((np = ALLOC_ONE(NR_TRANS)) == NULL) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1122 | return FAIL; |
| 1123 | |
| 1124 | /* |
Bram Moolenaar | a8ffcbb | 2010-06-21 06:15:46 +0200 | [diff] [blame] | 1125 | * Get a new number for the block. |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1126 | * If the first item in the free list has sufficient pages, use its number |
| 1127 | * Otherwise use mf_blocknr_max. |
| 1128 | */ |
| 1129 | freep = mfp->mf_free_first; |
| 1130 | page_count = hp->bh_page_count; |
| 1131 | if (freep != NULL && freep->bh_page_count >= page_count) |
| 1132 | { |
| 1133 | new_bnum = freep->bh_bnum; |
| 1134 | /* |
Bram Moolenaar | 84a05ac | 2013-05-06 04:24:17 +0200 | [diff] [blame] | 1135 | * If the page count of the free block was larger, reduce it. |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1136 | * If the page count matches, remove the block from the free list |
| 1137 | */ |
| 1138 | if (freep->bh_page_count > page_count) |
| 1139 | { |
| 1140 | freep->bh_bnum += page_count; |
| 1141 | freep->bh_page_count -= page_count; |
| 1142 | } |
| 1143 | else |
| 1144 | { |
| 1145 | freep = mf_rem_free(mfp); |
| 1146 | vim_free(freep); |
| 1147 | } |
| 1148 | } |
| 1149 | else |
| 1150 | { |
| 1151 | new_bnum = mfp->mf_blocknr_max; |
| 1152 | mfp->mf_blocknr_max += page_count; |
| 1153 | } |
| 1154 | |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 1155 | np->nt_old_bnum = hp->bh_bnum; // adjust number |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1156 | np->nt_new_bnum = new_bnum; |
| 1157 | |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 1158 | mf_rem_hash(mfp, hp); // remove from old hash list |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1159 | hp->bh_bnum = new_bnum; |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 1160 | mf_ins_hash(mfp, hp); // insert in new hash list |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1161 | |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 1162 | // Insert "np" into "mf_trans" hashtable with key "np->nt_old_bnum" |
Bram Moolenaar | b05b10a | 2011-03-22 18:10:45 +0100 | [diff] [blame] | 1163 | mf_hash_add_item(&mfp->mf_trans, (mf_hashitem_T *)np); |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1164 | |
| 1165 | return OK; |
| 1166 | } |
| 1167 | |
| 1168 | /* |
Bram Moolenaar | bc56336 | 2015-06-09 18:35:25 +0200 | [diff] [blame] | 1169 | * Lookup a translation from the trans lists and delete the entry. |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1170 | * |
| 1171 | * Return the positive new number when found, the old number when not found |
| 1172 | */ |
| 1173 | blocknr_T |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 1174 | mf_trans_del(memfile_T *mfp, blocknr_T old_nr) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1175 | { |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1176 | NR_TRANS *np; |
| 1177 | blocknr_T new_bnum; |
| 1178 | |
Bram Moolenaar | b05b10a | 2011-03-22 18:10:45 +0100 | [diff] [blame] | 1179 | np = (NR_TRANS *)mf_hash_find(&mfp->mf_trans, old_nr); |
| 1180 | |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 1181 | if (np == NULL) // not found |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1182 | return old_nr; |
| 1183 | |
| 1184 | mfp->mf_neg_count--; |
| 1185 | new_bnum = np->nt_new_bnum; |
Bram Moolenaar | b05b10a | 2011-03-22 18:10:45 +0100 | [diff] [blame] | 1186 | |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 1187 | // remove entry from the trans list |
Bram Moolenaar | b05b10a | 2011-03-22 18:10:45 +0100 | [diff] [blame] | 1188 | mf_hash_rem_item(&mfp->mf_trans, (mf_hashitem_T *)np); |
| 1189 | |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1190 | vim_free(np); |
| 1191 | |
| 1192 | return new_bnum; |
| 1193 | } |
| 1194 | |
| 1195 | /* |
| 1196 | * Set mfp->mf_ffname according to mfp->mf_fname and some other things. |
| 1197 | * Only called when creating or renaming the swapfile. Either way it's a new |
| 1198 | * name so we must work out the full path name. |
| 1199 | */ |
| 1200 | void |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 1201 | mf_set_ffname(memfile_T *mfp) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1202 | { |
| 1203 | mfp->mf_ffname = FullName_save(mfp->mf_fname, FALSE); |
| 1204 | } |
| 1205 | |
| 1206 | /* |
| 1207 | * Make the name of the file used for the memfile a full path. |
| 1208 | * Used before doing a :cd |
| 1209 | */ |
| 1210 | void |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 1211 | mf_fullname(memfile_T *mfp) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1212 | { |
Yegappan Lakshmanan | e857598 | 2023-01-14 12:32:28 +0000 | [diff] [blame] | 1213 | if (mfp == NULL || mfp->mf_fname == NULL || mfp->mf_ffname == NULL) |
| 1214 | return; |
| 1215 | |
| 1216 | vim_free(mfp->mf_fname); |
| 1217 | mfp->mf_fname = mfp->mf_ffname; |
| 1218 | mfp->mf_ffname = NULL; |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1219 | } |
| 1220 | |
| 1221 | /* |
| 1222 | * return TRUE if there are any translations pending for 'mfp' |
| 1223 | */ |
| 1224 | int |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 1225 | mf_need_trans(memfile_T *mfp) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1226 | { |
| 1227 | return (mfp->mf_fname != NULL && mfp->mf_neg_count > 0); |
| 1228 | } |
| 1229 | |
| 1230 | /* |
| 1231 | * Open a swap file for a memfile. |
| 1232 | * The "fname" must be in allocated memory, and is consumed (also when an |
| 1233 | * error occurs). |
| 1234 | */ |
| 1235 | static void |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 1236 | mf_do_open( |
| 1237 | memfile_T *mfp, |
| 1238 | char_u *fname, |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 1239 | int flags) // flags for open() |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1240 | { |
| 1241 | #ifdef HAVE_LSTAT |
Bram Moolenaar | 8767f52 | 2016-07-01 17:17:39 +0200 | [diff] [blame] | 1242 | stat_T sb; |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1243 | #endif |
| 1244 | |
| 1245 | mfp->mf_fname = fname; |
| 1246 | |
| 1247 | /* |
| 1248 | * Get the full path name before the open, because this is |
| 1249 | * not possible after the open on the Amiga. |
| 1250 | * fname cannot be NameBuff, because it must have been allocated. |
| 1251 | */ |
| 1252 | mf_set_ffname(mfp); |
Bram Moolenaar | 48e330a | 2016-02-23 14:53:34 +0100 | [diff] [blame] | 1253 | #if defined(MSWIN) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1254 | /* |
Bram Moolenaar | 84a05ac | 2013-05-06 04:24:17 +0200 | [diff] [blame] | 1255 | * A ":!cd e:xxx" may change the directory without us knowing, use the |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1256 | * full pathname always. Careful: This frees fname! |
| 1257 | */ |
| 1258 | mf_fullname(mfp); |
| 1259 | #endif |
| 1260 | |
| 1261 | #ifdef HAVE_LSTAT |
| 1262 | /* |
| 1263 | * Extra security check: When creating a swap file it really shouldn't |
| 1264 | * exist yet. If there is a symbolic link, this is most likely an attack. |
| 1265 | */ |
| 1266 | if ((flags & O_CREAT) && mch_lstat((char *)mfp->mf_fname, &sb) >= 0) |
| 1267 | { |
| 1268 | mfp->mf_fd = -1; |
Bram Moolenaar | eaaac01 | 2022-01-02 17:00:40 +0000 | [diff] [blame] | 1269 | emsg(_(e_swap_file_already_exists_symlink_attack)); |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1270 | } |
| 1271 | else |
| 1272 | #endif |
| 1273 | { |
| 1274 | /* |
| 1275 | * try to open the file |
| 1276 | */ |
Bram Moolenaar | a5792f5 | 2005-11-23 21:25:05 +0000 | [diff] [blame] | 1277 | flags |= O_EXTRA | O_NOFOLLOW; |
Bram Moolenaar | 4f97475 | 2019-02-17 17:44:42 +0100 | [diff] [blame] | 1278 | #ifdef MSWIN |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 1279 | // Prevent handle inheritance that cause problems with Cscope |
| 1280 | // (swap file may not be deleted if cscope connection was open after |
| 1281 | // the file) |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1282 | flags |= O_NOINHERIT; |
| 1283 | #endif |
Bram Moolenaar | b58a4b9 | 2019-05-27 23:36:21 +0200 | [diff] [blame] | 1284 | mfp->mf_flags = flags; |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1285 | mfp->mf_fd = mch_open_rw((char *)mfp->mf_fname, flags); |
| 1286 | } |
| 1287 | |
| 1288 | /* |
| 1289 | * If the file cannot be opened, use memory only |
| 1290 | */ |
| 1291 | if (mfp->mf_fd < 0) |
| 1292 | { |
Bram Moolenaar | d23a823 | 2018-02-10 18:45:26 +0100 | [diff] [blame] | 1293 | VIM_CLEAR(mfp->mf_fname); |
| 1294 | VIM_CLEAR(mfp->mf_ffname); |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1295 | } |
| 1296 | else |
Bram Moolenaar | 588ebeb | 2008-05-07 17:09:24 +0000 | [diff] [blame] | 1297 | { |
Bram Moolenaar | f05da21 | 2009-11-17 16:13:15 +0000 | [diff] [blame] | 1298 | #ifdef HAVE_FD_CLOEXEC |
| 1299 | int fdflags = fcntl(mfp->mf_fd, F_GETFD); |
| 1300 | if (fdflags >= 0 && (fdflags & FD_CLOEXEC) == 0) |
Bram Moolenaar | fbc4b4d | 2016-02-07 15:14:01 +0100 | [diff] [blame] | 1301 | (void)fcntl(mfp->mf_fd, F_SETFD, fdflags | FD_CLOEXEC); |
Bram Moolenaar | f05da21 | 2009-11-17 16:13:15 +0000 | [diff] [blame] | 1302 | #endif |
Bram Moolenaar | 5bd32f4 | 2014-04-02 14:05:38 +0200 | [diff] [blame] | 1303 | #if defined(HAVE_SELINUX) || defined(HAVE_SMACK) |
Bram Moolenaar | 588ebeb | 2008-05-07 17:09:24 +0000 | [diff] [blame] | 1304 | mch_copy_sec(fname, mfp->mf_fname); |
| 1305 | #endif |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 1306 | mch_hide(mfp->mf_fname); // try setting the 'hidden' flag |
Bram Moolenaar | 588ebeb | 2008-05-07 17:09:24 +0000 | [diff] [blame] | 1307 | } |
Bram Moolenaar | 071d427 | 2004-06-13 20:20:40 +0000 | [diff] [blame] | 1308 | } |
Bram Moolenaar | b05b10a | 2011-03-22 18:10:45 +0100 | [diff] [blame] | 1309 | |
| 1310 | /* |
| 1311 | * Implementation of mf_hashtab_T follows. |
| 1312 | */ |
| 1313 | |
| 1314 | /* |
| 1315 | * The number of buckets in the hashtable is increased by a factor of |
| 1316 | * MHT_GROWTH_FACTOR when the average number of items per bucket |
| 1317 | * exceeds 2 ^ MHT_LOG_LOAD_FACTOR. |
| 1318 | */ |
| 1319 | #define MHT_LOG_LOAD_FACTOR 6 |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 1320 | #define MHT_GROWTH_FACTOR 2 // must be a power of two |
Bram Moolenaar | b05b10a | 2011-03-22 18:10:45 +0100 | [diff] [blame] | 1321 | |
| 1322 | /* |
| 1323 | * Initialize an empty hash table. |
| 1324 | */ |
| 1325 | static void |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 1326 | mf_hash_init(mf_hashtab_T *mht) |
Bram Moolenaar | b05b10a | 2011-03-22 18:10:45 +0100 | [diff] [blame] | 1327 | { |
Bram Moolenaar | a80faa8 | 2020-04-12 19:37:17 +0200 | [diff] [blame] | 1328 | CLEAR_POINTER(mht); |
Bram Moolenaar | b05b10a | 2011-03-22 18:10:45 +0100 | [diff] [blame] | 1329 | mht->mht_buckets = mht->mht_small_buckets; |
| 1330 | mht->mht_mask = MHT_INIT_SIZE - 1; |
| 1331 | } |
| 1332 | |
| 1333 | /* |
| 1334 | * Free the array of a hash table. Does not free the items it contains! |
| 1335 | * The hash table must not be used again without another mf_hash_init() call. |
| 1336 | */ |
| 1337 | static void |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 1338 | mf_hash_free(mf_hashtab_T *mht) |
Bram Moolenaar | b05b10a | 2011-03-22 18:10:45 +0100 | [diff] [blame] | 1339 | { |
| 1340 | if (mht->mht_buckets != mht->mht_small_buckets) |
| 1341 | vim_free(mht->mht_buckets); |
| 1342 | } |
| 1343 | |
| 1344 | /* |
| 1345 | * Free the array of a hash table and all the items it contains. |
| 1346 | */ |
| 1347 | static void |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 1348 | mf_hash_free_all(mf_hashtab_T *mht) |
Bram Moolenaar | b05b10a | 2011-03-22 18:10:45 +0100 | [diff] [blame] | 1349 | { |
| 1350 | long_u idx; |
| 1351 | mf_hashitem_T *mhi; |
| 1352 | mf_hashitem_T *next; |
| 1353 | |
| 1354 | for (idx = 0; idx <= mht->mht_mask; idx++) |
| 1355 | for (mhi = mht->mht_buckets[idx]; mhi != NULL; mhi = next) |
| 1356 | { |
| 1357 | next = mhi->mhi_next; |
| 1358 | vim_free(mhi); |
| 1359 | } |
| 1360 | |
| 1361 | mf_hash_free(mht); |
| 1362 | } |
| 1363 | |
| 1364 | /* |
| 1365 | * Find "key" in hashtable "mht". |
| 1366 | * Returns a pointer to a mf_hashitem_T or NULL if the item was not found. |
| 1367 | */ |
| 1368 | static mf_hashitem_T * |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 1369 | mf_hash_find(mf_hashtab_T *mht, blocknr_T key) |
Bram Moolenaar | b05b10a | 2011-03-22 18:10:45 +0100 | [diff] [blame] | 1370 | { |
| 1371 | mf_hashitem_T *mhi; |
| 1372 | |
| 1373 | mhi = mht->mht_buckets[key & mht->mht_mask]; |
| 1374 | while (mhi != NULL && mhi->mhi_key != key) |
| 1375 | mhi = mhi->mhi_next; |
| 1376 | |
| 1377 | return mhi; |
| 1378 | } |
| 1379 | |
| 1380 | /* |
| 1381 | * Add item "mhi" to hashtable "mht". |
| 1382 | * "mhi" must not be NULL. |
| 1383 | */ |
| 1384 | static void |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 1385 | mf_hash_add_item(mf_hashtab_T *mht, mf_hashitem_T *mhi) |
Bram Moolenaar | b05b10a | 2011-03-22 18:10:45 +0100 | [diff] [blame] | 1386 | { |
| 1387 | long_u idx; |
| 1388 | |
| 1389 | idx = mhi->mhi_key & mht->mht_mask; |
| 1390 | mhi->mhi_next = mht->mht_buckets[idx]; |
| 1391 | mhi->mhi_prev = NULL; |
| 1392 | if (mhi->mhi_next != NULL) |
| 1393 | mhi->mhi_next->mhi_prev = mhi; |
| 1394 | mht->mht_buckets[idx] = mhi; |
| 1395 | |
| 1396 | mht->mht_count++; |
| 1397 | |
| 1398 | /* |
| 1399 | * Grow hashtable when we have more thank 2^MHT_LOG_LOAD_FACTOR |
| 1400 | * items per bucket on average |
| 1401 | */ |
| 1402 | if (mht->mht_fixed == 0 |
| 1403 | && (mht->mht_count >> MHT_LOG_LOAD_FACTOR) > mht->mht_mask) |
| 1404 | { |
| 1405 | if (mf_hash_grow(mht) == FAIL) |
| 1406 | { |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 1407 | // stop trying to grow after first failure to allocate memory |
Bram Moolenaar | b05b10a | 2011-03-22 18:10:45 +0100 | [diff] [blame] | 1408 | mht->mht_fixed = 1; |
| 1409 | } |
| 1410 | } |
| 1411 | } |
| 1412 | |
| 1413 | /* |
| 1414 | * Remove item "mhi" from hashtable "mht". |
| 1415 | * "mhi" must not be NULL and must have been inserted into "mht". |
| 1416 | */ |
| 1417 | static void |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 1418 | mf_hash_rem_item(mf_hashtab_T *mht, mf_hashitem_T *mhi) |
Bram Moolenaar | b05b10a | 2011-03-22 18:10:45 +0100 | [diff] [blame] | 1419 | { |
| 1420 | if (mhi->mhi_prev == NULL) |
| 1421 | mht->mht_buckets[mhi->mhi_key & mht->mht_mask] = mhi->mhi_next; |
| 1422 | else |
| 1423 | mhi->mhi_prev->mhi_next = mhi->mhi_next; |
| 1424 | |
| 1425 | if (mhi->mhi_next != NULL) |
| 1426 | mhi->mhi_next->mhi_prev = mhi->mhi_prev; |
| 1427 | |
| 1428 | mht->mht_count--; |
| 1429 | |
Bram Moolenaar | 4ba37b5 | 2019-12-04 21:57:43 +0100 | [diff] [blame] | 1430 | // We could shrink the table here, but it typically takes little memory, |
| 1431 | // so why bother? |
Bram Moolenaar | b05b10a | 2011-03-22 18:10:45 +0100 | [diff] [blame] | 1432 | } |
| 1433 | |
| 1434 | /* |
| 1435 | * Increase number of buckets in the hashtable by MHT_GROWTH_FACTOR and |
| 1436 | * rehash items. |
| 1437 | * Returns FAIL when out of memory. |
| 1438 | */ |
| 1439 | static int |
Bram Moolenaar | 52ea13d | 2016-01-30 18:51:09 +0100 | [diff] [blame] | 1440 | mf_hash_grow(mf_hashtab_T *mht) |
Bram Moolenaar | b05b10a | 2011-03-22 18:10:45 +0100 | [diff] [blame] | 1441 | { |
| 1442 | long_u i, j; |
| 1443 | int shift; |
| 1444 | mf_hashitem_T *mhi; |
| 1445 | mf_hashitem_T *tails[MHT_GROWTH_FACTOR]; |
| 1446 | mf_hashitem_T **buckets; |
| 1447 | size_t size; |
| 1448 | |
| 1449 | size = (mht->mht_mask + 1) * MHT_GROWTH_FACTOR * sizeof(void *); |
Bram Moolenaar | c799fe2 | 2019-05-28 23:08:19 +0200 | [diff] [blame] | 1450 | buckets = lalloc_clear(size, FALSE); |
Bram Moolenaar | b05b10a | 2011-03-22 18:10:45 +0100 | [diff] [blame] | 1451 | if (buckets == NULL) |
| 1452 | return FAIL; |
| 1453 | |
| 1454 | shift = 0; |
| 1455 | while ((mht->mht_mask >> shift) != 0) |
| 1456 | shift++; |
| 1457 | |
| 1458 | for (i = 0; i <= mht->mht_mask; i++) |
| 1459 | { |
| 1460 | /* |
| 1461 | * Traverse the items in the i-th original bucket and move them into |
| 1462 | * MHT_GROWTH_FACTOR new buckets, preserving their relative order |
| 1463 | * within each new bucket. Preserving the order is important because |
| 1464 | * mf_get() tries to keep most recently used items at the front of |
| 1465 | * each bucket. |
| 1466 | * |
| 1467 | * Here we strongly rely on the fact the hashes are computed modulo |
| 1468 | * a power of two. |
| 1469 | */ |
| 1470 | |
Bram Moolenaar | a80faa8 | 2020-04-12 19:37:17 +0200 | [diff] [blame] | 1471 | CLEAR_FIELD(tails); |
Bram Moolenaar | b05b10a | 2011-03-22 18:10:45 +0100 | [diff] [blame] | 1472 | |
| 1473 | for (mhi = mht->mht_buckets[i]; mhi != NULL; mhi = mhi->mhi_next) |
| 1474 | { |
| 1475 | j = (mhi->mhi_key >> shift) & (MHT_GROWTH_FACTOR - 1); |
| 1476 | if (tails[j] == NULL) |
| 1477 | { |
| 1478 | buckets[i + (j << shift)] = mhi; |
| 1479 | tails[j] = mhi; |
| 1480 | mhi->mhi_prev = NULL; |
| 1481 | } |
| 1482 | else |
| 1483 | { |
| 1484 | tails[j]->mhi_next = mhi; |
| 1485 | mhi->mhi_prev = tails[j]; |
| 1486 | tails[j] = mhi; |
| 1487 | } |
| 1488 | } |
| 1489 | |
| 1490 | for (j = 0; j < MHT_GROWTH_FACTOR; j++) |
| 1491 | if (tails[j] != NULL) |
| 1492 | tails[j]->mhi_next = NULL; |
| 1493 | } |
| 1494 | |
| 1495 | if (mht->mht_buckets != mht->mht_small_buckets) |
| 1496 | vim_free(mht->mht_buckets); |
| 1497 | |
| 1498 | mht->mht_buckets = buckets; |
| 1499 | mht->mht_mask = (mht->mht_mask + 1) * MHT_GROWTH_FACTOR - 1; |
| 1500 | |
| 1501 | return OK; |
| 1502 | } |