When I am trying to send a file in a message using RTI DDS I keep getting this error and can not decode its meaning for how to fix it. The file is only of 2kb size as of note.
com.rti.dds.infrastructure.RETCODE_ERROR: Unexpected string length: 2320 > 1023
at com.rti.dds.cdr.CdrOutputStream.writeString(Unknown Source)
at com.rti.dds.type.builtin.StringTypeSupport.serialize(Unknown Source)
at com.rti.dds.topic.TypeSupportImpl.serializeI(Unknown Source)
at com.rti.dds.publication.DataWriterImpl.DDS_DataWriter_write_untypedI(Native Method)
at com.rti.dds.publication.DataWriterImpl.write_untyped(Unknown Source)
at com.rti.dds.type.builtin.StringDataWriter.write(Unknown Source)
at publisher.main(publisher.java:80)
PRESWriterHistoryDriver_initializeSample:!serialize
WriterHistoryMemoryPlugin_addEntryToSessions:!initialize sample
WriterHistoryMemoryPlugin_getEntry:!add virtual sample to sessions
WriterHistoryMemoryPlugin_addSample:!get entry
PRESWriterHistoryDriver_addWrite:!add_sample
PRESPsWriter_writeInternal:!collator addWrite
com.rti.dds.infrastructure.RETCODE_ERROR
at com.rti.dds.util.Utilities.rethrow(Unknown Source)
at com.rti.dds.infrastructure.RETCODE_ERROR.check_return_codeI(Unknown Source)
at com.rti.dds.publication.DataWriterImpl.write_untyped(Unknown Source)
at com.rti.dds.type.builtin.StringDataWriter.write(Unknown Source)
at publisher.main(publisher.java:80)
Exiting...
Exception in thread "main"
Unexpected string length: 2320 > 1023
The defined type includes a string field defined something like:
string<1023> aString;
and you are trying to send a 2320 byte long string. The rest of the error messages we can try to address after you've resolved the initial problem in your code.
There is a qos property setting for defining the length supported for the built-in StringDataWriter (see Table 3.1 on pdf page 68, Properties for Allocating Size of Built-in Types). Note that if you change the size for Application A, you have to also change the size for Application B or they will still not communicate.
Thanks. I was able to solve the part of where to put this in the code since I decided to change the QOS policy file in the code. By doing
PropertyQosPolicyHelper.add_property(datawriter_qos.property,"dds.builtin_type.string.alloc_size" ,"2048" ,true);
PropertyQosPolicyHelper.add_property(datawriter_qos.property, "dds.builtin_type.string.max_size", "2048",true);
However now a new problem has appeared from this.
PRESTypePluginDefaultEndpointBuiltinTypeConfigData_initialize:invalid property dds.builtin_type.string.max_size
TypeSupportNativePeer_on_endpoint_attached:!init builtin type config data
PRESPsService_enableLocalEndpointWithCursor:failed to attach endpoint to typePlugin
PRESPsService_enableLocalEndpoint:!enable local endpoint
max_size isn't a datawriter_qos property, it's a participant_qos property. See section 3.2.7 of the Users Manual PDF, and Table 3-16 on page 3-90.
I did
PropertyQosPolicyHelper.add_property(dp_qos.property,"dds.builtin_type.string.max_size","2050",true);
and now get
PRESTypePluginDefaultEndpointBuiltinTypeConfigData_initialize:inconsistent values: dds.builtin_type.string.alloc_size and dds.builtin_type.string.max_size
Can you supply all the code around the configuration and creation of your QoS/entities, for both the participant and the writer entity.
codeimport java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import com.rti.dds.domain.DomainParticipant;
import com.rti.dds.domain.DomainParticipantFactory;
import com.rti.dds.domain.DomainParticipantFactoryQos;
import com.rti.dds.domain.DomainParticipantQos;
import com.rti.dds.infrastructure.InstanceHandle_t;
import com.rti.dds.infrastructure.PropertyQosPolicyHelper;
import com.rti.dds.infrastructure.RETCODE_ERROR;
import com.rti.dds.infrastructure.StatusKind;
import com.rti.dds.publication.DataWriterQos;
import com.rti.dds.publication.Publisher;
import com.rti.dds.subscription.DataReader;
import com.rti.dds.subscription.DataReaderListener;
import com.rti.dds.subscription.LivelinessChangedStatus;
import com.rti.dds.subscription.RequestedDeadlineMissedStatus;
import com.rti.dds.subscription.RequestedIncompatibleQosStatus;
import com.rti.dds.subscription.SampleLostStatus;
import com.rti.dds.subscription.SampleRejectedStatus;
import com.rti.dds.subscription.SubscriptionMatchedStatus;
import com.rti.dds.topic.Topic;
import com.rti.dds.type.builtin.StringDataWriter;
import com.rti.dds.type.builtin.StringTypeSupport;
import java.lang.reflect.Field;
import javax.xml.parsers.ParserConfigurationException;
import javax.xml.transform.TransformerException;
import javax.xml.transform.TransformerFactoryConfigurationError;
import org.xml.sax.SAXException;
public class publisher{
public static void main(String[] args) throws NoSuchFieldException, SecurityException, IllegalArgumentException, IllegalAccessException, ParserConfigurationException, SAXException, TransformerFactoryConfigurationError, TransformerException
{
//System.load("C:\\Program Files\\RTI\\ndds.5.1.0\\lib\\x64Win64jdk\\nddsc.dll");
//System.load("C:\\Program Files\\RTI\\ndds.5.1.0\\lib\\x64Win64jdk\\nddsjavad.dll");
//System.load("C:\\Program Files\\RTI\\ndds.5.1.0\\lib\\x64Win64jdk\\nddscd.dll");
//System.load("C:\\Program Files\\RTI\\ndds.5.1.0\\lib\\x64Win64jdk\\nddscore.dll");
//System.load("C:\\Program Files\\RTI\\ndds.5.1.0\\lib\\x64Win64jdk\\nddscored.dll");
//System.load("C:\\Program Files\\RTI\\ndds.5.1.0\\lib\\x64Win64jdk\\nddsjava.dll");
//System.load("C:\\Program Files\\RTI\\ndds.5.1.0\\lib\\x64Win64jdk\\nddsjavad.dll");
DomainParticipantQos dp_qos = new DomainParticipantQos();
//PropertyQosPolicyHelper.add_property(dp_qos.property,"dds.builtin_type.string.max_size","2050",true);
DomainParticipant participant = DomainParticipantFactory.get_instance().create_participant(0,DomainParticipantFactory.PARTICIPANT_QOS_DEFAULT, null,StatusKind.STATUS_MASK_NONE);
participant.get_qos(dp_qos);
PropertyQosPolicyHelper.add_property(dp_qos.property,"dds.builtin_type.string.max_size","2050",true);
participant = DomainParticipantFactory.get_instance().create_participant(0,DomainParticipantFactory.PARTICIPANT_QOS_DEFAULT, null,StatusKind.STATUS_MASK_NONE);
//PropertyQosPolicyHelper.add_property(dp_qos.property,"dds.builtin_type.string.max_size","2050",true);
DomainParticipantFactoryQos factoryQos =
new DomainParticipantFactoryQos();
factoryQos.profile.url_profile.setMaximum(1);
factoryQos.profile.url_profile.add("C:\\Users\\jricles\\Desktop\\custom_qos.xml");
DomainParticipantFactory.TheParticipantFactory.set_qos(factoryQos);
DomainParticipantFactory.TheParticipantFactory.get_qos(factoryQos);
if (participant == null)
{
System.err.println("Unable to create domain participant");
return;
}
Publisher publisher = participant.create_publisher(
DomainParticipant.PUBLISHER_QOS_DEFAULT, null /* listener */,
StatusKind.STATUS_MASK_NONE);
Topic topic = participant.create_topic(
"Event Logging",
StringTypeSupport.get_type_name(),
DomainParticipant.TOPIC_QOS_DEFAULT,
null, // listener
StatusKind.STATUS_MASK_NONE);
if (topic == null)
{
System.err.println("Unable to create topic.");
return;
}
DataWriterQos datawriter_qos = new DataWriterQos();
//publisher.set_default_library("C:\\Users\\jricles\\Desktop\\custom_qos.xml");
//participant.set_default_profile("BuiltinExampleLibrary","BuiltinExampleProfile");
StringDataWriter dataWriter =
(StringDataWriter) participant.create_datawriter(
topic,
Publisher.DATAWRITER_QOS_DEFAULT,
null, // listener
StatusKind.STATUS_MASK_NONE);
if (dataWriter == null)
{
System.err.println("Unable to create data writer\n");
return;
}
//DataWriterQos writerQos = new DataWriterQos();
participant.get_default_datawriter_qos(datawriter_qos);
//PropertyQosPolicyHelper.add_property(writerQos.property,"dds.builtin_type.string.alloc_size" ,"2048" ,true);
//PropertyQosPolicyHelper.add_property(dp_qos.property,"dds.builtin_type.string.max_size","2049",true);
//PropertyQosPolicyHelper.add_property(writerQos.property, "dds.builtin_type.string.max_size", "2048",true);
PropertyQosPolicyHelper.add_property(datawriter_qos.property,"dds.builtin_type.string.alloc_size" ,"2048" ,true);
//PropertyQosPolicyHelper.add_property(datawriter_qos.property, "dds.builtin_type.string.max_size", "2048",true);
dataWriter =
(StringDataWriter) publisher.create_datawriter(topic, datawriter_qos,
null, StatusKind.STATUS_MASK_NONE);
System.out.println("Ready to write data.");
System.out.println("When the subscriber is ready, you can start writing.");
System.out.print("Press CTRL+C to terminate or enter an empty line to do a clean shutdown.\n\n");
//BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
try {
//xmlReader x = new xmlReader();
//System.out.println(dataWriter.get_topic().get_name());
System.out.print("Please type a message> ");
//System.out.println(xmlReader.main(args));
//double i = Math.ceil(xmlReader.main(args).length()/1023);
//int start = 0;
//int end = 1023;
String toWrite = xmlReader.main(args).toString();
dataWriter.write(toWrite, InstanceHandle_t.HANDLE_NIL);
/*
for(int j = 0; j<=i;j++)
{
if(end < xmlReader.main(args).length())
toWrite = xmlReader.main(args).substring(start,end).toString();
else
toWrite = xmlReader.main(args).substring(start, xmlReader.main(args).length()).toString();
dataWriter.write(toWrite, InstanceHandle_t.HANDLE_NIL);
start = end;
end = end+1023;
}
*/
} catch (IOException e) {
e.printStackTrace();
} catch (RETCODE_ERROR e) {
e.printStackTrace();
}
System.out.println("Exiting...");
participant.delete_contained_entities();
DomainParticipantFactory.get_instance().delete_participant(participant);
}
}
import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import com.rti.dds.domain.*; import com.rti.dds.infrastructure.*; import com.rti.dds.publication.*; import com.rti.dds.subscription.*; import com.rti.dds.topic.Topic; import com.rti.dds.type.builtin.*; import java.lang.reflect.Field; import javax.xml.parsers.ParserConfigurationException; import javax.xml.transform.TransformerException; import javax.xml.transform.TransformerFactoryConfigurationError; import org.xml.sax.SAXException; public class Foo { public static void main(String[] args) throws NoSuchFieldException, SecurityException, IllegalArgumentException, IllegalAccessException, ParserConfigurationException, SAXException, TransformerFactoryConfigurationError, TransformerException { DomainParticipantQos dp_qos = new DomainParticipantQos(); DomainParticipantFactory.get_instance().get_default_participant_qos(dp_qos); PropertyQosPolicyHelper.add_property(dp_qos.property,"dds.builtin_type.string.max_size","2050",true); DomainParticipant participant = DomainParticipantFactory.get_instance().create_participant(0, dp_qos, null, StatusKind.STATUS_MASK_NONE); if (participant == null) { System.err.println("Unable to create domain participant"); return; } Publisher publisher = participant.create_publisher( DomainParticipant.PUBLISHER_QOS_DEFAULT, null /* listener */, StatusKind.STATUS_MASK_NONE); Topic topic = participant.create_topic( "Event Logging", StringTypeSupport.get_type_name(), DomainParticipant.TOPIC_QOS_DEFAULT, null, // listener StatusKind.STATUS_MASK_NONE); if (topic == null) { System.err.println("Unable to create topic."); return; } DataWriterQos datawriter_qos = new DataWriterQos(); publisher.get_default_datawriter_qos(datawriter_qos); PropertyQosPolicyHelper.add_property(datawriter_qos.property,"dds.builtin_type.string.alloc_size" ,"2048" ,true); StringDataWriter dataWriter = (StringDataWriter) participant.create_datawriter( topic, datawriter_qos, null, // listener StatusKind.STATUS_MASK_NONE); if (dataWriter == null) { System.err.println("Unable to create data writer\n"); return; } for (int i = 0; i < 100; i++) { String toWrite = Integer.toHexString(i); try { dataWriter.write(toWrite, InstanceHandle_t.HANDLE_NIL); } catch (RETCODE_TIMEOUT e) { e.printStackTrace(); } catch (RETCODE_ERROR e) { e.printStackTrace(); } try { Thread.sleep(1000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } System.out.println("Exiting..."); participant.delete_contained_entities(); DomainParticipantFactory.get_instance().delete_participant(participant); } }Note how I've created the qos variable, pre-populated it using a factory call, modified the single parameter you are looking at, and then used the qos variable in the create method for the entity I wanted. Certain qos -- and certainly any qos that deals with resource management, which max_size and alloc_size certainly do -- have to be configured prior to creation of the entity, as they won't be able to be modified once the resources are configured during the create call.
Others can be modified after creation but before enable (disable auto-enable of entities in the factory if you need to do this). And finally others can be modified even after enable, during the runtime. See the documentation.
I am getting this when the program is ran.
RTI Data Distribution Service Spy built with DDS version: 5.1.0 (Core: 1.7a.00, C: 1.7a.00, C++: 1.7a.00)Copyright 2012 Real-Time Innovations, Inc.
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
NddsSpy is listening for data, press CTRL+C to stop it.
source_timestamp Info Src HostId topic type
----------------- ---- ---------- ------------------ ------------------
1402405624.575992 R +N 0A0064AE Event Logging DDS::String
1402406515.185997 W +N 0A0064AE Event Logging DDS::String
1402406515.186997 W +N 0A0064AE Event Logging DDS::String
1402406515.265996 d +N 0A0064AE Event Logging DDS::String
1402406515.265996 W -M 0A0064AE Event Logging DDS::String
1402406515.266996 W -M 0A0064AE Event Logging DDS::String
DDS_TIME_INVALID d ?M 0A0064AE Event Logging DDS::String
Terminate batch job (Y/N)? Terminate batch job (Y/N)?
that tells me it's working. Use -printSample with rtiddsspy to see what was sent.
It was sending what should be sent. Now if I wanted to set up a datareader, would I have to make any changes to it's qos file as well?
Yes. if you don't the writer will be writing 2k strings, and the reader's buffers will only be set up for 1k strings.
If you make changes to Writer QoS, you should immediately look at the Reader's QoS also to see if it must mirror the changes. In this case yes.