import qemu
import os
import sys

class syborg_serial(qemu.devclass):
  REG_ID           = 0
  REG_DATA         = 1
  REG_FIFO_COUNT   = 2
  REG_INT_ENABLE   = 3
  REG_DMA_TX_ADDR  = 4
  REG_DMA_TX_COUNT = 5 # triggers dma
  REG_DMA_RX_ADDR  = 6
  REG_DMA_RX_COUNT = 7 # triggers dma

  def update_irq(self):
    level = 2 # TX DMA complete
    if len(self.fifo) > 0:
      level |= 1 # FIFO not empty
    if self.dma_rx_count == 0:
      level |= 4 # RX DMA complete
    self.set_irq_level(0, (level & self.int_enable) != 0)

  def can_receive(self):
    return self.fifo_size - len(self.fifo)

  def receive(self, buf):
    for x in buf:
      ch = ord(x)
      if self.dma_rx_count > 0:
        self.dma_writeb(self.dma_rx_addr, ch)
        self.dma_rx_addr += 1
        self.dma_rx_count -= 1
      else:
        self.fifo.append(ch)
    self.update_irq()

  def do_dma_tx(self, count):
    # TODO: Optimize block transmits.
    while count > 0:
      ch = self.dma_readb(self.dma_tx_addr)
      self.chardev.write(ch)
      self.dma_tx_addr += 1
      count -= 1
    self.update_irq()

  def dma_rx_start(self, count):
    while (count > 0) and (len(self.fifo) > 0):
      ch = self.fifo.pop(0)
      self.dma_writeb(self.dma_rx_addr, ch)
      self.dma_rx_addr += 1
      count -= 1
    self.dma_rx_count = count
    self.update_irq()

  def create(self):
    self.fifo_size = self.properties["fifo-size"]
    self.chardev = self.properties["chardev"]
    self.fifo=[]
    self.int_enable = 0
    self.chardev.set_handlers(self.can_receive, self.receive)
    self.dma_tx_addr = 0
    self.dma_rx_addr = 0
    self.dma_rx_count = 0

  def read_reg(self, offset):
    offset >>= 2
    if offset == self.REG_ID:
      return 0xc51d0001
    elif offset == self.REG_DATA:
      if len(self.fifo) == 0:
        return 0xffffffff
      val = self.fifo.pop(0)
      self.update_irq();
      return val
    elif offset == self.REG_FIFO_COUNT:
      return len(self.fifo)
    elif offset == self.REG_INT_ENABLE:
      return self.int_enable
    elif offset == self.REG_DMA_TX_ADDR:
      return self.dma_tx_addr
    elif offset == self.REG_DMA_TX_COUNT:
      return 0
    elif offset == self.REG_DMA_RX_ADDR:
      return self.dma_rx_addr
    elif offset == self.REG_DMA_RX_COUNT:
      return self.dma_rx_count
    return 0

  def write_reg(self, offset, value):
    offset >>= 2
    if offset == self.REG_DATA:
      self.chardev.write(value)
    elif offset == self.REG_INT_ENABLE:
      self.int_enable = value & 7
      self.update_irq()
    elif offset == self.REG_DMA_TX_ADDR:
      self.dma_tx_addr = value
    elif offset == self.REG_DMA_TX_COUNT:
      self.do_dma_tx(value)
    elif offset == self.REG_DMA_RX_ADDR:
      self.dma_rx_addr = value
    elif offset == self.REG_DMA_RX_COUNT:
      self.dma_rx_start(value)

  def save(self, f):
    f.put_u32(self.fifo_size)
    f.put_u32(self.int_enable)
    f.put_u32(self.dma_tx_addr)
    f.put_u32(self.dma_rx_addr)
    f.put_u32(self.dma_rx_count)
    f.put_u32(len(self.fifo))
    for x in self.fifo:
      f.put_u32(x)

  def load(self, f):
    if self.fifo_size != f.get_u32():
      raise ValueError, "fifo size mismatch"
    self.int_enable = f.get_u32()
    self.dma_tx_addr = f.get_u32()
    self.dma_rx_addr = f.get_u32()
    self.dma_rx_count = f.get_u32()
    n = f.get_u32()
    self.fifo = []
    while n > 0:
      self.fifo.append(f.get_u32())
      n -= 1;

  # Device class properties
  regions = [qemu.ioregion(0x1000, readl=read_reg, writel=write_reg)]
  irqs = 1
  name = "syborg,serial"
  properties = {"fifo-size":16, "chardev":None, "target": ""}

qemu.register_device(syborg_serial)

class syborg_modem(syborg_serial):
  
  def create(self):
    syborg_serial.create(self)
    
    # Find the path of the emulator executable
    path = os.path.dirname(sys.executable)
    executable = os.getenv("SVP_MODEM_EXECUTABLE")
    if None == executable:
      executable = self.modem_executable
    
    executable_name = executable
    fq_executable = os.path.join(path, executable_name)
    print(fq_executable)
    
    if not os.path.exists(fq_executable):
      executable_name = executable + ".exe"
      fq_executable = os.path.join(path, executable_name)
      
      if not os.path.exists(fq_executable):
        sys.exit("Could not locate modem executable '" + executable + "' in '" + path + "'!\n")
    
    # Attempt to find the correct port from the target spec
    target = self.properties["target"]
    
    if not(target.startswith("tcp:") or target.startswith("udp:")):
      sys.exit("Modem device is not accessed via an acceptable socket.")
    
    target = target[4:]
    port_start_idx = target.find(":");
    port_end_idx = target.find(",")
    if -1 == port_start_idx:
      sys.exit("Could not extract port number from modem target spec!")
    
    port = ""
    if -1 == port_end_idx:
      port = target[port_start_idx + 1:]
    else:
      port = target[port_start_idx + 1:port_end_idx]
    
    os.spawnl(os.P_NOWAIT, fq_executable, executable_name, "-p", port)
    self.chardev.handle_connect()
  
  # Name property override.
  name = "syborg,serial,modem"
  
  # Default modem executable
  modem_executable = "phonesim"

qemu.register_device(syborg_modem)