Requestor replier not working properly

Hello

This is my requestor code

#include "ndds/ndds_requestreply_cpp.h"
#include <iostream>
#include "idl/Primes.h"
#include "idl/PrimesSupport.h"
#include "idl/PrimesPlugin.h"
#include "ndds/ndds_namespace_cpp.h"
#include <QTime>

//#include <stdio.h>
//#include <stdlib.h>
#include <sstream>

using namespace connext;

int main()
{
DDS::WaitSet ws;
int domain_id = 1;

// Create a DomainParticipant

DDS::DomainParticipant * participant =
DDS::DomainParticipantFactory::get_instance()->create_participant(
domain_id, DDS::PARTICIPANT_QOS_DEFAULT,
NULL, DDS::STATUS_MASK_NONE);

if (participant == NULL)
{
std::cout<<"participant not created"<<std::endl;
}
else
{
//std::cout<<"participant created"<<std::endl;

// Create a Requester

Requester<Foo, Bar> * requester;
requester = new Requester<Foo, Bar>(participant, "TestService");

// Send request
for(int i = 1;i <= 10000;i++)
{
WriteSample<Foo> request;
request.data().count = i;
std::string buffer1 = "A Request";
std::ostringstream ostr;
ostr << request.data().count;
buffer1 += ostr.str();
ostr.str("");
//strcpy(request.data().message, "A Request"+ (request.data().count));
strcpy(request.data().message,buffer1.data());

requester->send_request(request);

// Create a reply Sample
Sample<Bar> reply;

// Receive reply (wait for it and get the sample)
DDS_Duration_t MAX_WAIT;
MAX_WAIT.sec = 1;

bool received = requester->receive_reply(reply, MAX_WAIT);
if (received)
{
if(reply.info().valid_data)
{
std::cout << "Received reply: " << reply.data().message << std::endl;
}
else
{
std::cout << "Received invalid reply" << std::endl;
}
}
else
{
std::cout << "Reply not received" << std::endl;
}
//sleep(1);
}
}
}

This is my replier code

#include "ndds/ndds_requestreply_cpp.h"
#include <iostream>
#include "idl/Primes.h"
#include "idl/PrimesSupport.h"
#include "idl/PrimesPlugin.h"
#include "ndds/ndds_namespace_cpp.h"
#include <sstream>

using namespace connext;

int main()
{
int domain_id = 1;
// Create a DomainParticipant
DDS::DomainParticipant * participant =
DDS::DomainParticipantFactory::get_instance()->create_participant(
domain_id, DDS::PARTICIPANT_QOS_DEFAULT,
NULL, DDS::STATUS_MASK_NONE);
// Create a Replier (if creation fails, the constructor throws exception)
Replier<Foo, Bar> * replier =
new Replier<Foo, Bar>(participant, "TestService");
DDS_Duration_t MAX_WAIT;
MAX_WAIT.sec = 1;
int i = 1;

while(1)
{

Sample<Foo> request;
// Receive one request
bool received = replier->receive_request(request, MAX_WAIT);
if (!received)
{
std::cout << "Requests not received" << std::endl;
//return false;
}
// A WriteSample automatically initializes and finalizes
// the data using the TypeSupport (in this case BarTypeSupport)
WriteSample<Bar> reply;

request.data().count = i;
std::string buffer1 = request.data().message;
std::ostringstream ostr;
ostr << reply.data().count;
buffer1 += ostr.str();
ostr.str("");

if (request.info().valid_data)
{
//sprintf(reply.data().message, "Reply for %s", request.data().message);
sprintf(reply.data().message, buffer1.data() );
// Send a reply for that request
replier->send_reply(reply, request.identity());
std::cout << "sent reply: " << reply.data().message << std::endl;
// Note: a replier can send more than one reply for the same request
}
i++;
//sleep(1);
}
}

First time my both program runs perfectly. As you can see in my code that i have a fixed for loop for requestor and replier runs in infinite loop. when i am agian started my requestor

Then after some time my replier crash with giving error

terminate called after throwing an instance of 'connext::TimeoutException'
what(): Replier(TestServiceReply, TestServiceRequest)::send_reply failure caused by EntityUntypedImpl::send_sample:!DataWriter write timeout

EntityUntypedImpl::send_sample:!DataWriter write timeout
Replier(TestServiceReply, TestServiceRequest)::send_reply:!failed (see previous errors)

and after that my requestor also crash by throwing error

terminate called after throwing an instance of 'connext::TimeoutException'
what(): Requester(TestServiceRequest, TestServiceReply)::send_request failure caused by EntityUntypedImpl::send_sample:!DataWriter write timeout

EntityUntypedImpl::send_sample:!DataWriter write timeout
Requester(TestServiceRequest, TestServiceReply)::send_request:!failed (see previous errors)

Please let we know the issue as soon as possible

Thanks

Bhawna Popli