Git-Mirrors/RetroShare
1
0
Fork 0
mirror of https://github.com/RetroShare/RetroShare.git synced 2024-12-29 01:16:20 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #2216 from csoler/v0.6-MemLeaks_2

Browse Source 
V0.6 mem leaks 2
This commit is contained in:
csoler 2021-01-10 21:12:19 +01:00 committed by GitHub
commit a8df555df2
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 35 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
libretroshare/src/pqi/authssl.cc
View File

@ -308,6 +308,20 @@ AuthSSLimpl::AuthSSLimpl() :
p3Config(), sslctx(nullptr), mOwnCert(nullptr), sslMtx("AuthSSL"),
mOwnPrivateKey(nullptr), mOwnPublicKey(nullptr), init(0) {}
AuthSSLimpl::~AuthSSLimpl()
{
RS_STACK_MUTEX(sslMtx);
SSL_CTX_free(sslctx);
X509_free(mOwnCert);
EVP_PKEY_free(mOwnPrivateKey);
EVP_PKEY_free(mOwnPublicKey);
for(auto pcert: mCerts)
X509_free(pcert.second);
}
bool AuthSSLimpl::active() { return init; }
int AuthSSLimpl::InitAuth(
@ -1459,14 +1473,14 @@ bool AuthSSLimpl::encrypt(void *&out, int &outlen, const void *in, int inlen,
if (peerId == mOwnId) { public_key = mOwnPublicKey; }
else
{
if (!mCerts[peerId])
auto it = mCerts.find(peerId);
if (it == mCerts.end())
{
RsErr() << __PRETTY_FUNCTION__ << " public key not found."
<< std::endl;
RsErr() << __PRETTY_FUNCTION__ << " public key not found." << std::endl;
return false;
}
else public_key = const_cast<EVP_PKEY*>(
RsX509Cert::getPubKey(*mCerts[peerId]) );
else public_key = const_cast<EVP_PKEY*>( RsX509Cert::getPubKey(*it->second) );
}
EVP_CIPHER_CTX *ctx = EVP_CIPHER_CTX_new();

2
libretroshare/src/pqi/authssl.h
View File

@ -161,6 +161,8 @@ public:
/** Initialisation Functions (Unique) */
AuthSSLimpl();
virtual ~AuthSSLimpl();
bool validateOwnCertificate(X509 *x509, EVP_PKEY *pkey) override;
bool active() override;

13
libretroshare/src/services/p3msgservice.cc
View File

@ -115,6 +115,19 @@ RsServiceInfo p3MsgService::getServiceInfo()
MSG_MIN_MINOR_VERSION);
}
p3MsgService::~p3MsgService()
{
RS_STACK_MUTEX(mMsgMtx); /********** STACK LOCKED MTX ******/
for(auto tag:mTags) delete tag.second;
for(auto tag:mMsgTags) delete tag.second;
for(auto msgid:mSrcIds) delete msgid.second;
for(auto parentid:mParentId) delete parentid.second;
for(auto img:imsg) delete img.second;
for(auto mout:msgOutgoing) delete mout.second;
for(auto mpend:_pendingPartialMessages) delete mpend.second;
}
uint32_t p3MsgService::getNewUniqueMsgId()
{

1
libretroshare/src/services/p3msgservice.h
View File

@ -56,6 +56,7 @@ class p3MsgService :
{
public:
p3MsgService(p3ServiceControl *sc, p3IdService *id_service, p3GxsTrans& gxsMS);
virtual ~p3MsgService();
virtual RsServiceInfo getServiceInfo();