Mirror of forum.nim-lang.org

1876 :: asyncDispatch and fsmonitor

• qqtop (orginal) [2015-12-15T13:04:13+01:00] view original

  This works with asyncio , but how to do this with asyncdispatch ?

  import os,osproc,fsmonitor,strutils,times
  import asyncio,net
  #import asyncdispatch,asyncnet
  
  
  var disp    = newDispatcher()
  var monitor = newMonitor()
  
  let orgDir  = "/home/lxuser/Dropbox/Test"
  
  monitor.add(orgDir)
  
  disp.register(monitor,proc (m: FSMonitor, ev: MonitorEvent) =
      echo("Got event: " & $ev.kind & " at : " & $getLocalTime(getTime())))
  
  proc main() =
      while true:
          try:
              if not disp.poll(): break
          except KeyError:
              echo "Hello KeyError detected"
  
  
  
  main()
  Run

---

• dom96 (orginal) [2015-12-15T23:09:39+01:00] view original

  Unfortunately the fsmonitor needs an asyncdispatch implementation, it also need to gain support for Windows but that's another issue...

  What you can do right now, as a workaround, is use both asyncdispatch and asyncio at the same time.

  import os,osproc,fsmonitor,strutils,times
  import asyncio,net
  import asyncdispatch,asyncnet
  
  
  var disp    = newDispatcher()
  var monitor = newMonitor()
  
  let orgDir  = "/home/lxuser/Dropbox/Test"
  
  monitor.add(orgDir)
  
  disp.register(monitor,proc (m: FSMonitor, ev: MonitorEvent) =
      echo("Got event: " & $ev.kind & " at : " & $getLocalTime(getTime())))
  
  proc main() {.async.} =
      while true:
          try:
              if not disp.poll(1): break
              await sleepAsync(1000)
          except KeyError:
              echo "Hello KeyError detected"
  
  
  
  asyncCheck main()
  runForever()
  Run

  Something like that should work (I haven't tested it).

---

• qqtop (orginal) [2015-12-16T01:50:41+01:00] view original

  Thank you , but this gives :

  Error: ambiguous call; both asyncio.newDispatcher() and asyncdispatch.newDispatcher() match for: ()
  Run

  changing this line to avoid ambiguity :

  # var disp  = newDispatcher()
  var disp    = asyncio.newDispatcher()
  Run

  unfortunately results in:

  lib/pure/asyncdispatch.nim(1254, 8) Error: 'cb' is not GC-safe as it accesses 'nameIterVar' which is a global using GC'ed memory
  Run

---

• dom96 (orginal) [2015-12-16T10:46:41+01:00] view original

  Are you compiling with --threads:on?

---

• qqtop (orginal) [2015-12-16T12:45:02+01:00] view original

  Yes, you are correct --threads:on as the plan was to have some other processing done via spawn later.

  With threads off the snippet compiles fine.

---