Lines Matching defs:fapi
97 PubSubInterface *fapi = NULL;
107 int result = iUnknown->QueryInterface(iUnknown, DEFAULT_VERSION, (void **)&fapi);
108 if (result != 0 || fapi == NULL) {
118 return fapi;
124 static void CASE_AddAndUnsubscribeTopic(PubSubInterface *fapi)
126 Subscriber *subscriber = &fapi->subscriber;
127 Provider *provider = &fapi->provider;
133 subscriber->AddTopic((IUnknown *)fapi, &topic0);
134 subscriber->Subscribe((IUnknown *)fapi, &topic0, &c1);
135 subscriber->Subscribe((IUnknown *)fapi, &topic0, &c2);
136 provider->Publish((IUnknown *)fapi, &topic0, (uint8_t *) "==>111<==", TEST_LEN);
138 subscriber->AddTopic((IUnknown *)fapi, &topic1);
139 subscriber->Subscribe((IUnknown *)fapi, &topic1, &c1);
140 subscriber->Subscribe((IUnknown *)fapi, &topic1, &c2);
141 provider->Publish((IUnknown *)fapi, &topic1, (uint8_t *) "==>444<==", TEST_LEN);
148 subscriber->Unsubscribe((IUnknown *)fapi, &topic0, &c1);
149 provider->Publish((IUnknown *)fapi, &topic0, (uint8_t *) "@@@222@@@", TEST_LEN);
151 subscriber->Unsubscribe((IUnknown *)fapi, &topic0, &c2);
152 provider->Publish((IUnknown *)fapi, &topic0, (uint8_t *) "@@@333@@@", TEST_LEN);
153 provider->Publish((IUnknown *)fapi, &topic1, (uint8_t *) "@@@444@@@", TEST_LEN);
162 static void CASE_ModifyConsumer(PubSubInterface *fapi)
164 Subscriber *subscriber = &fapi->subscriber;
165 Provider *provider = &fapi->provider;
172 subscriber->AddTopic((IUnknown *)fapi, &topic2);
173 subscriber->Subscribe((IUnknown *)fapi, &topic2, &c1);
174 provider->Publish((IUnknown *)fapi, &topic2, (uint8_t *) "==>555<==", TEST_LEN);
176 subscriber->ModifyConsumer((IUnknown *)fapi, &topic2, &c1, &c2);
177 provider->Publish((IUnknown *)fapi, &topic2, (uint8_t *) "@@@555@@@", TEST_LEN);
186 static void CASE_ReUnsubscribeTopic(PubSubInterface *fapi)
188 Subscriber *subscriber = &fapi->subscriber;
189 Provider *provider = &fapi->provider;
194 subscriber->AddTopic((IUnknown *)fapi, &topic3);
195 subscriber->Subscribe((IUnknown *)fapi, &topic3, &c1);
196 provider->Publish((IUnknown *)fapi, &topic3, (uint8_t *) "==>666<==", TEST_LEN);
198 Consumer *retConsumer = subscriber->Unsubscribe((IUnknown *)fapi, &topic3, &c1);
203 retConsumer = subscriber->Unsubscribe((IUnknown *)fapi, &topic3, &c1);
208 provider->Publish((IUnknown *)fapi, &topic3, (uint8_t *) "@@@666@@@", TEST_LEN);
215 static void CASE_ReleaseIUnknown(PubSubInterface *fapi)
219 int32 ref = fapi->Release((IUnknown *)fapi);
234 PubSubInterface *fapi = CASE_GetIUnknown();
235 CASE_AddAndUnsubscribeTopic(fapi);
236 CASE_ModifyConsumer(fapi);
237 CASE_ReUnsubscribeTopic(fapi);
238 CASE_ReleaseIUnknown(fapi);