{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2025,9,28]],"date-time":"2025-09-28T20:35:32Z","timestamp":1759091732854,"version":"3.41.0"},"reference-count":34,"publisher":"Association for Computing Machinery (ACM)","issue":"3","license":[{"start":{"date-parts":[[2019,7,31]],"date-time":"2019-07-31T00:00:00Z","timestamp":1564531200000},"content-version":"vor","delay-in-days":0,"URL":"https:\/\/www.acm.org\/publications\/policies\/copyright_policy#Background"}],"funder":[{"DOI":"10.13039\/100007297","name":"Office of Naval Research","doi-asserted-by":"publisher","award":["N000141612108"],"award-info":[{"award-number":["N000141612108"]}],"id":[{"id":"10.13039\/100007297","id-type":"DOI","asserted-by":"publisher"}]},{"DOI":"10.13039\/100000001","name":"National Science Foundation","doi-asserted-by":"publisher","award":["1329861"],"award-info":[{"award-number":["1329861"]}],"id":[{"id":"10.13039\/100000001","id-type":"DOI","asserted-by":"publisher"}]}],"content-domain":{"domain":["dl.acm.org"],"crossmark-restriction":true},"short-container-title":["ACM Trans. Cyber-Phys. Syst."],"published-print":{"date-parts":[[2019,7,31]]},"abstract":"<jats:p>Cyber-physical systems (CPS) involve tight integration of cyber (computation) and physical domains, and both the effectiveness and correctness of a cyber-physical system application may rely on successful enforcement of constraints such as bounded latency and temporal validity subject to physical conditions. For many such systems (e.g., edge computing in the Industrial Internet of Things), it is desirable to enforce such constraints within a common middleware service (e.g., during event processing). In this article, we introduce CPEP, a new real-time middleware for &lt;underline&gt;c&lt;\/underline&gt;yber-&lt;underline&gt;p&lt;\/underline&gt;hysical &lt;underline&gt;e&lt;\/underline&gt;vent &lt;underline&gt;p&lt;\/underline&gt;rocessing, with (1)\u00a0extensible support for complex event processing operations, (2)\u00a0execution prioritization and sharing, (3)\u00a0enforcement of time consistency with load shedding, and (4)\u00a0efficient memory management and concurrent data processing. We present the design, implementation, and empirical evaluation of CPEP and show that it can (1)\u00a0support complex operations needed by many applications, (2)\u00a0schedule data processing according to consumers\u2019 priority levels, (3)\u00a0enforce temporal validity, and (4)\u00a0reduce processing delay and improve throughput of time-consistent events.<\/jats:p>","DOI":"10.1145\/3218816","type":"journal-article","created":{"date-parts":[[2019,8,20]],"date-time":"2019-08-20T19:51:56Z","timestamp":1566330716000},"page":"1-25","update-policy":"https:\/\/doi.org\/10.1145\/crossmark-policy","source":"Crossref","is-referenced-by-count":2,"title":["Real-Time Middleware for Cyber-Physical Event Processing"],"prefix":"10.1145","volume":"3","author":[{"ORCID":"https:\/\/orcid.org\/0000-0003-0919-8781","authenticated-orcid":false,"given":"Chao","family":"Wang","sequence":"first","affiliation":[{"name":"Washington University in St. Louis, MO, USA"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Christopher","family":"Gill","sequence":"additional","affiliation":[{"name":"Washington University in St. Louis, MO, USA"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Chenyang","family":"Lu","sequence":"additional","affiliation":[{"name":"Washington University in St. Louis, MO, USA"}],"role":[{"role":"author","vocabulary":"crossref"}]}],"member":"320","published-online":{"date-parts":[[2019,8,20]]},"reference":[{"volume-title":"Apache Flink Home Page. Retrieved","year":"2017","key":"e_1_2_1_1_1"},{"key":"e_1_2_1_3_1","doi-asserted-by":"publisher","DOI":"10.1145\/1827418.1827427"},{"key":"e_1_2_1_4_1","doi-asserted-by":"publisher","DOI":"10.1145\/2187671.2187677"},{"key":"e_1_2_1_5_1","doi-asserted-by":"publisher","DOI":"10.1145\/1978802.1978814"},{"key":"e_1_2_1_7_1","doi-asserted-by":"publisher","DOI":"10.1016\/j.inffus.2010.06.001"},{"volume-title":"Evans and Marco Annunziata","year":"2012","author":"Peter","key":"e_1_2_1_8_1"},{"volume-title":"Retrieved","year":"2017","key":"e_1_2_1_9_1"},{"volume-title":"Retrieved","year":"2017","author":"Foundation The Linux","key":"e_1_2_1_10_1"},{"volume-title":"FFTW Home Page. Retrieved","year":"2017","author":"Frigo Matteo","key":"e_1_2_1_11_1"},{"volume-title":"Complex Event Processing for Flink. Retrieved","year":"2017","key":"e_1_2_1_12_1"},{"key":"e_1_2_1_13_1","unstructured":"GitHub. 2017. PTP Daemon. Retrieved September 7 2017 from https:\/\/github.com\/ptpd\/ptpd.  GitHub. 2017. PTP Daemon. Retrieved September 7 2017 from https:\/\/github.com\/ptpd\/ptpd."},{"volume-title":"Retrieved","year":"2017","author":"PG.","key":"e_1_2_1_14_1"},{"volume-title":"Retrieved","year":"2015","author":"Object Management Group","key":"e_1_2_1_15_1"},{"key":"e_1_2_1_16_1","doi-asserted-by":"publisher","DOI":"10.1145\/2933267.2933519"},{"key":"e_1_2_1_17_1","doi-asserted-by":"publisher","DOI":"10.1109\/RTSS.2008.40"},{"key":"e_1_2_1_18_1","doi-asserted-by":"publisher","DOI":"10.1145\/263700.263734"},{"volume-title":"IEEE standard for a precision clock synchronization protocol for networked measurement and control systems\u2014Redline","year":"2008","author":"IEEE.","key":"e_1_2_1_19_1"},{"volume-title":"Industrious Internet Reference Architecture","year":"2019","author":"Industrial Internet Consortium","key":"e_1_2_1_20_1"},{"key":"e_1_2_1_21_1","unstructured":"Real-Time Innovations. 2017. Connext DDS at a Glance: Understanding the Software Framework That Connects the Industrial IoT. White Paper. Real-Time Innovations.  Real-Time Innovations. 2017. Connext DDS at a Glance: Understanding the Software Framework That Connects the Industrial IoT. White Paper. Real-Time Innovations."},{"key":"e_1_2_1_22_1","doi-asserted-by":"publisher","DOI":"10.1145\/3047410"},{"key":"e_1_2_1_23_1","unstructured":"Daniel Kirsch. 2015. The Value of Bringing Analytics to the Edge. Hurwitz 8 Associates.  Daniel Kirsch. 2015. The Value of Bringing Analytics to the Edge. Hurwitz 8 Associates."},{"key":"e_1_2_1_24_1","doi-asserted-by":"publisher","DOI":"10.1145\/1827418.1827424"},{"volume-title":"Proceedings of the 6th International Workshop on Networking Meets Databases (NetDB\u201911)","year":"2011","author":"Kreps Jay","key":"e_1_2_1_25_1"},{"volume-title":"Proceedings of the Conference on Pattern Languages of Programs.","author":"Greg","key":"e_1_2_1_26_1"},{"volume-title":"The Power of Events: An Introduction to Complex Event Processing in Distributed Enterprise Systems","author":"Luckham David C.","key":"e_1_2_1_27_1"},{"key":"e_1_2_1_28_1","doi-asserted-by":"publisher","DOI":"10.1145\/2933267.2933509"},{"volume-title":"Sensor Fusion for Nanopositioning. Master\u2019s thesis","author":"Piri Daniel","key":"e_1_2_1_29_1"},{"volume-title":"Retrieved","year":"2017","author":"Schmidt Douglas C.","key":"e_1_2_1_30_1"},{"key":"e_1_2_1_31_1","doi-asserted-by":"publisher","DOI":"10.1109\/TCST.2011.2177982"},{"key":"e_1_2_1_32_1","doi-asserted-by":"publisher","DOI":"10.1109\/2.769440"},{"key":"e_1_2_1_33_1","doi-asserted-by":"crossref","unstructured":"Ciza Thomas (Ed.). 2010. Sensor Fusion and Its Applications. Sciyo.  Ciza Thomas (Ed.). 2010. Sensor Fusion and Its Applications. Sciyo.","DOI":"10.5772\/3302"},{"key":"e_1_2_1_34_1","doi-asserted-by":"publisher","DOI":"10.1109\/IWQoS.2017.7969159"},{"key":"e_1_2_1_35_1","doi-asserted-by":"publisher","DOI":"10.5555\/827268.828951"},{"volume-title":"Retrieved","year":"2008","author":"Zalzal Vincent","key":"e_1_2_1_36_1"}],"container-title":["ACM Transactions on Cyber-Physical Systems"],"original-title":[],"language":"en","link":[{"URL":"https:\/\/dl.acm.org\/doi\/10.1145\/3218816","content-type":"unspecified","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/dl.acm.org\/doi\/pdf\/10.1145\/3218816","content-type":"application\/pdf","content-version":"vor","intended-application":"syndication"},{"URL":"https:\/\/dl.acm.org\/doi\/pdf\/10.1145\/3218816","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2025,6,18]],"date-time":"2025-06-18T02:07:05Z","timestamp":1750212425000},"score":1,"resource":{"primary":{"URL":"https:\/\/dl.acm.org\/doi\/10.1145\/3218816"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2019,7,31]]},"references-count":34,"journal-issue":{"issue":"3","published-print":{"date-parts":[[2019,7,31]]}},"alternative-id":["10.1145\/3218816"],"URL":"https:\/\/doi.org\/10.1145\/3218816","relation":{},"ISSN":["2378-962X","2378-9638"],"issn-type":[{"type":"print","value":"2378-962X"},{"type":"electronic","value":"2378-9638"}],"subject":[],"published":{"date-parts":[[2019,7,31]]},"assertion":[{"value":"2017-09-01","order":0,"name":"received","label":"Received","group":{"name":"publication_history","label":"Publication History"}},{"value":"2018-05-01","order":1,"name":"accepted","label":"Accepted","group":{"name":"publication_history","label":"Publication History"}},{"value":"2019-08-20","order":2,"name":"published","label":"Published","group":{"name":"publication_history","label":"Publication History"}}]}}