]> granicus.if.org Git - esp-idf/blob - components/spi_flash/flash_mmap.c
console/linenoise: support buffered stdout
[esp-idf] / components / spi_flash / flash_mmap.c
1 // Copyright 2015-2016 Espressif Systems (Shanghai) PTE LTD
2 //
3 // Licensed under the Apache License, Version 2.0 (the "License");
4 // you may not use this file except in compliance with the License.
5 // You may obtain a copy of the License at
6 //
7 //     http://www.apache.org/licenses/LICENSE-2.0
8 //
9 // Unless required by applicable law or agreed to in writing, software
10 // distributed under the License is distributed on an "AS IS" BASIS,
11 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 // See the License for the specific language governing permissions and
13 // limitations under the License.
14
15 #include <stdlib.h>
16 #include <assert.h>
17 #include <string.h>
18 #include <stdio.h>
19
20 #include <freertos/FreeRTOS.h>
21 #include <freertos/task.h>
22 #include <freertos/semphr.h>
23 #include <rom/spi_flash.h>
24 #include <rom/cache.h>
25 #include <soc/soc.h>
26 #include <soc/dport_reg.h>
27 #include "sdkconfig.h"
28 #include "esp_ipc.h"
29 #include "esp_attr.h"
30 #include "esp_spi_flash.h"
31 #include "esp_flash_encrypt.h"
32 #include "esp_log.h"
33 #include "cache_utils.h"
34 #include "esp_spiram.h"
35
36 #ifndef NDEBUG
37 // Enable built-in checks in queue.h in debug builds
38 #define INVARIANTS
39 #endif
40 #include "rom/queue.h"
41
42 #define REGIONS_COUNT 4
43 #define PAGES_PER_REGION 64
44 #define INVALID_ENTRY_VAL 0x100
45 #define VADDR0_START_ADDR 0x3F400000
46 #define VADDR1_START_ADDR 0x40000000
47 #define VADDR1_FIRST_USABLE_ADDR 0x400D0000
48 #define PRO_IRAM0_FIRST_USABLE_PAGE ((VADDR1_FIRST_USABLE_ADDR - VADDR1_START_ADDR) / SPI_FLASH_MMU_PAGE_SIZE + 64)
49
50 /* Ensure pages in a region haven't been marked as written via
51    spi_flash_mark_modified_region(). If the page has
52    been written, flush the entire flash cache before returning.
53
54    This ensures stale cache entries are never read after fresh calls
55    to spi_flash_mmap(), while keeping the number of cache flushes to a
56    minimum.
57
58    Returns true if cache was flushed.
59 */
60
61 static bool spi_flash_ensure_unmodified_region(size_t start_addr, size_t length);
62
63 typedef struct mmap_entry_{
64     uint32_t handle;
65     int page;
66     int count;
67     LIST_ENTRY(mmap_entry_) entries;
68 } mmap_entry_t;
69
70
71 static LIST_HEAD(mmap_entries_head, mmap_entry_) s_mmap_entries_head =
72         LIST_HEAD_INITIALIZER(s_mmap_entries_head);
73 static uint8_t s_mmap_page_refcnt[REGIONS_COUNT * PAGES_PER_REGION] = {0};
74 static uint32_t s_mmap_last_handle = 0;
75
76
77 static void IRAM_ATTR spi_flash_mmap_init()
78 {
79     if (s_mmap_page_refcnt[0] != 0) {
80         return; /* mmap data already initialised */
81     }
82     DPORT_INTERRUPT_DISABLE();
83     for (int i = 0; i < REGIONS_COUNT * PAGES_PER_REGION; ++i) {
84         uint32_t entry_pro = DPORT_SEQUENCE_REG_READ((uint32_t)&DPORT_PRO_FLASH_MMU_TABLE[i]);
85         uint32_t entry_app = DPORT_SEQUENCE_REG_READ((uint32_t)&DPORT_APP_FLASH_MMU_TABLE[i]);
86
87         if (entry_pro != entry_app) {
88             // clean up entries used by boot loader
89             entry_pro = DPORT_FLASH_MMU_TABLE_INVALID_VAL;
90             DPORT_PRO_FLASH_MMU_TABLE[i] = DPORT_FLASH_MMU_TABLE_INVALID_VAL;
91         }
92         if ((entry_pro & INVALID_ENTRY_VAL) == 0 && (i == 0 || i == PRO_IRAM0_FIRST_USABLE_PAGE || entry_pro != 0)) {
93             s_mmap_page_refcnt[i] = 1;
94         } else {
95             DPORT_PRO_FLASH_MMU_TABLE[i] = DPORT_FLASH_MMU_TABLE_INVALID_VAL;
96             DPORT_APP_FLASH_MMU_TABLE[i] = DPORT_FLASH_MMU_TABLE_INVALID_VAL;
97         }
98     }
99     DPORT_INTERRUPT_RESTORE();
100 }
101
102 static void IRAM_ATTR get_mmu_region(spi_flash_mmap_memory_t memory, int* out_begin, int* out_size,uint32_t* region_addr)
103 {
104     if (memory == SPI_FLASH_MMAP_DATA) {
105         // Vaddr0
106         *out_begin = 0;
107         *out_size = 64;
108         *region_addr = VADDR0_START_ADDR;
109     } else {
110         // only part of VAddr1 is usable, so adjust for that
111         *out_begin = PRO_IRAM0_FIRST_USABLE_PAGE;
112         *out_size = 3 * 64 - *out_begin;
113         *region_addr = VADDR1_FIRST_USABLE_ADDR;
114     }
115 }
116
117 esp_err_t IRAM_ATTR spi_flash_mmap(size_t src_addr, size_t size, spi_flash_mmap_memory_t memory,
118                          const void** out_ptr, spi_flash_mmap_handle_t* out_handle)
119 {
120     esp_err_t ret;
121     if (src_addr & 0xffff) {
122         return ESP_ERR_INVALID_ARG;
123     }
124     if (src_addr + size > g_rom_flashchip.chip_size) {
125         return ESP_ERR_INVALID_ARG;
126     }
127     // region which should be mapped
128     int phys_page = src_addr / SPI_FLASH_MMU_PAGE_SIZE;
129     int page_count = (size + SPI_FLASH_MMU_PAGE_SIZE - 1) / SPI_FLASH_MMU_PAGE_SIZE;
130     // prepare a linear pages array to feed into spi_flash_mmap_pages
131     int *pages = heap_caps_malloc(sizeof(int)*page_count, MALLOC_CAP_INTERNAL);
132     if (pages == NULL) {
133         return ESP_ERR_NO_MEM;
134     }
135     for (int i = 0; i < page_count; i++) {
136         pages[i] = phys_page+i;
137     }
138     ret = spi_flash_mmap_pages(pages, page_count, memory, out_ptr, out_handle);
139     free(pages);
140     return ret;
141 }
142
143 esp_err_t IRAM_ATTR spi_flash_mmap_pages(const int *pages, size_t page_count, spi_flash_mmap_memory_t memory,
144                          const void** out_ptr, spi_flash_mmap_handle_t* out_handle)
145 {
146     esp_err_t ret;
147     bool did_flush, need_flush = false;
148     if (!page_count) {
149         return ESP_ERR_INVALID_ARG;
150     }
151     if (!esp_ptr_internal(pages)) {
152         return ESP_ERR_INVALID_ARG;
153     }
154     for (int i = 0; i < page_count; i++) {
155         if (pages[i] < 0 || pages[i]*SPI_FLASH_MMU_PAGE_SIZE >= g_rom_flashchip.chip_size) {
156             return ESP_ERR_INVALID_ARG;
157         }
158     }
159     mmap_entry_t* new_entry = (mmap_entry_t*) heap_caps_malloc(sizeof(mmap_entry_t), MALLOC_CAP_INTERNAL|MALLOC_CAP_8BIT);
160     if (new_entry == 0) {
161         return ESP_ERR_NO_MEM;
162     }
163
164     spi_flash_disable_interrupts_caches_and_other_cpu();
165
166     did_flush = 0;
167     for (int i = 0; i < page_count; i++) {
168         if (spi_flash_ensure_unmodified_region(pages[i]*SPI_FLASH_MMU_PAGE_SIZE, SPI_FLASH_MMU_PAGE_SIZE)) {
169             did_flush = 1;
170         }
171     }
172     spi_flash_mmap_init();
173     // figure out the memory region where we should look for pages
174     int region_begin;   // first page to check
175     int region_size;    // number of pages to check
176     uint32_t region_addr;  // base address of memory region
177     get_mmu_region(memory,&region_begin,&region_size,&region_addr);
178     if (region_size < page_count) {
179         return ESP_ERR_NO_MEM;
180     }
181     // The following part searches for a range of MMU entries which can be used.
182     // Algorithm is essentially naïve strstr algorithm, except that unused MMU
183     // entries are treated as wildcards.
184     int start;
185     // the " + 1" is a fix when loop the MMU table pages, because the last MMU page 
186     // is valid as well if it have not been used
187     int end = region_begin + region_size - page_count + 1;
188     for (start = region_begin; start < end; ++start) {
189         int pageno = 0;
190         int pos;
191         DPORT_INTERRUPT_DISABLE();
192         for (pos = start; pos < start + page_count; ++pos, ++pageno) {
193             int table_val = (int) DPORT_SEQUENCE_REG_READ((uint32_t)&DPORT_PRO_FLASH_MMU_TABLE[pos]);
194             uint8_t refcnt = s_mmap_page_refcnt[pos]; 
195             if (refcnt != 0 && table_val != pages[pageno]) {
196                 break;
197             }
198         }
199         DPORT_INTERRUPT_RESTORE();
200         // whole mapping range matched, bail out
201         if (pos - start == page_count) {
202             break;
203         }
204     }
205     // checked all the region(s) and haven't found anything?
206     if (start == end) {
207         *out_handle = 0;
208         *out_ptr = NULL;
209         ret = ESP_ERR_NO_MEM;
210     } else {
211         // set up mapping using pages
212         uint32_t pageno = 0;
213         DPORT_INTERRUPT_DISABLE();
214         for (int i = start; i != start + page_count; ++i, ++pageno) {
215             // sanity check: we won't reconfigure entries with non-zero reference count
216             uint32_t entry_pro = DPORT_SEQUENCE_REG_READ((uint32_t)&DPORT_PRO_FLASH_MMU_TABLE[i]);
217             uint32_t entry_app = DPORT_SEQUENCE_REG_READ((uint32_t)&DPORT_APP_FLASH_MMU_TABLE[i]);
218             assert(s_mmap_page_refcnt[i] == 0 ||
219                     (entry_pro == pages[pageno] &&
220                      entry_app == pages[pageno]));
221             if (s_mmap_page_refcnt[i] == 0) {
222                 if (entry_pro != pages[pageno] || entry_app != pages[pageno]) {
223                     DPORT_PRO_FLASH_MMU_TABLE[i] = pages[pageno];
224                     DPORT_APP_FLASH_MMU_TABLE[i] = pages[pageno];
225                     need_flush = true;
226                 }
227             }
228             ++s_mmap_page_refcnt[i];
229         }
230         DPORT_INTERRUPT_RESTORE();
231         LIST_INSERT_HEAD(&s_mmap_entries_head, new_entry, entries);
232         new_entry->page = start;
233         new_entry->count = page_count;
234         new_entry->handle = ++s_mmap_last_handle;
235         *out_handle = new_entry->handle;
236         *out_ptr = (void*) (region_addr + (start - region_begin) * SPI_FLASH_MMU_PAGE_SIZE);
237         ret = ESP_OK;
238     }
239
240     /* This is a temporary fix for an issue where some
241        cache reads may see stale data.
242
243        Working on a long term fix that doesn't require invalidating
244        entire cache.
245     */
246     if (!did_flush && need_flush) {
247 #if CONFIG_SPIRAM_SUPPORT
248         esp_spiram_writeback_cache();
249 #endif
250         Cache_Flush(0);
251         Cache_Flush(1);
252     }
253
254     spi_flash_enable_interrupts_caches_and_other_cpu();
255     if (*out_ptr == NULL) {
256         free(new_entry);
257     }
258     return ret;
259 }
260
261 void IRAM_ATTR spi_flash_munmap(spi_flash_mmap_handle_t handle)
262 {
263     spi_flash_disable_interrupts_caches_and_other_cpu();
264     mmap_entry_t* it;
265     // look for handle in linked list
266     for (it = LIST_FIRST(&s_mmap_entries_head); it != NULL; it = LIST_NEXT(it, entries)) {
267         if (it->handle == handle) {
268             // for each page, decrement reference counter
269             // if reference count is zero, disable MMU table entry to
270             // facilitate debugging of use-after-free conditions
271             for (int i = it->page; i < it->page + it->count; ++i) {
272                 assert(s_mmap_page_refcnt[i] > 0);
273                 if (--s_mmap_page_refcnt[i] == 0) {
274                     DPORT_PRO_FLASH_MMU_TABLE[i] = INVALID_ENTRY_VAL;
275                     DPORT_APP_FLASH_MMU_TABLE[i] = INVALID_ENTRY_VAL;
276                 }
277             }
278             LIST_REMOVE(it, entries);
279             break;
280         }
281     }
282     spi_flash_enable_interrupts_caches_and_other_cpu();
283     if (it == NULL) {
284         assert(0 && "invalid handle, or handle already unmapped");
285     }
286     free(it);
287 }
288
289 static void IRAM_ATTR NOINLINE_ATTR spi_flash_protected_mmap_init()
290 {
291     spi_flash_disable_interrupts_caches_and_other_cpu();
292     spi_flash_mmap_init();
293     spi_flash_enable_interrupts_caches_and_other_cpu();
294 }
295
296 static uint32_t IRAM_ATTR NOINLINE_ATTR spi_flash_protected_read_mmu_entry(int index)
297 {
298     uint32_t value;
299     spi_flash_disable_interrupts_caches_and_other_cpu();
300     value = DPORT_REG_READ((uint32_t)&DPORT_PRO_FLASH_MMU_TABLE[index]);
301     spi_flash_enable_interrupts_caches_and_other_cpu();
302     return value;
303 }
304
305 void spi_flash_mmap_dump()
306 {
307     spi_flash_protected_mmap_init();
308
309     mmap_entry_t* it;
310     for (it = LIST_FIRST(&s_mmap_entries_head); it != NULL; it = LIST_NEXT(it, entries)) {
311         printf("handle=%d page=%d count=%d\n", it->handle, it->page, it->count);
312     }
313     for (int i = 0; i < REGIONS_COUNT * PAGES_PER_REGION; ++i) {
314         if (s_mmap_page_refcnt[i] != 0) {
315             uint32_t paddr = spi_flash_protected_read_mmu_entry(i);
316             printf("page %d: refcnt=%d paddr=%d\n", i, (int) s_mmap_page_refcnt[i], paddr);
317         }
318     }
319 }
320
321 uint32_t IRAM_ATTR spi_flash_mmap_get_free_pages(spi_flash_mmap_memory_t memory)
322 {
323     spi_flash_disable_interrupts_caches_and_other_cpu();
324     spi_flash_mmap_init();
325     int count = 0;
326     int region_begin;   // first page to check
327     int region_size;    // number of pages to check
328     uint32_t region_addr;  // base address of memory region
329     get_mmu_region(memory,&region_begin,&region_size,&region_addr);
330     DPORT_INTERRUPT_DISABLE();
331     for (int i = region_begin; i < region_begin + region_size; ++i) {
332         if (s_mmap_page_refcnt[i] == 0 && DPORT_SEQUENCE_REG_READ((uint32_t)&DPORT_PRO_FLASH_MMU_TABLE[i]) == INVALID_ENTRY_VAL) {
333             count++;
334         }
335     }
336     DPORT_INTERRUPT_RESTORE();
337     spi_flash_enable_interrupts_caches_and_other_cpu();
338     return count;
339 }
340
341 /* 256-bit (up to 16MB of 64KB pages) bitset of all flash pages
342    that have been written to since last cache flush.
343
344    Before mmaping a page, need to flush caches if that page has been
345    written to.
346
347    Note: It's possible to do some additional performance tweaks to
348    this algorithm, as we actually only need to flush caches if a page
349    was first mmapped, then written to, then is about to be mmaped a
350    second time. This is a fair bit more complex though, so unless
351    there's an access pattern that this would significantly boost then
352    it's probably not worth it.
353 */
354 static uint32_t written_pages[256/32];
355
356 static bool update_written_pages(size_t start_addr, size_t length, bool mark);
357
358 void IRAM_ATTR spi_flash_mark_modified_region(size_t start_addr, size_t length)
359 {
360     update_written_pages(start_addr, length, true);
361 }
362
363 static IRAM_ATTR bool spi_flash_ensure_unmodified_region(size_t start_addr, size_t length)
364 {
365     return update_written_pages(start_addr, length, false);
366 }
367
368 /* generic implementation for the previous two functions */
369 static inline IRAM_ATTR bool update_written_pages(size_t start_addr, size_t length, bool mark)
370 {
371     /* align start_addr & length to full MMU pages */
372     uint32_t page_start_addr = start_addr & ~(SPI_FLASH_MMU_PAGE_SIZE-1);
373     length += (start_addr - page_start_addr);
374     length = (length + SPI_FLASH_MMU_PAGE_SIZE - 1) & ~(SPI_FLASH_MMU_PAGE_SIZE-1);
375     for (uint32_t addr = page_start_addr; addr < page_start_addr + length; addr += SPI_FLASH_MMU_PAGE_SIZE) {
376         int page = addr / SPI_FLASH_MMU_PAGE_SIZE;
377         if (page >= 256) {
378             return false; /* invalid address */
379         }
380
381         int idx = page / 32;
382         uint32_t bit = 1 << (page % 32);
383
384         if (mark) {
385             written_pages[idx] |= bit;
386         } else if (written_pages[idx] & bit) {
387             /* it is tempting to write a version of this that only
388                flushes each CPU's cache as needed. However this is
389                tricky because mmaped memory can be used on un-pinned
390                cores, or the pointer passed between CPUs.
391             */
392 #if CONFIG_SPIRAM_SUPPORT
393             esp_spiram_writeback_cache();
394 #endif
395             Cache_Flush(0);
396 #ifndef CONFIG_FREERTOS_UNICORE
397             Cache_Flush(1);
398 #endif
399             bzero(written_pages, sizeof(written_pages));
400             return true;
401         }
402     }
403     return false;
404 }
405
406 uint32_t spi_flash_cache2phys(const void *cached)
407 {
408     intptr_t c = (intptr_t)cached;
409     size_t cache_page;
410     if (c >= VADDR1_START_ADDR && c < VADDR1_FIRST_USABLE_ADDR) {
411         /* IRAM address, doesn't map to flash */
412         return SPI_FLASH_CACHE2PHYS_FAIL;
413     }
414     else if (c < VADDR1_FIRST_USABLE_ADDR) {
415         /* expect cache is in DROM */
416         cache_page = (c - VADDR0_START_ADDR) / SPI_FLASH_MMU_PAGE_SIZE;
417     } else {
418         /* expect cache is in IROM */
419         cache_page = (c - VADDR1_START_ADDR) / SPI_FLASH_MMU_PAGE_SIZE + 64;
420     }
421
422     if (cache_page >= 256) {
423         /* cached address was not in IROM or DROM */
424         return SPI_FLASH_CACHE2PHYS_FAIL;
425     }
426     uint32_t phys_page = spi_flash_protected_read_mmu_entry(cache_page);
427     if (phys_page == INVALID_ENTRY_VAL) {
428         /* page is not mapped */
429         return SPI_FLASH_CACHE2PHYS_FAIL;
430     }
431     uint32_t phys_offs = phys_page * SPI_FLASH_MMU_PAGE_SIZE;
432     return phys_offs | (c & (SPI_FLASH_MMU_PAGE_SIZE-1));
433 }
434
435 const void *IRAM_ATTR spi_flash_phys2cache(uint32_t phys_offs, spi_flash_mmap_memory_t memory)
436 {
437     uint32_t phys_page = phys_offs / SPI_FLASH_MMU_PAGE_SIZE;
438     int start, end, page_delta;
439     intptr_t base;
440
441     if (memory == SPI_FLASH_MMAP_DATA) {
442         start = 0;
443         end = 64;
444         base = VADDR0_START_ADDR;
445         page_delta = 0;
446     } else {
447         start = PRO_IRAM0_FIRST_USABLE_PAGE;
448         end = 256;
449         base = VADDR1_START_ADDR;
450         page_delta = 64;
451     }
452     spi_flash_disable_interrupts_caches_and_other_cpu();
453     DPORT_INTERRUPT_DISABLE();
454     for (int i = start; i < end; i++) {
455         if (DPORT_SEQUENCE_REG_READ((uint32_t)&DPORT_PRO_FLASH_MMU_TABLE[i]) == phys_page) {
456             i -= page_delta;
457             intptr_t cache_page =  base + (SPI_FLASH_MMU_PAGE_SIZE * i);
458             DPORT_INTERRUPT_RESTORE();
459             spi_flash_enable_interrupts_caches_and_other_cpu();
460             return (const void *) (cache_page | (phys_offs & (SPI_FLASH_MMU_PAGE_SIZE-1)));
461         }
462     }
463     DPORT_INTERRUPT_RESTORE();
464     spi_flash_enable_interrupts_caches_and_other_cpu();
465     return NULL;
466 }