| 1362 | } |
| 1363 | |
| 1364 | void DCPS_IR_Domain::dispose_subscription_bit(DCPS_IR_Subscription* subscription) |
| 1365 | { |
| 1366 | #if !defined (DDS_HAS_MINIMUM_BIT) |
| 1367 | |
| 1368 | if (useBIT_) { |
| 1369 | if (!subscription->is_bit()) { |
| 1370 | try { |
| 1371 | DDS::SubscriptionBuiltinTopicData key_data; |
| 1372 | DDS::InstanceHandle_t handle = subscription->get_handle(); |
| 1373 | |
| 1374 | DDS::ReturnCode_t retGetKey |
| 1375 | = bitSubscriptionDataWriter_->get_key_value(key_data, |
| 1376 | handle); |
| 1377 | |
| 1378 | if (DDS::RETCODE_OK != retGetKey) { |
| 1379 | ACE_ERROR((LM_ERROR, |
| 1380 | ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Domain::dispose_subscription_bit ") |
| 1381 | ACE_TEXT("Unable to get_key_value for subscription ptr 0x%x handle %d. ") |
| 1382 | ACE_TEXT("Call returned %d.\n"), |
| 1383 | subscription, |
| 1384 | handle, |
| 1385 | retGetKey)); |
| 1386 | } |
| 1387 | |
| 1388 | DDS::ReturnCode_t retDispose = |
| 1389 | bitSubscriptionDataWriter_->dispose(key_data, |
| 1390 | handle); |
| 1391 | |
| 1392 | if (DDS::RETCODE_OK != retDispose) { |
| 1393 | ACE_ERROR((LM_ERROR, |
| 1394 | ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Domain::dispose_subscription_bit ") |
| 1395 | ACE_TEXT("Unable to dispose for subscription ptr 0x%x handle %d. ") |
| 1396 | ACE_TEXT("Call returned %d.\n"), |
| 1397 | subscription, |
| 1398 | handle, |
| 1399 | retDispose)); |
| 1400 | } |
| 1401 | |
| 1402 | } catch (const CORBA::Exception& ex) { |
| 1403 | ex._tao_print_exception( |
| 1404 | "(%P|%t) ERROR: Exception caught in DCPS_IR_Domain::dispose_subscription_bit:"); |
| 1405 | } |
| 1406 | } |
| 1407 | } |
| 1408 | |
| 1409 | #else |
| 1410 | ACE_UNUSED_ARG(subscription); |
| 1411 | #endif // !defined (DDS_HAS_MINIMUM_BIT) |
| 1412 | } |
| 1413 | |
| 1414 | void DCPS_IR_Domain::dispose_publication_bit(DCPS_IR_Publication* publication) |
| 1415 | { |
no test coverage detected