|
654
|
1 |
/*
|
|
|
2 |
* Copyright (c) 2010 Nokia Corporation and/or its subsidiary(-ies).
|
|
|
3 |
* All rights reserved.
|
|
|
4 |
* This component and the accompanying materials are made available
|
|
|
5 |
* under the terms of the License "Eclipse Public License v1.0"
|
|
|
6 |
* which accompanies this distribution, and is available
|
|
|
7 |
* at the URL "http://www.eclipse.org/legal/epl-v10.html".
|
|
|
8 |
*
|
|
|
9 |
* Initial Contributors:
|
|
|
10 |
* Nokia Corporation - initial contribution.
|
|
|
11 |
*
|
|
|
12 |
* Contributors:
|
|
|
13 |
*
|
|
|
14 |
* Description:
|
|
|
15 |
*
|
|
|
16 |
*/
|
|
|
17 |
|
|
|
18 |
#include <vector>
|
|
600
|
19 |
#include <boost/regex.hpp>
|
|
|
20 |
#define MAX_LINE 65535
|
|
|
21 |
#include "symbolgenerator.h"
|
|
|
22 |
#include "e32image.h"
|
|
|
23 |
|
|
|
24 |
#if defined(__LINUX__)
|
|
|
25 |
#define PATH_SEPARATOR '/'
|
|
|
26 |
#else
|
|
|
27 |
#define PATH_SEPARATOR '\\'
|
|
|
28 |
#endif
|
|
654
|
29 |
extern TInt gThreadNum;
|
|
600
|
30 |
|
|
|
31 |
boost::mutex SymbolGenerator::iMutexSingleton;
|
|
|
32 |
SymbolGenerator* SymbolGenerator::iInst = NULL;
|
|
|
33 |
SymbolGenerator* SymbolGenerator::GetInstance(){
|
|
|
34 |
iMutexSingleton.lock();
|
|
|
35 |
if(iInst == NULL) {
|
|
|
36 |
iInst = new SymbolGenerator();
|
|
|
37 |
}
|
|
|
38 |
iMutexSingleton.unlock();
|
|
|
39 |
return iInst;
|
|
|
40 |
}
|
|
|
41 |
void SymbolGenerator::Release() {
|
|
654
|
42 |
if(iInst != NULL) {
|
|
|
43 |
iInst->join();
|
|
|
44 |
}
|
|
600
|
45 |
iMutexSingleton.lock();
|
|
|
46 |
if(iInst != NULL) {
|
|
|
47 |
delete iInst;
|
|
|
48 |
iInst = NULL;
|
|
|
49 |
}
|
|
|
50 |
iMutexSingleton.unlock();
|
|
|
51 |
}
|
|
|
52 |
void SymbolGenerator::SetSymbolFileName( const string& fileName ){
|
|
|
53 |
if(iSymFile.is_open())
|
|
|
54 |
iSymFile.close();
|
|
|
55 |
string s = fileName.substr(0,fileName.rfind('.'))+".symbol";
|
|
|
56 |
printf("* Writing %s - ROFS symbol file\n", s.c_str());
|
|
|
57 |
iSymFile.open(s.c_str());
|
|
|
58 |
}
|
|
|
59 |
void SymbolGenerator::AddFile( const string& fileName, bool isExecutable ){
|
|
|
60 |
iMutex.lock();
|
|
|
61 |
iQueueFiles.push(TPlacedEntry(fileName,isExecutable));
|
|
|
62 |
iMutex.unlock();
|
|
|
63 |
iCond.notify_all();
|
|
|
64 |
}
|
|
654
|
65 |
void SymbolGenerator::SetFinished()
|
|
|
66 |
{
|
|
600
|
67 |
|
|
654
|
68 |
iFinished = true;
|
|
|
69 |
iCond.notify_all();
|
|
600
|
70 |
}
|
|
654
|
71 |
TPlacedEntry SymbolGenerator::GetNextPlacedEntry()
|
|
|
72 |
{
|
|
|
73 |
TPlacedEntry pe("", false);
|
|
|
74 |
if(1)
|
|
|
75 |
{
|
|
|
76 |
boost::mutex::scoped_lock lock(iMutex);
|
|
|
77 |
while(!iFinished && iQueueFiles.empty())
|
|
|
78 |
iCond.wait(lock);
|
|
|
79 |
if(!iQueueFiles.empty())
|
|
|
80 |
{
|
|
|
81 |
pe = iQueueFiles.front();
|
|
|
82 |
iQueueFiles.pop();
|
|
600
|
83 |
}
|
|
|
84 |
}
|
|
654
|
85 |
return pe;
|
|
600
|
86 |
}
|
|
654
|
87 |
void SymbolGenerator::thrd_func(){
|
|
|
88 |
boost::thread_group threads;
|
|
|
89 |
SymbolWorker worker;
|
|
|
90 |
for(int i=0; i < gThreadNum; i++)
|
|
|
91 |
{
|
|
|
92 |
threads.create_thread(worker);
|
|
600
|
93 |
}
|
|
654
|
94 |
threads.join_all();
|
|
|
95 |
}
|
|
|
96 |
SymbolGenerator::SymbolGenerator() : boost::thread(thrd_func),iFinished(false) {
|
|
|
97 |
}
|
|
|
98 |
SymbolGenerator::~SymbolGenerator(){
|
|
|
99 |
if(joinable())
|
|
|
100 |
join();
|
|
|
101 |
iSymFile.flush();
|
|
|
102 |
iSymFile.close();
|
|
600
|
103 |
}
|
|
654
|
104 |
SymbolWorker::SymbolWorker()
|
|
|
105 |
{
|
|
600
|
106 |
// end of regex_search
|
|
|
107 |
}
|
|
654
|
108 |
SymbolWorker::~SymbolWorker()
|
|
|
109 |
{
|
|
600
|
110 |
}
|
|
654
|
111 |
void SymbolWorker::operator()()
|
|
|
112 |
{
|
|
|
113 |
SymbolProcessUnit* aSymbolProcessUnit = new CommenSymbolProcessUnit();
|
|
|
114 |
SymbolGenerator* symbolgenerator = SymbolGenerator::GetInstance();
|
|
600
|
115 |
|
|
654
|
116 |
while(1)
|
|
|
117 |
{
|
|
|
118 |
if(symbolgenerator->HasFinished() && symbolgenerator->IsEmpty())
|
|
|
119 |
{
|
|
|
120 |
|
|
600
|
121 |
break;
|
|
|
122 |
}
|
|
654
|
123 |
|
|
|
124 |
|
|
|
125 |
|
|
600
|
126 |
|
|
654
|
127 |
TPlacedEntry pe = symbolgenerator->GetNextPlacedEntry();
|
|
600
|
128 |
|
|
|
129 |
//scope the code block with if(1) for lock
|
|
|
130 |
/*
|
|
|
131 |
if(me->iQueueFiles.empty()) {
|
|
|
132 |
boost::this_thread::sleep(boost::posix_time::milliseconds(10));
|
|
|
133 |
continue;
|
|
|
134 |
}
|
|
|
135 |
*/
|
|
|
136 |
|
|
|
137 |
|
|
|
138 |
if(pe.iFileName == "")
|
|
654
|
139 |
continue;
|
|
600
|
140 |
else if(pe.iExecutable)
|
|
654
|
141 |
aSymbolProcessUnit->ProcessExecutableFile(pe.iFileName);
|
|
600
|
142 |
else
|
|
654
|
143 |
aSymbolProcessUnit->ProcessDataFile(pe.iFileName);
|
|
|
144 |
symbolgenerator->LockOutput();
|
|
|
145 |
aSymbolProcessUnit->FlushStdOut(cout);
|
|
|
146 |
aSymbolProcessUnit->FlushSymbolContent(symbolgenerator->GetOutputFileStream());
|
|
|
147 |
symbolgenerator->UnlockOutput();
|
|
600
|
148 |
}
|
|
654
|
149 |
delete aSymbolProcessUnit;
|
|
600
|
150 |
}
|