Improved the ZeroMQ server send method

Author: adeas31

Compiler/Main/Main.mo

@@ -878,7 +878,7 @@ algorithm
   end if;
 
   // Don't allow running omc as root due to security risks.
-  if System.userIsRoot() and (Flags.isSet(Flags.INTERACTIVE) or Flags.isSet(Flags.INTERACTIVE_CORBA)) then
+  if System.userIsRoot() and (Flags.isSet(Flags.INTERACTIVE) or Flags.isSet(Flags.INTERACTIVE_CORBA) or Flags.isSet(Flags.INTERACTIVE_ZMQ)) then
     Error.addMessage(Error.ROOT_USER_INTERACTIVE, {});
     print(ErrorExt.printMessagesStr(false));
     fail();

Compiler/runtime/zeromqimpl.c

@@ -80,7 +80,15 @@ void ZeroMQ_sendReply(void *mmcZmqSocket, const char* reply)
   intptr_t zmqSocket = (intptr_t)MMC_FETCH(MMC_OFFSET(MMC_UNTAGPTR(mmcZmqSocket),1));
   // send the reply
   //fprintf(stdout, "Sending message %s\n", reply);fflush(NULL);
-  zmq_send((void*)zmqSocket, reply, strlen(reply) + 1, 0);
+  // Create an empty ZeroMQ message to hold the message part
+  zmq_msg_t replyMsg;
+  zmq_msg_init_size(&replyMsg, strlen(reply));
+  // copy the char* to zmq_msg_t
+  memcpy(zmq_msg_data(&replyMsg), reply, strlen(reply));
+  // send the message
+  zmq_msg_send(&replyMsg, (void*)zmqSocket, 0);
+  // release the zmq_msg_t
+  zmq_msg_close(&replyMsg);
 }
 
 void ZeroMQ_close(void *mmcZmqSocket)