/**************************************************************************** * fs/nxffs/nxffs_pack.c * * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. The * ASF licenses this file to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance with the * License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the * License for the specific language governing permissions and limitations * under the License. * ****************************************************************************/ /**************************************************************************** * Included Files ****************************************************************************/ #include #include #include #include #include #include #include #include #include "nxffs.h" /**************************************************************************** * Private Types ****************************************************************************/ /* This structure supports access to one inode data stream */ struct nxffs_packstream_s { struct nxffs_entry_s entry; /* Describes the inode header */ off_t fpos; /* Current file position */ off_t blkoffset; /* Offset to the current data block */ uint16_t blklen; /* Size of this block */ uint16_t blkpos; /* Position in block corresponding to fpos */ }; /* The structure supports the overall packing operation */ struct nxffs_pack_s { /* These describe the source and destination streams */ struct nxffs_packstream_s src; struct nxffs_packstream_s dest; /* These describe the state of the current contents of the (destination) * volume->pack buffer. */ FAR uint8_t *iobuffer; /* I/O block start position */ off_t ioblock; /* I/O block number */ off_t block0; /* First I/O block number in the erase block */ uint16_t iooffset; /* I/O block offset */ }; /**************************************************************************** * Private Functions ****************************************************************************/ /**************************************************************************** * Name: nxffs_getblock * * Description: * Return the I/O block number that includes the provided offset. * * Input Parameters: * volume - Describes the NXFFS volume * offset - FLASH offset * * Returned Value: * The I/O block number. * ****************************************************************************/ static off_t nxffs_getblock(FAR struct nxffs_volume_s *volume, off_t offset) { return offset / volume->geo.blocksize; } /**************************************************************************** * Name: nxffs_getoffset * * Description: * Given an I/O block number return the block offset corresponding to the * FLASH offset; * * Input Parameters: * volume - Describes the NXFFS volume * offset - FLASH offset * * Returned Value: * The I/O block number. * ****************************************************************************/ static off_t nxffs_getoffset(FAR struct nxffs_volume_s *volume, off_t offset, off_t block) { return offset - block * volume->geo.blocksize; } /**************************************************************************** * Name: nxffs_packtell * * Description: * Report the current destination position in the pack buffer. * * Input Parameters: * volume - Describes the NXFFS volume * pack - The volume packing state structure. * * Returned Value: * The offset from the beginning of FLASH to the current seek position. * ****************************************************************************/ static off_t nxffs_packtell(FAR struct nxffs_volume_s *volume, FAR struct nxffs_pack_s *pack) { return pack->ioblock * volume->geo.blocksize + pack->iooffset; } /**************************************************************************** * Name: nxffs_packvalid * * Description: * Check if the current destination block is valid. * * Input Parameters: * pack - The volume packing state structure. * * Returned Value: * None * ****************************************************************************/ static inline bool nxffs_packvalid(FAR struct nxffs_pack_s *pack) { FAR struct nxffs_block_s *blkhdr; blkhdr = (FAR struct nxffs_block_s *)pack->iobuffer; return (memcmp(blkhdr->magic, g_blockmagic, NXFFS_MAGICSIZE) == 0 && blkhdr->state == BLOCK_STATE_GOOD); } /**************************************************************************** * Name: nxffs_mediacheck * * Description: * Verify that there is at least one valid block and at least one valid * inode header on the media. On successful return, the volume packing * structure is initialized and contains the offset to the first valid * inode header is returned. * * Input Parameters: * volume - The volume to be packed. * pack - The volume packing state structure. * * Returned Value: * The offset to the data area on the first valid block. Zero is return * if there are no valid blocks or if there are no valid inode headers * after the first valid block. * ****************************************************************************/ static inline off_t nxffs_mediacheck(FAR struct nxffs_volume_s *volume, FAR struct nxffs_pack_s *pack) { off_t froffset; int ret; /* Initialize the packing structure to all zero */ memset(pack, 0, sizeof(struct nxffs_pack_s)); /* Find the FLASH offset to the first valid block */ volume->ioblock = 0; ret = nxffs_validblock(volume, &volume->ioblock); if (ret < 0) { /* No valid blocks? Return offset zero. */ return 0; } /* The offset to the free location to pack is then just after the block * header in this block. */ volume->iooffset = SIZEOF_NXFFS_BLOCK_HDR; froffset = nxffs_iotell(volume); /* Get the offset to the first valid inode entry after this free offset */ ret = nxffs_nextentry(volume, froffset, &pack->src.entry); if (ret < 0) { /* No valid entries on the media -- Return offset zero */ return 0; } /* Okay.. the start block and first entry have been found */ return froffset; } /**************************************************************************** * Name: nxffs_startpos * * Description: * Find the position in FLASH memory where we should begin packing. That * position is the place where there is a gap between the last and the next * valid inode. On entry, the volume packing structure should be as it * was initialized by nxffx_mediacheck. on successful return, the volume * packing state structure will be updated to begin the packing operation. * * Input Parameters: * volume - The volume to be packed * pack - The volume packing state structure. * froffset - On input, this is the location where we should be searching * for the location to begin packing. On successful return, froffset * will be set to the offset in FLASH where the first inode should be * copied to. If -ENOSPC is returned -- meaning that the FLASH is full * -- then no packing can be performed. In this case, then the free * flash offset is returned through this location. * * Returned Value: * Zero on success; Otherwise, a negated errno value is returned to * indicate the nature of the failure. If -ENOSPC is returned then the * free FLASH offset is also returned. * ****************************************************************************/ static inline int nxffs_startpos(FAR struct nxffs_volume_s *volume, FAR struct nxffs_pack_s *pack, off_t *froffset) { struct nxffs_blkentry_s blkentry; off_t offset = *froffset; off_t wasted; off_t nbytes; int ret; /* Loop until we find a gap of unused FLASH large enough to warrant * compacting. */ for (; ; ) { /* Is there wasted space between the offset where the we could have * valid data and the offset to the beginning of the first valid * inode header? NOTE: The threshold check is not accurate, there * may or may not be intervening block headers making the separation * seem larger than it is. */ DEBUGASSERT(pack->src.entry.hoffset >= offset); wasted = pack->src.entry.hoffset - offset; if (wasted > CONFIG_NXFFS_PACKTHRESHOLD) { /* This is where we must begin packing. Describe the destination * inode header (only non-zero entries need to be initialized). */ pack->dest.entry.name = pack->src.entry.name; pack->dest.entry.utc = pack->src.entry.utc; pack->dest.entry.datlen = pack->src.entry.datlen; /* The destination entry now "owns" the name string */ pack->src.entry.name = NULL; /* Return the FLASH offset to the destination inode header */ *froffset = offset; return OK; } /* Free the allocated memory in the entry */ nxffs_freeentry(&pack->src.entry); /* Update the offset to the first byte at the end of the last data * block. */ nbytes = 0; offset = pack->src.entry.doffset; while (nbytes < pack->src.entry.datlen) { /* Read the next data block header */ ret = nxffs_nextblock(volume, offset, &blkentry); if (ret < 0) { ferr("ERROR: Failed to find next data block: %d\n", -ret); return ret; } /* Get the number of blocks and pointer to where the next * data block might lie. */ nbytes += blkentry.datlen; offset = blkentry.hoffset + SIZEOF_NXFFS_DATA_HDR + blkentry.datlen; } /* Make sure there is space at this location for an inode header */ nxffs_ioseek(volume, offset); if (volume->iooffset + SIZEOF_NXFFS_INODE_HDR > volume->geo.blocksize) { /* No.. not enough space here. Find the next valid block */ volume->ioblock++; ret = nxffs_validblock(volume, &volume->ioblock); if (ret < 0) { /* No valid blocks? Then there is nothing we can do. Return * the end-of-flash indication. */ *froffset = volume->froffset; return -ENOSPC; } volume->iooffset = SIZEOF_NXFFS_BLOCK_HDR; offset = nxffs_iotell(volume); } /* Get the offset to the next valid inode entry */ ret = nxffs_nextentry(volume, offset, &pack->src.entry); if (ret < 0) { /* No more valid inode entries. Just return an end-of-flash error * indication. However, there could be many deleted inodes; set * volume->froffset to indicate the true free FLASH position. */ *froffset = offset; return -ENOSPC; } } /* We won't get here */ return -ENOSYS; } /**************************************************************************** * Name: nxffs_srcsetup * * Description: * Given a valid src inode, configure the src data stream. * * Input Parameters: * volume - The volume to be packed * pack - The volume packing state structure. * offset - FLASH offset to the data block header (will be zero for zero- * files. * * Returned Value: * Zero on success; Otherwise, a negated errno value is returned to * indicate the nature of the failure. * ****************************************************************************/ static int nxffs_srcsetup(FAR struct nxffs_volume_s *volume, FAR struct nxffs_pack_s *pack, off_t offset) { /* Start with the first data block */ pack->src.blkoffset = offset; pack->src.blkpos = 0; /* Zero-length files have no valid data block offset */ if (offset > 0) { /* Seek to the data block header, read and verify the block header */ int ret = nxffs_rdblkhdr(volume, offset, &pack->src.blklen); if (ret < 0) { ferr("ERROR: Failed to verify the data block header: %d\n", -ret); } return ret; } DEBUGASSERT(pack->src.entry.datlen == 0); return OK; } /**************************************************************************** * Name: nxffs_destsetup * * Description: * Given a valid dest inode, configure the dest data stream. * * Input Parameters: * volume - The volume to be packed * pack - The volume packing state structure. * * Returned Value: * Zero on success; Otherwise, a negated errno value is returned to * indicate the nature of the failure. * ****************************************************************************/ static int nxffs_destsetup(FAR struct nxffs_volume_s *volume, FAR struct nxffs_pack_s *pack) { size_t mindata; int namlen; int ret; /* The destination can be in one of three of states: * * State 1: The inode position was not yet been found. This condition can * only occur on initial entry into nxffs_packblock() when there we no * space for the inode header at the end of the previous block. We must * now be at the beginning of a shiny new I/O block, so we should always * have space for a new inode header right here. */ if (pack->dest.entry.hoffset == 0) { /* Is there room for an inode structure in this block? */ if (pack->iooffset + SIZEOF_NXFFS_INODE_HDR > volume->geo.blocksize) { /* No.. that inode name will not fit in this block. Return an * indication that we are at the end of the block and try again * later. */ return -ENOSPC; } /* The inode header will be placed at this position (but not until * we are finished. */ pack->dest.entry.hoffset = nxffs_packtell(volume, pack); /* Make sure that the initialize state of the inode header memory is * erased. This is important because we may not write to inode header * until it has already been written to FLASH. */ memset(&pack->iobuffer[pack->iooffset], CONFIG_NXFFS_ERASEDSTATE, SIZEOF_NXFFS_INODE_HDR); /* Then set the new FLASH offset */ pack->iooffset += SIZEOF_NXFFS_INODE_HDR; } /* State 2: inode position found, inode header not written, inode name * position not determined. */ if (pack->dest.entry.noffset == 0) { /* Find the offset to the string memory. Will if fit in this block? * Note: iooffset has already been incremented to account for the * size of the inode header. */ namlen = strlen(pack->dest.entry.name); if (pack->iooffset + namlen > volume->geo.blocksize) { /* No.. that inode name will not fit in this block. Return an * indication that we are at the end of the block and try again * later. */ return -ENOSPC; } /* Yes.. Write the inode name to the volume packing buffer now, but do * not free the name string memory yet; it will be needed later to\ * calculate the header CRC. */ memcpy(&pack->iobuffer[pack->iooffset], pack->dest.entry.name, namlen); /* Reserve space for the inode name */ pack->dest.entry.noffset = nxffs_packtell(volume, pack); pack->iooffset += namlen; } /* State 3: Inode header not-written, inode name written. Still need the * position of the first data block. * * Deal with the special case where the source inode is a zero length file * with no data blocks to be transferred. */ if (pack->src.entry.doffset > 0) { if (pack->dest.entry.doffset == 0) { /* Will the data block header plus a minimal amount of data fit in * this block? (or the whole file if the file is very small). */ mindata = MIN(NXFFS_MINDATA, pack->dest.entry.datlen); if (pack->iooffset + SIZEOF_NXFFS_DATA_HDR + mindata > volume->geo.blocksize) { /* No.. return an indication that we are at the end of the * block and try again later. */ ret = -ENOSPC; goto errout; } /* Yes.. reserve space for the data block header */ pack->dest.entry.doffset = nxffs_packtell(volume, pack); pack->iooffset += SIZEOF_NXFFS_DATA_HDR; /* Initialize the output data stream to start with the first data * block */ pack->dest.blkoffset = pack->dest.entry.doffset; pack->dest.blklen = 0; pack->dest.blkpos = 0; } /* State 4: Starting a new block. Verify that there is space in the * current block for another (minimal sized) block */ if (pack->dest.blkoffset == 0) { /* Will the data block header plus a minimal amount of data fit in * this block? (or the whole file if the file is very small). */ mindata = MIN(NXFFS_MINDATA, pack->dest.entry.datlen); if (pack->iooffset + SIZEOF_NXFFS_DATA_HDR + mindata > volume->geo.blocksize) { /* No.. return an indication that we are at the end of the * block and try again later. */ ret = -ENOSPC; goto errout; } /* Yes.. reserve space for the data block header */ pack->dest.blkoffset = nxffs_packtell(volume, pack); pack->iooffset += SIZEOF_NXFFS_DATA_HDR; pack->dest.blklen = 0; pack->dest.blkpos = 0; } } ret = OK; errout: volume->froffset = nxffs_packtell(volume, pack); return ret; } /**************************************************************************** * Name: nxffs_wrinodehdr * * Description: * Write the destination inode header (only) to FLASH. Note that the inode * name has already been written to FLASH (thus greatly simplifying the * the complexity of this operation). * * Input Parameters: * volume - The volume to be packed * pack - The volume packing state structure. * * Returned Value: * Zero on success; Otherwise, a negated errno value is returned to * indicate the nature of the failure (not used). * ****************************************************************************/ static int nxffs_wrinodehdr(FAR struct nxffs_volume_s *volume, FAR struct nxffs_pack_s *pack) { FAR struct nxffs_inode_s *inode; off_t ioblock; uint16_t iooffset; uint32_t crc; int namlen; int ret; /* Get seek positions corresponding to the inode header location */ ioblock = nxffs_getblock(volume, pack->dest.entry.hoffset); iooffset = nxffs_getoffset(volume, pack->dest.entry.hoffset, ioblock); /* The inode header is not written until all of the inode data has been * packed into its new location. As a result, there are two possibilities: * * 1. The inode header lies in the current, unwritten erase block, * 2. The inode header resides in an earlier erase block and has already * been written to FLASH. * * Recall that the inode name has already been written to FLASH. If that * were not the case, then there would be other complex possibilities. * * Case 2: Does the inode header reside in a block before the beginning * of the current erase block? */ if (ioblock < pack->block0) { /* Case 2: The inode header lies in an earlier erase block that has * already been written to FLASH. In this case, if we are very * careful, we can just use the standard routine to write the inode * header that is called during the normal file close operation: */ ret = nxffs_wrinode(volume, &pack->dest.entry); } else { /* Cases 1: Both the inode header and name are in the unwritten cache * memory. * * Initialize the inode header. */ iooffset += (ioblock - pack->block0) * volume->geo.blocksize; inode = (FAR struct nxffs_inode_s *)&volume->pack[iooffset]; memcpy(inode->magic, g_inodemagic, NXFFS_MAGICSIZE); nxffs_wrle32(inode->noffs, pack->dest.entry.noffset); nxffs_wrle32(inode->doffs, pack->dest.entry.doffset); nxffs_wrle32(inode->utc, pack->dest.entry.utc); nxffs_wrle32(inode->crc, 0); nxffs_wrle32(inode->datlen, pack->dest.entry.datlen); /* Get the length of the inode name */ namlen = strlen(pack->dest.entry.name); DEBUGASSERT(namlen < CONFIG_NXFFS_MAXNAMLEN); inode->state = CONFIG_NXFFS_ERASEDSTATE; inode->namlen = namlen; /* Calculate the CRC */ crc = crc32((FAR const uint8_t *)inode, SIZEOF_NXFFS_INODE_HDR); crc = crc32part((FAR const uint8_t *)pack->dest.entry.name, namlen, crc); /* Finish the inode header */ inode->state = INODE_STATE_FILE; nxffs_wrle32(inode->crc, crc); /* If any open files reference this inode, then update the open file * state. */ ret = nxffs_updateinode(volume, &pack->dest.entry); if (ret < 0) { ferr("ERROR: Failed to update inode info: %d\n", -ret); } } /* Reset the dest inode information */ nxffs_freeentry(&pack->dest.entry); memset(&pack->dest, 0, sizeof(struct nxffs_packstream_s)); return ret; } /**************************************************************************** * Name: nxffs_wrdatthdr * * Description: * Write the destination data block header to FLASH. * * Input Parameters: * volume - The volume to be packed * pack - The volume packing state structure. * * Returned Value: * Zero on success; Otherwise, a negated errno value is returned to * indicate the nature of the failure. * ****************************************************************************/ static void nxffs_wrdathdr(FAR struct nxffs_volume_s *volume, FAR struct nxffs_pack_s *pack) { FAR struct nxffs_data_s *dathdr; off_t ioblock; uint16_t iooffset; uint32_t crc; if (pack->dest.blklen > 0) { /* Get the offset in the block corresponding to the location of the * data block header. NOTE: This must lie in the same block as we * currently have buffered. */ ioblock = nxffs_getblock(volume, pack->dest.blkoffset); iooffset = nxffs_getoffset(volume, pack->dest.blkoffset, ioblock); DEBUGASSERT(pack->dest.blkoffset && ioblock == pack->ioblock); /* Write the data block header to memory */ dathdr = (FAR struct nxffs_data_s *)&pack->iobuffer[iooffset]; memcpy(dathdr->magic, g_datamagic, NXFFS_MAGICSIZE); nxffs_wrle32(dathdr->crc, 0); nxffs_wrle16(dathdr->datlen, pack->dest.blklen); /* Update the entire data block CRC (including the header) */ crc = crc32(&pack->iobuffer[iooffset], pack->dest.blklen + SIZEOF_NXFFS_DATA_HDR); nxffs_wrle32(dathdr->crc, crc); } /* Setup state to allocate the next data block */ pack->dest.blkoffset = 0; pack->dest.blklen = 0; pack->dest.blkpos = 0; } /**************************************************************************** * Name: nxffs_packtransfer * * Description: * Transfer data from the source to the destination buffer. * * Input Parameters: * volume - The volume to be packed * pack - The volume packing state structure. * * Returned Value: * None. * ****************************************************************************/ static void nxffs_packtransfer(FAR struct nxffs_volume_s *volume, FAR struct nxffs_pack_s *pack) { /* Determine how much data is available in the dest pack buffer */ uint16_t destlen = volume->geo.blocksize - pack->iooffset; /* Dermined how much data is available in the src data block */ uint16_t srclen = pack->src.blklen - pack->src.blkpos; /* Transfer the smaller of the two amounts data */ uint16_t xfrlen = MIN(srclen, destlen); if (xfrlen > 0) { nxffs_ioseek(volume, pack->src.blkoffset + SIZEOF_NXFFS_DATA_HDR + pack->src.blkpos); memcpy(&pack->iobuffer[pack->iooffset], &volume->cache[volume->iooffset], xfrlen); /* Increment counts and offset for this data transfer */ pack->src.fpos += xfrlen; /* Source data offsets */ pack->src.blkpos += xfrlen; pack->dest.fpos += xfrlen; /* Destination data offsets */ pack->dest.blkpos += xfrlen; pack->dest.blklen += xfrlen; /* Destination data block size */ pack->iooffset += xfrlen; /* Destination I/O block offset */ volume->iooffset += xfrlen; /* Source I/O block offset */ volume->froffset += xfrlen; /* Free FLASH offset */ } } /**************************************************************************** * Name: nxffs_endsrcblock * * Description: * The end of a source data block has been encountered. Locate the next * source block and setup to continue the transfer. * * Input Parameters: * volume - The volume to be packed * pack - The volume packing state structure. * * Returned Value: * Zero on success; Otherwise, a negated errno value is returned to * indicate the nature of the failure. * ****************************************************************************/ static int nxffs_endsrcblock(FAR struct nxffs_volume_s *volume, FAR struct nxffs_pack_s *pack) { struct nxffs_blkentry_s blkentry; off_t offset; int ret; /* Yes.. find the next data block in the source input stream. */ offset = pack->src.blkoffset + SIZEOF_NXFFS_DATA_HDR + pack->src.blklen; ret = nxffs_nextblock(volume, offset, &blkentry); if (ret < 0) { ferr("ERROR: Failed to find next data block: %d\n", -ret); return ret; } /* Set up the source stream */ pack->src.blkoffset = blkentry.hoffset; pack->src.blklen = blkentry.datlen; pack->src.blkpos = 0; return OK; } /**************************************************************************** * Name: nxffs_packblock * * Description: * Resume packing from the source stream into the newly identified * destination block. * * Input Parameters: * volume - The volume to be packed * pack - The volume packing state structure. * * Returned Value: * Zero on success; Otherwise, a negated errno value is returned to * indicate the nature of the failure. * ****************************************************************************/ static inline int nxffs_packblock(FAR struct nxffs_volume_s *volume, FAR struct nxffs_pack_s *pack) { off_t offset; int ret; /* Are we currently processing a block from the source stream? */ if (pack->src.blkoffset == 0) { /* No.. setup the source stream */ ret = nxffs_srcsetup(volume, pack, pack->src.entry.doffset); if (ret < 0) { ferr("ERROR: Failed to configure the src stream: %d\n", -ret); return ret; } } /* We enter here on a new block every time, so we always have to setup * the dest data stream. There should never be data block allocated at * this point in time. */ DEBUGASSERT(pack->dest.blkoffset == 0 && pack->dest.blkpos == 0); ret = nxffs_destsetup(volume, pack); if (ret < 0) { /* -ENOSPC is a special return value which simply means that all of * the FLASH has been used up to the end of the current. We need to * return OK in this case and resume at the next block. */ if (ret == -ENOSPC) { return OK; } else { ferr("ERROR: Failed to configure the dest stream: %d\n", -ret); return ret; } } /* Loop, transferring data from the source block to the destination pack * buffer until either (1) the source stream is exhausted, (2) the * destination block is full, or (3) an error occurs. */ for (; ; ) { /* Transfer data from the source buffer to the destination buffer */ nxffs_packtransfer(volume, pack); /* Now, either the (1) src block has been fully transferred, (2) all * of the source data has been transferred, or (3) the destination * block is full, .. or all three. * * Check if all of the bytes in the source inode have been transferred. */ if (pack->src.fpos >= pack->src.entry.datlen) { /* Write the final destination data block header and inode * headers. */ nxffs_wrdathdr(volume, pack); nxffs_wrinodehdr(volume, pack); /* Find the next valid source inode */ offset = pack->src.blkoffset + pack->src.blklen; memset(&pack->src, 0, sizeof(struct nxffs_packstream_s)); ret = nxffs_nextentry(volume, offset, &pack->src.entry); if (ret < 0) { /* No more valid inode entries. Just return an end-of-flash * error indication. */ return -ENOSPC; } /* Setup the new source stream */ ret = nxffs_srcsetup(volume, pack, pack->src.entry.doffset); if (ret < 0) { return ret; } /* Setup the dest stream */ memset(&pack->dest, 0, sizeof(struct nxffs_packstream_s)); pack->dest.entry.name = pack->src.entry.name; pack->dest.entry.utc = pack->src.entry.utc; pack->dest.entry.datlen = pack->src.entry.datlen; pack->src.entry.name = NULL; /* Is there sufficient space at the end of the I/O block to hold * the inode header? */ if (pack->iooffset + SIZEOF_NXFFS_INODE_HDR > volume->geo.blocksize) { /* No, just return success... we will handle this condition * when this function is called on the next I/O block. */ return OK; } /* Configure the destination stream */ ret = nxffs_destsetup(volume, pack); if (ret < 0) { /* -ENOSPC is a special return value which simply means that * all of the has been used up to the end. We need to return * OK in this case and resume at the next block. */ if (ret == -ENOSPC) { return OK; } else { ferr("ERROR: Failed to configure the dest stream: %d\n", -ret); return ret; } } } /* Not at the end of the source data stream. Check if we are at the * end of the current source data block. */ else if (pack->src.blkpos >= pack->src.blklen) { ret = nxffs_endsrcblock(volume, pack); if (ret < 0) { return ret; } } /* Check if the destination block is full */ if (pack->iooffset >= volume->geo.blocksize) { /* Yes.. Write the destination data block header and return * success */ nxffs_wrdathdr(volume, pack); return OK; } } return -ENOSYS; } /**************************************************************************** * Name: nxffs_setupwriter * * Description: * Writing is performed at the end of the free FLASH region. When we * finish packing the other inodes, we still need to pack the partially * written file at the end of FLASH. This function performs the setup * necessary to perform that packing phase. * * Input Parameters: * volume - The volume to be packed * pack - The volume packing state structure. * * Returned Value: * If there is an active writer of the volume, its open file instance is * returned. NULL is returned otherwise. * ****************************************************************************/ static FAR struct nxffs_wrfile_s * nxffs_setupwriter(FAR struct nxffs_volume_s *volume, FAR struct nxffs_pack_s *pack) { FAR struct nxffs_wrfile_s *wrfile; /* Is there a writer? */ wrfile = nxffs_findwriter(volume); if (wrfile) { /* Yes... It is the activity of this write that probably initiated * this packing activity. The writer may have failed in one of several * different stages: * * hoffset == 0: The write failed early before even FLASH for the * inode header was set aside. * noffset == 0: The write failed after the inode header was set * aside, but before the inode name was written. * doffset == 0: The write failed after writing the inode name, bue * before any data blocks were written to FLASH. * * If no FLASH has been set aside for the write, then we don't need to * do anything here. */ if (wrfile->ofile.entry.hoffset > 0) { /* Initialize for the packing operation. */ memset(&pack->dest, 0, sizeof(struct nxffs_packstream_s)); pack->dest.entry.name = strdup(wrfile->ofile.entry.name); pack->dest.entry.utc = wrfile->ofile.entry.utc; pack->dest.entry.datlen = wrfile->ofile.entry.datlen; memset(&pack->src, 0, sizeof(struct nxffs_packstream_s)); memcpy(&pack->src.entry, &wrfile->ofile.entry, sizeof(struct nxffs_entry_s)); pack->src.entry.name = NULL; return wrfile; } } return NULL; } /**************************************************************************** * Name: nxffs_packwriter * * Description: * There is a write in progress at the time that the volume is packed. * This is the normal case because it is the write failures that trigger * the packing operation to begin with. * * Writing is performed at the end of the free FLASH region and this * implementation is restricted to a single writer. The new inode is not * written to FLASH until the writer is closed and so will not be * found by nxffs_packblock(). * * Input Parameters: * volume - The volume to be packed * pack - The volume packing state structure. * * Returned Value: * Zero on success; Otherwise, a negated errno value is returned to * indicate the nature of the failure. * ****************************************************************************/ static inline int nxffs_packwriter(FAR struct nxffs_volume_s *volume, FAR struct nxffs_pack_s *pack, FAR struct nxffs_wrfile_s *wrfile) { int ret; /* Are we currently processing a block from the source stream? */ if (pack->src.blkoffset == 0) { /* No.. setup the source stream */ ret = nxffs_srcsetup(volume, pack, pack->src.entry.doffset); if (ret < 0) { ferr("ERROR: Failed to configure the src stream: %d\n", -ret); return ret; } } /* We enter here on a new block every time, so we always have to setup * the dest data stream. There should never be data block allocated at * this point in time. */ DEBUGASSERT(pack->dest.blkoffset == 0 && pack->dest.blkpos == 0); ret = nxffs_destsetup(volume, pack); if (ret < 0) { /* -ENOSPC is a special return value which simply means that all of the * has been used up to the end. We need to return OK in this case and * resume at the next block. */ if (ret == -ENOSPC) { return OK; } else { ferr("ERROR: Failed to configure the dest stream: %d\n", -ret); return ret; } } /* Loop, transferring data from the source block to the destination pack * buffer until either (1) the source stream is exhausted, (2) the * destination block is full, or (3) an error occurs. */ for (; ; ) { /* Transfer data from the source buffer to the destination buffer */ nxffs_packtransfer(volume, pack); /* Now, either the (1) src block has been fully transferred, (2) all * of the source data has been transferred, or (3) the destination * block is full, .. or all three. * * Check if all of the bytes in the source inode have been transferred. */ if (pack->src.fpos >= pack->src.entry.datlen) { /* Write the final destination data block header and inode * headers. */ nxffs_wrdathdr(volume, pack); /* Set the new offsets in the open file instance. */ wrfile->ofile.entry.hoffset = pack->dest.entry.hoffset; wrfile->ofile.entry.noffset = pack->dest.entry.noffset; wrfile->ofile.entry.doffset = pack->dest.entry.doffset; /* Return an end-of-flash error to indicate that all of the write * data has been transferred. */ return -ENOSPC; } /* Not at the end of the source data stream. Check if we are at the * end of the current source data block. */ else if (pack->src.blkpos >= pack->src.blklen) { ret = nxffs_endsrcblock(volume, pack); if (ret < 0) { return ret; } } /* Check if the destination block is full */ if (pack->iooffset >= volume->geo.blocksize) { /* Yes.. Write the destination data block header and return * success */ nxffs_wrdathdr(volume, pack); return OK; } } return -ENOSYS; } /**************************************************************************** * Public Functions ****************************************************************************/ /**************************************************************************** * Name: nxffs_pack * * Description: * Pack and re-write the filesystem in order to free up memory at the end * of FLASH. * * Input Parameters: * volume - The volume to be packed. * * Returned Value: * Zero on success; Otherwise, a negated errno value is returned to * indicate the nature of the failure. * ****************************************************************************/ int nxffs_pack(FAR struct nxffs_volume_s *volume) { struct nxffs_pack_s pack; FAR struct nxffs_wrfile_s *wrfile; off_t iooffset; off_t eblock; off_t block; bool packed; int i; int ret = OK; /* Get the offset to the first valid inode entry */ wrfile = NULL; packed = false; iooffset = nxffs_mediacheck(volume, &pack); if (iooffset == 0) { /* Offset zero is only returned if no valid blocks were found on the * FLASH media or if there are no valid inode entries on the FLASH * after the first valid block. There are two possibilities: (1) * there* really is nothing on the FLASH, or (2) there is a file being * written to the FLASH now. */ /* Is there a writer? */ wrfile = nxffs_setupwriter(volume, &pack); if (wrfile) { /* If there is a write, just set ioffset to the offset of data in * first block. Setting 'packed' to true will suppress normal inode * packing operation. Then we can start compacting the FLASH. */ iooffset = SIZEOF_NXFFS_BLOCK_HDR; packed = true; goto start_pack; } else { /* No, there is no write in progress. We just have an empty flash * full of deleted files. In this case, the media needs to be re- * formatted. */ ret = nxffs_reformat(volume); if (ret == OK) { /* The free flash offset will be in the first valid block of * the FLASH. */ block = 0; ret = nxffs_validblock(volume, &block); if (ret == OK) { /* Set to the offset past the block header in the first * valid block */ volume->froffset = block * volume->geo.blocksize + SIZEOF_NXFFS_BLOCK_HDR; } } return ret; } } /* There is a valid format and valid inodes on the media.. setup up to * begin the packing operation. */ ret = nxffs_startpos(volume, &pack, &iooffset); if (ret < 0) { /* This is a normal situation if the volume is full */ if (ret == -ENOSPC) { /* In the case where the volume is full, nxffs_startpos() will * recalculate the free FLASH offset and store it in iooffset. * There may be deleted files at the end of FLASH. In this case, * we don't have to pack any files, we simply have to erase FLASH * at the end. But don't do this unless there is some particularly * big FLASH savings (otherwise, we risk wearing out these final * blocks). */ if (iooffset + CONFIG_NXFFS_TAILTHRESHOLD < volume->froffset) { /* Setting 'packed' to true will suppress normal inode packing * operation. */ packed = true; /* Writing is performed at the end of the free FLASH region. * If we are not packing files, we could still need to pack * the partially written file at the end of FLASH. */ wrfile = nxffs_setupwriter(volume, &pack); } /* Otherwise return OK.. meaning that there is nothing more we can * do to recover FLASH space. */ else { return OK; } } else { ferr("ERROR: Failed to find a packing position: %d\n", -ret); return ret; } } /* Otherwise, begin pack at this src/dest block combination. Initialize * ioblock and iooffset with the position of the first inode header. In * this case, the FLASH offset to the first inode header is return in * iooffset. */ start_pack: pack.ioblock = nxffs_getblock(volume, iooffset); pack.iooffset = nxffs_getoffset(volume, iooffset, pack.ioblock); volume->froffset = iooffset; /* Then pack all erase blocks starting with the erase block that contains * the ioblock and through the final erase block on the FLASH. */ for (eblock = pack.ioblock / volume->blkper; eblock < volume->geo.neraseblocks; eblock++) { /* Get the starting block number of the erase block */ pack.block0 = eblock * volume->blkper; #ifndef CONFIG_NXFFS_NAND /* Read the erase block into the pack buffer. We need to do this even * if we are overwriting the entire block so that we skip over * previously marked bad blocks. */ ret = MTD_BREAD(volume->mtd, pack.block0, volume->blkper, volume->pack); if (ret < 0) { ferr("ERROR: Failed to read erase block %jd: %d\n", (intmax_t)eblock, -ret); goto errout_with_pack; } #else /* Read the entire erase block into the pack buffer, one-block-at-a- * time. We need to do this even if we are overwriting the entire * block so that (1) we skip over previously marked bad blocks, and * (2) we can handle individual block read failures. * * For most FLASH, a read failure indicates a fatal hardware failure. * But for NAND FLASH, the read failure probably indicates a block * with uncorrectable bit errors. */ /* Read each I/O block */ for (i = 0, block = pack.block0, pack.iobuffer = volume->pack; i < volume->blkper; i++, block++, pack.iobuffer += volume->geo.blocksize) { /* Read the next block in the erase block */ ret = MTD_BREAD(volume->mtd, block, 1, pack.iobuffer); if (ret < 0) { /* Force a the block to be an NXFFS bad block */ ferr("ERROR: Failed to read block %d: %d\n", block, ret); nxffs_blkinit(volume, pack.iobuffer, BLOCK_STATE_BAD); } } #endif /* Now pack each I/O block */ for (i = 0, block = pack.block0, pack.iobuffer = volume->pack; i < volume->blkper; i++, block++, pack.iobuffer += volume->geo.blocksize) { /* The first time here, the ioblock may point to an offset into * the erase block. We just need to skip over those cases. */ if (block >= pack.ioblock) { /* Set the I/O position. Note on the first time we get * pack.iooffset will hold the offset in the first I/O block * to the first inode header. After that, it will always * refer to the first byte after the block header. */ pack.ioblock = block; /* If this is not a valid block or if we have already * finished packing the valid inode entries, then just fall * through, reset the FLASH memory to the erase state, and * write the reset values to FLASH. (The first block that * we want to process will always be valid -- we have * already verified that). */ if (nxffs_packvalid(&pack)) { /* Have we finished packing inodes? */ if (!packed) { DEBUGASSERT(wrfile == NULL); /* Pack inode data into this block */ ret = nxffs_packblock(volume, &pack); if (ret < 0) { /* The error -ENOSPC is a special value that simply * means that there is nothing further to be * packed. */ if (ret == -ENOSPC) { packed = true; /* Writing is performed at the end of the free * FLASH region and this implementation is * restricted to a single writer. The new * inode is not written to FLASH until the * writer is closed and so will not be found * by nxffs_packblock(). */ wrfile = nxffs_setupwriter(volume, &pack); } else { /* Otherwise, something really bad happened */ ferr("ERROR: Failed to pack into block %jd: " "%d\n", (intmax_t)block, ret); goto errout_with_pack; } } } /* If all of the "normal" inodes have been packed, then * check if we need to pack the current, in-progress write * operation. */ if (wrfile) { DEBUGASSERT(packed == true); /* Pack write data into this block */ ret = nxffs_packwriter(volume, &pack, wrfile); if (ret < 0) { /* The error -ENOSPC is a special value that simply * means that there is nothing further to be * packed. */ if (ret == -ENOSPC) { wrfile = NULL; } else { /* Otherwise, something really bad happened */ ferr("ERROR: Failed to pack into block %jd: " "%d\n", (intmax_t)block, ret); goto errout_with_pack; } } } } /* Set any unused portion at the end of the block to the * erased state. */ if (pack.iooffset < volume->geo.blocksize) { memset(&pack.iobuffer[pack.iooffset], CONFIG_NXFFS_ERASEDSTATE, volume->geo.blocksize - pack.iooffset); } /* Next time through the loop, pack.iooffset will point to the * first byte after the block header. */ pack.iooffset = SIZEOF_NXFFS_BLOCK_HDR; } } /* We now have an in-memory image of how we want this erase block to * appear. Now it is safe to erase the block. */ ret = MTD_ERASE(volume->mtd, eblock, 1); if (ret < 0) { ferr("ERROR: Failed to erase block %jd [%jd]: %d\n", (intmax_t)eblock, (intmax_t)pack.block0, -ret); goto errout_with_pack; } /* Write the packed I/O block to FLASH */ ret = MTD_BWRITE(volume->mtd, pack.block0, volume->blkper, volume->pack); if (ret < 0) { ferr("ERROR: Failed to write erase block %jd [%jd]: %d\n", (intmax_t)eblock, (intmax_t)pack.block0, -ret); goto errout_with_pack; } } errout_with_pack: nxffs_freeentry(&pack.src.entry); nxffs_freeentry(&pack.dest.entry); return ret; }