feed event client ack into the event master queue from listener threads

source/daemons/qmaster/sge_qmaster_process_message.cc

@@ -158,10 +158,19 @@ do_c_ack_request(struct_msg_t *message, monitoring_t *monitor) {
       }
 
       // store the request for a handling thread
-      // sge_c_ack() will be called by the worker thread to execute the ACK request stored here
-      lList *ack_list = lCreateList("ACK list", lGetElemDescr(ack));
-      lAppendElem(ack_list, ack);
-      ocs_store_packet(message, ack_list, PACKET_ACK_REQUEST);
+      if (ack_tag == ACK_EVENT_DELIVERY) {
+         // event ACKs are handled in the event master thread
+         // sge_handle_event_ack stores them into the event master message queue
+         u_long32 ack_ulong = lGetUlong(ack, ACK_id);
+         u_long32 ack_ulong2 = lGetUlong(ack, ACK_id2);
+         sge_handle_event_ack(ack_ulong2, (ev_event) ack_ulong);
+         lFreeElem(&ack);
+      } else {
+         // sge_c_ack() will be called by the worker thread to execute the ACK request stored here
+         lList *ack_list = lCreateList("ACK list", lGetElemDescr(ack));
+         lAppendElem(ack_list, ack);
+         ocs_store_packet(message, ack_list, PACKET_ACK_REQUEST);
+      }
    }
 }