Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Added ZeroMQ communication interface
- Loading branch information
Showing
15 changed files
with
284 additions
and
8 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,70 @@ | ||
| /* | ||
| * This file is part of OpenModelica. | ||
| * | ||
| * Copyright (c) 1998-2014, Open Source Modelica Consortium (OSMC), | ||
| * c/o Linköpings universitet, Department of Computer and Information Science, | ||
| * SE-58183 Linköping, Sweden. | ||
| * | ||
| * All rights reserved. | ||
| * | ||
| * THIS PROGRAM IS PROVIDED UNDER THE TERMS OF GPL VERSION 3 LICENSE OR | ||
| * THIS OSMC PUBLIC LICENSE (OSMC-PL) VERSION 1.2. | ||
| * ANY USE, REPRODUCTION OR DISTRIBUTION OF THIS PROGRAM CONSTITUTES | ||
| * RECIPIENT'S ACCEPTANCE OF THE OSMC PUBLIC LICENSE OR THE GPL VERSION 3, | ||
| * ACCORDING TO RECIPIENTS CHOICE. | ||
| * | ||
| * The OpenModelica software and the Open Source Modelica | ||
| * Consortium (OSMC) Public License (OSMC-PL) are obtained | ||
| * from OSMC, either from the above address, | ||
| * from the URLs: http://www.ida.liu.se/projects/OpenModelica or | ||
| * http://www.openmodelica.org, and in the OpenModelica distribution. | ||
| * GNU version 3 is obtained from: http://www.gnu.org/copyleft/gpl.html. | ||
| * | ||
| * This program is distributed WITHOUT ANY WARRANTY; without | ||
| * even the implied warranty of MERCHANTABILITY or FITNESS | ||
| * FOR A PARTICULAR PURPOSE, EXCEPT AS EXPRESSLY SET FORTH | ||
| * IN THE BY RECIPIENT SELECTED SUBSIDIARY LICENSE CONDITIONS OF OSMC-PL. | ||
| * | ||
| * See the full OSMC Public License conditions for more details. | ||
| * | ||
| */ | ||
|
|
||
| encapsulated package ZeroMQ | ||
| " file: ZeroMQ.mo | ||
| package: ZeroMQ | ||
| description: ZeroMQ communication module | ||
|
|
||
|
|
||
| This is the ZeroMQ connection module of the compiler | ||
| Used in interactive mode if omc is started with +d=interactiveZMQ | ||
| Implemented in ./runtime/zeromqimpl.c" | ||
|
|
||
| public function initialize | ||
| input Integer port; | ||
| output Option<Integer> zmqSocket; | ||
|
|
||
| external "C" zmqSocket = ZeroMQ_initialize(port) annotation(Library = "omcruntime"); | ||
| end initialize; | ||
|
|
||
| public function handleRequest | ||
| input Option<Integer> zmqSocket; | ||
| output String request; | ||
|
|
||
| external "C" request = ZeroMQ_handleRequest(zmqSocket) annotation(Library = "omcruntime"); | ||
| end handleRequest; | ||
|
|
||
| public function sendReply | ||
| input Option<Integer> zmqSocket; | ||
| input String reply; | ||
|
|
||
| external "C" ZeroMQ_sendReply(zmqSocket, reply) annotation(Library = "omcruntime"); | ||
| end sendReply; | ||
|
|
||
| public function close | ||
| input Option<Integer> zmqSocket; | ||
|
|
||
| external "C" ZeroMQ_close(zmqSocket) annotation(Library = "omcruntime"); | ||
| end close; | ||
|
|
||
| annotation(__OpenModelica_Interface="util"); | ||
| end ZeroMQ; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,49 @@ | ||
| /* | ||
| * This file is part of OpenModelica. | ||
| * | ||
| * Copyright (c) 1998-2010, Linköpings University, | ||
| * Department of Computer and Information Science, | ||
| * SE-58183 Linköping, Sweden. | ||
| * | ||
| * All rights reserved. | ||
| * | ||
| * THIS PROGRAM IS PROVIDED UNDER THE TERMS OF THIS OSMC PUBLIC | ||
| * LICENSE (OSMC-PL). ANY USE, REPRODUCTION OR DISTRIBUTION OF | ||
| * THIS PROGRAM CONSTITUTES RECIPIENT'S ACCEPTANCE OF THE OSMC | ||
| * PUBLIC LICENSE. | ||
| * | ||
| * The OpenModelica software and the Open Source Modelica | ||
| * Consortium (OSMC) Public License (OSMC-PL) are obtained | ||
| * from Linköpings University, either from the above address, | ||
| * from the URL: http://www.ida.liu.se/projects/OpenModelica | ||
| * and in the OpenModelica distribution. | ||
| * | ||
| * This program is distributed WITHOUT ANY WARRANTY; without | ||
| * even the implied warranty of MERCHANTABILITY or FITNESS | ||
| * FOR A PARTICULAR PURPOSE, EXCEPT AS EXPRESSLY SET FORTH | ||
| * IN THE BY RECIPIENT SELECTED SUBSIDIARY LICENSE CONDITIONS | ||
| * OF OSMC-PL. | ||
| * | ||
| * See the full OSMC Public License conditions for more details. | ||
| * | ||
| */ | ||
|
|
||
| #if defined(_MSC_VER) || defined(__MINGW32__) | ||
| #define WIN32_LEAN_AND_MEAN | ||
| #include <windows.h> | ||
| #endif | ||
|
|
||
| #include <stdio.h> | ||
| #include <meta_modelica.h> | ||
|
|
||
| #include "zeromqimpl.c" | ||
| #include "meta_modelica.h" | ||
| #include "ModelicaUtilities.h" | ||
|
|
||
| extern const char* ZeroMQ_handleRequest(void* mmcZmqSocket) | ||
| { | ||
| char *str = ZeroMQImpl_handleRequest(mmcZmqSocket); | ||
| char *res = strcpy(ModelicaAllocateString(strlen(str)),str); | ||
| free(str); | ||
| return res; | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,82 @@ | ||
| /* | ||
| * This file is part of OpenModelica. | ||
| * | ||
| * Copyright (c) 1998-2010, Linköpings University, | ||
| * Department of Computer and Information Science, | ||
| * SE-58183 Linköping, Sweden. | ||
| * | ||
| * All rights reserved. | ||
| * | ||
| * THIS PROGRAM IS PROVIDED UNDER THE TERMS OF THIS OSMC PUBLIC | ||
| * LICENSE (OSMC-PL). ANY USE, REPRODUCTION OR DISTRIBUTION OF | ||
| * THIS PROGRAM CONSTITUTES RECIPIENT'S ACCEPTANCE OF THE OSMC | ||
| * PUBLIC LICENSE. | ||
| * | ||
| * The OpenModelica software and the Open Source Modelica | ||
| * Consortium (OSMC) Public License (OSMC-PL) are obtained | ||
| * from Linköpings University, either from the above address, | ||
| * from the URL: http://www.ida.liu.se/projects/OpenModelica | ||
| * and in the OpenModelica distribution. | ||
| * | ||
| * This program is distributed WITHOUT ANY WARRANTY; without | ||
| * even the implied warranty of MERCHANTABILITY or FITNESS | ||
| * FOR A PARTICULAR PURPOSE, EXCEPT AS EXPRESSLY SET FORTH | ||
| * IN THE BY RECIPIENT SELECTED SUBSIDIARY LICENSE CONDITIONS | ||
| * OF OSMC-PL. | ||
| * | ||
| * See the full OSMC Public License conditions for more details. | ||
| * | ||
| */ | ||
|
|
||
| #include <zmq.h> | ||
| #include <stdio.h> | ||
| #include <unistd.h> | ||
| #include <string.h> | ||
|
|
||
| #include "modelica_string.h" | ||
|
|
||
| void* ZeroMQ_initialize(int port) | ||
| { | ||
| // Create a pointer for storing the ZeroMQ socket | ||
| void *mmcZmqSocket = mmc_mk_some(0); | ||
| // Create the ZeroMQ context | ||
| void *context = zmq_ctx_new(); | ||
| void *zmqSocket = zmq_socket(context, ZMQ_REP); | ||
| char hostname[20]; | ||
| sprintf(hostname, "tcp://*:%d", port); | ||
| int rc = zmq_bind(zmqSocket, hostname); | ||
| if (rc != 0) { | ||
| printf("Error creating ZeroMQ Server\n"); | ||
| return mmcZmqSocket; | ||
| } | ||
| mmcZmqSocket = mmc_mk_some(zmqSocket); | ||
| return mmcZmqSocket; | ||
| } | ||
|
|
||
| extern char* ZeroMQImpl_handleRequest(void *mmcZmqSocket) | ||
| { | ||
| int bufferSize = 4000; | ||
| char *buffer = (char*)malloc(bufferSize + 1); | ||
| // Convert the void* to ZeroMQ Socket | ||
| intptr_t zmqSocket = (intptr_t)MMC_FETCH(MMC_OFFSET(MMC_UNTAGPTR(mmcZmqSocket),1)); | ||
| zmq_recv((void*)zmqSocket, buffer, bufferSize, 0); | ||
| fprintf(stdout, "Recieved message %s\n", buffer);fflush(NULL); | ||
| return buffer; | ||
| } | ||
|
|
||
| void ZeroMQ_sendReply(void *mmcZmqSocket, const char* reply) | ||
| { | ||
| // Convert the void* to ZeroMQ Socket | ||
| 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); | ||
| } | ||
|
|
||
| void ZeroMQ_close(void *mmcZmqSocket) | ||
| { | ||
| // Convert the void* to ZeroMQ Socket | ||
| intptr_t zmqSocket = (intptr_t)MMC_FETCH(MMC_OFFSET(MMC_UNTAGPTR(mmcZmqSocket),1)); | ||
| // close the ZeroMQ socket | ||
| zmq_close((void*)zmqSocket); | ||
| } |
Oops, something went wrong.