| 1237 | } |
| 1238 | |
| 1239 | void |
| 1240 | Config::loadWriter( |
| 1241 | ACE_Configuration_Heap& heap, |
| 1242 | ACE_Configuration_Section_Key& sectionKey, |
| 1243 | std::basic_string<ACE_TCHAR> sectionName |
| 1244 | ) |
| 1245 | { |
| 1246 | /** |
| 1247 | * [writer/<name>] |
| 1248 | * # DataWriter Qos Policy values |
| 1249 | * Durability = <string> # One of VOLATILE, LOCAL, TRANSIENT, PERSISTENT |
| 1250 | * DurabilityServiceDuration = <number> |
| 1251 | * DurabilityServiceHistoryKind = <string> # One of ALL, LAST |
| 1252 | * DurabilityServiceHistoryDepth = <number> |
| 1253 | * DurabilityServiceSamples = <number> |
| 1254 | * DurabilityServiceInstances = <number> |
| 1255 | * DurabilityServiceSamplesPerInstance = <number> |
| 1256 | * Deadline = <number> |
| 1257 | * LatencyBudget = <number> |
| 1258 | * LivelinessKind = <string> # One of AUTOMATIC, PARTICIPANT, TOPIC |
| 1259 | * LivelinessDuration = <number> |
| 1260 | * ReliabilityKind = <string> # One of BEST_EFFORT, RELIABLE |
| 1261 | * ReliabilityMaxBlocking = <number> |
| 1262 | * DestinationOrder = <string> # One of SOURCE, RECEPTION |
| 1263 | * HistoryKind = <string> # One of ALL, LAST |
| 1264 | * HistoryDepth = <number> |
| 1265 | * ResourceMaxSamples = <number> |
| 1266 | * ResourceMaxInstances = <number> |
| 1267 | * ResourceMaxSamplesPerInstance = <number> |
| 1268 | * TransportPriority = <number> |
| 1269 | * Lifespan = <number> |
| 1270 | * UserData = <string> |
| 1271 | * OwnershipKind = <string> # One of SHARED, EXCLUSIVE |
| 1272 | * OwnershipStrength = <number> |
| 1273 | * WriterDataLifecycle = <bool> # Boolean: numeric 0 or 1 |
| 1274 | * |
| 1275 | * Publisher = <string> # One of publisher <name> |
| 1276 | * Topic = <string> # One of topic <name> |
| 1277 | */ |
| 1278 | |
| 1279 | // Note that this requires that the Service Participant already be |
| 1280 | // initialized before we configure from the file. Also, since we have |
| 1281 | // not created any Entities yet, we go to the initial default values |
| 1282 | // rather than to the containing Entity. |
| 1283 | WriterProfile* profile = new WriterProfile(); |
| 1284 | profile->qos = TheServiceParticipant->initial_DataWriterQos(); |
| 1285 | profile->mask = 0; |
| 1286 | ACE_TString valueString; |
| 1287 | |
| 1288 | // Durability = <string> # One of VOLATILE, LOCAL, TRANSIENT, PERSISTENT |
| 1289 | valueString.clear(); |
| 1290 | heap.get_string_value( sectionKey, DURABILITY_KEYNAME, valueString); |
| 1291 | if (valueString.length() > 0) { |
| 1292 | if( OpenDDS::DCPS::DCPS_debug_level>1) { |
| 1293 | ACE_DEBUG((LM_DEBUG, |
| 1294 | ACE_TEXT("(%P|%t) Config::loadWriter() - ") |
| 1295 | ACE_TEXT(" [writer/%s] %s == %s.\n"), |
| 1296 | sectionName.c_str(), |
nothing calls this directly
no test coverage detected