Logo Search packages:      
Sourcecode: linux-qcm-msm version File versions  Download package

smd.c

/* arch/arm/mach-msm/smd.c
 *
 * Copyright (C) 2007 Google, Inc.
 * Copyright (c) 2008-2009, Code Aurora Forum. All rights reserved.
 * Author: Brian Swetland <swetland@google.com>
 *
 * This software is licensed under the terms of the GNU General Public
 * License version 2, as published by the Free Software Foundation, and
 * may be copied, distributed, and modified under those terms.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 */

#include <linux/platform_device.h>
#include <linux/module.h>
#include <linux/fs.h>
#include <linux/cdev.h>
#include <linux/device.h>
#include <linux/wait.h>
#include <linux/interrupt.h>
#include <linux/irq.h>
#include <linux/list.h>
#include <linux/slab.h>
#include <linux/delay.h>
#include <linux/io.h>
#include <linux/termios.h>
#include <linux/ctype.h>
#include <mach/msm_smd.h>
#include <mach/msm_iomap.h>
#include <mach/system.h>

#include "smd_private.h"
#include "proc_comm.h"
#include "modem_notifier.h"

#if defined(CONFIG_ARCH_QSD8X50)
#define CONFIG_QDSP6 1
#endif

#define MODULE_NAME "msm_smd"
#define SMEM_VERSION 0x000B
#define SMD_VERSION 0x00020000

enum {
      MSM_SMD_DEBUG = 1U << 0,
      MSM_SMSM_DEBUG = 1U << 1,
      MSM_SMD_INFO = 1U << 2,
      MSM_SMSM_INFO = 1U << 3,
};

struct smsm_shared_info {
      uint32_t *state;
      uint32_t *intr_mask;
      uint32_t *intr_mux;
};

static struct smsm_shared_info smsm_info;

#define SMSM_STATE_ADDR(entry)           (smsm_info.state + entry)
#define SMSM_INTR_MASK_ADDR(entry, host) (smsm_info.intr_mask + \
                                entry * SMSM_NUM_HOSTS + host)
#define SMSM_INTR_MUX_ADDR(entry)        (smsm_info.intr_mux + entry)

/* Internal definitions which are not exported in some targets */
enum {
      SMSM_Q6_I = 2,
};

enum {
      SMSM_APPS_DEM_I = 3,
};

enum {
      SMD_APPS_QDSP_I = 1,
      SMD_MODEM_QDSP_I = 2
};

static int msm_smd_debug_mask;
module_param_named(debug_mask, msm_smd_debug_mask,
               int, S_IRUGO | S_IWUSR | S_IWGRP);

#if defined(CONFIG_MSM_SMD_DEBUG)
#define SMD_DBG(x...) do {                      \
            if (msm_smd_debug_mask & MSM_SMD_DEBUG) \
                  printk(KERN_DEBUG x);         \
      } while (0)

#define SMSM_DBG(x...) do {                           \
            if (msm_smd_debug_mask & MSM_SMSM_DEBUG)  \
                  printk(KERN_DEBUG x);               \
      } while (0)

#define SMD_INFO(x...) do {                     \
            if (msm_smd_debug_mask & MSM_SMD_INFO)    \
                  printk(KERN_INFO x);          \
      } while (0)

#define SMSM_INFO(x...) do {                    \
            if (msm_smd_debug_mask & MSM_SMSM_INFO) \
                  printk(KERN_INFO x);          \
      } while (0)
#else
#define SMD_DBG(x...) do { } while (0)
#define SMSM_DBG(x...) do { } while (0)
#define SMD_INFO(x...) do { } while (0)
#define SMSM_INFO(x...) do { } while (0)
#endif

static unsigned last_heap_free = 0xffffffff;

#if defined(CONFIG_ARCH_MSM7X30)
#define MSM_TRIG_A2M_INT(n) (writel(1 << n, MSM_GCC_BASE + 0x8))
#else
#define MSM_TRIG_A2M_INT(n) (writel(1, MSM_CSR_BASE + 0x400 + (n) * 4))
#endif

static void notify_other_smsm(uint32_t smsm_entry, uint32_t notify_mask)
{
      uint32_t mux_val;

      /* older protocol don't use smsm_intr_mask,
         but still communicates with modem */
      if (!smsm_info.intr_mask ||
          (readl(SMSM_INTR_MASK_ADDR(smsm_entry, SMSM_MODEM)) & notify_mask))
            MSM_TRIG_A2M_INT(5);

      if (smsm_info.intr_mask &&
          (readl(SMSM_INTR_MASK_ADDR(smsm_entry, SMSM_Q6_I)) & notify_mask)) {
            if (smsm_info.intr_mux) {
                  mux_val = readl(SMSM_INTR_MUX_ADDR(SMEM_APPS_Q6_SMSM));
                  mux_val++;
                  writel(mux_val, SMSM_INTR_MUX_ADDR(SMEM_APPS_Q6_SMSM));
            }

            MSM_TRIG_A2M_INT(8);
      }
}

static inline void notify_modem_smd(void)
{
      MSM_TRIG_A2M_INT(0);
}

static inline void notify_dsp_smd(void)
{
      MSM_TRIG_A2M_INT(8);
}

void smd_diag(void)
{
      char *x;
      int size;

      x = smem_find(ID_DIAG_ERR_MSG, SZ_DIAG_ERR_MSG);
      if (x != 0) {
            x[SZ_DIAG_ERR_MSG - 1] = 0;
            SMD_INFO("smem: DIAG '%s'\n", x);
      }

      x = smem_get_entry(SMEM_ERR_CRASH_LOG, &size);
      if (x != 0) {
            x[size - 1] = 0;
            pr_err("smem: CRASH LOG\n'%s'\n", x);
      }
}


static void handle_modem_crash(void)
{
      pr_err("ARM9 has CRASHED\n");
      smd_diag();

      /* hard reboot if possible FIXME
      if (msm_reset_hook)
            msm_reset_hook();
      */

      /* in this case the modem or watchdog should reboot us */
      for (;;)
            ;
}

static int check_for_modem_crash(void)
{
      /* if the modem's not ready yet, we have to hope for the best */
      if (!smsm_info.state)
            return 0;

      if (readl(SMSM_STATE_ADDR(SMSM_MODEM_STATE)) & SMSM_RESET) {
            handle_modem_crash();
            return -1;
      }
      return 0;
}

/* the spinlock is used to synchronize between the
 * irq handler and code that mutates the channel
 * list or fiddles with channel state
 */
static DEFINE_SPINLOCK(smd_lock);
DEFINE_SPINLOCK(smem_lock);

/* the mutex is used during open() and close()
 * operations to avoid races while creating or
 * destroying smd_channel structures
 */
static DEFINE_MUTEX(smd_creation_mutex);

static int smd_initialized;

struct smd_shared_v1 {
      struct smd_half_channel ch0;
      unsigned char data0[SMD_BUF_SIZE];
      struct smd_half_channel ch1;
      unsigned char data1[SMD_BUF_SIZE];
};

struct smd_shared_v2 {
      struct smd_half_channel ch0;
      struct smd_half_channel ch1;
};

struct smd_channel {
      volatile struct smd_half_channel *send;
      volatile struct smd_half_channel *recv;
      unsigned char *send_data;
      unsigned char *recv_data;
      unsigned fifo_size;
      unsigned fifo_mask;
      struct list_head ch_list;

      unsigned current_packet;
      unsigned n;
      void *priv;
      void (*notify)(void *priv, unsigned flags);

      int (*read)(smd_channel_t *ch, void *data, int len);
      int (*write)(smd_channel_t *ch, const void *data, int len);
      int (*read_avail)(smd_channel_t *ch);
      int (*write_avail)(smd_channel_t *ch);
      int (*read_from_cb)(smd_channel_t *ch, void *data, int len);

      void (*update_state)(smd_channel_t *ch);
      unsigned last_state;
      void (*notify_other_cpu)(void);

      char name[20];
      struct platform_device pdev;
      unsigned type;
};

static LIST_HEAD(smd_ch_closed_list);
static LIST_HEAD(smd_ch_list_modem);
static LIST_HEAD(smd_ch_list_dsp);

static unsigned char smd_ch_allocated[64];
static struct work_struct probe_work;

static void smd_alloc_channel(struct smd_alloc_elm *alloc_elm);

static void smd_channel_probe_worker(struct work_struct *work)
{
      struct smd_alloc_elm *shared;
      unsigned n;

      shared = smem_find(ID_CH_ALLOC_TBL, sizeof(*shared) * 64);

      BUG_ON(!shared);

      for (n = 0; n < 64; n++) {
            if (smd_ch_allocated[n])
                  continue;

            /* channel should be allocated only if APPS
               processor is involved */
            if (SMD_CHANNEL_TYPE(shared[n].type) == SMD_MODEM_QDSP_I)
                  continue;
            if (!shared[n].ref_count)
                  continue;
            if (!shared[n].name[0])
                  continue;

            smd_alloc_channel(&shared[n]);
            smd_ch_allocated[n] = 1;
      }
}

/* how many bytes are available for reading */
static int smd_stream_read_avail(struct smd_channel *ch)
{
      return (ch->recv->head - ch->recv->tail) & ch->fifo_mask;
}

/* how many bytes we are free to write */
static int smd_stream_write_avail(struct smd_channel *ch)
{
      return ch->fifo_mask -
            ((ch->send->head - ch->send->tail) & ch->fifo_mask);
}

static int smd_packet_read_avail(struct smd_channel *ch)
{
      if (ch->current_packet) {
            int n = smd_stream_read_avail(ch);
            if (n > ch->current_packet)
                  n = ch->current_packet;
            return n;
      } else {
            return 0;
      }
}

static int smd_packet_write_avail(struct smd_channel *ch)
{
      int n = smd_stream_write_avail(ch);
      return n > SMD_HEADER_SIZE ? n - SMD_HEADER_SIZE : 0;
}

static int ch_is_open(struct smd_channel *ch)
{
      return (ch->recv->state == SMD_SS_OPENED ||
            ch->recv->state == SMD_SS_FLUSHING)
            && (ch->send->state == SMD_SS_OPENED);
}

/* provide a pointer and length to readable data in the fifo */
static unsigned ch_read_buffer(struct smd_channel *ch, void **ptr)
{
      unsigned head = ch->recv->head;
      unsigned tail = ch->recv->tail;
      *ptr = (void *) (ch->recv_data + tail);

      if (tail <= head)
            return head - tail;
      else
            return ch->fifo_size - tail;
}

/* advance the fifo read pointer after data from ch_read_buffer is consumed */
static void ch_read_done(struct smd_channel *ch, unsigned count)
{
      BUG_ON(count > smd_stream_read_avail(ch));
      ch->recv->tail = (ch->recv->tail + count) & ch->fifo_mask;
      ch->send->fTAIL = 1;
}

/* basic read interface to ch_read_{buffer,done} used
 * by smd_*_read() and update_packet_state()
 * will read-and-discard if the _data pointer is null
 */
static int ch_read(struct smd_channel *ch, void *_data, int len)
{
      void *ptr;
      unsigned n;
      unsigned char *data = _data;
      int orig_len = len;

      while (len > 0) {
            n = ch_read_buffer(ch, &ptr);
            if (n == 0)
                  break;

            if (n > len)
                  n = len;
            if (_data)
                  memcpy(data, ptr, n);

            data += n;
            len -= n;
            ch_read_done(ch, n);
      }

      return orig_len - len;
}

static void update_stream_state(struct smd_channel *ch)
{
      /* streams have no special state requiring updating */
}

static void update_packet_state(struct smd_channel *ch)
{
      unsigned hdr[5];
      int r;

      /* can't do anything if we're in the middle of a packet */
      while (ch->current_packet == 0) {
            /* discard 0 length packets if any */

            /* don't bother unless we can get the full header */
            if (smd_stream_read_avail(ch) < SMD_HEADER_SIZE)
                  return;

            r = ch_read(ch, hdr, SMD_HEADER_SIZE);
            BUG_ON(r != SMD_HEADER_SIZE);

            ch->current_packet = hdr[0];
      }
}

/* provide a pointer and length to next free space in the fifo */
static unsigned ch_write_buffer(struct smd_channel *ch, void **ptr)
{
      unsigned head = ch->send->head;
      unsigned tail = ch->send->tail;
      *ptr = (void *) (ch->send_data + head);

      if (head < tail) {
            return tail - head - 1;
      } else {
            if (tail == 0)
                  return ch->fifo_size - head - 1;
            else
                  return ch->fifo_size - head;
      }
}

/* advace the fifo write pointer after freespace
 * from ch_write_buffer is filled
 */
static void ch_write_done(struct smd_channel *ch, unsigned count)
{
      BUG_ON(count > smd_stream_write_avail(ch));
      ch->send->head = (ch->send->head + count) & ch->fifo_mask;
      ch->send->fHEAD = 1;
}

static void ch_set_state(struct smd_channel *ch, unsigned n)
{
      if (n == SMD_SS_OPENED) {
            ch->send->fDSR = 1;
            ch->send->fCTS = 1;
            ch->send->fCD = 1;
      } else {
            ch->send->fDSR = 0;
            ch->send->fCTS = 0;
            ch->send->fCD = 0;
      }
      ch->send->state = n;
      ch->send->fSTATE = 1;
      ch->notify_other_cpu();
}

static void do_smd_probe(void)
{
      struct smem_shared *shared = (void *) MSM_SHARED_RAM_BASE;
      if (shared->heap_info.free_offset != last_heap_free) {
            last_heap_free = shared->heap_info.free_offset;
            schedule_work(&probe_work);
      }
}

static void smd_state_change(struct smd_channel *ch,
                       unsigned last, unsigned next)
{
      ch->last_state = next;

      SMD_INFO("SMD: ch %d %d -> %d\n", ch->n, last, next);

      switch (next) {
      case SMD_SS_OPENING:
            if (ch->send->state == SMD_SS_CLOSING ||
                ch->send->state == SMD_SS_CLOSED) {
                  ch->recv->tail = 0;
                  ch->send->head = 0;
                  ch_set_state(ch, SMD_SS_OPENING);
            }
            break;
      case SMD_SS_OPENED:
            if (ch->send->state == SMD_SS_OPENING) {
                  ch_set_state(ch, SMD_SS_OPENED);
                  ch->notify(ch->priv, SMD_EVENT_OPEN);
            }
            break;
      case SMD_SS_FLUSHING:
      case SMD_SS_RESET:
            /* we should force them to close? */
            break;
      case SMD_SS_CLOSED:
            if (ch->send->state == SMD_SS_OPENED) {
                  ch_set_state(ch, SMD_SS_CLOSING);
                  ch->notify(ch->priv, SMD_EVENT_CLOSE);
            }
            break;
      }
}

static void handle_smd_irq(struct list_head *list, void (*notify)(void))
{
      unsigned long flags;
      struct smd_channel *ch;
      int do_notify = 0;
      unsigned ch_flags;
      unsigned tmp;

      spin_lock_irqsave(&smd_lock, flags);
      list_for_each_entry(ch, list, ch_list) {
            ch_flags = 0;
            if (ch_is_open(ch)) {
                  if (ch->recv->fHEAD) {
                        ch->recv->fHEAD = 0;
                        ch_flags |= 1;
                        do_notify |= 1;
                  }
                  if (ch->recv->fTAIL) {
                        ch->recv->fTAIL = 0;
                        ch_flags |= 2;
                        do_notify |= 1;
                  }
                  if (ch->recv->fSTATE) {
                        ch->recv->fSTATE = 0;
                        ch_flags |= 4;
                        do_notify |= 1;
                  }
            }
            tmp = ch->recv->state;
            if (tmp != ch->last_state)
                  smd_state_change(ch, ch->last_state, tmp);
            if (ch_flags) {
                  ch->update_state(ch);
                  ch->notify(ch->priv, SMD_EVENT_DATA);
            }
      }
      if (do_notify)
            notify();
      spin_unlock_irqrestore(&smd_lock, flags);
      do_smd_probe();
}

static irqreturn_t smd_modem_irq_handler(int irq, void *data)
{
      handle_smd_irq(&smd_ch_list_modem, notify_modem_smd);
      return IRQ_HANDLED;
}

#if defined(CONFIG_QDSP6)
static irqreturn_t smd_dsp_irq_handler(int irq, void *data)
{
      handle_smd_irq(&smd_ch_list_dsp, notify_dsp_smd);
      return IRQ_HANDLED;
}
#endif

static void smd_fake_irq_handler(unsigned long arg)
{
      handle_smd_irq(&smd_ch_list_modem, notify_modem_smd);
      handle_smd_irq(&smd_ch_list_dsp, notify_dsp_smd);
}

static DECLARE_TASKLET(smd_fake_irq_tasklet, smd_fake_irq_handler, 0);

static inline int smd_need_int(struct smd_channel *ch)
{
      if (ch_is_open(ch)) {
            if (ch->recv->fHEAD || ch->recv->fTAIL || ch->recv->fSTATE)
                  return 1;
            if (ch->recv->state != ch->last_state)
                  return 1;
      }
      return 0;
}

void smd_sleep_exit(void)
{
      unsigned long flags;
      struct smd_channel *ch;
      int need_int = 0;

      spin_lock_irqsave(&smd_lock, flags);
      list_for_each_entry(ch, &smd_ch_list_modem, ch_list) {
            if (smd_need_int(ch)) {
                  need_int = 1;
                  break;
            }
      }
      list_for_each_entry(ch, &smd_ch_list_dsp, ch_list) {
            if (smd_need_int(ch)) {
                  need_int = 1;
                  break;
            }
      }
      spin_unlock_irqrestore(&smd_lock, flags);
      do_smd_probe();

      if (need_int) {
            SMD_DBG("smd_sleep_exit need interrupt\n");
            tasklet_schedule(&smd_fake_irq_tasklet);
      }
}

static int smd_is_packet(struct smd_alloc_elm *alloc_elm)
{
      if (SMD_XFER_TYPE(alloc_elm->type) == 1)
            return 0;
      else if (SMD_XFER_TYPE(alloc_elm->type) == 2)
            return 1;

      /* for cases where xfer type is 0 */
      if (!strncmp(alloc_elm->name, "DAL", 3))
            return 0;

      if (alloc_elm->cid > 4 || alloc_elm->cid == 1)
            return 1;
      else
            return 0;
}

static int smd_stream_write(smd_channel_t *ch, const void *_data, int len)
{
      void *ptr;
      const unsigned char *buf = _data;
      unsigned xfer;
      int orig_len = len;

      SMD_DBG("smd_stream_write() %d -> ch%d\n", len, ch->n);
      if (len < 0)
            return -EINVAL;
      else if (len == 0)
            return 0;

      while ((xfer = ch_write_buffer(ch, &ptr)) != 0) {
            if (!ch_is_open(ch))
                  break;
            if (xfer > len)
                  xfer = len;
            memcpy(ptr, buf, xfer);
            ch_write_done(ch, xfer);
            len -= xfer;
            buf += xfer;
            if (len == 0)
                  break;
      }

      if (orig_len - len)
            ch->notify_other_cpu();

      return orig_len - len;
}

static int smd_packet_write(smd_channel_t *ch, const void *_data, int len)
{
      int ret;
      unsigned hdr[5];

      SMD_DBG("smd_packet_write() %d -> ch%d\n", len, ch->n);
      if (len < 0)
            return -EINVAL;
      else if (len == 0)
            return 0;

      if (smd_stream_write_avail(ch) < (len + SMD_HEADER_SIZE))
            return -ENOMEM;

      hdr[0] = len;
      hdr[1] = hdr[2] = hdr[3] = hdr[4] = 0;


      ret = smd_stream_write(ch, hdr, sizeof(hdr));
      if (ret < 0 || ret != sizeof(hdr)) {
            SMD_DBG("%s failed to write pkt header: "
                  "%d returned\n", __func__, ret);
            return -1;
      }


      ret = smd_stream_write(ch, _data, len);
      if (ret < 0 || ret != len) {
            SMD_DBG("%s failed to write pkt data: "
                  "%d returned\n", __func__, ret);
            return ret;
      }

      return len;
}

static int smd_stream_read(smd_channel_t *ch, void *data, int len)
{
      int r;

      if (len < 0)
            return -EINVAL;

      r = ch_read(ch, data, len);
      if (r > 0)
            ch->notify_other_cpu();

      return r;
}

static int smd_packet_read(smd_channel_t *ch, void *data, int len)
{
      unsigned long flags;
      int r;

      if (len < 0)
            return -EINVAL;

      if (len > ch->current_packet)
            len = ch->current_packet;

      r = ch_read(ch, data, len);
      if (r > 0)
            ch->notify_other_cpu();

      spin_lock_irqsave(&smd_lock, flags);
      ch->current_packet -= r;
      update_packet_state(ch);
      spin_unlock_irqrestore(&smd_lock, flags);

      return r;
}

static int smd_packet_read_from_cb(smd_channel_t *ch, void *data, int len)
{
      int r;

      if (len < 0)
            return -EINVAL;

      if (len > ch->current_packet)
            len = ch->current_packet;

      r = ch_read(ch, data, len);
      if (r > 0)
            ch->notify_other_cpu();

      ch->current_packet -= r;
      update_packet_state(ch);

      return r;
}

static int smd_alloc_v2(struct smd_channel *ch)
{
      struct smd_shared_v2 *shared2;
      void *buffer;
      unsigned buffer_sz;

      shared2 = smem_alloc(SMEM_SMD_BASE_ID + ch->n, sizeof(*shared2));
      buffer = smem_get_entry(SMEM_SMD_FIFO_BASE_ID + ch->n, &buffer_sz);
      if (!buffer)
            return -1;

      /* buffer must be a power-of-two size */
      if (buffer_sz & (buffer_sz - 1))
            return -1;

      buffer_sz /= 2;
      ch->send = &shared2->ch0;
      ch->recv = &shared2->ch1;
      ch->send_data = buffer;
      ch->recv_data = buffer + buffer_sz;
      ch->fifo_size = buffer_sz;
      return 0;
}

static int smd_alloc_v1(struct smd_channel *ch)
{
      struct smd_shared_v1 *shared1;
      shared1 = smem_alloc(ID_SMD_CHANNELS + ch->n, sizeof(*shared1));
      if (!shared1) {
            pr_err("smd_alloc_channel() cid %d does not exist\n", ch->n);
            return -1;
      }
      ch->send = &shared1->ch0;
      ch->recv = &shared1->ch1;
      ch->send_data = shared1->data0;
      ch->recv_data = shared1->data1;
      ch->fifo_size = SMD_BUF_SIZE;
      return 0;
}

static void smd_alloc_channel(struct smd_alloc_elm *alloc_elm)
{
      struct smd_channel *ch;

      ch = kzalloc(sizeof(struct smd_channel), GFP_KERNEL);
      if (ch == 0) {
            pr_err("smd_alloc_channel() out of memory\n");
            return;
      }
      ch->n = alloc_elm->cid;

      if (smd_alloc_v2(ch) && smd_alloc_v1(ch)) {
            kfree(ch);
            return;
      }

      ch->fifo_mask = ch->fifo_size - 1;
      ch->type = SMD_CHANNEL_TYPE(alloc_elm->type);

      if (ch->type == SMD_APPS_MODEM)
            ch->notify_other_cpu = notify_modem_smd;
      else
            ch->notify_other_cpu = notify_dsp_smd;

      if (smd_is_packet(alloc_elm)) {
            ch->read = smd_packet_read;
            ch->write = smd_packet_write;
            ch->read_avail = smd_packet_read_avail;
            ch->write_avail = smd_packet_write_avail;
            ch->update_state = update_packet_state;
            ch->read_from_cb = smd_packet_read_from_cb;
      } else {
            ch->read = smd_stream_read;
            ch->write = smd_stream_write;
            ch->read_avail = smd_stream_read_avail;
            ch->write_avail = smd_stream_write_avail;
            ch->update_state = update_stream_state;
            ch->read_from_cb = smd_stream_read;
      }

      memcpy(ch->name, alloc_elm->name, 20);
      ch->name[19] = 0;

      ch->pdev.name = ch->name;
      ch->pdev.id = ch->type;

      SMD_INFO("smd_alloc_channel() '%s' cid=%d\n",
             ch->name, ch->n);

      mutex_lock(&smd_creation_mutex);
      list_add(&ch->ch_list, &smd_ch_closed_list);
      mutex_unlock(&smd_creation_mutex);

      platform_device_register(&ch->pdev);
}

static void do_nothing_notify(void *priv, unsigned flags)
{
}

struct smd_channel *smd_get_channel(const char *name, uint32_t type)
{
      struct smd_channel *ch;

      mutex_lock(&smd_creation_mutex);
      list_for_each_entry(ch, &smd_ch_closed_list, ch_list) {
            if (!strcmp(name, ch->name) &&
                  (type == ch->type)) {
                  list_del(&ch->ch_list);
                  mutex_unlock(&smd_creation_mutex);
                  return ch;
            }
      }
      mutex_unlock(&smd_creation_mutex);

      return NULL;
}

int smd_named_open_on_edge(const char *name, uint32_t edge,
                     smd_channel_t **_ch,
                     void *priv, void (*notify)(void *, unsigned))
{
      struct smd_channel *ch;
      unsigned long flags;

      if (smd_initialized == 0) {
            SMD_INFO("smd_open() before smd_init()\n");
            return -ENODEV;
      }

      SMD_DBG("smd_open('%s', %p, %p)\n", name, priv, notify);

      ch = smd_get_channel(name, edge);
      if (!ch)
            return -ENODEV;

      if (notify == 0)
            notify = do_nothing_notify;

      ch->notify = notify;
      ch->current_packet = 0;
      ch->last_state = SMD_SS_CLOSED;
      ch->priv = priv;

      *_ch = ch;

      SMD_DBG("smd_open: opening '%s'\n", ch->name);

      spin_lock_irqsave(&smd_lock, flags);
      if (SMD_CHANNEL_TYPE(ch->type) == SMD_APPS_MODEM)
            list_add(&ch->ch_list, &smd_ch_list_modem);
      else
            list_add(&ch->ch_list, &smd_ch_list_dsp);

      SMD_DBG("%s: opening ch %d\n", __func__, ch->n);

      smd_state_change(ch, ch->last_state, SMD_SS_OPENING);

      spin_unlock_irqrestore(&smd_lock, flags);

      return 0;
}
EXPORT_SYMBOL(smd_named_open_on_edge);


int smd_open(const char *name, smd_channel_t **_ch,
           void *priv, void (*notify)(void *, unsigned))
{
      return smd_named_open_on_edge(name, SMD_APPS_MODEM, _ch, priv,
                              notify);
}
EXPORT_SYMBOL(smd_open);

int smd_close(smd_channel_t *ch)
{
      unsigned long flags;

      SMD_INFO("smd_close(%p)\n", ch);

      if (ch == 0)
            return -1;

      spin_lock_irqsave(&smd_lock, flags);
      ch->notify = do_nothing_notify;
      list_del(&ch->ch_list);
      ch_set_state(ch, SMD_SS_CLOSED);
      spin_unlock_irqrestore(&smd_lock, flags);

      mutex_lock(&smd_creation_mutex);
      list_add(&ch->ch_list, &smd_ch_closed_list);
      mutex_unlock(&smd_creation_mutex);

      return 0;
}
EXPORT_SYMBOL(smd_close);

int smd_read(smd_channel_t *ch, void *data, int len)
{
      return ch->read(ch, data, len);
}
EXPORT_SYMBOL(smd_read);

int smd_read_from_cb(smd_channel_t *ch, void *data, int len)
{
      return ch->read_from_cb(ch, data, len);
}
EXPORT_SYMBOL(smd_read_from_cb);

int smd_write(smd_channel_t *ch, const void *data, int len)
{
      return ch->write(ch, data, len);
}
EXPORT_SYMBOL(smd_write);

int smd_read_avail(smd_channel_t *ch)
{
      return ch->read_avail(ch);
}
EXPORT_SYMBOL(smd_read_avail);

int smd_write_avail(smd_channel_t *ch)
{
      return ch->write_avail(ch);
}
EXPORT_SYMBOL(smd_write_avail);

int smd_wait_until_readable(smd_channel_t *ch, int bytes)
{
      return -1;
}

int smd_wait_until_writable(smd_channel_t *ch, int bytes)
{
      return -1;
}

int smd_cur_packet_size(smd_channel_t *ch)
{
      return ch->current_packet;
}

int smd_tiocmget(smd_channel_t *ch)
{
      return  (ch->recv->fDSR ? TIOCM_DSR : 0) |
            (ch->recv->fCTS ? TIOCM_CTS : 0) |
            (ch->recv->fCD ? TIOCM_CD : 0) |
            (ch->recv->fRI ? TIOCM_RI : 0) |
            (ch->send->fCTS ? TIOCM_RTS : 0) |
            (ch->send->fDSR ? TIOCM_DTR : 0);
}

int smd_tiocmset(smd_channel_t *ch, unsigned int set, unsigned int clear)
{
      unsigned long flags;

      spin_lock_irqsave(&smd_lock, flags);
      if (set & TIOCM_DTR)
            ch->send->fDSR = 1;

      if (set & TIOCM_RTS)
            ch->send->fCTS = 1;

      if (clear & TIOCM_DTR)
            ch->send->fDSR = 0;

      if (clear & TIOCM_RTS)
            ch->send->fCTS = 0;

      ch->send->fSTATE = 1;
      barrier();
      ch->notify_other_cpu();
      spin_unlock_irqrestore(&smd_lock, flags);

      return 0;
}


/* -------------------------------------------------------------------------- */

void *smem_alloc(unsigned id, unsigned size)
{
      return smem_find(id, size);
}

void *smem_get_entry(unsigned id, unsigned *size)
{
      struct smem_shared *shared = (void *) MSM_SHARED_RAM_BASE;
      struct smem_heap_entry *toc = shared->heap_toc;

      if (id >= SMEM_NUM_ITEMS)
            return 0;

      if (toc[id].allocated) {
            *size = toc[id].size;
            return (void *) (MSM_SHARED_RAM_BASE + toc[id].offset);
      } else {
            *size = 0;
      }

      return 0;
}

void *smem_find(unsigned id, unsigned size_in)
{
      unsigned size;
      void *ptr;

      ptr = smem_get_entry(id, &size);
      if (!ptr)
            return 0;

      size_in = ALIGN(size_in, 8);
      if (size_in != size) {
            pr_err("smem_find(%d, %d): wrong size %d\n",
                   id, size_in, size);
            return 0;
      }

      return ptr;
}

static int smsm_init(void)
{
      struct smem_shared *shared = (void *) MSM_SHARED_RAM_BASE;
      int i;

      if (!smsm_info.state) {
            smsm_info.state = smem_alloc(ID_SHARED_STATE,
                                   SMSM_NUM_ENTRIES *
                                   sizeof(uint32_t));

            if (smsm_info.state) {
                  writel(0, SMSM_STATE_ADDR(SMSM_APPS_STATE));
                  if ((shared->version[VERSION_MODEM] >> 16) >= 0xB)
                        writel(0, SMSM_STATE_ADDR(SMSM_APPS_DEM_I));
            }
      }

      if (!smsm_info.intr_mask) {
            smsm_info.intr_mask = smem_alloc(SMEM_SMSM_CPU_INTR_MASK,
                                     SMSM_NUM_ENTRIES *
                                     SMSM_NUM_HOSTS *
                                     sizeof(uint32_t));

            if (smsm_info.intr_mask)
                  for (i = 0; i < SMSM_NUM_ENTRIES; i++)
                        writel(0xffffffff,
                               SMSM_INTR_MASK_ADDR(i, SMSM_APPS));
      }

      if (!smsm_info.intr_mux)
            smsm_info.intr_mux = smem_alloc(SMEM_SMD_SMSM_INTR_MUX,
                                    SMSM_NUM_INTR_MUX *
                                    sizeof(uint32_t));

      return 0;
}

void smsm_reset_modem(unsigned mode)
{
      if (mode == SMSM_SYSTEM_DOWNLOAD) {
            mode = SMSM_RESET | SMSM_SYSTEM_DOWNLOAD;
      } else if (mode == SMSM_MODEM_WAIT) {
            mode = SMSM_RESET | SMSM_MODEM_WAIT;
      } else { /* reset_mode is SMSM_RESET or default */
            mode = SMSM_RESET;
      }

      smsm_change_state(SMSM_APPS_STATE, mode, mode);
}
EXPORT_SYMBOL(smsm_reset_modem);

void smsm_reset_modem_cont(void)
{
      unsigned long flags;
      uint32_t state;

      if (!smsm_info.state)
            return;

      spin_lock_irqsave(&smem_lock, flags);
      state = readl(SMSM_STATE_ADDR(SMSM_APPS_STATE)) & ~SMSM_MODEM_WAIT;
      writel(state, SMSM_STATE_ADDR(SMSM_APPS_STATE));
      spin_unlock_irqrestore(&smem_lock, flags);
}
EXPORT_SYMBOL(smsm_reset_modem_cont);

static irqreturn_t smsm_irq_handler(int irq, void *data)
{
      unsigned long flags;
      static uint32_t prev_smem_q6_apps_smsm;
      uint32_t mux_val;

      smsm_init();
      if (irq == INT_ADSP_A11) {
            if (!smsm_info.intr_mux)
                  return IRQ_HANDLED;
            mux_val = readl(SMSM_INTR_MUX_ADDR(SMEM_Q6_APPS_SMSM));
            if (mux_val == prev_smem_q6_apps_smsm)
                  return IRQ_HANDLED;

            prev_smem_q6_apps_smsm = mux_val;
      }

      spin_lock_irqsave(&smem_lock, flags);
      if (!smsm_info.state) {
            SMSM_INFO("<SM NO STATE>\n");
      } else {
            unsigned old_apps, apps;
            unsigned modm = readl(SMSM_STATE_ADDR(SMSM_MODEM_STATE));

            old_apps = apps = readl(SMSM_STATE_ADDR(SMSM_APPS_STATE));

            SMSM_DBG("<SM %08x %08x>\n", apps, modm);
            if (apps & SMSM_RESET) {
                  /* If we get an interrupt and the apps SMSM_RESET
                     bit is already set, the modem is acking the
                     app's reset ack. */
                  apps &= ~SMSM_RESET;

                  /* Issue a fake irq to handle any
                   * smd state changes during reset
                   */
                  smd_fake_irq_handler(0);

                  /* queue modem restart notify chain */
                  modem_queue_start_reset_notify();

            } else if (modm & SMSM_RESET) {
                  apps |= SMSM_RESET;
            } else {
                  apps |= SMSM_INIT;
                  if (modm & SMSM_SMDINIT)
                        apps |= SMSM_SMDINIT;
                  if (modm & SMSM_RPCINIT)
                        apps |= SMSM_RPCINIT;
                  if ((apps & (SMSM_INIT | SMSM_SMDINIT | SMSM_RPCINIT)) ==
                        (SMSM_INIT | SMSM_SMDINIT | SMSM_RPCINIT))
                        apps |= SMSM_RUN;
            }

            if (old_apps != apps) {
                  SMSM_DBG("<SM %08x NOTIFY>\n", apps);
                  writel(apps, SMSM_STATE_ADDR(SMSM_APPS_STATE));
                  do_smd_probe();
                  notify_other_smsm(SMSM_APPS_STATE, (old_apps ^ apps));
            }
      }
      spin_unlock_irqrestore(&smem_lock, flags);
      return IRQ_HANDLED;
}

int smsm_change_intr_mask(uint32_t smsm_entry,
                    uint32_t clear_mask, uint32_t set_mask)
{
      uint32_t  old_mask, new_mask;
      unsigned long flags;

      if (smsm_entry >= SMSM_NUM_ENTRIES) {
            pr_err("smsm_change_state: Invalid entry %d\n",
                   smsm_entry);
            return -EINVAL;
      }

      if (!smsm_info.intr_mask) {
            pr_err("smsm_change_intr_mask <SM NO STATE>\n");
            return -EIO;
      }

      spin_lock_irqsave(&smem_lock, flags);

      old_mask = readl(SMSM_INTR_MASK_ADDR(smsm_entry, SMSM_APPS));
      new_mask = (old_mask & ~clear_mask) | set_mask;
      writel(new_mask, SMSM_INTR_MASK_ADDR(smsm_entry, SMSM_APPS));

      spin_unlock_irqrestore(&smem_lock, flags);

      return 0;
}

int smsm_get_intr_mask(uint32_t smsm_entry, uint32_t *intr_mask)
{
      if (smsm_entry >= SMSM_NUM_ENTRIES) {
            pr_err("smsm_change_state: Invalid entry %d\n",
                   smsm_entry);
            return -EINVAL;
      }

      if (!smsm_info.intr_mask) {
            pr_err("smsm_change_intr_mask <SM NO STATE>\n");
            return -EIO;
      }

      *intr_mask = readl(SMSM_INTR_MASK_ADDR(smsm_entry, SMSM_APPS));
      return 0;
}

int smsm_change_state(uint32_t smsm_entry,
                  uint32_t clear_mask, uint32_t set_mask)
{
      unsigned long flags;
      uint32_t  old_state, new_state;

      if (smsm_entry >= SMSM_NUM_ENTRIES) {
            pr_err("smsm_change_state: Invalid entry %d",
                   smsm_entry);
            return -EINVAL;
      }

      if (!smsm_info.state) {
            pr_err("smsm_change_state <SM NO STATE>\n");
            return -EIO;
      }
      spin_lock_irqsave(&smem_lock, flags);

      old_state = readl(SMSM_STATE_ADDR(smsm_entry));
      new_state = (old_state & ~clear_mask) | set_mask;
      writel(new_state, SMSM_STATE_ADDR(smsm_entry));
      SMSM_DBG("smsm_change_state %x\n", new_state);
      notify_other_smsm(SMSM_APPS_STATE, (old_state ^ new_state));

      spin_unlock_irqrestore(&smem_lock, flags);

      return 0;
}

uint32_t smsm_get_state(uint32_t smsm_entry)
{
      uint32_t rv = 0;

      /* needs interface change to return error code */
      if (smsm_entry >= SMSM_NUM_ENTRIES) {
            pr_err("smsm_change_state: Invalid entry %d",
                   smsm_entry);
            return 0;
      }

      if (!smsm_info.state)
            pr_err("smsm_get_state <SM NO STATE>\n");
      else
            rv = readl(SMSM_STATE_ADDR(smsm_entry));

      return rv;
}

int smd_core_init(void)
{
      int r;
      SMD_INFO("smd_core_init()\n");

      r = request_irq(INT_A9_M2A_0, smd_modem_irq_handler,
                  IRQF_TRIGGER_RISING, "smd_dev", 0);
      if (r < 0)
            return r;
      r = enable_irq_wake(INT_A9_M2A_0);
      if (r < 0)
            pr_err("smd_core_init: "
                   "enable_irq_wake failed for INT_A9_M2A_0\n");

      r = request_irq(INT_A9_M2A_5, smsm_irq_handler,
                  IRQF_TRIGGER_RISING, "smsm_dev", 0);
      if (r < 0) {
            free_irq(INT_A9_M2A_0, 0);
            return r;
      }
      r = enable_irq_wake(INT_A9_M2A_5);
      if (r < 0)
            pr_err("smd_core_init: "
                   "enable_irq_wake failed for INT_A9_M2A_5\n");

#if defined(CONFIG_QDSP6)
      r = request_irq(INT_ADSP_A11, smd_dsp_irq_handler,
                  IRQF_TRIGGER_RISING | IRQF_SHARED, "smd_dev",
                  smd_dsp_irq_handler);
      if (r < 0) {
            free_irq(INT_A9_M2A_0, 0);
            free_irq(INT_A9_M2A_5, 0);
            return r;
      }

      r = request_irq(INT_ADSP_A11, smsm_irq_handler,
                  IRQF_TRIGGER_RISING | IRQF_SHARED, "smsm_dev",
                  smsm_irq_handler);
      if (r < 0) {
            free_irq(INT_A9_M2A_0, 0);
            free_irq(INT_A9_M2A_5, 0);
            free_irq(INT_ADSP_A11, 0);
            return r;
      }

      r = enable_irq_wake(INT_ADSP_A11);
      if (r < 0)
            pr_err("smd_core_init: "
                   "enable_irq_wake failed for INT_ADSP_A11\n");
#endif

      /* we may have missed a signal while booting -- fake
       * an interrupt to make sure we process any existing
       * state
       */
      smsm_irq_handler(0, 0);

      SMD_INFO("smd_core_init() done\n");

      return 0;
}

static int __init msm_smd_probe(struct platform_device *pdev)
{
      /* enable smd and smsm info messages */
      msm_smd_debug_mask = 0xc;

      SMD_INFO("smd probe\n");

      INIT_WORK(&probe_work, smd_channel_probe_worker);

      if (smsm_init()) {
            pr_err("smsm_init() failed\n");
            return -1;
      }

      if (smd_core_init()) {
            pr_err("smd_core_init() failed\n");
            return -1;
      }

      do_smd_probe();

      msm_check_for_modem_crash = check_for_modem_crash;

      smd_initialized = 1;

      return 0;
}

static struct platform_driver msm_smd_driver = {
      .probe = msm_smd_probe,
      .driver = {
            .name = MODULE_NAME,
            .owner = THIS_MODULE,
      },
};

static int __init msm_smd_init(void)
{
      return platform_driver_register(&msm_smd_driver);
}

module_init(msm_smd_init);

MODULE_DESCRIPTION("MSM Shared Memory Core");
MODULE_AUTHOR("Brian Swetland <swetland@google.com>");
MODULE_LICENSE("GPL");

Generated by  Doxygen 1.6.0   Back to index