i2p/haiku-beta6
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Memory leaks in Cortex

Browse Source 
CID 605755, 605756, 605757 and 605758.
This commit is contained in:
Philippe Saint-Pierre
2015-07-01 19:32:54 -04:00
parent 82652e65f7
commit 385d90724e
1 changed files with 24 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/apps/cortex/NodeManager/NodeRef.cpp
+24 -16
View File
@@ -996,13 +996,15 @@ status_t NodeRef::getFreeInputs(
int32 inputBufferSize = 16; int32 inputBufferSize = 16;
media_input* inputBuffer = new media_input[inputBufferSize]; media_input* inputBuffer = new media_input[inputBufferSize];
while(true) { while (true) {
err = r->GetFreeInputsFor( err = r->GetFreeInputsFor(
m_info.node, inputBuffer, inputBufferSize, &count, filterType); m_info.node, inputBuffer, inputBufferSize, &count, filterType);
if(err < B_OK) if (err < B_OK) {
delete [] inputBuffer;
return err; return err;
}
if(count == inputBufferSize) { if (count == inputBufferSize) {
// buffer too small; increase & try again // buffer too small; increase & try again
inputBufferSize += bufferInc; inputBufferSize += bufferInc;
delete [] inputBuffer; delete [] inputBuffer;
@@ -1010,7 +1012,7 @@ status_t NodeRef::getFreeInputs(
continue; continue;
} }
if(count) if (count)
// copy found inputs into vector // copy found inputs into vector
copy(inputBuffer, inputBuffer + count, copy(inputBuffer, inputBuffer + count,
back_inserter(ioInputs)); back_inserter(ioInputs));
@@ -1038,13 +1040,15 @@ status_t NodeRef::getConnectedInputs(
int32 inputBufferSize = 16; int32 inputBufferSize = 16;
media_input* inputBuffer = new media_input[inputBufferSize]; media_input* inputBuffer = new media_input[inputBufferSize];
while(true) { while (true) {
err = r->GetConnectedInputsFor( err = r->GetConnectedInputsFor(
m_info.node, inputBuffer, inputBufferSize, &count); m_info.node, inputBuffer, inputBufferSize, &count);
if(err < B_OK) if (err < B_OK) {
delete [] inputBuffer;
return err; return err;
}
if(count == inputBufferSize) { if (count == inputBufferSize) {
// buffer too small; increase & try again // buffer too small; increase & try again
inputBufferSize += bufferInc; inputBufferSize += bufferInc;
delete [] inputBuffer; delete [] inputBuffer;
@@ -1052,7 +1056,7 @@ status_t NodeRef::getConnectedInputs(
continue; continue;
} }
if(count) if (count)
// copy found inputs matching the given type into vector // copy found inputs matching the given type into vector
remove_copy_if(inputBuffer, inputBuffer + count, remove_copy_if(inputBuffer, inputBuffer + count,
back_inserter(ioInputs), back_inserter(ioInputs),
@@ -1080,13 +1084,15 @@ status_t NodeRef::getFreeOutputs(
int32 outputBufferSize = 16; int32 outputBufferSize = 16;
media_output* outputBuffer = new media_output[outputBufferSize]; media_output* outputBuffer = new media_output[outputBufferSize];
while(true) { while (true) {
err = r->GetFreeOutputsFor( err = r->GetFreeOutputsFor(
m_info.node, outputBuffer, outputBufferSize, &count, filterType); m_info.node, outputBuffer, outputBufferSize, &count, filterType);
if(err < B_OK) if (err < B_OK) {
delete [] outputBuffer;
return err; return err;
}
if(count == outputBufferSize) { if (count == outputBufferSize) {
// buffer too small; increase & try again // buffer too small; increase & try again
outputBufferSize += bufferInc; outputBufferSize += bufferInc;
delete [] outputBuffer; delete [] outputBuffer;
@@ -1094,7 +1100,7 @@ status_t NodeRef::getFreeOutputs(
continue; continue;
} }
if(count) if (count)
// copy found outputs into vector // copy found outputs into vector
copy(outputBuffer, outputBuffer + count, copy(outputBuffer, outputBuffer + count,
back_inserter(ioOutputs)); back_inserter(ioOutputs));
@@ -1121,13 +1127,15 @@ status_t NodeRef::getConnectedOutputs(
int32 outputBufferSize = 16; int32 outputBufferSize = 16;
media_output* outputBuffer = new media_output[outputBufferSize]; media_output* outputBuffer = new media_output[outputBufferSize];
while(true) { while (true) {
err = r->GetConnectedOutputsFor( err = r->GetConnectedOutputsFor(
m_info.node, outputBuffer, outputBufferSize, &count); m_info.node, outputBuffer, outputBufferSize, &count);
if(err < B_OK) if (err < B_OK) {
delete [] outputBuffer;
return err; return err;
}
if(count == outputBufferSize) { if (count == outputBufferSize) {
// buffer too small; increase & try again // buffer too small; increase & try again
outputBufferSize += bufferInc; outputBufferSize += bufferInc;
delete [] outputBuffer; delete [] outputBuffer;
@@ -1135,7 +1143,7 @@ status_t NodeRef::getConnectedOutputs(
continue; continue;
} }
if(count) if (count)
// copy found outputs matching the given type into vector // copy found outputs matching the given type into vector
remove_copy_if(outputBuffer, outputBuffer + count, remove_copy_if(outputBuffer, outputBuffer + count,
back_inserter(ioOutputs), back_inserter(ioOutputs),