Revision c22d21ad doc/activitydiagrams/subscriber/urtSubscriberSubscribeNrt.uml
doc/activitydiagrams/subscriber/urtSubscriberSubscribeNrt.uml | ||
---|---|---|
53 | 53 |
fork again |
54 | 54 |
:set topic; |
55 | 55 |
endfork |
56 |
:lock topic; |
|
57 | 56 |
fork |
58 |
if (Messages to contribute?) then (yes) |
|
59 |
partition "contribute messages" { |
|
60 |
:set next pointer of topic's latest message to first message to contribute; |
|
61 |
:set next pointer of last message to contribute to the message after the topic's latest message; |
|
62 |
} |
|
63 |
else (no) |
|
64 |
endif |
|
65 |
fork again |
|
66 |
:set message pointer to topic's latest message; |
|
57 |
:lock topic; |
|
58 |
fork |
|
59 |
if (Messages to contribute?) then (yes) |
|
60 |
partition "contribute messages" { |
|
61 |
:set next pointer of topic's latest message to first message to contribute; |
|
62 |
:set next pointer of last message to contribute to the message after the topic's latest message; |
|
63 |
} |
|
64 |
else (no) |
|
65 |
endif |
|
66 |
fork again |
|
67 |
:set message pointer to topic's latest message; |
|
68 |
endfork |
|
69 |
:unlock topic; |
|
67 | 70 |
fork again |
68 | 71 |
:register to topic's event source; |
69 | 72 |
endfork |
70 |
:unlock topic; |
|
71 | 73 |
:return ""URT_STATUS_OK""; |
72 | 74 |
endif |
73 | 75 |
|
Also available in: Unified diff