// Copyright (c) 1997-2009 Nokia Corporation and/or its subsidiary(-ies).
// All rights reserved.
// This component and the accompanying materials are made available
// under the terms of "Eclipse Public License v1.0"
// which accompanies this distribution, and is available
// at the URL "http://www.eclipse.org/legal/epl-v10.html".
//
// Initial Contributors:
// Nokia Corporation - initial contribution.
//
// Contributors:
//
// Description:
//
#include "wappstor.h"
#include "ws_main.h"
#include "smsstackutils.h"
_LIT(KStoreName,"wapreast.dat");
const TInt KWapReassemblyStoreUidValue=0x100008CB;
const TUid KWapReassemblyStoreUid={KWapReassemblyStoreUidValue}; // Used for second uid of SAR stores
CWapReassemblyStore* CWapReassemblyStore::NewL(RFs& aFs)
{
LOGWAPPROT1("CWapReassemblyStore::NewL()");
CWapReassemblyStore* reassembly=new (ELeave)CWapReassemblyStore(aFs);
CleanupStack::PushL(reassembly);
reassembly->ConstructL();
CleanupStack::Pop(reassembly);
return reassembly;
} // CWapReassemblyStore::NewL
CWapReassemblyStore::~CWapReassemblyStore()
{
this->Close();
}
TBool CWapReassemblyStore::AddMessageL( TInt& aIndex, const CWapDatagram& aDatagram)
{
LOGWAPPROT1("CWapReassemblyStore::AddMessageL()");
CArrayPtrFlat<CWapDatagram::TSegmentData>* segmentArray = new
(ELeave) CArrayPtrFlat<CWapDatagram::TSegmentData> (8);
CleanupStack::PushL(segmentArray);
CleanupResetAndDestroyPushL(*segmentArray);
TBool isComplete = aDatagram.IsComplete();
// count of incomplete WAP short messages
TInt Count = Entries().Count();
if (!isComplete)
{
TWapReassemblyEntry Entry;
TBool isFound = EFalse;
// go through all entries in the reassembly store
// and find the short message entry,
// which matches with the given entry
for(aIndex=0;aIndex<Count; aIndex++)
{
TInt ToPort = 0;
TInt FromPort = 0;
aDatagram.Ports(FromPort,ToPort);
Entry = (TWapReassemblyEntry&)Entries()[aIndex];
isFound = ((Entry.Reference() ==
aDatagram.ConcatenatedMessageReference())
&& (Entry.Total() ==
aDatagram.NumConcatenatedMessages())
&& (Entry.ToPort() == ToPort)
&& (Entry.Description1() ==
aDatagram.FromAddress()));
if (isFound)
break;
}
if (isFound)
{
isFound = EFalse;
// new short message fragment received for an existing
// incomplete WAP datagram
TStreamId StreamdId = Entry.DataStreamId();
CWapDatagram* tempDatagram = CWapDatagram::NewL(KNullDesC8);
CleanupStack::PushL(tempDatagram);
TRAPD(ret, InternalizeEntryL(StreamdId,*tempDatagram,*segmentArray));
if(ret == KErrCorrupt)
{
Close();
User::LeaveIfError(iFs.Delete(iFullPathBuf));
DoOpenL(); //create a new file
}
else
User::LeaveIfError(ret);
// For the first: discard duplicates
// It takes place by comparing indexes of TSegmentDatas
CWapDatagram::TSegmentData *segmentData = new (ELeave)CWapDatagram::TSegmentData;
CleanupStack::PushL(segmentData);
aDatagram.SegmentData(*segmentData);
if(aDatagram.NumConcatenatedMessages() < segmentData->iSegmentNumber)
{
isFound = ETrue; // out of range discard
CleanupStack::PopAndDestroy(segmentData);
}
else
{
Count=segmentArray->Count();
for (TInt i=0; i<Count; i++)
{
CWapDatagram::TSegmentData* thisSegmentData =
segmentArray->At(i);
if (thisSegmentData->iSegmentNumber
== segmentData->iSegmentNumber)
{
// duplicate found. It is not saved.
isFound = ETrue;
CleanupStack::PopAndDestroy(segmentData);
break;
}
}
}
if (!isFound)
{
TInt j=0;
for (; (j<segmentArray->Count()) && (segmentData->iSegmentNumber>(*segmentArray)[j]->iSegmentNumber); j++)
{
}
segmentArray->InsertL(j,segmentData);
CleanupStack::Pop(segmentData);
if (segmentArray->Count() ==
aDatagram.NumConcatenatedMessages())
// all fragments of a datagram are available
isComplete = ETrue;
BeginTransactionLC();
ExternalizeEntryL(StreamdId,*tempDatagram,*segmentArray);
PopulateEntry(Entry,*tempDatagram,segmentArray->Count());
ChangeEntryL(aIndex,Entry);
CommitTransactionL();
}
CleanupStack::PopAndDestroy(tempDatagram);
}
// else - a duplicate was found. Ignored.
else
{
// a first short message fragment received for a
// non-existing WAP datagram
CWapDatagram::TSegmentData *segmentData = new (ELeave)CWapDatagram::TSegmentData;
CleanupStack::PushL(segmentData);
aDatagram.SegmentData(*segmentData);
if(aDatagram.NumConcatenatedMessages() < segmentData->iSegmentNumber)
{
CleanupStack::PopAndDestroy(segmentData);
isComplete=EFalse;
}
else
{
segmentArray->AppendL(segmentData);
CleanupStack::Pop(segmentData);
aIndex = Count;
CreateEntryL(aDatagram,*segmentArray);
}
}
}
else // the datagram is complete
{
CWapDatagram::TSegmentData *segmentData = new (ELeave)CWapDatagram::TSegmentData;
CleanupStack::PushL(segmentData);
aDatagram.SegmentData(*segmentData);
if(aDatagram.NumConcatenatedMessages() < segmentData->iSegmentNumber)
{
CleanupStack::PopAndDestroy(segmentData);
isComplete=EFalse;
}
else
{
segmentArray->AppendL(segmentData);
CleanupStack::Pop(segmentData);
aIndex = Count;
CreateEntryL(aDatagram,*segmentArray);
}
}
CleanupStack::PopAndDestroy(2, segmentArray); // segmentArray elements (Reset and Destroy), segmentArray
return isComplete;
} // CWapReassemblyStore::AddMessageL
void CWapReassemblyStore::GetDatagramL( TInt aIndex,
CWapDatagram& aDatagram)
{
LOGWAPPROT1("CWapReassemblyStore::GetDatagramL()");
CArrayPtrFlat<CWapDatagram::TSegmentData>* segmentArray = new
(ELeave) CArrayPtrFlat<CWapDatagram::TSegmentData> (8);
// here we need to push 'segmentArray' pointer to the cleanup stack, since it's a heap allocation (pointer must be deleted)
// CleanupResetAndDestroyPushL() just trigers ResetAndDestroy() to be called on CleanupStack::PopAndDestroy()
CleanupStack::PushL(segmentArray);
CleanupResetAndDestroyPushL(*segmentArray);
// defect fix for EDNJJUN-4WYJGP
// Unable to send sms cause sms*.dat is corrupted
TRAPD(ret, InternalizeEntryL(Entries()[aIndex].DataStreamId(), aDatagram,*segmentArray));
if(ret == KErrCorrupt)
{
Close(); //because the file is in use
User::LeaveIfError(iFs.Delete(iFullPathBuf));
DoOpenL(); //create a new file
}
else
User::LeaveIfError(ret);
if(aDatagram.Alphabet() == TSmsDataCodingScheme::ESmsAlphabet7Bit)
{
aDatagram.DecodeConcatenatedMessagesL(*segmentArray);
}
CleanupStack::PopAndDestroy(2, segmentArray); // segmentArray elements (Reset and Destroy), segmentArray
} // CWapReassemblyStore::GetDatagramL
TBool CWapReassemblyStore::FindAndDeleteDatagramL( CWapDatagram& aDatagram)
{
LOGWAPPROT1("CWapReassemblyStore::FindAndDeleteDatagramL()");
TInt index;
TBool isFound = EFalse;
TWapReassemblyEntry entry;
TInt toPort = 0;
TInt fromPort = 0;
aDatagram.Ports(fromPort,toPort);
TInt Count = Entries().Count();
for(index=0;index<Count; index++)
{
entry = (TWapReassemblyEntry&)Entries()[index];
isFound = ((entry.Reference() ==
aDatagram.ConcatenatedMessageReference())
&& (entry.ToPort() == toPort)
&&(entry.Total() ==
aDatagram.NumConcatenatedMessages()));
if (isFound)
{
BeginTransactionLC();
DeleteEntryL(index);
CommitTransactionL();
return isFound;
}
}
return isFound;
} // CWapReassemblyStore::FindAndDeleteDatagramL
void CWapReassemblyStore::ConstructL()
{
LOGWAPPROT1("CWapReassemblyStore::ConstructL()");
//get full path of reassembly store
PrivatePath(iFullPathBuf);
//append store name
iFullPathBuf.Append(KStoreName);
OpenStoreL();
} // CWapReassemblyStore::ConstructL
/**
* internalize all the entries from the permanent file store to internal memory
*
* @note You have to call CSARStore::OpenFileLC() before calling this function
* @param aStreamId, unique id associated with the stream
* @param aDatagram, the datagram which will be internalized
* @param aSegmentArray, the array of segments for the datagram
*/
void CWapReassemblyStore::InternalizeEntryL(
TStreamId aStreamId,
CWapDatagram& aDatagram,
CArrayPtr<CWapDatagram::TSegmentData>& aSegmentArray)
{
LOGWAPPROT1("CWapReassemblyStore::InternalizeEntryL Start");
BeginTransactionLC();
RStoreReadStream ReadStream;
TInt32 Count;
ReadStream.OpenLC(FileStore(),aStreamId);
ReadStream >> aDatagram;
if(aDatagram.Alphabet() == TSmsDataCodingScheme::ESmsAlphabet8Bit)
{
aDatagram.InternalizeBufferL(ReadStream);
}
else
{
Count=ReadStream.ReadInt32L();
aSegmentArray.Reset();
for (TInt i=0; i<Count; i++)
{
CWapDatagram::TSegmentData* Segment = new (ELeave) CWapDatagram::TSegmentData;
CleanupStack::PushL(Segment);
aSegmentArray.AppendL(Segment);
CleanupStack::Pop();
Segment->iSegmentNumber = ReadStream.ReadInt32L();
ReadStream >> Segment->iData;
}
}
// Closes the ReadStream
CleanupStack::PopAndDestroy();
CommitTransactionL();
LOGWAPPROT1("CWapReassemblyStore::InternalizeEntryL End");
} // CWapReassemblyStore::InternalizeEntryL
/**
* externalizes all the entries from the internal memory to the permanent file store
*
* @note You have to call CSARStore::OpenFileLC() before calling this function
* @param aStreamId, unique id associated with the stream
* @param aDatagram, the datagram which should be externalized
* @param aSegmentArray, the array of segments for the datagram
*/
void CWapReassemblyStore::ExternalizeEntryL(
TStreamId& aStreamId,
const CWapDatagram& aDatagram,
const CArrayPtr<CWapDatagram::TSegmentData>& aSegmentArray)
{
LOGWAPPROT1("CWapReassemblyStore::ExternalizeEntryL Start");
TInt32 Count = aSegmentArray.Count();
RStoreWriteStream WriteStream;
if (aStreamId==KNullStreamId)
aStreamId=WriteStream.CreateLC(FileStore());
else
WriteStream.ReplaceLC(FileStore(),aStreamId);
WriteStream<<aDatagram;
if(aDatagram.Alphabet() == TSmsDataCodingScheme::ESmsAlphabet8Bit)
{
aDatagram.ExternalizeBufferL(WriteStream);
}
else
{
WriteStream.WriteInt32L(Count);
for(TInt i=0; i<Count; i++)
{
WriteStream.WriteInt32L(aSegmentArray[i]->iSegmentNumber);
WriteStream<<aSegmentArray[i]->iData;
}
}
// Closes the ReadStream
WriteStream.CommitL();
CleanupStack::PopAndDestroy();
} // CWapReassemblyStore::ExternalizeEntryL
void CWapReassemblyStore::PopulateEntry(TWapReassemblyEntry& aEntry,
const CWapDatagram& aDatagram,
TInt aNumDatagrams)
{
LOGWAPPROT1("CWapReassemblyStore::PopulateEntry()");
TInt ToPort = 0;
TInt FromPort = 0;
aDatagram.Ports(FromPort,ToPort);
// complete or not complete
if (!aDatagram.IsComplete())
{
aEntry.SetReference(aDatagram.ConcatenatedMessageReference());
aEntry.SetTotal(aDatagram.NumConcatenatedMessages());
aEntry.SetCount(aNumDatagrams);
}
else
{
//Wap Datagram might contain reference number which will be
//needed at the time of deleting the datagram from permanent store file
//Refer To Defect Fix: PDEF114607.
aEntry.SetReference(aDatagram.ConcatenatedMessageReference());
aEntry.SetTotal(1);
aEntry.SetCount(1);
}
aEntry.SetToPort(ToPort);
aEntry.SetDescription1(aDatagram.FromAddress());
aEntry.SetTime(aDatagram.Time());
} // CWapReassemblyStore::PopulateEntry
void CWapReassemblyStore::CreateEntryL(const CWapDatagram& aDatagram,
const CArrayPtr<CWapDatagram::TSegmentData>& aSegmentArray)
{
LOGWAPPROT1("CWapReassemblyStore::CreateEntryL");
TWapReassemblyEntry Entry;
TStreamId WriteStream = KNullStreamId;
BeginTransactionLC();
ExternalizeEntryL(WriteStream,aDatagram,aSegmentArray);
Entry.SetDataStreamId(WriteStream);
PopulateEntry(Entry,aDatagram,aDatagram.NumConcatenatedMessages());
AddEntryL(Entry);
CommitTransactionL();
} // CWapReassemblyStore::CreateEntryL
CWapReassemblyStore::CWapReassemblyStore(RFs& aFs)
:CSARStore(aFs)
{
} // CWapReassemblyStore::CWapReassemblyStore
/**
* Open the wap reassembly store.
* Use RFs::PrivatePath to generate private path.
*/
void CWapReassemblyStore::OpenStoreL()
{
LOGWAPPROT1("CWapReassemblyStore::OpenStoreL()");
OpenL(iFullPathBuf,KWapReassemblyStoreUid);
} // CWapReassemblyStore::OpenStoreL
// EOF - WAPPSTOR.CPP