src/Pure/General/sql.scala
changeset 79726 621676d7fb9a
parent 79725 abb5eedfeecf
child 79727 529a6e35aaa9
equal deleted inserted replaced
79725:abb5eedfeecf 79726:621676d7fb9a
   803         val conn = the_postgresql_connection
   803         val conn = the_postgresql_connection
   804         val self_pid = conn.getBackendPID
   804         val self_pid = conn.getBackendPID
   805 
   805 
   806         try {
   806         try {
   807           while (true) {
   807           while (true) {
   808             Isabelle_Thread.interruptible { receiver_delay.sleep() }
   808             Isabelle_Thread.interruptible { receiver_delay.sleep(); Option(conn.getNotifications())}
   809             Option(conn.getNotifications()) match {
   809             match {
   810               case Some(array) if array.nonEmpty =>
   810               case Some(array) if array.nonEmpty =>
   811                 synchronized {
   811                 synchronized {
   812                   var received = _receiver_buffer.getOrElse(Map.empty)
   812                   var received = _receiver_buffer.getOrElse(Map.empty)
   813                   for (a <- array.iterator if a.getPID != self_pid) {
   813                   for (a <- array.iterator if a.getPID != self_pid) {
   814                     val msg = SQL.Notification(a.getName, a.getParameter)
   814                     val msg = SQL.Notification(a.getName, a.getParameter)