Statistics
| Branch: | Revision:

urtware / doc / activitydiagrams / subscriber / srtsubscriber / urtSrtSubscriberSubscribe.svg @ 17d978fe

History | View | Annotate | Download (36.339 KB)

1 2d315870 Thomas Schöpping
<?xml version="1.0" encoding="UTF-8" standalone="no"?><svg xmlns="http://www.w3.org/2000/svg" xmlns:xlink="http://www.w3.org/1999/xlink" contentScriptType="application/ecmascript" contentStyleType="text/css" height="1132px" preserveAspectRatio="none" style="width:2815px;height:1132px;" version="1.1" viewBox="0 0 2815 1132" width="2815px" zoomAndPan="magnify"><defs><filter height="300%" id="f14o4f9gmkaecl" width="300%" x="-1" y="-1"><feGaussianBlur result="blurOut" stdDeviation="2.0"/><feColorMatrix in="blurOut" result="blurOut2" type="matrix" values="0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 .4 0"/><feOffset dx="4.0" dy="4.0" in="blurOut2" result="blurOut3"/><feBlend in="SourceGraphic" in2="blurOut3" mode="normal"/></filter></defs><g><text fill="#000000" font-family="sans-serif" font-size="18" font-weight="bold" lengthAdjust="spacingAndGlyphs" textLength="89" x="1362" y="26.708">µRtWare</text><text fill="#000000" font-family="sans-serif" font-size="18" lengthAdjust="spacingAndGlyphs" textLength="244" x="1284.5" y="47.6611">urtSrtSubscriberSubscribe()</text><text fill="#000000" font-family="sans-serif" font-size="18" lengthAdjust="spacingAndGlyphs" textLength="0" x="1409.5" y="68.6143"/><path d="M656.5,72.8594 L656.5,395.5156 L1274.5,395.5156 L1274.5,82.8594 L1264.5,72.8594 L656.5,72.8594 " fill="#FBFB77" filter="url(#f14o4f9gmkaecl)" style="stroke: #A80036; stroke-width: 1.0;"/><path d="M1264.5,72.8594 L1264.5,82.8594 L1274.5,82.8594 L1264.5,72.8594 " fill="#FBFB77" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.0;" x1="656.5" x2="853" y1="85.4258" y2="85.4258"/><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="0" x="857" y="89.4263"/><text fill="#000000" font-family="sans-serif" font-size="13" font-weight="bold" lengthAdjust="spacingAndGlyphs" textLength="78" x="857" y="89.4263">subscriber</text><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="135" x="939" y="89.4263">: urt_srtsubscriber_t*</text><line style="stroke: #A80036; stroke-width: 1.0;" x1="1078" x2="1274.5" y1="85.4258" y2="85.4258"/><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="326" x="662.5" y="105.0591">The SRT subscriber which shall subscribe to a topic.</text><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="76" x="662.5" y="120.1919">Must not be</text><text fill="#000000" font-family="monospace" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="32" x="742.5" y="120.1919">NULL</text><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="4" x="774.5" y="120.1919">.</text><line style="stroke: #A80036; stroke-width: 1.0;" x1="656.5" x2="899.5" y1="130.8242" y2="130.8242"/><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="0" x="903.5" y="134.8247"/><text fill="#000000" font-family="sans-serif" font-size="13" font-weight="bold" lengthAdjust="spacingAndGlyphs" textLength="37" x="903.5" y="134.8247">topic</text><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="83" x="944.5" y="134.8247">: urt_topic_t*</text><line style="stroke: #A80036; stroke-width: 1.0;" x1="1031.5" x2="1274.5" y1="130.8242" y2="130.8242"/><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="161" x="662.5" y="150.4575">The topic to subscribe to.</text><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="76" x="662.5" y="165.5903">Must not be</text><text fill="#000000" font-family="monospace" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="32" x="742.5" y="165.5903">NULL</text><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="4" x="774.5" y="165.5903">.</text><line style="stroke: #A80036; stroke-width: 1.0;" x1="656.5" x2="866.5" y1="176.2227" y2="176.2227"/><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="0" x="870.5" y="180.2231"/><text fill="#000000" font-family="sans-serif" font-size="13" font-weight="bold" lengthAdjust="spacingAndGlyphs" textLength="75" x="870.5" y="180.2231">messages</text><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="111" x="949.5" y="180.2231">: urt_message_t*</text><line style="stroke: #A80036; stroke-width: 1.0;" x1="1064.5" x2="1274.5" y1="176.2227" y2="176.2227"/><text fill="#000000" font-family="monospace" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="32" x="662.5" y="195.856">NULL</text><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="346" x="698.5" y="195.856">terminated list of messages to contribute to the topic.</text><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="329" x="662.5" y="210.9888">Messages must not be associated to another topic.</text><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="430" x="662.5" y="226.1216">Once a message has been contributed, it cannot be removed later.</text><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="46" x="662.5" y="241.2544">May be</text><text fill="#000000" font-family="monospace" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="32" x="712.5" y="241.2544">NULL</text><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="186" x="748.5" y="241.2544">(no messages to contribute).</text><line style="stroke: #A80036; stroke-width: 1.0;" x1="656.5" x2="829" y1="251.8867" y2="251.8867"/><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="0" x="833" y="255.8872"/><text fill="#000000" font-family="sans-serif" font-size="13" font-weight="bold" lengthAdjust="spacingAndGlyphs" textLength="97" x="833" y="255.8872">usefulnesscb</text><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="164" x="934" y="255.8872">: urt_srtusefulnessfunc_t*</text><line style="stroke: #A80036; stroke-width: 1.0;" x1="1102" x2="1274.5" y1="251.8867" y2="251.8867"/><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="374" x="662.5" y="271.52">Pointer to a function to calculate usefulness of a message.</text><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="76" x="662.5" y="286.6528">Must not be</text><text fill="#000000" font-family="monospace" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="32" x="742.5" y="286.6528">NULL</text><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="4" x="774.5" y="286.6528">.</text><line style="stroke: #A80036; stroke-width: 1.0;" x1="656.5" x2="902" y1="297.2852" y2="297.2852"/><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="0" x="906" y="301.2856"/><text fill="#000000" font-family="sans-serif" font-size="13" font-weight="bold" lengthAdjust="spacingAndGlyphs" textLength="74" x="906" y="301.2856">cbparams</text><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="41" x="984" y="301.2856">: void*</text><line style="stroke: #A80036; stroke-width: 1.0;" x1="1029" x2="1274.5" y1="297.2852" y2="297.2852"/><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="309" x="662.5" y="316.9185">Optional parameters for the usefulness callback.</text><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="46" x="662.5" y="332.0513">May be</text><text fill="#000000" font-family="monospace" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="32" x="712.5" y="332.0513">NULL</text><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="244" x="748.5" y="332.0513">if the callback expects no parameters.</text><line style="stroke: #A80036; stroke-width: 1.0;" x1="656.5" x2="1274.5" y1="340.1172" y2="340.1172"/><line style="stroke: #A80036; stroke-width: 1.0;" x1="656.5" x2="1274.5" y1="342.1172" y2="342.1172"/><line style="stroke: #A80036; stroke-width: 1.0;" x1="656.5" x2="894.5" y1="352.6836" y2="352.6836"/><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="0" x="898.5" y="356.6841"/><text fill="#000000" font-family="sans-serif" font-size="13" font-weight="bold" lengthAdjust="spacingAndGlyphs" textLength="45" x="898.5" y="356.6841">return</text><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="85" x="947.5" y="356.6841">: urt_status_t</text><line style="stroke: #A80036; stroke-width: 1.0;" x1="1036.5" x2="1274.5" y1="352.6836" y2="352.6836"/><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="49" x="662.5" y="372.3169">Returns</text><text fill="#000000" font-family="monospace" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="104" x="715.5" y="372.3169">URT_STATUS_OK</text><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="75" x="823.5" y="372.3169">on success.</text><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="49" x="662.5" y="387.4497">Returns</text><text fill="#000000" font-family="monospace" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="232" x="715.5" y="387.4497">URT_STATUS_SUBSCRIBE_TOPICSET</text><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="308" x="951.5" y="387.4497">if the subscriber is already associated to a topic.</text><ellipse cx="965.5" cy="425.5156" fill="#000000" filter="url(#f14o4f9gmkaecl)" rx="10" ry="10" style="stroke: none; stroke-width: 1.0;"/><polygon fill="#FEFECE" filter="url(#f14o4f9gmkaecl)" points="908,455.5156,1023,455.5156,1035,467.5156,1023,479.5156,908,479.5156,896,467.5156,908,455.5156" style="stroke: #A80036; stroke-width: 1.5;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="115" x="908" y="471.3237">Is topic already set?</text><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="20" x="876" y="464.9214">yes</text><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="14" x="1035" y="464.9214">no</text><path d="M10,489.5156 L10,514.6484 A0,0 0 0 0 10,514.6484 L320,514.6484 A0,0 0 0 0 320,514.6484 L320,507.5156 L340,502.082 L320,499.5156 L320,499.5156 L310,489.5156 L10,489.5156 A0,0 0 0 0 10,489.5156 " fill="#FBFB77" filter="url(#f14o4f9gmkaecl)" style="stroke: #A80036; stroke-width: 1.0;"/><path d="M310,489.5156 L310,499.5156 L320,499.5156 L310,489.5156 " fill="#FBFB77" style="stroke: #A80036; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="49" x="16" y="506.5825">Returns</text><text fill="#000000" font-family="monospace" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="232" x="69" y="506.5825">URT_STATUS_SUBSCRIBE_TOPICSET</text><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="4" x="301" y="506.5825">.</text><ellipse cx="351" cy="502.082" fill="#FFFFFF" filter="url(#f14o4f9gmkaecl)" rx="11" ry="11" style="stroke: #000000; stroke-width: 1.0;"/><ellipse cx="351" cy="502.082" fill="#000000" rx="6" ry="6" style="stroke: #7F7F7F; stroke-width: 1.0;"/><rect fill="#000000" filter="url(#f14o4f9gmkaecl)" height="6" rx="2.5" ry="2.5" style="stroke: #000000; stroke-width: 1.0;" width="976" x="1114" y="489.5156"/><rect fill="#FEFECE" filter="url(#f14o4f9gmkaecl)" height="33.9688" rx="12.5" ry="12.5" style="stroke: #A80036; stroke-width: 1.5;" width="75" x="1128" y="564.0625"/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacingAndGlyphs" textLength="55" x="1138" y="585.2012">set topic</text><path d="M1231,560.9141 L1231,601.1797 A0,0 0 0 0 1231,601.1797 L1462,601.1797 A0,0 0 0 0 1462,601.1797 L1462,585.0469 L1482,581.0469 L1462,577.0469 L1462,570.9141 L1452,560.9141 L1231,560.9141 A0,0 0 0 0 1231,560.9141 " fill="#FBFB77" filter="url(#f14o4f9gmkaecl)" style="stroke: #A80036; stroke-width: 1.0;"/><path d="M1452,560.9141 L1452,570.9141 L1462,570.9141 L1452,560.9141 " fill="#FBFB77" style="stroke: #A80036; stroke-width: 1.0;"/><ellipse cx="1242.5" cy="573.5469" fill="#000000" rx="2.5" ry="2.5" style="stroke: #000000; stroke-width: 0.0;"/><text fill="#000000" font-family="sans-serif" font-size="13" font-weight="bold" lengthAdjust="spacingAndGlyphs" textLength="97" x="1248" y="577.981">usefulnesscb</text><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="98" x="1349" y="577.981">← usefulnesscb</text><ellipse cx="1242.5" cy="588.6797" fill="#000000" rx="2.5" ry="2.5" style="stroke: #000000; stroke-width: 0.0;"/><text fill="#000000" font-family="sans-serif" font-size="13" font-weight="bold" lengthAdjust="spacingAndGlyphs" textLength="74" x="1248" y="593.1138">cbparams</text><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="79" x="1326" y="593.1138">← cbparams</text><rect fill="#FEFECE" filter="url(#f14o4f9gmkaecl)" height="33.9688" rx="12.5" ry="12.5" style="stroke: #A80036; stroke-width: 1.5;" width="124" x="1482" y="564.0625"/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacingAndGlyphs" textLength="104" x="1492" y="585.2012">initialize callback</text><path d="M1634,515.5156 L1634,646.5781 A0,0 0 0 0 1634,646.5781 L1925,646.5781 A0,0 0 0 0 1925,646.5781 L1925,585.0469 L1945,581.0469 L1925,577.0469 L1925,525.5156 L1915,515.5156 L1634,515.5156 A0,0 0 0 0 1634,515.5156 " fill="#EEEEEE" filter="url(#f14o4f9gmkaecl)" style="stroke: #A80036; stroke-width: 1.0;"/><path d="M1915,515.5156 L1915,525.5156 L1925,525.5156 L1915,515.5156 " fill="#EEEEEE" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.0;" x1="1634" x2="1708.5" y1="528.082" y2="528.082"/><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="134" x="1712.5" y="532.0825">urt_basesubscriber_t</text><line style="stroke: #A80036; stroke-width: 1.0;" x1="1850.5" x2="1925" y1="528.082" y2="528.082"/><line style="stroke: #A80036; stroke-width: 1.0; stroke-dasharray: 1.0,2.0;" x1="1634" x2="1651" y1="543.2148" y2="543.2148"/><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="249" x="1655" y="547.2153">URT_CFG_PUBSUB_PROFILING == true</text><line style="stroke: #A80036; stroke-width: 1.0; stroke-dasharray: 1.0,2.0;" x1="1908" x2="1925" y1="543.2148" y2="543.2148"/><ellipse cx="1645.5" cy="558.4141" fill="#000000" rx="2.5" ry="2.5" style="stroke: #000000; stroke-width: 0.0;"/><text fill="#000000" font-family="sans-serif" font-size="13" font-weight="bold" lengthAdjust="spacingAndGlyphs" textLength="101" x="1651" y="562.8481">sumLatencies</text><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="23" x="1756" y="562.8481">← 0</text><ellipse cx="1645.5" cy="573.5469" fill="#000000" rx="2.5" ry="2.5" style="stroke: #000000; stroke-width: 0.0;"/><text fill="#000000" font-family="sans-serif" font-size="13" font-weight="bold" lengthAdjust="spacingAndGlyphs" textLength="173" x="1651" y="577.981">numMessagesReceived</text><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="23" x="1828" y="577.981">← 0</text><line style="stroke: #A80036; stroke-width: 1.0;" x1="1634" x2="1715.5" y1="588.6133" y2="588.6133"/><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="120" x="1719.5" y="592.6138">urt_srtsubscriber_t</text><line style="stroke: #A80036; stroke-width: 1.0;" x1="1843.5" x2="1925" y1="588.6133" y2="588.6133"/><line style="stroke: #A80036; stroke-width: 1.0; stroke-dasharray: 1.0,2.0;" x1="1634" x2="1651" y1="603.7461" y2="603.7461"/><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="249" x="1655" y="607.7466">URT_CFG_PUBSUB_PROFILING == true</text><line style="stroke: #A80036; stroke-width: 1.0; stroke-dasharray: 1.0,2.0;" x1="1908" x2="1925" y1="603.7461" y2="603.7461"/><ellipse cx="1645.5" cy="618.9453" fill="#000000" rx="2.5" ry="2.5" style="stroke: #000000; stroke-width: 0.0;"/><text fill="#000000" font-family="sans-serif" font-size="13" font-weight="bold" lengthAdjust="spacingAndGlyphs" textLength="84" x="1651" y="623.3794">minLatency</text><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="11" x="1739" y="623.3794">←</text><text fill="#000000" font-family="monospace" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="144" x="1754" y="623.3794">URT_DELAY_INFINITE</text><ellipse cx="1645.5" cy="634.0781" fill="#000000" rx="2.5" ry="2.5" style="stroke: #000000; stroke-width: 0.0;"/><text fill="#000000" font-family="sans-serif" font-size="13" font-weight="bold" lengthAdjust="spacingAndGlyphs" textLength="88" x="1651" y="638.5122">maxLatency</text><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="11" x="1743" y="638.5122">←</text><text fill="#000000" font-family="monospace" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="152" x="1758" y="638.5122">URT_DELAY_IMMEDIATE</text><rect fill="#EEEEEE" filter="url(#f14o4f9gmkaecl)" height="33.9688" rx="12.5" ry="12.5" style="stroke: #A80036; stroke-width: 1.5;" width="131" x="1945" y="564.0625"/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacingAndGlyphs" textLength="111" x="1955" y="585.2012">initialize members</text><rect fill="#000000" filter="url(#f14o4f9gmkaecl)" height="6" rx="2.5" ry="2.5" style="stroke: #000000; stroke-width: 1.0;" width="976" x="1114" y="666.5781"/><rect fill="#FEFECE" filter="url(#f14o4f9gmkaecl)" height="33.9688" rx="12.5" ry="12.5" style="stroke: #A80036; stroke-width: 1.5;" width="80" x="1562" y="692.5781"/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacingAndGlyphs" textLength="60" x="1572" y="713.7168">lock topic</text><rect fill="#000000" filter="url(#f14o4f9gmkaecl)" height="6" rx="2.5" ry="2.5" style="stroke: #000000; stroke-width: 1.0;" width="2432" x="372" y="746.5469"/><rect fill="#FFFFFF" filter="url(#f14o4f9gmkaecl)" height="134.2656" style="stroke: #000000; stroke-width: 2.0;" width="1170" x="384" y="819.0591"/><path d="M541,820.0591 L541,828.356 L531,838.356 L384,838.356 " fill="none" style="stroke: #000000; stroke-width: 2.0;"/><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacingAndGlyphs" textLength="147" x="387" y="833.0542">contribute messages</text><rect fill="#000000" filter="url(#f14o4f9gmkaecl)" height="6" rx="2.5" ry="2.5" style="stroke: #000000; stroke-width: 1.0;" width="1150" x="394" y="855.356"/><rect fill="#FEFECE" filter="url(#f14o4f9gmkaecl)" height="33.9688" rx="12.5" ry="12.5" style="stroke: #A80036; stroke-width: 1.5;" width="619" x="408" y="881.356"/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacingAndGlyphs" textLength="20" x="418" y="902.4946">set</text><text fill="#000000" font-family="monospace" font-size="12" lengthAdjust="spacingAndGlyphs" textLength="28" x="442" y="902.4946">next</text><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacingAndGlyphs" textLength="543" x="474" y="902.4946">pointer of last message to contribute to the message after the topic's latest message</text><rect fill="#FEFECE" filter="url(#f14o4f9gmkaecl)" height="33.9688" rx="12.5" ry="12.5" style="stroke: #A80036; stroke-width: 1.5;" width="475" x="1055" y="881.356"/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacingAndGlyphs" textLength="20" x="1065" y="902.4946">set</text><text fill="#000000" font-family="monospace" font-size="12" lengthAdjust="spacingAndGlyphs" textLength="28" x="1089" y="902.4946">next</text><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacingAndGlyphs" textLength="399" x="1121" y="902.4946">pointer of topic's latest message to first message to contribute</text><rect fill="#000000" filter="url(#f14o4f9gmkaecl)" height="6" rx="2.5" ry="2.5" style="stroke: #000000; stroke-width: 1.0;" width="1150" x="394" y="935.3247"/><polygon fill="#FEFECE" filter="url(#f14o4f9gmkaecl)" points="899,772.5469,1039,772.5469,1051,784.5469,1039,796.5469,899,796.5469,887,784.5469,899,772.5469" style="stroke: #A80036; stroke-width: 1.5;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="20" x="973" y="806.7573">yes</text><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="140" x="899" y="788.355">Messages to contribute?</text><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="14" x="1051" y="781.9526">no</text><polygon fill="#FEFECE" filter="url(#f14o4f9gmkaecl)" points="969,973.3247,981,985.3247,969,997.3247,957,985.3247,969,973.3247" style="stroke: #A80036; stroke-width: 1.5;"/><rect fill="#000000" filter="url(#f14o4f9gmkaecl)" height="6" rx="2.5" ry="2.5" style="stroke: #000000; stroke-width: 1.0;" width="664" x="1604" y="847.2075"/><rect fill="#FEFECE" filter="url(#f14o4f9gmkaecl)" height="33.9688" rx="12.5" ry="12.5" style="stroke: #A80036; stroke-width: 1.5;" width="313" x="1618" y="873.2075"/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacingAndGlyphs" textLength="293" x="1628" y="894.3462">set message pointer to topic's latest message</text><rect fill="#FEFECE" filter="url(#f14o4f9gmkaecl)" height="33.9688" rx="12.5" ry="12.5" style="stroke: #A80036; stroke-width: 1.5;" width="297" x="1959" y="873.2075"/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacingAndGlyphs" textLength="277" x="1969" y="894.3462">copy timestamp from topic's latest message</text><rect fill="#000000" filter="url(#f14o4f9gmkaecl)" height="6" rx="2.5" ry="2.5" style="stroke: #000000; stroke-width: 1.0;" width="664" x="1604" y="927.1763"/><rect fill="#FEFECE" filter="url(#f14o4f9gmkaecl)" height="33.9688" rx="12.5" ry="12.5" style="stroke: #A80036; stroke-width: 1.5;" width="217" x="2278" y="873.2075"/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacingAndGlyphs" textLength="197" x="2288" y="894.3462">register to topic's event source</text><rect fill="#EEEEEE" filter="url(#f14o4f9gmkaecl)" height="47.9375" rx="12.5" ry="12.5" style="stroke: #A80036; stroke-width: 1.5;" width="287" x="2505" y="866.2231"/><line style="stroke: #A80036; stroke-width: 1.0; stroke-dasharray: 1.0,2.0;" x1="2505" x2="2532.5" y1="883.2075" y2="883.2075"/><text fill="#000000" font-family="sans-serif" font-size="12" font-style="italic" lengthAdjust="spacingAndGlyphs" textLength="232" x="2532.5" y="886.8618">URT_CFG_PUBSUB_PROFILING == true</text><line style="stroke: #A80036; stroke-width: 1.0; stroke-dasharray: 1.0,2.0;" x1="2764.5" x2="2792" y1="883.2075" y2="883.2075"/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacingAndGlyphs" textLength="267" x="2515" y="901.3306">increment counter of subscribers (@topic)</text><rect fill="#000000" filter="url(#f14o4f9gmkaecl)" height="6" rx="2.5" ry="2.5" style="stroke: #000000; stroke-width: 1.0;" width="2432" x="372" y="1017.3247"/><rect fill="#FEFECE" filter="url(#f14o4f9gmkaecl)" height="33.9688" rx="12.5" ry="12.5" style="stroke: #A80036; stroke-width: 1.5;" width="96" x="1554" y="1043.3247"/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacingAndGlyphs" textLength="76" x="1564" y="1064.4634">unlock topic</text><path d="M1389,1095.7271 L1389,1120.8599 A0,0 0 0 0 1389,1120.8599 L1571,1120.8599 A0,0 0 0 0 1571,1120.8599 L1571,1113.7271 L1591,1108.2935 L1571,1105.7271 L1571,1105.7271 L1561,1095.7271 L1389,1095.7271 A0,0 0 0 0 1389,1095.7271 " fill="#FBFB77" filter="url(#f14o4f9gmkaecl)" style="stroke: #A80036; stroke-width: 1.0;"/><path d="M1561,1095.7271 L1561,1105.7271 L1571,1105.7271 L1561,1095.7271 " fill="#FBFB77" style="stroke: #A80036; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="49" x="1395" y="1112.7939">Returns</text><text fill="#000000" font-family="monospace" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="104" x="1448" y="1112.7939">URT_STATUS_OK</text><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="4" x="1552" y="1112.7939">.</text><ellipse cx="1602" cy="1108.2935" fill="#FFFFFF" filter="url(#f14o4f9gmkaecl)" rx="11" ry="11" style="stroke: #000000; stroke-width: 1.0;"/><ellipse cx="1602" cy="1108.2935" fill="#000000" rx="6" ry="6" style="stroke: #7F7F7F; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="965.5" x2="965.5" y1="395.5156" y2="415.5156"/><polygon fill="#A80036" points="961.5,405.5156,965.5,415.5156,969.5,405.5156,965.5,409.5156" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="1165.5" x2="1165.5" y1="495.5156" y2="564.0625"/><polygon fill="#A80036" points="1161.5,554.0625,1165.5,564.0625,1169.5,554.0625,1165.5,558.0625" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="1544" x2="1544" y1="495.5156" y2="564.0625"/><polygon fill="#A80036" points="1540,554.0625,1544,564.0625,1548,554.0625,1544,558.0625" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="2010.5" x2="2010.5" y1="495.5156" y2="564.0625"/><polygon fill="#A80036" points="2006.5,554.0625,2010.5,564.0625,2014.5,554.0625,2010.5,558.0625" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="1165.5" x2="1165.5" y1="598.0313" y2="666.5781"/><polygon fill="#A80036" points="1161.5,656.5781,1165.5,666.5781,1169.5,656.5781,1165.5,660.5781" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="1544" x2="1544" y1="598.0313" y2="666.5781"/><polygon fill="#A80036" points="1540,656.5781,1544,666.5781,1548,656.5781,1544,660.5781" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="2010.5" x2="2010.5" y1="598.0313" y2="666.5781"/><polygon fill="#A80036" points="2006.5,656.5781,2010.5,666.5781,2014.5,656.5781,2010.5,660.5781" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="1602" x2="1602" y1="672.5781" y2="692.5781"/><polygon fill="#A80036" points="1598,682.5781,1602,692.5781,1606,682.5781,1602,686.5781" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="717.5" x2="717.5" y1="861.356" y2="881.356"/><polygon fill="#A80036" points="713.5,871.356,717.5,881.356,721.5,871.356,717.5,875.356" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="1292.5" x2="1292.5" y1="861.356" y2="881.356"/><polygon fill="#A80036" points="1288.5,871.356,1292.5,881.356,1296.5,871.356,1292.5,875.356" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="717.5" x2="717.5" y1="915.3247" y2="935.3247"/><polygon fill="#A80036" points="713.5,925.3247,717.5,935.3247,721.5,925.3247,717.5,929.3247" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="1292.5" x2="1292.5" y1="915.3247" y2="935.3247"/><polygon fill="#A80036" points="1288.5,925.3247,1292.5,935.3247,1296.5,925.3247,1292.5,929.3247" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="969" x2="969" y1="796.5469" y2="855.356"/><polygon fill="#A80036" points="965,845.356,969,855.356,973,845.356,969,849.356" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="1051" x2="1564" y1="784.5469" y2="784.5469"/><polygon fill="#A80036" points="1560,880.1919,1564,890.1919,1568,880.1919,1564,884.1919" style="stroke: #A80036; stroke-width: 1.5;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="1564" x2="1564" y1="784.5469" y2="985.3247"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="1564" x2="981" y1="985.3247" y2="985.3247"/><polygon fill="#A80036" points="991,981.3247,981,985.3247,991,989.3247,987,985.3247" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="969" x2="969" y1="941.3247" y2="973.3247"/><polygon fill="#A80036" points="965,963.3247,969,973.3247,973,963.3247,969,967.3247" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="1774.5" x2="1774.5" y1="853.2075" y2="873.2075"/><polygon fill="#A80036" points="1770.5,863.2075,1774.5,873.2075,1778.5,863.2075,1774.5,867.2075" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="2107.5" x2="2107.5" y1="853.2075" y2="873.2075"/><polygon fill="#A80036" points="2103.5,863.2075,2107.5,873.2075,2111.5,863.2075,2107.5,867.2075" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="1774.5" x2="1774.5" y1="907.1763" y2="927.1763"/><polygon fill="#A80036" points="1770.5,917.1763,1774.5,927.1763,1778.5,917.1763,1774.5,921.1763" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="2107.5" x2="2107.5" y1="907.1763" y2="927.1763"/><polygon fill="#A80036" points="2103.5,917.1763,2107.5,927.1763,2111.5,917.1763,2107.5,921.1763" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="969" x2="969" y1="752.5469" y2="772.5469"/><polygon fill="#A80036" points="965,762.5469,969,772.5469,973,762.5469,969,766.5469" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="1937" x2="1937" y1="752.5469" y2="847.2075"/><polygon fill="#A80036" points="1933,837.2075,1937,847.2075,1941,837.2075,1937,841.2075" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="2386.5" x2="2386.5" y1="752.5469" y2="873.2075"/><polygon fill="#A80036" points="2382.5,863.2075,2386.5,873.2075,2390.5,863.2075,2386.5,867.2075" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="2648.5" x2="2648.5" y1="752.5469" y2="866.2231"/><polygon fill="#A80036" points="2644.5,856.2231,2648.5,866.2231,2652.5,856.2231,2648.5,860.2231" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="969" x2="969" y1="997.3247" y2="1017.3247"/><polygon fill="#A80036" points="965,1007.3247,969,1017.3247,973,1007.3247,969,1011.3247" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="1937" x2="1937" y1="933.1763" y2="1017.3247"/><polygon fill="#A80036" points="1933,1007.3247,1937,1017.3247,1941,1007.3247,1937,1011.3247" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="2386.5" x2="2386.5" y1="907.1763" y2="1017.3247"/><polygon fill="#A80036" points="2382.5,1007.3247,2386.5,1017.3247,2390.5,1007.3247,2386.5,1011.3247" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="2648.5" x2="2648.5" y1="914.1606" y2="1017.3247"/><polygon fill="#A80036" points="2644.5,1007.3247,2648.5,1017.3247,2652.5,1007.3247,2648.5,1011.3247" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="1602" x2="1602" y1="726.5469" y2="746.5469"/><polygon fill="#A80036" points="1598,736.5469,1602,746.5469,1606,736.5469,1602,740.5469" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="1602" x2="1602" y1="1023.3247" y2="1043.3247"/><polygon fill="#A80036" points="1598,1033.3247,1602,1043.3247,1606,1033.3247,1602,1037.3247" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="1602" x2="1602" y1="1077.2935" y2="1097.2935"/><polygon fill="#A80036" points="1598,1087.2935,1602,1097.2935,1606,1087.2935,1602,1091.2935" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="896" x2="351" y1="467.5156" y2="467.5156"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="351" x2="351" y1="467.5156" y2="491.082"/><polygon fill="#A80036" points="347,481.082,351,491.082,355,481.082,351,485.082" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="1035" x2="1602" y1="467.5156" y2="467.5156"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="1602" x2="1602" y1="467.5156" y2="489.5156"/><polygon fill="#A80036" points="1598,479.5156,1602,489.5156,1606,479.5156,1602,483.5156" style="stroke: #A80036; stroke-width: 1.0;"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="965.5" x2="965.5" y1="435.5156" y2="455.5156"/><polygon fill="#A80036" points="961.5,445.5156,965.5,455.5156,969.5,445.5156,965.5,449.5156" style="stroke: #A80036; stroke-width: 1.0;"/><!--MD5=[0422afd517ff3c3dbae988194c69e819]
2 dd31cb03 Thomas Schöpping
@startuml
3
4
title **µRtWare**\nurtSrtSubscriberSubscribe()\n
5
6
7
8
9
10
note
11
  - - **subscriber** : urt_srtsubscriber_t* - -
12
  The SRT subscriber which shall subscribe to a topic.
13
  Must not be ""NULL"".
14
  - - **topic** : urt_topic_t* - -
15
  The topic to subscribe to.
16
  Must not be ""NULL"".
17
  - - **messages** : urt_message_t* - -
18
  ""NULL"" terminated list of messages to contribute to the topic.
19
  Messages must not be associated to another topic.
20
  Once a message has been contributed, it cannot be removed later.
21
  May be ""NULL"" (no messages to contribute).
22
  - - **usefulnesscb** : urt_srtusefulnessfunc_t* - -
23
  Pointer to a function to calculate usefulness of a message.
24
  Must not be ""NULL"".
25
  - - **cbparams** : void* - -
26
  Optional parameters for the usefulness callback.
27
  May be ""NULL"" if the callback expects no parameters.
28
  ====
29
  - - **return** : urt_status_t - -
30
  Returns ""URT_STATUS_OK"" on success.
31
  Returns ""URT_STATUS_SUBSCRIBE_TOPICSET"" if the subscriber is already associated to a topic.
32
endnote
33
34
35
start
36
if (Is topic already set?) then (yes)
37
  stop
38
  note
39
    Returns ""URT_STATUS_SUBSCRIBE_TOPICSET"".
40
  endnote
41
else (no)
42
  fork
43
    :set topic;
44
  fork again
45
    :initialize callback;
46
    note
47
      * **usefulnesscb** ← usefulnesscb
48
      * **cbparams** ← cbparams
49
    endnote
50
  fork again
51
    #EEEEEE:initialize members;
52
    note #EEEEEE
53
      - - urt_basesubscriber_t - -
54
      .. URT_CFG_PUBSUB_PROFILING == true ..
55
      * **sumLatencies** ← 0
56
      * **numMessagesReceived** ← 0
57
      - - urt_srtsubscriber_t - -
58
      .. URT_CFG_PUBSUB_PROFILING == true ..
59 2d315870 Thomas Schöpping
      * **minLatency** ← ""URT_DELAY_INFINITE""
60
      * **maxLatency** ← ""URT_DELAY_IMMEDIATE""
61 dd31cb03 Thomas Schöpping
    endnote
62
  endfork
63
  :lock topic;
64
  fork
65
    if (Messages to contribute?) then (yes)
66
        partition "contribute messages" {
67
    fork
68
      :set ""next"" pointer of last message to contribute to the message after the topic's latest message;
69
    fork again
70
      :set ""next"" pointer of topic's latest message to first message to contribute;
71
    endfork
72
  }
73
    else (no)
74
    endif
75
  fork again
76
    fork
77
      :set message pointer to topic's latest message;
78
    fork again
79
      :copy timestamp from topic's latest message;
80
    endfork
81
  fork again
82
    :register to topic's event source;
83
  fork again
84
    #EEEEEE:..//URT_CFG_PUBSUB_PROFILING == true//..\nincrement counter of subscribers (@topic);
85
  endfork
86
  :unlock topic;
87
  stop
88
  note
89
    Returns ""URT_STATUS_OK"".
90
  endnote
91
endif
92
93
94
@enduml
95
96
PlantUML version 1.2020.00(Sat Jan 11 13:30:53 CET 2020)
97
(GPL source distribution)
98
Java Runtime: OpenJDK Runtime Environment
99
JVM: OpenJDK 64-Bit Server VM
100 2d315870 Thomas Schöpping
Java Version: 11.0.7+10-post-Ubuntu-2ubuntu218.04
101 dd31cb03 Thomas Schöpping
Operating System: Linux
102
Default Encoding: UTF-8
103
Language: en
104
Country: US
105
--></g></svg>