Revision dd31cb03 doc/activitydiagrams/topic/urtTopicInit.uml
doc/activitydiagrams/topic/urtTopicInit.uml | ||
---|---|---|
36 | 36 |
==== |
37 | 37 |
-- **return** : urt_status_t -- |
38 | 38 |
Returns ""URT_STATUS_OK"" on success. |
39 |
Returns ""URT_STATUS_ERROR"" if another topic with the same identifier already exists.
|
|
39 |
Returns ""URT_STATUS_TOPIC_DUPLICATE"" if another topic with the same identifier already exists.
|
|
40 | 40 |
endnote |
41 | 41 |
|
42 | 42 |
/'### PROCEDURE ##############################################################'/ |
... | ... | |
44 | 44 |
start |
45 | 45 |
:initialize members; |
46 | 46 |
note |
47 |
**next** ← ""NULL"" |
|
48 |
**id** ← id |
|
49 |
urtMutexInit(**lock**) |
|
50 |
urtEventSourceInit(**evtSource**) |
|
51 |
**numHrtSubscriber** ← 0 |
|
52 |
**hrtSubscribers** ← ""NULL"" |
|
53 |
urtCondvarInit(**hrtReleased**) |
|
54 |
urtMessageInit(**mandatoryMessage**) |
|
55 |
**latestMessage** ← &mandatoryMessage |
|
47 |
* **next** ← ""NULL"" |
|
48 |
* **id** ← id |
|
49 |
* urtMutexInit(**lock**) |
|
50 |
* urtEventSourceInit(**evtSource**) |
|
51 |
* **numHrtSubscriber** ← 0 |
|
52 |
* urtCondvarInit(**hrtReleased**) |
|
53 |
* urtMessageInit(**mandatoryMessage**) |
|
54 |
* **latestMessage** ← &mandatoryMessage |
|
56 | 55 |
.. URT_CFG_PUBSUB_QOS_RATECHECKS == true .. |
57 |
urtTimerInit(**qosRateTimer**) |
|
56 |
* **hrtSubscribers** ← ""NULL"" |
|
57 |
* urtTimerInit(**qosRateTimer**) |
|
58 | 58 |
.. URT_CFG_PUBSUB_PROFILING == true .. |
59 |
**numDiscardedMessages** ← 0 |
|
60 |
**numSubscribers** ← 0 |
|
59 |
* **numMessagesPublished** ← 0 |
|
60 |
* **numMessagesDiscarded** ← 0 |
|
61 |
* **numSubscribers** ← 0 |
|
61 | 62 |
endnote |
62 | 63 |
:close circular message buffer; |
63 | 64 |
note |
... | ... | |
86 | 87 |
:unlock core; |
87 | 88 |
stop |
88 | 89 |
note |
89 |
Returns ""URT_STATUS_ERROR"".
|
|
90 |
Returns ""URT_STATUS_TOPIC_DUPLICATE"".
|
|
90 | 91 |
endnote |
91 | 92 |
endif |
92 | 93 |
|
Also available in: Unified diff