equal
deleted
inserted
replaced
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) |