Clean up. Rename variable.
[bertos.git] / bertos / drv / eeprom.c
index 52ab70c72f7ab5f1cf8232f1b66ec818212a9905..fd644e4c995317750f04036aa6d0c078fbc37e07 100644 (file)
@@ -26,7 +26,7 @@
  * invalidate any other reasons why the executable file might be covered by
  * the GNU General Public License.
  *
- * Copyright 2003, 2004, 2005 Develer S.r.l. (http://www.develer.com/)
+ * Copyright 2003, 2004, 2005, 2010 Develer S.r.l. (http://www.develer.com/)
  *
  * -->
  *
@@ -38,6 +38,8 @@
 
 #include "eeprom.h"
 
+#include "cfg/cfg_i2c.h"
+
 #include <cfg/macros.h>  // MIN()
 #include <cfg/debug.h>
 #include <cfg/module.h>  // MOD_CHECK()
@@ -103,162 +105,6 @@ static const EepromInfo mem_info[] =
 
 STATIC_ASSERT(countof(mem_info) == EEPROM_CNT);
 
-
-/**
- * Copy \a size bytes from buffer \a buf to
- * eeprom.
- */
-static size_t eeprom_writeRaw(struct KFile *_fd, const void *buf, size_t size)
-{
-       Eeprom *fd = EEPROM_CAST(_fd);
-       e2dev_addr_t dev_addr;
-       uint8_t addr_buf[2];
-       uint8_t addr_len;
-       size_t wr_len = 0;
-
-       e2blk_size_t blk_size = mem_info[fd->type].blk_size;
-
-       STATIC_ASSERT(countof(addr_buf) <= sizeof(e2addr_t));
-
-       /* clamp size to memory limit (otherwise may roll back) */
-       ASSERT(_fd->seek_pos + (kfile_off_t)size <= (kfile_off_t)_fd->size);
-       size = MIN((kfile_off_t)size, _fd->size - _fd->seek_pos);
-
-       if (mem_info[fd->type].has_dev_addr)
-       {
-               dev_addr = fd->addr;
-               addr_len = 2;
-       }
-       else
-       {
-               dev_addr = (e2dev_addr_t)((fd->fd.seek_pos >> 8) & 0x07);
-               addr_len = 1;
-       }
-
-       while (size)
-       {
-               /*
-                * Split write in multiple sequential mode operations that
-                * don't cross page boundaries.
-                */
-               size_t count = MIN(size, (size_t)(blk_size - (fd->fd.seek_pos & (blk_size - 1))));
-
-               if (mem_info[fd->type].has_dev_addr)
-               {
-                       addr_buf[0] = (fd->fd.seek_pos >> 8) & 0xFF;
-                       addr_buf[1] = (fd->fd.seek_pos & 0xFF);
-               }
-               else
-               {
-                       dev_addr = (e2dev_addr_t)((fd->fd.seek_pos >> 8) & 0x07);
-                       addr_buf[0] = (fd->fd.seek_pos & 0xFF);
-               }
-
-
-               if (!(i2c_start_w(EEPROM_ADDR(dev_addr))
-                       && i2c_send(addr_buf, addr_len)
-                       && i2c_send(buf, count)))
-               {
-                       i2c_stop();
-                       return wr_len;
-               }
-
-               i2c_stop();
-
-               /* Update count and addr for next operation */
-               size -= count;
-               fd->fd.seek_pos += count;
-               buf = ((const char *)buf) + count;
-               wr_len += count;
-       }
-
-       return wr_len;
-}
-
-/**
- * Copy \a size bytes from buffer \a _buf to
- * eeprom.
- * \note Writes are verified and if buffer content
- *       is not matching we retry 5 times max.
- */
-static size_t eeprom_writeVerify(struct KFile *_fd, const void *_buf, size_t size)
-{
-       Eeprom *fd = EEPROM_CAST(_fd);
-       int retries = 5;
-       size_t wr_len = 0;
-
-       while (retries--)
-       {
-               wr_len = eeprom_writeRaw(_fd, _buf, size);
-               /* rewind to verify what we have just written */
-               kfile_seek(_fd, -(kfile_off_t)wr_len, KSM_SEEK_CUR);
-               if (wr_len == size
-                && eeprom_verify(fd, _buf, wr_len))
-               {
-                       /* Forward to go after what we have written*/
-                       kfile_seek(_fd, wr_len, KSM_SEEK_CUR);
-                       return wr_len;
-               }
-       }
-       return wr_len;
-}
-
-
-/**
- * Copy \a size bytes
- * from eeprom to RAM to buffer \a _buf.
- *
- * \return the number of bytes read.
- */
-static size_t eeprom_read(struct KFile *_fd, void *_buf, size_t size)
-{
-       Eeprom *fd = EEPROM_CAST(_fd);
-       uint8_t addr_buf[2];
-       uint8_t addr_len;
-       size_t rd_len = 0;
-       uint8_t *buf = (uint8_t *)_buf;
-
-       STATIC_ASSERT(countof(addr_buf) <= sizeof(e2addr_t));
-
-       /* clamp size to memory limit (otherwise may roll back) */
-       ASSERT(_fd->seek_pos + (kfile_off_t)size <= (kfile_off_t)_fd->size);
-       size = MIN((kfile_off_t)size, _fd->size - _fd->seek_pos);
-
-       e2dev_addr_t dev_addr;
-       if (mem_info[fd->type].has_dev_addr)
-       {
-               dev_addr = fd->addr;
-               addr_len = 2;
-               addr_buf[0] = (fd->fd.seek_pos >> 8) & 0xFF;
-               addr_buf[1] = (fd->fd.seek_pos & 0xFF);
-       }
-       else
-       {
-               dev_addr = (e2dev_addr_t)((fd->fd.seek_pos >> 8) & 0x07);
-               addr_len = 1;
-               addr_buf[0] = (fd->fd.seek_pos & 0xFF);
-       }
-
-
-       if (!(i2c_start_w(EEPROM_ADDR(dev_addr))
-          && i2c_send(addr_buf, addr_len)
-          && i2c_start_r(EEPROM_ADDR(dev_addr))))
-       {
-               i2c_stop();
-               return 0;
-       }
-
-
-       if (i2c_recv(buf, size))
-       {
-               fd->fd.seek_pos += size;
-               rd_len += size;
-       }
-
-       i2c_stop();
-       return rd_len;
-}
-
 /**
  * Check that the contents of an EEPROM range
  * match with a provided data buffer.
@@ -388,3 +234,138 @@ void eeprom_init(Eeprom *fd, EepromType type, e2dev_addr_t addr, bool verify)
 
        fd->fd.seek = kfile_genericSeek;
 }
+
+
+static size_t eeprom_writeDirect(KBlock *blk, block_idx_t idx, const void *buf, size_t offset, size_t size)
+{
+       Eeprom *fd = EEPROM_CAST_KBLOCK(blk);
+       e2dev_addr_t dev_addr;
+       uint8_t addr_buf[2];
+       uint8_t addr_len;
+       uint32_t abs_addr = blk->blk_size * idx + offset;
+
+       STATIC_ASSERT(countof(addr_buf) <= sizeof(e2addr_t));
+
+
+       /* clamp size to memory limit (otherwise may roll back) */
+       ASSERT(idx <= blk->blk_cnt);
+       size = MIN(size, blk->blk_size - offset);
+
+       if (mem_info[fd->type].has_dev_addr)
+       {
+               dev_addr = fd->addr;
+               addr_len = 2;
+       }
+       else
+       {
+               dev_addr = (e2dev_addr_t)((abs_addr >> 8) & 0x07);
+               addr_len = 1;
+       }
+
+       if (mem_info[fd->type].has_dev_addr)
+       {
+               addr_buf[0] = (abs_addr >> 8) & 0xFF;
+               addr_buf[1] = (abs_addr & 0xFF);
+       }
+       else
+       {
+               dev_addr = (e2dev_addr_t)((abs_addr >> 8) & 0x07);
+               addr_buf[0] = (abs_addr & 0xFF);
+       }
+
+       i2c_start_w(fd->i2c, EEPROM_ADDR(dev_addr),  addr_len + size, I2C_STOP);
+       i2c_write(fd->i2c, addr_buf, addr_len);
+       i2c_write(fd->i2c, buf, size);
+
+       if (i2c_error(fd->i2c))
+               return 0;
+
+       return size;
+}
+
+
+static size_t eeprom_readDirect(struct KBlock *_blk, block_idx_t idx, void *_buf, size_t offset, size_t size)
+{
+       Eeprom *blk = EEPROM_CAST_KBLOCK(_blk);
+       uint8_t addr_buf[2];
+       uint8_t addr_len;
+       size_t rd_len = 0;
+       uint8_t *buf = (uint8_t *)_buf;
+       uint32_t abs_addr = mem_info[blk->type].blk_size * idx + offset;
+
+       STATIC_ASSERT(countof(addr_buf) <= sizeof(e2addr_t));
+
+       /* clamp size to memory limit (otherwise may roll back) */
+       ASSERT(idx <= blk->blk.blk_cnt);
+       size = MIN(size, blk->blk.blk_size - offset);
+
+       e2dev_addr_t dev_addr;
+       if (mem_info[blk->type].has_dev_addr)
+       {
+               dev_addr = blk->addr;
+               addr_len = 2;
+               addr_buf[0] = (abs_addr >> 8) & 0xFF;
+               addr_buf[1] = (abs_addr & 0xFF);
+       }
+       else
+       {
+               dev_addr = (e2dev_addr_t)((abs_addr >> 8) & 0x07);
+               addr_len = 1;
+               addr_buf[0] = (abs_addr & 0xFF);
+       }
+
+
+       i2c_start_w(blk->i2c, EEPROM_ADDR(dev_addr),  addr_len, I2C_NOSTOP);
+       i2c_write(blk->i2c, addr_buf, addr_len);
+
+       i2c_start_r(blk->i2c, EEPROM_ADDR(dev_addr), size, I2C_STOP);
+       i2c_read(blk->i2c, buf, size);
+
+       if (i2c_error(blk->i2c))
+                  return rd_len;
+
+       rd_len += size;
+
+       return rd_len;
+}
+
+static int kblockEeprom_dummy(UNUSED_ARG(struct KBlock *,b))
+{
+       return 0;
+}
+
+
+static const KBlockVTable eeprom_unbuffered_vt =
+{
+       .readDirect = eeprom_readDirect,
+       .writeDirect = eeprom_writeDirect,
+
+       .error = kblockEeprom_dummy,
+       .clearerr = (kblock_clearerr_t)kblockEeprom_dummy,
+};
+
+/**
+ * Initialize EEPROM module.
+ * \param b is the Kblock context.
+ * \param type is the eeprom device we want to initialize (\see EepromType)
+ * \param i2c context for i2c channel
+ * \param addr is the i2c devide address (usually pins A0, A1, A2).
+ */
+void eeprom_init_5(Eeprom *blk, I2c *i2c, EepromType type, e2dev_addr_t addr, bool verify)
+{
+       ASSERT(type < EEPROM_CNT);
+
+       memset(blk, 0, sizeof(*blk));
+       DB(blk->blk.priv.type = KBT_EEPROM);
+
+       blk->type = type;
+       blk->addr = addr;
+       blk->i2c = i2c;
+
+       blk->blk.blk_size = mem_info[type].blk_size;
+       blk->blk.blk_cnt = mem_info[type].e2_size / mem_info[type].blk_size;
+       blk->blk.priv.flags |= KB_PARTIAL_WRITE;
+       blk->blk.priv.vt = &eeprom_unbuffered_vt;
+}
+
+