evt.c 57 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114
  1. /*
  2. * Copyright (c) 2004-2005 Mark Haverkamp
  3. * Copyright (c) 2004-2005 Open Source Development Lab
  4. *
  5. * All rights reserved.
  6. *
  7. * This software licensed under BSD license, the text of which follows:
  8. *
  9. * Redistribution and use in source and binary forms, with or without
  10. * modification, are permitted provided that the following conditions are met:
  11. *
  12. * - Redistributions of source code must retain the above copyright notice,
  13. * this list of conditions and the following disclaimer.
  14. * - Redistributions in binary form must reproduce the above copyright notice,
  15. * this list of conditions and the following disclaimer in the documentation
  16. * and/or other materials provided with the distribution.
  17. * - Neither the name of the Open Source Developement Lab nor the names of its
  18. * contributors may be used to endorse or promote products derived from this
  19. * software without specific prior written permission.
  20. *
  21. * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
  22. * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  23. * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  24. * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
  25. * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
  26. * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
  27. * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
  28. * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
  29. * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
  30. * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF
  31. * THE POSSIBILITY OF SUCH DAMAGE.
  32. */
  33. #include <sys/types.h>
  34. #include <errno.h>
  35. #include <stdio.h>
  36. #include <stdlib.h>
  37. #include <string.h>
  38. #include <unistd.h>
  39. #include <sys/time.h>
  40. #include <sys/socket.h>
  41. #include "../include/ipc_evt.h"
  42. #include "util.h"
  43. #include "../exec/totempg.h"
  44. #include "../include/list.h"
  45. static void evtHandleInstanceDestructor(void *instance);
  46. static void chanHandleInstanceDestructor(void *instance);
  47. static void eventHandleInstanceDestructor(void *instance);
  48. /*
  49. * Versions of the SAF AIS specification supported by this library
  50. */
  51. static SaVersionT supported_versions[] = {
  52. {'B', 0x01, 0x01}
  53. };
  54. static struct saVersionDatabase evt_version_database = {
  55. sizeof(supported_versions) / sizeof(SaVersionT),
  56. supported_versions
  57. };
  58. /*
  59. * Event instance data
  60. */
  61. struct saHandleDatabase evt_instance_handle_db = {
  62. .handleCount = 0,
  63. .handles = 0,
  64. .mutex = PTHREAD_MUTEX_INITIALIZER,
  65. .handleInstanceDestructor = evtHandleInstanceDestructor
  66. };
  67. /*
  68. * Channel instance data
  69. */
  70. struct saHandleDatabase channel_handle_db = {
  71. .handleCount = 0,
  72. .handles = 0,
  73. .mutex = PTHREAD_MUTEX_INITIALIZER,
  74. .handleInstanceDestructor = chanHandleInstanceDestructor
  75. };
  76. /*
  77. * Event instance data
  78. */
  79. struct saHandleDatabase event_handle_db = {
  80. .handleCount = 0,
  81. .handles = 0,
  82. .mutex = PTHREAD_MUTEX_INITIALIZER,
  83. .handleInstanceDestructor = eventHandleInstanceDestructor
  84. };
  85. struct res_overlay {
  86. struct res_header header;
  87. char data[MESSAGE_SIZE_MAX];
  88. };
  89. struct handle_list {
  90. SaUint64T hl_handle;
  91. struct list_head hl_entry;
  92. };
  93. /*
  94. * data required to support events for a given initialization
  95. *
  96. * ei_dispatch_fd: fd used for getting callback data e.g. async event data
  97. * ei_response_fd: fd used for everything else (i.e. evt sync api commands).
  98. * ei_callback: callback function.
  99. * ei_version: version sent to the evtInitialize call.
  100. * ei_node_id: our node id.
  101. * ei_node_name: our node name.
  102. * ei_finalize: instance in finalize flag
  103. * ei_dispatch_mutex: mutex for dispatch fd
  104. * ei_response_mutex: mutex for response fd
  105. * ei_channel_list: list of associated channels (struct handle_list)
  106. *
  107. */
  108. struct event_instance {
  109. int ei_dispatch_fd;
  110. int ei_response_fd;
  111. SaEvtCallbacksT ei_callback;
  112. SaVersionT ei_version;
  113. SaClmNodeIdT ei_node_id;
  114. SaNameT ei_node_name;
  115. int ei_finalize;
  116. pthread_mutex_t ei_dispatch_mutex;
  117. pthread_mutex_t ei_response_mutex;
  118. struct list_head ei_channel_list;
  119. };
  120. /*
  121. * Data associated with an opened channel
  122. *
  123. * eci_channel_name: name of channel
  124. * eci_open_flags: channel open flags
  125. * eci_svr_channel_handle: channel handle returned from server
  126. * eci_closing: channel in process of being closed
  127. * eci_mutex: channel mutex
  128. * eci_event_list: events associated with this
  129. * channel (struct handle_list)
  130. * eci_hl: pointer to event instance handle struct
  131. * for this channel.
  132. */
  133. struct event_channel_instance {
  134. SaNameT eci_channel_name;
  135. SaEvtChannelOpenFlagsT eci_open_flags;
  136. uint32_t eci_svr_channel_handle;
  137. SaEvtHandleT eci_instance_handle;
  138. int eci_closing;
  139. pthread_mutex_t eci_mutex;
  140. struct list_head eci_event_list;
  141. struct handle_list *eci_hl;
  142. };
  143. /*
  144. * Event data.
  145. *
  146. * Store event data from saEvtEventAllocate function.
  147. * Store event data from received events.
  148. *
  149. * edi_channel_handle: handle (local) of assocated channel
  150. * edi_patterns: event patterns
  151. * edi_priority: event priority
  152. * edi_retention_time: event's retention time
  153. * edi_pub_name: event's publisher name
  154. * edi_pub_node: event's publisher node
  155. * edi_pub_time: event's publish time
  156. * edi_event_id: event's Id
  157. * edi_event_data: event's data
  158. * edi_event_data_size: size of edi_event_data
  159. * edi_freeing: event is being freed
  160. * edi_mutex: event data mutex
  161. * edi_hl: pointer to channel's handle
  162. * struct for this event.
  163. */
  164. struct event_data_instance {
  165. SaEvtChannelHandleT edi_channel_handle;
  166. SaEvtEventPatternArrayT edi_patterns;
  167. SaUint8T edi_priority;
  168. SaTimeT edi_retention_time;
  169. SaNameT edi_pub_name;
  170. SaClmNodeIdT edi_pub_node;
  171. SaTimeT edi_pub_time;
  172. SaEvtEventIdT edi_event_id;
  173. void *edi_event_data;
  174. SaSizeT edi_event_data_size;
  175. int edi_freeing;
  176. pthread_mutex_t edi_mutex;
  177. struct handle_list *edi_hl;
  178. };
  179. #define min(a,b) ((a) < (b) ? (a) : (b))
  180. /*
  181. * Clean up function for an evt instance (saEvtInitialize) handle
  182. * Not to be confused with event data.
  183. */
  184. static void evtHandleInstanceDestructor(void *instance)
  185. {
  186. struct event_instance *evti = instance;
  187. struct event_channel_instance *eci;
  188. struct handle_list *hl;
  189. struct list_head *l, *nxt;
  190. uint64_t handle;
  191. SaAisErrorT error;
  192. /*
  193. * Free up any channel data
  194. */
  195. for (l = evti->ei_channel_list.next;
  196. l != &evti->ei_channel_list; l = nxt) {
  197. nxt = l->next;
  198. hl = list_entry(l, struct handle_list, hl_entry);
  199. handle = hl->hl_handle;
  200. error = saHandleInstanceGet(&channel_handle_db, hl->hl_handle,
  201. (void*)&eci);
  202. if (error != SA_AIS_OK) {
  203. /*
  204. * already gone
  205. */
  206. continue;
  207. }
  208. saHandleDestroy(&channel_handle_db, handle);
  209. saHandleInstancePut(&channel_handle_db, handle);
  210. }
  211. }
  212. /*
  213. * Clean up function for an open channel handle
  214. */
  215. static void chanHandleInstanceDestructor(void *instance)
  216. {
  217. struct event_channel_instance *eci = instance;
  218. struct list_head *l, *nxt;
  219. struct handle_list *hl;
  220. uint64_t handle;
  221. if (eci->eci_hl) {
  222. list_del(&eci->eci_hl->hl_entry);
  223. free(eci->eci_hl);
  224. eci->eci_hl = 0;
  225. }
  226. /*
  227. * Free up any channel associated events
  228. */
  229. for (l = eci->eci_event_list.next; l != &eci->eci_event_list; l = nxt) {
  230. nxt = l->next;
  231. hl = list_entry(l, struct handle_list, hl_entry);
  232. handle = hl->hl_handle;
  233. saEvtEventFree(handle);
  234. }
  235. }
  236. /*
  237. * Clean up function for an event handle
  238. */
  239. static void eventHandleInstanceDestructor(void *instance)
  240. {
  241. struct event_data_instance *edi = instance;
  242. int i;
  243. if (edi->edi_hl) {
  244. list_del(&edi->edi_hl->hl_entry);
  245. free(edi->edi_hl);
  246. edi->edi_hl = 0;
  247. }
  248. for (i = 0; i < edi->edi_patterns.patternsNumber; i++) {
  249. free(edi->edi_patterns.patterns[i].pattern);
  250. }
  251. if (edi->edi_patterns.patterns) {
  252. free(edi->edi_patterns.patterns);
  253. }
  254. if (edi->edi_event_data) {
  255. free(edi->edi_event_data);
  256. }
  257. }
  258. static SaErrorT evt_recv_event(int fd, struct lib_event_data **msg)
  259. {
  260. SaErrorT error;
  261. struct res_header hdr;
  262. void *data;
  263. error = saRecvRetry(fd, &hdr, sizeof(hdr), MSG_WAITALL | MSG_NOSIGNAL);
  264. if (error != SA_AIS_OK) {
  265. goto msg_out;
  266. }
  267. *msg = malloc(hdr.size);
  268. if (!*msg) {
  269. error = SA_AIS_ERR_LIBRARY;
  270. goto msg_out;
  271. }
  272. data = (void *)((unsigned long)*msg) + sizeof(hdr);
  273. memcpy(*msg, &hdr, sizeof(hdr));
  274. if (hdr.size > sizeof(hdr)) {
  275. error = saRecvRetry(fd, data, hdr.size - sizeof(hdr),
  276. MSG_WAITALL | MSG_NOSIGNAL);
  277. if (error != SA_AIS_OK) {
  278. goto msg_out;
  279. }
  280. }
  281. msg_out:
  282. return error;
  283. }
  284. /*
  285. * The saEvtInitialize() function initializes the Event Service for the
  286. * invoking process. A user of the Event Service must invoke this function
  287. * before it invokes any other function of the Event Service API. Each
  288. * initialization returns a different callback handle that the process
  289. * can use to communicate with that library instance.
  290. */
  291. SaAisErrorT
  292. saEvtInitialize(
  293. SaEvtHandleT *evtHandle,
  294. const SaEvtCallbacksT *callbacks,
  295. SaVersionT *version)
  296. {
  297. SaAisErrorT error = SA_AIS_OK;
  298. struct event_instance *evti;
  299. if (!version || !evtHandle) {
  300. error = SA_AIS_ERR_INVALID_PARAM;
  301. goto error_nofree;
  302. }
  303. /*
  304. * validate the requested version with what we support
  305. */
  306. error = saVersionVerify(&evt_version_database, version);
  307. if (error != SA_AIS_OK) {
  308. goto error_nofree;
  309. }
  310. /*
  311. * Allocate instance data, allocate unique handle for instance,
  312. * assign instance data to unique handle
  313. */
  314. error = saHandleCreate(&evt_instance_handle_db, sizeof(*evti),
  315. (void*)evtHandle);
  316. if (error != SA_AIS_OK) {
  317. goto error_nofree;
  318. }
  319. error = saHandleInstanceGet(&evt_instance_handle_db, *evtHandle,
  320. (void*)&evti);
  321. if (error != SA_AIS_OK) {
  322. if (error == SA_AIS_ERR_BAD_HANDLE) {
  323. error = SA_AIS_ERR_LIBRARY;
  324. }
  325. goto error_handle_free;
  326. }
  327. memset(evti, 0, sizeof(*evti));
  328. list_init(&evti->ei_channel_list);
  329. /*
  330. * Save the version so we can check with the event server
  331. * and see if it supports this version.
  332. */
  333. evti->ei_version = *version;
  334. /*
  335. * Set up communication with the event server
  336. */
  337. error = saServiceConnectTwo(&evti->ei_response_fd,
  338. &evti->ei_dispatch_fd, EVT_SERVICE);
  339. if (error != SA_AIS_OK) {
  340. goto error_handle_put;
  341. }
  342. /*
  343. * The callback function is saved in the event instance for
  344. * saEvtDispatch() to use.
  345. */
  346. if (callbacks) {
  347. memcpy(&evti->ei_callback, callbacks,
  348. sizeof(evti->ei_callback));
  349. }
  350. pthread_mutex_init(&evti->ei_dispatch_mutex, NULL);
  351. pthread_mutex_init(&evti->ei_response_mutex, NULL);
  352. saHandleInstancePut(&evt_instance_handle_db, *evtHandle);
  353. return SA_AIS_OK;
  354. error_handle_put:
  355. saHandleInstancePut(&evt_instance_handle_db, *evtHandle);
  356. error_handle_free:
  357. (void)saHandleDestroy(&evt_instance_handle_db, *evtHandle);
  358. error_nofree:
  359. return error;
  360. }
  361. /*
  362. * The saEvtSelectionObjectGet() function returns the operating system
  363. * handle selectionObject, associated with the handle evtHandle, allowing
  364. * the invoking process to ascertain when callbacks are pending. This
  365. * function allows a process to avoid repeated invoking saEvtDispatch() to
  366. * see if there is a new event, thus, needlessly consuming CPU time. In a
  367. * POSIX environment the system handle could be a file descriptor that is
  368. * used with the poll() or select() system calls to detect incoming callbacks.
  369. */
  370. SaAisErrorT
  371. saEvtSelectionObjectGet(
  372. SaEvtHandleT evtHandle,
  373. SaSelectionObjectT *selectionObject)
  374. {
  375. struct event_instance *evti;
  376. SaAisErrorT error;
  377. if (!selectionObject) {
  378. return SA_AIS_ERR_INVALID_PARAM;
  379. }
  380. error = saHandleInstanceGet(&evt_instance_handle_db, evtHandle,
  381. (void *)&evti);
  382. if (error != SA_AIS_OK) {
  383. return error;
  384. }
  385. *selectionObject = evti->ei_dispatch_fd;
  386. saHandleInstancePut(&evt_instance_handle_db, evtHandle);
  387. return SA_AIS_OK;
  388. }
  389. /*
  390. * Alocate an event data structure and associated handle to be
  391. * used to supply event data to a call back function.
  392. */
  393. static SaAisErrorT make_event(SaEvtEventHandleT *event_handle,
  394. struct lib_event_data *evt)
  395. {
  396. struct event_data_instance *edi;
  397. struct event_channel_instance *eci;
  398. SaEvtEventPatternT *pat;
  399. SaUint8T *str;
  400. SaAisErrorT error;
  401. struct handle_list *hl;
  402. int i;
  403. error = saHandleCreate(&event_handle_db, sizeof(*edi),
  404. (void*)event_handle);
  405. if (error != SA_AIS_OK) {
  406. if (error == SA_AIS_ERR_NO_MEMORY) {
  407. error = SA_AIS_ERR_LIBRARY;
  408. }
  409. goto make_evt_done;
  410. }
  411. error = saHandleInstanceGet(&event_handle_db, *event_handle,
  412. (void*)&edi);
  413. if (error != SA_AIS_OK) {
  414. goto make_evt_done;
  415. }
  416. error = saHandleInstanceGet(&channel_handle_db,
  417. evt->led_lib_channel_handle,
  418. (void*)&eci);
  419. if (error != SA_AIS_OK) {
  420. goto make_evt_done_put;
  421. }
  422. memset(edi, 0, sizeof(*edi));
  423. pthread_mutex_init(&edi->edi_mutex, NULL);
  424. edi->edi_freeing = 0;
  425. edi->edi_channel_handle = evt->led_lib_channel_handle;
  426. edi->edi_priority = evt->led_priority;
  427. edi->edi_retention_time = evt->led_retention_time;
  428. edi->edi_pub_node = evt->led_publisher_node_id;
  429. edi->edi_pub_time = evt->led_publish_time;
  430. edi->edi_event_data_size = evt->led_user_data_size;
  431. edi->edi_event_id = evt->led_event_id;
  432. edi->edi_pub_name = evt->led_publisher_name;
  433. if (edi->edi_event_data_size) {
  434. edi->edi_event_data = malloc(edi->edi_event_data_size);
  435. memcpy(edi->edi_event_data,
  436. evt->led_body + evt->led_user_data_offset,
  437. edi->edi_event_data_size);
  438. }
  439. /*
  440. * Move the pattern bits into the SaEvtEventPatternArrayT
  441. */
  442. edi->edi_patterns.patternsNumber = evt->led_patterns_number;
  443. edi->edi_patterns.allocatedNumber = evt->led_patterns_number;
  444. edi->edi_patterns.patterns = malloc(sizeof(SaEvtEventPatternT) *
  445. edi->edi_patterns.patternsNumber);
  446. pat = (SaEvtEventPatternT *)evt->led_body;
  447. str = evt->led_body + sizeof(SaEvtEventPatternT) *
  448. edi->edi_patterns.patternsNumber;
  449. for (i = 0; i < evt->led_patterns_number; i++) {
  450. edi->edi_patterns.patterns[i].patternSize = pat->patternSize;
  451. edi->edi_patterns.patterns[i].allocatedSize = pat->patternSize;
  452. edi->edi_patterns.patterns[i].pattern = malloc(pat->patternSize);
  453. if (!edi->edi_patterns.patterns[i].pattern) {
  454. printf("make_event: couldn't alloc %lld bytes\n", pat->patternSize);
  455. error = SA_AIS_ERR_LIBRARY;
  456. break;
  457. }
  458. memcpy(edi->edi_patterns.patterns[i].pattern,
  459. str, pat->patternSize);
  460. str += pat->patternSize;
  461. pat++;
  462. }
  463. hl = malloc(sizeof(*hl));
  464. edi->edi_hl = hl;
  465. hl->hl_handle = *event_handle;
  466. list_init(&hl->hl_entry);
  467. list_add(&hl->hl_entry, &eci->eci_event_list);
  468. saHandleInstancePut (&channel_handle_db, evt->led_lib_channel_handle);
  469. make_evt_done_put:
  470. saHandleInstancePut (&event_handle_db, *event_handle);
  471. make_evt_done:
  472. return error;
  473. }
  474. /*
  475. * The saEvtDispatch() function invokes, in the context of the calling
  476. * thread, one or all of the pending callbacks for the handle evtHandle.
  477. */
  478. SaAisErrorT
  479. saEvtDispatch(
  480. SaEvtHandleT evtHandle,
  481. SaDispatchFlagsT dispatchFlags)
  482. {
  483. struct pollfd ufds;
  484. int timeout = -1;
  485. SaAisErrorT error;
  486. int dispatch_avail;
  487. struct event_instance *evti;
  488. SaEvtEventHandleT event_handle;
  489. SaEvtCallbacksT callbacks;
  490. int ignore_dispatch = 0;
  491. int cont = 1; /* always continue do loop except when set to 0 */
  492. int poll_fd;
  493. struct res_overlay dispatch_data;
  494. struct lib_event_data *evt = 0;
  495. struct res_evt_event_data res;
  496. if (dispatchFlags < SA_DISPATCH_ONE ||
  497. dispatchFlags > SA_DISPATCH_BLOCKING) {
  498. return SA_AIS_ERR_INVALID_PARAM;
  499. }
  500. error = saHandleInstanceGet(&evt_instance_handle_db, evtHandle,
  501. (void *)&evti);
  502. if (error != SA_AIS_OK) {
  503. return error;
  504. }
  505. /*
  506. * Timeout instantly for SA_DISPATCH_ALL
  507. */
  508. if (dispatchFlags == SA_DISPATCH_ALL || dispatchFlags == SA_DISPATCH_ONE) {
  509. timeout = 0;
  510. }
  511. do {
  512. poll_fd = evti->ei_dispatch_fd;
  513. ufds.fd = poll_fd;
  514. ufds.events = POLLIN;
  515. ufds.revents = 0;
  516. error = saPollRetry(&ufds, 1, timeout);
  517. if (error != SA_AIS_OK) {
  518. goto dispatch_unlock;
  519. }
  520. pthread_mutex_lock(&evti->ei_dispatch_mutex);
  521. /*
  522. * Check the poll data in case the fd status has changed
  523. * since taking the lock
  524. */
  525. error = saPollRetry(&ufds, 1, 0);
  526. if (error != SA_AIS_OK) {
  527. goto dispatch_unlock;
  528. }
  529. /*
  530. * Handle has been finalized in another thread
  531. */
  532. if (evti->ei_finalize == 1) {
  533. error = SA_AIS_OK;
  534. goto dispatch_unlock;
  535. }
  536. if ((ufds.revents & (POLLERR|POLLHUP|POLLNVAL)) != 0) {
  537. error = SA_AIS_ERR_BAD_HANDLE;
  538. goto dispatch_unlock;
  539. }
  540. dispatch_avail = ufds.revents & POLLIN;
  541. if (dispatch_avail == 0 &&
  542. (dispatchFlags == SA_DISPATCH_ALL ||
  543. dispatchFlags == SA_DISPATCH_ONE)) {
  544. pthread_mutex_unlock(&evti->ei_dispatch_mutex);
  545. break; /* exit do while cont is 1 loop */
  546. } else if (dispatch_avail == 0) {
  547. pthread_mutex_unlock(&evti->ei_dispatch_mutex);
  548. continue; /* next poll */
  549. }
  550. if (ufds.revents & POLLIN) {
  551. error = saRecvRetry (evti->ei_dispatch_fd, &dispatch_data.header,
  552. sizeof (struct res_header), MSG_WAITALL | MSG_NOSIGNAL);
  553. if (error != SA_AIS_OK) {
  554. goto dispatch_unlock;
  555. }
  556. if (dispatch_data.header.size > sizeof (struct res_header)) {
  557. error = saRecvRetry (evti->ei_dispatch_fd, &dispatch_data.data,
  558. dispatch_data.header.size - sizeof (struct res_header),
  559. MSG_WAITALL | MSG_NOSIGNAL);
  560. if (error != SA_AIS_OK) {
  561. goto dispatch_unlock;
  562. }
  563. }
  564. } else {
  565. pthread_mutex_unlock(&evti->ei_dispatch_mutex);
  566. continue;
  567. }
  568. /*
  569. * Make copy of callbacks, message data, unlock instance,
  570. * and call callback. A risk of this dispatch method is that
  571. * the callback routines may operate at the same time that
  572. * EvtFinalize has been called in another thread.
  573. */
  574. memcpy(&callbacks, &evti->ei_callback, sizeof(evti->ei_callback));
  575. pthread_mutex_unlock(&evti->ei_dispatch_mutex);
  576. /*
  577. * Dispatch incoming response
  578. */
  579. switch (dispatch_data.header.id) {
  580. case MESSAGE_RES_EVT_AVAILABLE:
  581. /*
  582. * There are events available. Send a request for one and then
  583. * dispatch it.
  584. */
  585. res.evd_head.id = MESSAGE_REQ_EVT_EVENT_DATA;
  586. res.evd_head.size = sizeof(res);
  587. pthread_mutex_lock(&evti->ei_response_mutex);
  588. error = saSendRetry(evti->ei_response_fd, &res, sizeof(res),
  589. MSG_NOSIGNAL);
  590. if (error != SA_AIS_OK) {
  591. printf("MESSAGE_RES_EVT_AVAILABLE: send failed: %d\n", error);
  592. pthread_mutex_unlock(&evti->ei_response_mutex);
  593. break;
  594. }
  595. error = evt_recv_event(evti->ei_response_fd, &evt);
  596. pthread_mutex_unlock(&evti->ei_response_mutex);
  597. if (error != SA_AIS_OK) {
  598. printf("MESSAGE_RES_EVT_AVAILABLE: receive failed: %d\n",
  599. error);
  600. break;
  601. }
  602. /*
  603. * No data available. This is OK, another thread may have
  604. * grabbed it.
  605. */
  606. if (evt->led_head.error == SA_AIS_ERR_NOT_EXIST) {
  607. // printf("MESSAGE_RES_EVT_AVAILABLE: No event data\n");
  608. error = SA_AIS_OK;
  609. break;
  610. }
  611. if (evt->led_head.error != SA_AIS_OK) {
  612. error = evt->led_head.error;
  613. printf("MESSAGE_RES_EVT_AVAILABLE: Error returned: %d\n",
  614. error);
  615. break;
  616. }
  617. error = make_event(&event_handle, evt);
  618. if (error != SA_AIS_OK) {
  619. break;
  620. }
  621. /*
  622. * Only call if there was a function registered
  623. */
  624. if (callbacks.saEvtEventDeliverCallback) {
  625. callbacks.saEvtEventDeliverCallback(evt->led_sub_id,
  626. event_handle, evt->led_user_data_size);
  627. }
  628. break;
  629. case MESSAGE_RES_EVT_CHAN_OPEN_CALLBACK:
  630. {
  631. struct res_evt_open_chan_async *resa =
  632. (struct res_evt_open_chan_async *)&dispatch_data;
  633. struct event_channel_instance *eci;
  634. /*
  635. * Check for errors. If there are none, then
  636. * look up the local channel via the handle that we
  637. * got from the callback request. All we need to do
  638. * is place in the handle from the server side and then
  639. * we can call the callback.
  640. */
  641. error = resa->ica_head.error;
  642. if (error == SA_AIS_OK) {
  643. error = saHandleInstanceGet(&channel_handle_db,
  644. resa->ica_c_handle, (void*)&eci);
  645. if (error == SA_AIS_OK) {
  646. eci->eci_svr_channel_handle = resa->ica_channel_handle;
  647. saHandleInstancePut (&channel_handle_db,
  648. resa->ica_c_handle);
  649. }
  650. }
  651. /*
  652. * Only call if there was a function registered
  653. */
  654. if (callbacks.saEvtChannelOpenCallback) {
  655. callbacks.saEvtChannelOpenCallback(resa->ica_invocation,
  656. resa->ica_c_handle, error);
  657. }
  658. }
  659. break;
  660. default:
  661. printf("Dispatch: Bad message type 0x%x\n",
  662. dispatch_data.header.id);
  663. error = SA_AIS_ERR_LIBRARY;
  664. goto dispatch_put;
  665. }
  666. /*
  667. * If empty is zero it means the we got the
  668. * message from the queue and we are responsible
  669. * for freeing it.
  670. */
  671. if (evt) {
  672. free(evt);
  673. evt = 0;
  674. }
  675. /*
  676. * Determine if more messages should be processed
  677. */
  678. switch (dispatchFlags) {
  679. case SA_DISPATCH_ONE:
  680. if (ignore_dispatch) {
  681. ignore_dispatch = 0;
  682. } else {
  683. cont = 0;
  684. }
  685. break;
  686. case SA_DISPATCH_ALL:
  687. if (ignore_dispatch) {
  688. ignore_dispatch = 0;
  689. }
  690. break;
  691. case SA_DISPATCH_BLOCKING:
  692. break;
  693. }
  694. } while (cont);
  695. goto dispatch_put;
  696. dispatch_unlock:
  697. pthread_mutex_unlock(&evti->ei_dispatch_mutex);
  698. dispatch_put:
  699. saHandleInstancePut(&evt_instance_handle_db, evtHandle);
  700. return error;
  701. }
  702. /*
  703. * The saEvtFinalize() function closes the association, represented by the
  704. * evtHandle parameter, between the process and the Event Service. It may
  705. * free up resources.
  706. * This function cannot be invoked before the process has invoked the
  707. * corresponding saEvtInitialize() function for the Event Service. After
  708. * this function is invoked, the selection object is no longer valid.
  709. * Moreover, the Event Service is unavailable for further use unless it is
  710. * reinitialized using the saEvtInitialize() function.
  711. */
  712. SaAisErrorT
  713. saEvtFinalize(SaEvtHandleT evtHandle)
  714. {
  715. struct event_instance *evti;
  716. SaAisErrorT error;
  717. error = saHandleInstanceGet(&evt_instance_handle_db, evtHandle,
  718. (void *)&evti);
  719. if (error != SA_AIS_OK) {
  720. return error;
  721. }
  722. pthread_mutex_lock(&evti->ei_response_mutex);
  723. /*
  724. * Another thread has already started finalizing
  725. */
  726. if (evti->ei_finalize) {
  727. pthread_mutex_unlock(&evti->ei_response_mutex);
  728. saHandleInstancePut(&evt_instance_handle_db, evtHandle);
  729. return SA_AIS_ERR_BAD_HANDLE;
  730. }
  731. evti->ei_finalize = 1;
  732. pthread_mutex_unlock(&evti->ei_response_mutex);
  733. saHandleDestroy(&evt_instance_handle_db, evtHandle);
  734. /*
  735. * Disconnect from the server
  736. */
  737. if (evti->ei_response_fd != -1) {
  738. shutdown(evti->ei_response_fd, 0);
  739. close(evti->ei_response_fd);
  740. }
  741. if (evti->ei_dispatch_fd != -1) {
  742. shutdown(evti->ei_dispatch_fd, 0);
  743. close(evti->ei_dispatch_fd);
  744. }
  745. saHandleInstancePut(&evt_instance_handle_db, evtHandle);
  746. return error;
  747. }
  748. /*
  749. * The saEvtChannelOpen() function creates a new event channel or open an
  750. * existing channel. The saEvtChannelOpen() function is a blocking operation
  751. * and returns a new event channel handle. An event channel may be opened
  752. * multiple times by the same or different processes for publishing, and
  753. * subscribing to, events. If a process opens an event channel multiple
  754. * times, it is possible to receive the same event multiple times. However,
  755. * a process shall never receive an event more than once on a particular
  756. * event channel handle. If a process opens a channel twice and an event is
  757. * matched on both open channels, the Event Service performs two
  758. * callbacks -- one for each opened channel.
  759. */
  760. SaAisErrorT
  761. saEvtChannelOpen(
  762. SaEvtHandleT evtHandle,
  763. const SaNameT *channelName,
  764. SaEvtChannelOpenFlagsT channelOpenFlags,
  765. SaTimeT timeout,
  766. SaEvtChannelHandleT *channelHandle)
  767. {
  768. struct event_instance *evti;
  769. struct req_evt_channel_open req;
  770. struct res_evt_channel_open res;
  771. struct event_channel_instance *eci;
  772. struct handle_list *hl;
  773. SaAisErrorT error;
  774. struct iovec iov;
  775. if (!channelHandle || !channelName) {
  776. return SA_AIS_ERR_INVALID_PARAM;
  777. }
  778. error = saHandleInstanceGet(&evt_instance_handle_db, evtHandle,
  779. (void*)&evti);
  780. if (error != SA_AIS_OK) {
  781. goto chan_open_done;
  782. }
  783. /*
  784. * create a handle for this open channel
  785. */
  786. error = saHandleCreate(&channel_handle_db, sizeof(*eci),
  787. (void*)channelHandle);
  788. if (error != SA_AIS_OK) {
  789. goto chan_open_put;
  790. }
  791. error = saHandleInstanceGet(&channel_handle_db, *channelHandle,
  792. (void*)&eci);
  793. if (error != SA_AIS_OK) {
  794. saHandleDestroy(&channel_handle_db, *channelHandle);
  795. goto chan_open_put;
  796. }
  797. list_init(&eci->eci_event_list);
  798. /*
  799. * Send the request to the server and wait for a response
  800. */
  801. req.ico_head.size = sizeof(req);
  802. req.ico_head.id = MESSAGE_REQ_EVT_OPEN_CHANNEL;
  803. req.ico_c_handle = *channelHandle;
  804. req.ico_timeout = timeout;
  805. req.ico_open_flag = channelOpenFlags;
  806. req.ico_channel_name = *channelName;
  807. iov.iov_base = &req;
  808. iov.iov_len = sizeof(req);
  809. pthread_mutex_lock(&evti->ei_response_mutex);
  810. error = saSendMsgReceiveReply(evti->ei_response_fd, &iov, 1,
  811. &res, sizeof(res));
  812. pthread_mutex_unlock (&evti->ei_response_mutex);
  813. if (error != SA_AIS_OK) {
  814. goto chan_open_free;
  815. }
  816. if (res.ico_head.id != MESSAGE_RES_EVT_OPEN_CHANNEL) {
  817. error = SA_AIS_ERR_LIBRARY;
  818. goto chan_open_free;
  819. }
  820. error = res.ico_head.error;
  821. if (error != SA_AIS_OK) {
  822. goto chan_open_free;
  823. }
  824. eci->eci_svr_channel_handle = res.ico_channel_handle;
  825. eci->eci_channel_name = *channelName;
  826. eci->eci_open_flags = channelOpenFlags;
  827. eci->eci_instance_handle = evtHandle;
  828. eci->eci_closing = 0;
  829. hl = malloc(sizeof(*hl));
  830. eci->eci_hl = hl;
  831. hl->hl_handle = *channelHandle;
  832. list_init(&hl->hl_entry);
  833. list_add(&hl->hl_entry, &evti->ei_channel_list);
  834. pthread_mutex_init(&eci->eci_mutex, NULL);
  835. saHandleInstancePut (&evt_instance_handle_db, evtHandle);
  836. saHandleInstancePut (&channel_handle_db, *channelHandle);
  837. return SA_AIS_OK;
  838. chan_open_free:
  839. saHandleDestroy(&channel_handle_db, *channelHandle);
  840. saHandleInstancePut (&channel_handle_db, *channelHandle);
  841. chan_open_put:
  842. saHandleInstancePut (&evt_instance_handle_db, evtHandle);
  843. chan_open_done:
  844. return error;
  845. }
  846. /*
  847. * The saEvtChannelClose() function closes an event channel and frees
  848. * resources allocated for that event channel in the invoking process.
  849. */
  850. SaAisErrorT
  851. saEvtChannelClose(SaEvtChannelHandleT channelHandle)
  852. {
  853. SaAisErrorT error;
  854. struct event_instance *evti;
  855. struct event_channel_instance *eci;
  856. struct req_evt_channel_close req;
  857. struct res_evt_channel_close res;
  858. struct iovec iov;
  859. error = saHandleInstanceGet(&channel_handle_db, channelHandle,
  860. (void*)&eci);
  861. if (error != SA_AIS_OK) {
  862. goto chan_close_done;
  863. }
  864. /*
  865. * get the evt handle for the fd
  866. */
  867. error = saHandleInstanceGet(&evt_instance_handle_db,
  868. eci->eci_instance_handle, (void*)&evti);
  869. if (error != SA_AIS_OK) {
  870. goto chan_close_put1;
  871. }
  872. /*
  873. * Make sure that the channel isn't being closed elsewhere
  874. */
  875. pthread_mutex_lock(&eci->eci_mutex);
  876. if (eci->eci_closing) {
  877. pthread_mutex_unlock(&eci->eci_mutex);
  878. saHandleInstancePut(&channel_handle_db, channelHandle);
  879. return SA_AIS_ERR_BAD_HANDLE;
  880. }
  881. eci->eci_closing = 1;
  882. pthread_mutex_unlock(&eci->eci_mutex);
  883. /*
  884. * Send the request to the server and wait for a response
  885. */
  886. req.icc_head.size = sizeof(req);
  887. req.icc_head.id = MESSAGE_REQ_EVT_CLOSE_CHANNEL;
  888. req.icc_channel_handle = eci->eci_svr_channel_handle;
  889. iov.iov_base = &req;
  890. iov.iov_len = sizeof (req);
  891. pthread_mutex_lock(&evti->ei_response_mutex);
  892. error = saSendMsgReceiveReply (evti->ei_response_fd, &iov, 1,
  893. &res, sizeof (res));
  894. pthread_mutex_unlock(&evti->ei_response_mutex);
  895. if (error != SA_AIS_OK) {
  896. eci->eci_closing = 0;
  897. goto chan_close_put2;
  898. }
  899. if (res.icc_head.id != MESSAGE_RES_EVT_CLOSE_CHANNEL) {
  900. error = SA_AIS_ERR_LIBRARY;
  901. eci->eci_closing = 0;
  902. goto chan_close_put2;
  903. }
  904. error = res.icc_head.error;
  905. saHandleInstancePut(&evt_instance_handle_db,
  906. eci->eci_instance_handle);
  907. saHandleDestroy(&channel_handle_db, channelHandle);
  908. saHandleInstancePut(&channel_handle_db, channelHandle);
  909. return error;
  910. chan_close_put2:
  911. saHandleInstancePut(&evt_instance_handle_db,
  912. eci->eci_instance_handle);
  913. chan_close_put1:
  914. saHandleInstancePut(&channel_handle_db, channelHandle);
  915. chan_close_done:
  916. return error;
  917. }
  918. /*
  919. * The saEvtChannelOpenAsync() function creates a new event channel or open an
  920. * existing channel. The saEvtChannelOpenAsync() function is a non-blocking
  921. * operation. A new event channel handle is returned in the channel open
  922. * callback function (SaEvtChannelOpenCallbackT).
  923. */
  924. SaAisErrorT
  925. saEvtChannelOpenAsync(SaEvtHandleT evtHandle,
  926. SaInvocationT invocation,
  927. const SaNameT *channelName,
  928. SaEvtChannelOpenFlagsT channelOpenFlags)
  929. {
  930. struct event_instance *evti;
  931. struct req_evt_channel_open req;
  932. struct res_evt_channel_open res;
  933. struct event_channel_instance *eci;
  934. SaEvtChannelHandleT channel_handle;
  935. SaAisErrorT error;
  936. struct handle_list *hl;
  937. struct iovec iov;
  938. if (!channelName) {
  939. return SA_AIS_ERR_INVALID_PARAM;
  940. }
  941. error = saHandleInstanceGet(&evt_instance_handle_db, evtHandle,
  942. (void*)&evti);
  943. if (error != SA_AIS_OK) {
  944. goto chan_open_done;
  945. }
  946. /*
  947. * Make sure that an open channel callback has been
  948. * registered before allowing the open to continue.
  949. */
  950. if (!evti->ei_callback.saEvtChannelOpenCallback) {
  951. error = SA_AIS_ERR_INIT;
  952. goto chan_open_put;
  953. }
  954. /*
  955. * create a handle for this open channel
  956. */
  957. error = saHandleCreate(&channel_handle_db, sizeof(*eci),
  958. &channel_handle);
  959. if (error != SA_AIS_OK) {
  960. goto chan_open_put;
  961. }
  962. error = saHandleInstanceGet(&channel_handle_db, channel_handle,
  963. (void*)&eci);
  964. if (error != SA_AIS_OK) {
  965. saHandleDestroy(&channel_handle_db, channel_handle);
  966. goto chan_open_put;
  967. }
  968. list_init(&eci->eci_event_list);
  969. /*
  970. * Send the request to the server. The response isn't the open channel,
  971. * just an ack. The open channel will be returned when the channel open
  972. * callback is called.
  973. */
  974. req.ico_head.size = sizeof(req);
  975. req.ico_head.id = MESSAGE_REQ_EVT_OPEN_CHANNEL_ASYNC;
  976. req.ico_c_handle = channel_handle;
  977. req.ico_timeout = 0;
  978. req.ico_invocation = invocation;
  979. req.ico_open_flag = channelOpenFlags;
  980. req.ico_channel_name = *channelName;
  981. iov.iov_base = &req;
  982. iov.iov_len = sizeof(req);
  983. pthread_mutex_lock(&evti->ei_response_mutex);
  984. error = saSendMsgReceiveReply (evti->ei_response_fd, &iov, 1,
  985. &res, sizeof (res));
  986. pthread_mutex_unlock(&evti->ei_response_mutex);
  987. if (error != SA_AIS_OK) {
  988. goto chan_open_free;
  989. }
  990. if (res.ico_head.id != MESSAGE_RES_EVT_OPEN_CHANNEL) {
  991. error = SA_AIS_ERR_LIBRARY;
  992. goto chan_open_free;
  993. }
  994. error = res.ico_head.error;
  995. if (error != SA_AIS_OK) {
  996. goto chan_open_free;
  997. }
  998. eci->eci_svr_channel_handle = 0; /* filled in by callback */
  999. eci->eci_channel_name = *channelName;
  1000. eci->eci_open_flags = channelOpenFlags;
  1001. eci->eci_instance_handle = evtHandle;
  1002. eci->eci_closing = 0;
  1003. list_init(&eci->eci_event_list);
  1004. hl = malloc(sizeof(*hl));
  1005. eci->eci_hl = hl;
  1006. hl->hl_handle = channel_handle;
  1007. list_init(&hl->hl_entry);
  1008. list_add(&hl->hl_entry, &evti->ei_channel_list);
  1009. pthread_mutex_init(&eci->eci_mutex, NULL);
  1010. saHandleInstancePut (&evt_instance_handle_db, evtHandle);
  1011. saHandleInstancePut (&channel_handle_db, channel_handle);
  1012. return SA_AIS_OK;
  1013. chan_open_free:
  1014. saHandleDestroy(&channel_handle_db, channel_handle);
  1015. saHandleInstancePut (&channel_handle_db, channel_handle);
  1016. chan_open_put:
  1017. saHandleInstancePut (&evt_instance_handle_db, evtHandle);
  1018. chan_open_done:
  1019. return error;
  1020. }
  1021. /*
  1022. * The SaEvtChannelUnlink function deletes an existing event channel
  1023. * from the cluster.
  1024. *
  1025. * After completion of the invocation:
  1026. * - An open of the channel name without a create will fail.
  1027. * - The channel remains available to any already opened instances.
  1028. * - If an open/create is performed on this channel name a new instance
  1029. * is created.
  1030. * - The ulinked channel's resources will be deleted when the last open
  1031. * instance is closed.
  1032. *
  1033. * Note that an event channel is only deleted from the cluster
  1034. * namespace when saEvtChannelUnlink() is invoked on it. The deletion
  1035. * of an event channel frees all resources allocated by the Event
  1036. * Service for it, such as published events with non-zero retention
  1037. * time.
  1038. */
  1039. SaAisErrorT
  1040. saEvtChannelUnlink(
  1041. SaEvtHandleT evtHandle,
  1042. const SaNameT *channelName)
  1043. {
  1044. struct event_instance *evti;
  1045. struct req_evt_channel_unlink req;
  1046. struct res_evt_channel_unlink res;
  1047. struct iovec iov;
  1048. SaAisErrorT error;
  1049. if (!channelName) {
  1050. return SA_AIS_ERR_INVALID_PARAM;
  1051. }
  1052. error = saHandleInstanceGet(&evt_instance_handle_db, evtHandle,
  1053. (void*)&evti);
  1054. if (error != SA_AIS_OK) {
  1055. goto chan_unlink_done;
  1056. }
  1057. /*
  1058. * Send the request to the server and wait for a response
  1059. */
  1060. req.iuc_head.size = sizeof(req);
  1061. req.iuc_head.id = MESSAGE_REQ_EVT_UNLINK_CHANNEL;
  1062. req.iuc_channel_name = *channelName;
  1063. iov.iov_base = &req;
  1064. iov.iov_len = sizeof(req);
  1065. pthread_mutex_lock(&evti->ei_response_mutex);
  1066. error = saSendMsgReceiveReply (evti->ei_response_fd, &iov, 1,
  1067. &res, sizeof (res));
  1068. pthread_mutex_unlock(&evti->ei_response_mutex);
  1069. if (error != SA_AIS_OK) {
  1070. goto chan_unlink_put;
  1071. }
  1072. if (res.iuc_head.id != MESSAGE_RES_EVT_UNLINK_CHANNEL) {
  1073. error = SA_AIS_ERR_LIBRARY;
  1074. goto chan_unlink_put;
  1075. }
  1076. error = res.iuc_head.error;
  1077. chan_unlink_put:
  1078. saHandleInstancePut (&evt_instance_handle_db, evtHandle);
  1079. chan_unlink_done:
  1080. return error;
  1081. }
  1082. /*
  1083. * The saEvtEventAllocate() function allocates memory for the event, but not
  1084. * for the eventHandle, and initializes all event attributes to default values.
  1085. * The event allocated by saEvtEventAllocate() is freed by invoking
  1086. * saEvtEventFree().
  1087. * The memory associated with the eventHandle is not deallocated by the
  1088. * saEvtEventAllocate() function or the saEvtEventFree() function. It is the
  1089. * responsibility of the invoking process to deallocate the memory for the
  1090. * eventHandle when the process has published the event and has freed the
  1091. * event by invoking saEvtEventFree().
  1092. */
  1093. SaAisErrorT
  1094. saEvtEventAllocate(
  1095. const SaEvtChannelHandleT channelHandle,
  1096. SaEvtEventHandleT *eventHandle)
  1097. {
  1098. SaAisErrorT error;
  1099. struct event_data_instance *edi;
  1100. struct event_instance *evti;
  1101. struct event_channel_instance *eci;
  1102. struct handle_list *hl;
  1103. if (!eventHandle) {
  1104. return SA_AIS_ERR_INVALID_PARAM;
  1105. }
  1106. error = saHandleInstanceGet(&channel_handle_db, channelHandle,
  1107. (void*)&eci);
  1108. if (error != SA_AIS_OK) {
  1109. goto alloc_done;
  1110. }
  1111. error = saHandleInstanceGet(&evt_instance_handle_db,
  1112. eci->eci_instance_handle, (void*)&evti);
  1113. if (error != SA_AIS_OK) {
  1114. goto alloc_put1;
  1115. }
  1116. error = saHandleCreate(&event_handle_db, sizeof(*edi),
  1117. (void*)eventHandle);
  1118. if (error != SA_AIS_OK) {
  1119. goto alloc_put2;
  1120. }
  1121. error = saHandleInstanceGet(&event_handle_db, *eventHandle,
  1122. (void*)&edi);
  1123. if (error != SA_AIS_OK) {
  1124. goto alloc_put2;
  1125. }
  1126. memset(edi, 0, sizeof(*edi));
  1127. pthread_mutex_init(&edi->edi_mutex, NULL);
  1128. edi->edi_freeing = 0;
  1129. edi->edi_channel_handle = channelHandle;
  1130. edi->edi_pub_node = evti->ei_node_id;
  1131. edi->edi_priority = SA_EVT_LOWEST_PRIORITY;
  1132. edi->edi_event_id = SA_EVT_EVENTID_NONE;
  1133. hl = malloc(sizeof(*hl));
  1134. edi->edi_hl = hl;
  1135. hl->hl_handle = *eventHandle;
  1136. list_init(&hl->hl_entry);
  1137. list_add(&hl->hl_entry, &eci->eci_event_list);
  1138. saHandleInstancePut (&event_handle_db, *eventHandle);
  1139. alloc_put2:
  1140. saHandleInstancePut (&evt_instance_handle_db, eci->eci_instance_handle);
  1141. alloc_put1:
  1142. saHandleInstancePut (&channel_handle_db, edi->edi_channel_handle);
  1143. alloc_done:
  1144. return error;
  1145. }
  1146. /*
  1147. * The saEvtEventFree() function gives the Event Service premission to
  1148. * deallocate the memory that contains the attributes of the event that is
  1149. * associated with eventHandle. The function is used to free events allocated
  1150. * by saEvtEventAllocate() and by saEvtEventDeliverCallback().
  1151. */
  1152. SaAisErrorT
  1153. saEvtEventFree(SaEvtEventHandleT eventHandle)
  1154. {
  1155. SaAisErrorT error;
  1156. struct event_data_instance *edi;
  1157. error = saHandleInstanceGet(&event_handle_db, eventHandle,
  1158. (void*)&edi);
  1159. if (error != SA_AIS_OK) {
  1160. goto evt_free_done;
  1161. }
  1162. /*
  1163. * Make sure that the event isn't being freed elsewhere
  1164. */
  1165. pthread_mutex_lock(&edi->edi_mutex);
  1166. if (edi->edi_freeing) {
  1167. pthread_mutex_unlock(&edi->edi_mutex);
  1168. saHandleInstancePut(&event_handle_db, eventHandle);
  1169. return SA_AIS_ERR_BAD_HANDLE;
  1170. }
  1171. edi->edi_freeing = 1;
  1172. pthread_mutex_unlock(&edi->edi_mutex);
  1173. saHandleDestroy(&event_handle_db, eventHandle);
  1174. saHandleInstancePut(&event_handle_db, eventHandle);
  1175. evt_free_done:
  1176. return error;
  1177. }
  1178. /*
  1179. * This function may be used to assign writeable event attributes. It takes
  1180. * as arguments an event handle eventHandle and the attribute to be set in
  1181. * the event structure of the event with that handle. Note: The only
  1182. * attributes that a process can set are the patternArray, priority,
  1183. * retentionTime and publisherName attributes.
  1184. */
  1185. SaAisErrorT
  1186. saEvtEventAttributesSet(
  1187. const SaEvtEventHandleT eventHandle,
  1188. const SaEvtEventPatternArrayT *patternArray,
  1189. SaEvtEventPriorityT priority,
  1190. SaTimeT retentionTime,
  1191. const SaNameT *publisherName)
  1192. {
  1193. SaEvtEventPatternT *oldpatterns;
  1194. SaSizeT oldnumber;
  1195. SaAisErrorT error;
  1196. struct event_data_instance *edi;
  1197. int i;
  1198. error = saHandleInstanceGet(&event_handle_db, eventHandle,
  1199. (void*)&edi);
  1200. if (error != SA_AIS_OK) {
  1201. goto attr_set_done;
  1202. }
  1203. pthread_mutex_lock(&edi->edi_mutex);
  1204. edi->edi_priority = priority;
  1205. edi->edi_retention_time = retentionTime;
  1206. if (publisherName) {
  1207. edi->edi_pub_name = *publisherName;
  1208. }
  1209. if (!patternArray) {
  1210. goto attr_set_unlock;
  1211. }
  1212. oldpatterns = edi->edi_patterns.patterns;
  1213. oldnumber = edi->edi_patterns.patternsNumber;
  1214. edi->edi_patterns.patterns = 0;
  1215. edi->edi_patterns.patterns = malloc(sizeof(SaEvtEventPatternT) *
  1216. patternArray->patternsNumber);
  1217. if (!edi->edi_patterns.patterns) {
  1218. error = SA_AIS_ERR_NO_MEMORY;
  1219. goto attr_set_done_reset;
  1220. }
  1221. edi->edi_patterns.patternsNumber = patternArray->patternsNumber;
  1222. edi->edi_patterns.allocatedNumber = patternArray->patternsNumber;
  1223. /*
  1224. * copy the patterns from the caller. allocating memory for
  1225. * of all the strings.
  1226. */
  1227. for (i = 0; i < patternArray->patternsNumber; i++) {
  1228. edi->edi_patterns.patterns[i].pattern =
  1229. malloc(patternArray->patterns[i].patternSize);
  1230. if (!edi->edi_patterns.patterns[i].pattern) {
  1231. int j;
  1232. for (j = 0; j < i; j++) {
  1233. free(edi->edi_patterns.patterns[j].pattern);
  1234. }
  1235. free(edi->edi_patterns.patterns);
  1236. error = SA_AIS_ERR_NO_MEMORY;
  1237. goto attr_set_done_reset;
  1238. }
  1239. memcpy(edi->edi_patterns.patterns[i].pattern,
  1240. patternArray->patterns[i].pattern,
  1241. patternArray->patterns[i].patternSize);
  1242. edi->edi_patterns.patterns[i].patternSize =
  1243. patternArray->patterns[i].patternSize;
  1244. edi->edi_patterns.patterns[i].allocatedSize =
  1245. patternArray->patterns[i].patternSize;
  1246. }
  1247. /*
  1248. * free up the old pattern memory
  1249. */
  1250. if (oldpatterns) {
  1251. for (i = 0; i < oldnumber; i++) {
  1252. if (oldpatterns[i].pattern) {
  1253. free(oldpatterns[i].pattern);
  1254. }
  1255. }
  1256. free (oldpatterns);
  1257. }
  1258. goto attr_set_unlock;
  1259. attr_set_done_reset:
  1260. edi->edi_patterns.patterns = oldpatterns;
  1261. edi->edi_patterns.patternsNumber = oldnumber;
  1262. attr_set_unlock:
  1263. pthread_mutex_unlock(&edi->edi_mutex);
  1264. saHandleInstancePut(&event_handle_db, eventHandle);
  1265. attr_set_done:
  1266. return error;
  1267. }
  1268. /*
  1269. * This function takes as parameters an event handle eventHandle and the
  1270. * attributes of the event with that handle. The function retrieves the
  1271. * value of the attributes for the event and stores them at the address
  1272. * provided for the out parameters.
  1273. * It is the responsibility of the invoking process to allocate memory for
  1274. * the out parameters before it invokes this function. The Event Service
  1275. * assigns the out values into that memory. For each of the out, or in/out,
  1276. * parameters, if the invoking process provides a NULL reference, the
  1277. * Availability Management Framework does not return the out value.
  1278. * Similarly, it is the responsibility of the invoking process to allocate
  1279. * memory for the patternArray.
  1280. */
  1281. SaAisErrorT
  1282. saEvtEventAttributesGet(
  1283. SaEvtEventHandleT eventHandle,
  1284. SaEvtEventPatternArrayT *patternArray,
  1285. SaEvtEventPriorityT *priority,
  1286. SaTimeT *retentionTime,
  1287. SaNameT *publisherName,
  1288. SaTimeT *publishTime,
  1289. SaEvtEventIdT *eventId)
  1290. {
  1291. SaAisErrorT error;
  1292. struct event_data_instance *edi;
  1293. SaSizeT npats;
  1294. int i;
  1295. error = saHandleInstanceGet(&event_handle_db, eventHandle,
  1296. (void*)&edi);
  1297. if (error != SA_AIS_OK) {
  1298. goto attr_get_done;
  1299. }
  1300. pthread_mutex_lock(&edi->edi_mutex);
  1301. /*
  1302. * Go through the args and send back information if the pointer
  1303. * isn't NULL
  1304. */
  1305. if (eventId) {
  1306. *eventId = edi->edi_event_id;
  1307. }
  1308. if (publishTime) {
  1309. *publishTime = edi->edi_pub_time;
  1310. }
  1311. if (publisherName) {
  1312. *publisherName = edi->edi_pub_name;
  1313. }
  1314. if (retentionTime) {
  1315. *retentionTime = edi->edi_retention_time;
  1316. }
  1317. if (priority) {
  1318. *priority = edi->edi_priority;
  1319. }
  1320. if (!patternArray) {
  1321. goto attr_get_unlock;
  1322. }
  1323. /*
  1324. * The spec says that if the called passes in a NULL patterns array,
  1325. * then we allocate the required data and the caller is responsible
  1326. * for dealocating later. Otherwise, we copy to pre-allocated space.
  1327. * If there are more patterns than allcated space, we set the return
  1328. * code to SA_AIS_ERR_NO_SPACE and copy as much as will fit. We will
  1329. * return the total number of patterns available in the patternsNumber
  1330. * regardless of how much was allocated.
  1331. *
  1332. */
  1333. if (patternArray->patterns == NULL) {
  1334. npats = edi->edi_patterns.patternsNumber;
  1335. patternArray->allocatedNumber = edi->edi_patterns.patternsNumber;
  1336. patternArray->patternsNumber = edi->edi_patterns.patternsNumber;
  1337. patternArray->patterns = malloc(sizeof(*patternArray->patterns) *
  1338. edi->edi_patterns.patternsNumber);
  1339. for (i = 0; i < edi->edi_patterns.patternsNumber; i++) {
  1340. patternArray->patterns[i].allocatedSize =
  1341. edi->edi_patterns.patterns[i].allocatedSize;
  1342. patternArray->patterns[i].patternSize =
  1343. edi->edi_patterns.patterns[i].patternSize;
  1344. patternArray->patterns[i].pattern =
  1345. malloc(edi->edi_patterns.patterns[i].patternSize);
  1346. }
  1347. } else {
  1348. if (patternArray->allocatedNumber < edi->edi_patterns.allocatedNumber) {
  1349. error = SA_AIS_ERR_NO_SPACE;
  1350. npats = patternArray->allocatedNumber;
  1351. } else {
  1352. npats = edi->edi_patterns.patternsNumber;
  1353. }
  1354. }
  1355. patternArray->patternsNumber = edi->edi_patterns.patternsNumber;
  1356. /*
  1357. * copy the patterns to the callers structure. If we have pre-allocated
  1358. * data, the patterns may not fit in the supplied space. In that case we
  1359. * return NO_SPACE.
  1360. */
  1361. for (i = 0; i < npats; i++) {
  1362. memcpy(patternArray->patterns[i].pattern,
  1363. edi->edi_patterns.patterns[i].pattern,
  1364. min(patternArray->patterns[i].allocatedSize,
  1365. edi->edi_patterns.patterns[i].patternSize));
  1366. if (patternArray->patterns[i].allocatedSize <
  1367. edi->edi_patterns.patterns[i].patternSize) {
  1368. error = SA_AIS_ERR_NO_SPACE;
  1369. }
  1370. patternArray->patterns[i].patternSize =
  1371. edi->edi_patterns.patterns[i].patternSize;
  1372. }
  1373. attr_get_unlock:
  1374. pthread_mutex_unlock(&edi->edi_mutex);
  1375. saHandleInstancePut(&event_handle_db, eventHandle);
  1376. attr_get_done:
  1377. return error;
  1378. }
  1379. /*
  1380. * The saEvtEventDataGet() function allows a process to retrieve the data
  1381. * associated with an event previously delivered by
  1382. * saEvtEventDeliverCallback().
  1383. */
  1384. SaAisErrorT
  1385. saEvtEventDataGet(
  1386. const SaEvtEventHandleT eventHandle,
  1387. void *eventData,
  1388. SaSizeT *eventDataSize)
  1389. {
  1390. SaAisErrorT error = SA_AIS_OK;
  1391. struct event_data_instance *edi;
  1392. SaSizeT xfsize;
  1393. if (!eventData || !eventDataSize) {
  1394. goto data_get_done;
  1395. }
  1396. error = saHandleInstanceGet(&event_handle_db, eventHandle,
  1397. (void*)&edi);
  1398. if (error != SA_AIS_OK) {
  1399. goto data_get_done;
  1400. }
  1401. pthread_mutex_lock(&edi->edi_mutex);
  1402. if (edi->edi_event_data && edi->edi_event_data_size) {
  1403. xfsize = min(*eventDataSize, edi->edi_event_data_size);
  1404. *eventDataSize = edi->edi_event_data_size;
  1405. if (*eventDataSize < edi->edi_event_data_size) {
  1406. error = SA_AIS_ERR_NO_SPACE;
  1407. }
  1408. memcpy(eventData, edi->edi_event_data, xfsize);
  1409. } else {
  1410. *eventDataSize = 0;
  1411. }
  1412. pthread_mutex_unlock(&edi->edi_mutex);
  1413. saHandleInstancePut(&event_handle_db, eventHandle);
  1414. data_get_done:
  1415. return error;
  1416. }
  1417. /*
  1418. * Calculate the size in bytes for patterns
  1419. */
  1420. static size_t patt_size(const SaEvtEventPatternArrayT *patterns)
  1421. {
  1422. int i;
  1423. size_t size = sizeof(SaEvtEventPatternArrayT);
  1424. for (i = 0; i < patterns->patternsNumber; i++) {
  1425. size += sizeof(SaEvtEventPatternT);
  1426. size += patterns->patterns[i].patternSize;
  1427. }
  1428. return size;
  1429. }
  1430. /*
  1431. * copy patterns to a form for sending to the server
  1432. */
  1433. static uint32_t aispatt_to_evt_patt(const SaEvtEventPatternArrayT *patterns,
  1434. void *data)
  1435. {
  1436. int i;
  1437. SaEvtEventPatternT *pats = data;
  1438. SaUint8T *str = (SaUint8T *)pats +
  1439. (patterns->patternsNumber * sizeof(*pats));
  1440. /*
  1441. * Pointers are replaced with offsets into the data array. These
  1442. * will be later converted back into pointers when received as events.
  1443. */
  1444. for (i = 0; i < patterns->patternsNumber; i++) {
  1445. memcpy(str, patterns->patterns[i].pattern,
  1446. patterns->patterns[i].patternSize);
  1447. pats->patternSize = patterns->patterns[i].patternSize;
  1448. pats->pattern = (SaUint8T *)((void *)str - data);
  1449. str += patterns->patterns[i].patternSize;
  1450. pats++;
  1451. }
  1452. return patterns->patternsNumber;
  1453. }
  1454. /*
  1455. * Calculate the size in bytes for filters
  1456. */
  1457. static size_t filt_size(const SaEvtEventFilterArrayT *filters)
  1458. {
  1459. int i;
  1460. size_t size = sizeof(SaEvtEventFilterArrayT);
  1461. for (i = 0; i < filters->filtersNumber; i++) {
  1462. size += sizeof(SaEvtEventFilterT);
  1463. size += filters->filters[i].filter.patternSize;
  1464. }
  1465. return size;
  1466. }
  1467. /*
  1468. * Convert the Sa filters to a form that can be sent over the network
  1469. * i.e. replace pointers with offsets. The pointers will be reconstituted
  1470. * by the receiver.
  1471. */
  1472. static uint32_t aisfilt_to_evt_filt(const SaEvtEventFilterArrayT *filters,
  1473. void *data)
  1474. {
  1475. int i;
  1476. SaEvtEventFilterArrayT *filta = data;
  1477. SaEvtEventFilterT *filts = data + sizeof(SaEvtEventFilterArrayT);
  1478. SaUint8T *str = (SaUint8T *)filts +
  1479. (filters->filtersNumber * sizeof(*filts));
  1480. /*
  1481. * Pointers are replaced with offsets into the data array. These
  1482. * will be later converted back into pointers by the evt server.
  1483. */
  1484. filta->filters = (SaEvtEventFilterT *)((void *)filts - data);
  1485. filta->filtersNumber = filters->filtersNumber;
  1486. for (i = 0; i < filters->filtersNumber; i++) {
  1487. filts->filterType = filters->filters[i].filterType;
  1488. filts->filter.patternSize =
  1489. filters->filters[i].filter.patternSize;
  1490. memcpy(str,
  1491. filters->filters[i].filter.pattern,
  1492. filters->filters[i].filter.patternSize);
  1493. filts->filter.pattern = (SaUint8T *)((void *)str - data);
  1494. str += filters->filters[i].filter.patternSize;
  1495. filts++;
  1496. }
  1497. return filters->filtersNumber;
  1498. }
  1499. /*
  1500. * The saEvtEventPublish() function publishes an event on the associated
  1501. * channel. The event to be published consists of a
  1502. * standard set of attributes (the event header) and an optional data part.
  1503. * Before an event can be published, the publisher process must invoke the
  1504. * saEvtEventPatternArraySet() function to set the event patterns. The event
  1505. * is delivered to subscribers whose subscription filter matches the event
  1506. * patterns.
  1507. * When the Event Service publishes an event, it automatically sets
  1508. * the following readonly event attributes:
  1509. * - Event attribute time
  1510. * - Event publisher identifier
  1511. * - Event publisher node identifier
  1512. * - Event identifier
  1513. * In addition to the event attributes, a process can supply values for the
  1514. * eventData and eventDataSize parameters for publication as part of the
  1515. * event. The data portion of the event may be at most SA_EVT_DATA_MAX_LEN
  1516. * bytes in length.
  1517. * The process may assume that the invocation of saEvtEventPublish() copies
  1518. * all pertinent parameters, including the memory associated with the
  1519. * eventHandle and eventData parameters, to its own local memory. However,
  1520. * the invocation does not automatically deallocate memory associated with
  1521. * the eventHandle and eventData parameters. It is the responsibility of the
  1522. * invoking process to deallocate the memory for those parameters after
  1523. * saEvtEventPublish() returns.
  1524. */
  1525. SaAisErrorT
  1526. saEvtEventPublish(
  1527. const SaEvtEventHandleT eventHandle,
  1528. const void *eventData,
  1529. SaSizeT eventDataSize,
  1530. SaEvtEventIdT *eventId)
  1531. {
  1532. SaAisErrorT error;
  1533. struct event_data_instance *edi;
  1534. struct event_instance *evti;
  1535. struct event_channel_instance *eci;
  1536. struct lib_event_data *req;
  1537. struct res_evt_event_publish res;
  1538. size_t pattern_size;
  1539. struct event_pattern *patterns;
  1540. void *data_start;
  1541. struct iovec iov;
  1542. if (!eventId) {
  1543. return SA_AIS_ERR_INVALID_PARAM;
  1544. }
  1545. if (eventDataSize > SA_EVT_DATA_MAX_LEN) {
  1546. error = SA_AIS_ERR_INVALID_PARAM;
  1547. goto pub_done;
  1548. }
  1549. error = saHandleInstanceGet(&event_handle_db, eventHandle,
  1550. (void*)&edi);
  1551. if (error != SA_AIS_OK) {
  1552. goto pub_done;
  1553. }
  1554. pthread_mutex_lock(&edi->edi_mutex);
  1555. error = saHandleInstanceGet(&channel_handle_db, edi->edi_channel_handle,
  1556. (void*)&eci);
  1557. if (error != SA_AIS_OK) {
  1558. goto pub_put1;
  1559. }
  1560. /*
  1561. * See if we can publish to this channel
  1562. */
  1563. if (!(eci->eci_open_flags & SA_EVT_CHANNEL_PUBLISHER)) {
  1564. error = SA_AIS_ERR_ACCESS;
  1565. goto pub_put2;
  1566. }
  1567. error = saHandleInstanceGet(&evt_instance_handle_db,
  1568. eci->eci_instance_handle, (void*)&evti);
  1569. if (error != SA_AIS_OK) {
  1570. goto pub_put2;
  1571. }
  1572. /*
  1573. * Figure out how much memory we need for the patterns and data
  1574. */
  1575. pattern_size = patt_size(&edi->edi_patterns);
  1576. req = malloc(sizeof(*req) + eventDataSize + pattern_size);
  1577. patterns = (struct event_pattern *)req->led_body;
  1578. data_start = (void *)req->led_body + pattern_size;
  1579. if (!req) {
  1580. error = SA_AIS_ERR_NO_MEMORY;
  1581. goto pub_put3;
  1582. }
  1583. /*
  1584. * copy everything to the request structure
  1585. */
  1586. aispatt_to_evt_patt(&edi->edi_patterns, patterns);
  1587. req->led_patterns_number = edi->edi_patterns.patternsNumber;
  1588. req->led_user_data_offset = pattern_size;
  1589. if (eventData && eventDataSize) {
  1590. memcpy(data_start, eventData, eventDataSize);
  1591. req->led_user_data_size = eventDataSize;
  1592. } else {
  1593. req->led_user_data_size = 0;
  1594. }
  1595. req->led_head.id = MESSAGE_REQ_EVT_PUBLISH;
  1596. req->led_head.size = sizeof(*req) + pattern_size + eventDataSize;
  1597. req->led_svr_channel_handle = eci->eci_svr_channel_handle;
  1598. req->led_retention_time = edi->edi_retention_time;
  1599. req->led_publish_time = clustTimeNow();
  1600. req->led_priority = edi->edi_priority;
  1601. req->led_publisher_name = edi->edi_pub_name;
  1602. iov.iov_base = req;
  1603. iov.iov_len = req->led_head.size;
  1604. pthread_mutex_lock(&evti->ei_response_mutex);
  1605. error = saSendMsgReceiveReply(evti->ei_response_fd, &iov, 1, &res,
  1606. sizeof(res));
  1607. pthread_mutex_unlock (&evti->ei_response_mutex);
  1608. free(req);
  1609. if (error != SA_AIS_OK) {
  1610. pthread_mutex_unlock (&evti->ei_response_mutex);
  1611. goto pub_put3;
  1612. }
  1613. error = res.iep_head.error;
  1614. if (error == SA_AIS_OK) {
  1615. *eventId = res.iep_event_id;
  1616. }
  1617. pub_put3:
  1618. saHandleInstancePut (&evt_instance_handle_db, eci->eci_instance_handle);
  1619. pub_put2:
  1620. saHandleInstancePut (&channel_handle_db, edi->edi_channel_handle);
  1621. pub_put1:
  1622. pthread_mutex_unlock(&edi->edi_mutex);
  1623. saHandleInstancePut(&event_handle_db, eventHandle);
  1624. pub_done:
  1625. return error;
  1626. }
  1627. /*
  1628. * The saEvtEventSubscribe() function enables a process to subscribe for
  1629. * events on an event channel by registering one or more filters on that
  1630. * event channel. The process must have opened the event channel, designated
  1631. * by channelHandle, with the SA_EVT_CHANNEL_SUBSCRIBER flag set for an
  1632. * invocation of this function to be successful.
  1633. * The memory associated with the filters is not deallocated by the
  1634. * saEvtEventSubscribe() function. It is the responsibility of the invoking
  1635. * process to deallocate the memory when the saEvtEventSubscribe() function
  1636. * returns.
  1637. * For a given subscription, the filters parameter cannot be modified. To
  1638. * change the filters parameter without losing events, a process must
  1639. * establish a new subscription with the new filters parameter. After the new
  1640. * subscription is established, the old subscription can be removed by
  1641. * invoking the saEvtEventUnsubscribe() function.
  1642. */
  1643. SaAisErrorT
  1644. saEvtEventSubscribe(
  1645. const SaEvtChannelHandleT channelHandle,
  1646. const SaEvtEventFilterArrayT *filters,
  1647. SaEvtSubscriptionIdT subscriptionId)
  1648. {
  1649. SaAisErrorT error;
  1650. struct event_instance *evti;
  1651. struct event_channel_instance *eci;
  1652. struct req_evt_event_subscribe *req;
  1653. struct res_evt_event_subscribe res;
  1654. int sz;
  1655. struct iovec iov;
  1656. if (!filters) {
  1657. return SA_AIS_ERR_INVALID_PARAM;
  1658. }
  1659. error = saHandleInstanceGet(&channel_handle_db, channelHandle,
  1660. (void*)&eci);
  1661. if (error != SA_AIS_OK) {
  1662. goto subscribe_done;
  1663. }
  1664. /*
  1665. * get the evt handle for the fd
  1666. */
  1667. error = saHandleInstanceGet(&evt_instance_handle_db,
  1668. eci->eci_instance_handle, (void*)&evti);
  1669. if (error != SA_AIS_OK) {
  1670. goto subscribe_put1;
  1671. }
  1672. /*
  1673. * Make sure that a deliver callback has been
  1674. * registered before allowing the subscribe to continue.
  1675. */
  1676. if (!evti->ei_callback.saEvtEventDeliverCallback) {
  1677. error = SA_AIS_ERR_INIT;
  1678. goto subscribe_put2;
  1679. }
  1680. /*
  1681. * See if we can subscribe to this channel
  1682. */
  1683. if (!(eci->eci_open_flags & SA_EVT_CHANNEL_SUBSCRIBER)) {
  1684. error = SA_AIS_ERR_ACCESS;
  1685. goto subscribe_put2;
  1686. }
  1687. /*
  1688. * calculate size needed to store the filters
  1689. */
  1690. sz = filt_size(filters);
  1691. req = malloc(sizeof(*req) + sz);
  1692. if (!req) {
  1693. error = SA_AIS_ERR_NO_MEMORY;
  1694. goto subscribe_put2;
  1695. }
  1696. /*
  1697. * Copy the supplied filters to the request
  1698. */
  1699. req->ics_filter_count = aisfilt_to_evt_filt(filters,
  1700. req->ics_filter_data);
  1701. req->ics_head.id = MESSAGE_REQ_EVT_SUBSCRIBE;
  1702. req->ics_head.size = sizeof(*req) + sz;
  1703. req->ics_channel_handle = eci->eci_svr_channel_handle;
  1704. req->ics_sub_id = subscriptionId;
  1705. req->ics_filter_size = sz;
  1706. iov.iov_base = req;
  1707. iov.iov_len = req->ics_head.size;
  1708. pthread_mutex_lock(&evti->ei_response_mutex);
  1709. error = saSendMsgReceiveReply(evti->ei_response_fd, &iov, 1,
  1710. &res, sizeof(res));
  1711. pthread_mutex_unlock (&evti->ei_response_mutex);
  1712. free(req);
  1713. if (res.ics_head.id != MESSAGE_RES_EVT_SUBSCRIBE) {
  1714. goto subscribe_put2;
  1715. }
  1716. error = res.ics_head.error;
  1717. subscribe_put2:
  1718. saHandleInstancePut(&evt_instance_handle_db,
  1719. eci->eci_instance_handle);
  1720. subscribe_put1:
  1721. saHandleInstancePut(&channel_handle_db, channelHandle);
  1722. subscribe_done:
  1723. return error;
  1724. }
  1725. /*
  1726. * The saEvtEventUnsubscribe() function allows a process to stop receiving
  1727. * events for a particular subscription on an event channel by removing the
  1728. * subscription. The saEvtEventUnsubscribe() operation is successful if the
  1729. * subscriptionId parameter matches a previously registered subscription.
  1730. * Pending events that no longer match any subscription, because the
  1731. * saEvtEventUnsubscribe() operation had been invoked, are purged. a process
  1732. * that wishes to modify a subscription without losing any events must
  1733. * establish the new subscription before removing the existing subscription.
  1734. */
  1735. SaAisErrorT
  1736. saEvtEventUnsubscribe(
  1737. const SaEvtChannelHandleT channelHandle,
  1738. SaEvtSubscriptionIdT subscriptionId)
  1739. {
  1740. SaAisErrorT error;
  1741. struct event_instance *evti;
  1742. struct event_channel_instance *eci;
  1743. struct req_evt_event_unsubscribe req;
  1744. struct res_evt_event_unsubscribe res;
  1745. struct iovec iov;
  1746. error = saHandleInstanceGet(&channel_handle_db, channelHandle,
  1747. (void*)&eci);
  1748. if (error != SA_AIS_OK) {
  1749. goto unsubscribe_done;
  1750. }
  1751. error = saHandleInstanceGet(&evt_instance_handle_db,
  1752. eci->eci_instance_handle, (void*)&evti);
  1753. if (error != SA_AIS_OK) {
  1754. goto unsubscribe_put1;
  1755. }
  1756. req.icu_head.id = MESSAGE_REQ_EVT_UNSUBSCRIBE;
  1757. req.icu_head.size = sizeof(req);
  1758. req.icu_channel_handle = eci->eci_svr_channel_handle;
  1759. req.icu_sub_id = subscriptionId;
  1760. iov.iov_base = &req;
  1761. iov.iov_len = sizeof(req);
  1762. pthread_mutex_lock(&evti->ei_response_mutex);
  1763. error = saSendMsgReceiveReply(evti->ei_response_fd, &iov, 1,
  1764. &res, sizeof(res));
  1765. pthread_mutex_unlock (&evti->ei_response_mutex);
  1766. if (error != SA_AIS_OK) {
  1767. goto unsubscribe_put2;
  1768. }
  1769. if (res.icu_head.id != MESSAGE_RES_EVT_UNSUBSCRIBE) {
  1770. error = SA_AIS_ERR_LIBRARY;
  1771. goto unsubscribe_put2;
  1772. }
  1773. error = res.icu_head.error;
  1774. unsubscribe_put2:
  1775. saHandleInstancePut(&evt_instance_handle_db,
  1776. eci->eci_instance_handle);
  1777. unsubscribe_put1:
  1778. saHandleInstancePut(&channel_handle_db, channelHandle);
  1779. unsubscribe_done:
  1780. return error;
  1781. }
  1782. /*
  1783. * The saEvtEventRetentionTimeClear() function is used to clear the retention
  1784. * time of a published event. It indicates to the Event Service that it does
  1785. * not need to keep the event any longer for potential new subscribers. Once
  1786. * the value of the retention time is reset to 0, the event is no longer
  1787. * available for new subscribers. The event is held until all old subscribers
  1788. * in the system process the event and free the event using saEvtEventFree().
  1789. */
  1790. SaAisErrorT
  1791. saEvtEventRetentionTimeClear(
  1792. const SaEvtChannelHandleT channelHandle,
  1793. const SaEvtEventIdT eventId)
  1794. {
  1795. SaAisErrorT error;
  1796. struct event_instance *evti;
  1797. struct event_channel_instance *eci;
  1798. struct req_evt_event_clear_retentiontime req;
  1799. struct res_evt_event_clear_retentiontime res;
  1800. struct iovec iov;
  1801. error = saHandleInstanceGet(&channel_handle_db, channelHandle,
  1802. (void*)&eci);
  1803. if (error != SA_AIS_OK) {
  1804. goto ret_time_done;
  1805. }
  1806. error = saHandleInstanceGet(&evt_instance_handle_db,
  1807. eci->eci_instance_handle, (void*)&evti);
  1808. if (error != SA_AIS_OK) {
  1809. goto ret_time_put1;
  1810. }
  1811. req.iec_head.id = MESSAGE_REQ_EVT_CLEAR_RETENTIONTIME;
  1812. req.iec_head.size = sizeof(req);
  1813. req.iec_channel_handle = eci->eci_svr_channel_handle;
  1814. req.iec_event_id = eventId;
  1815. iov.iov_base = &req;
  1816. iov.iov_len = sizeof(req);
  1817. pthread_mutex_lock(&evti->ei_response_mutex);
  1818. error = saSendMsgReceiveReply(evti->ei_response_fd, &iov, 1,
  1819. &res, sizeof(res));
  1820. pthread_mutex_unlock (&evti->ei_response_mutex);
  1821. if (error != SA_AIS_OK) {
  1822. goto ret_time_put2;
  1823. }
  1824. if (res.iec_head.id != MESSAGE_RES_EVT_CLEAR_RETENTIONTIME) {
  1825. error = SA_AIS_ERR_LIBRARY;
  1826. goto ret_time_put2;
  1827. }
  1828. error = res.iec_head.error;
  1829. ret_time_put2:
  1830. saHandleInstancePut(&evt_instance_handle_db,
  1831. eci->eci_instance_handle);
  1832. ret_time_put1:
  1833. saHandleInstancePut(&channel_handle_db, channelHandle);
  1834. ret_time_done:
  1835. return error;
  1836. }
  1837. /*
  1838. * vi: set autoindent tabstop=4 shiftwidth=4 :
  1839. */