Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
M
mariadb
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
Analytics
Analytics
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Commits
Issue Boards
Open sidebar
Kirill Smelkov
mariadb
Commits
ce6ffc3d
Commit
ce6ffc3d
authored
Feb 23, 2005
by
tomas@poseidon.ndb.mysql.com
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
removed printout "- Repeated 1 times"
make sure transporter connections are close early in shutdown
parent
a50be4d4
Changes
4
Hide whitespace changes
Inline
Side-by-side
Showing
4 changed files
with
23 additions
and
13 deletions
+23
-13
ndb/src/common/logger/LogHandler.cpp
ndb/src/common/logger/LogHandler.cpp
+2
-2
ndb/src/kernel/main.cpp
ndb/src/kernel/main.cpp
+2
-9
ndb/src/kernel/vm/Emulator.cpp
ndb/src/kernel/vm/Emulator.cpp
+17
-1
ndb/src/kernel/vm/Emulator.hpp
ndb/src/kernel/vm/Emulator.hpp
+2
-1
No files found.
ndb/src/common/logger/LogHandler.cpp
View file @
ce6ffc3d
...
@@ -76,15 +76,15 @@ LogHandler::append_impl(const char* pCategory, Logger::LoggerLevel level,
...
@@ -76,15 +76,15 @@ LogHandler::append_impl(const char* pCategory, Logger::LoggerLevel level,
const
char
*
pMsg
)
const
char
*
pMsg
)
{
{
writeHeader
(
pCategory
,
level
);
writeHeader
(
pCategory
,
level
);
if
(
m_count_repeated_messages
==
0
)
if
(
m_count_repeated_messages
<=
1
)
writeMessage
(
pMsg
);
writeMessage
(
pMsg
);
else
else
{
{
BaseString
str
(
pMsg
);
BaseString
str
(
pMsg
);
str
.
appfmt
(
" - Repeated %d times"
,
m_count_repeated_messages
);
str
.
appfmt
(
" - Repeated %d times"
,
m_count_repeated_messages
);
writeMessage
(
str
.
c_str
());
writeMessage
(
str
.
c_str
());
m_count_repeated_messages
=
0
;
}
}
m_count_repeated_messages
=
0
;
writeFooter
();
writeFooter
();
}
}
...
...
ndb/src/kernel/main.cpp
View file @
ce6ffc3d
...
@@ -180,11 +180,9 @@ int main(int argc, char** argv)
...
@@ -180,11 +180,9 @@ int main(int argc, char** argv)
assert
(
"Illegal state globalData.theRestartFlag"
==
0
);
assert
(
"Illegal state globalData.theRestartFlag"
==
0
);
}
}
SocketServer
socket_server
;
globalTransporterRegistry
.
startSending
();
globalTransporterRegistry
.
startSending
();
globalTransporterRegistry
.
startReceiving
();
globalTransporterRegistry
.
startReceiving
();
if
(
!
globalTransporterRegistry
.
start_service
(
socket_server
)){
if
(
!
globalTransporterRegistry
.
start_service
(
*
globalEmulatorData
.
m_
socket_server
)){
ndbout_c
(
"globalTransporterRegistry.start_service() failed"
);
ndbout_c
(
"globalTransporterRegistry.start_service() failed"
);
exit
(
-
1
);
exit
(
-
1
);
}
}
...
@@ -196,7 +194,7 @@ int main(int argc, char** argv)
...
@@ -196,7 +194,7 @@ int main(int argc, char** argv)
globalEmulatorData
.
theWatchDog
->
doStart
();
globalEmulatorData
.
theWatchDog
->
doStart
();
socket_server
.
startServer
();
globalEmulatorData
.
m_socket_server
->
startServer
();
// theConfig->closeConfiguration();
// theConfig->closeConfiguration();
...
@@ -204,11 +202,6 @@ int main(int argc, char** argv)
...
@@ -204,11 +202,6 @@ int main(int argc, char** argv)
NdbShutdown
(
NST_Normal
);
NdbShutdown
(
NST_Normal
);
socket_server
.
stopServer
();
socket_server
.
stopSessions
();
globalTransporterRegistry
.
stop_clients
();
return
NRT_Default
;
return
NRT_Default
;
}
}
...
...
ndb/src/kernel/vm/Emulator.cpp
View file @
ce6ffc3d
...
@@ -68,6 +68,7 @@ EmulatorData::EmulatorData(){
...
@@ -68,6 +68,7 @@ EmulatorData::EmulatorData(){
theThreadConfig
=
0
;
theThreadConfig
=
0
;
theSimBlockList
=
0
;
theSimBlockList
=
0
;
theShutdownMutex
=
0
;
theShutdownMutex
=
0
;
m_socket_server
=
0
;
}
}
void
void
...
@@ -83,6 +84,7 @@ EmulatorData::create(){
...
@@ -83,6 +84,7 @@ EmulatorData::create(){
theWatchDog
=
new
WatchDog
();
theWatchDog
=
new
WatchDog
();
theThreadConfig
=
new
ThreadConfig
();
theThreadConfig
=
new
ThreadConfig
();
theSimBlockList
=
new
SimBlockList
();
theSimBlockList
=
new
SimBlockList
();
m_socket_server
=
new
SocketServer
();
theShutdownMutex
=
NdbMutex_Create
();
theShutdownMutex
=
NdbMutex_Create
();
...
@@ -99,7 +101,8 @@ EmulatorData::destroy(){
...
@@ -99,7 +101,8 @@ EmulatorData::destroy(){
delete
theThreadConfig
;
theThreadConfig
=
0
;
delete
theThreadConfig
;
theThreadConfig
=
0
;
if
(
theSimBlockList
)
if
(
theSimBlockList
)
delete
theSimBlockList
;
theSimBlockList
=
0
;
delete
theSimBlockList
;
theSimBlockList
=
0
;
if
(
m_socket_server
)
delete
m_socket_server
;
m_socket_server
=
0
;
NdbMem_Destroy
();
NdbMem_Destroy
();
}
}
...
@@ -195,9 +198,22 @@ NdbShutdown(NdbShutdownType type,
...
@@ -195,9 +198,22 @@ NdbShutdown(NdbShutdownType type,
fclose
(
outputStream
);
fclose
(
outputStream
);
#endif
#endif
/**
* Stop all transporter connection attempts and accepts
*/
globalEmulatorData
.
m_socket_server
->
stopServer
();
globalEmulatorData
.
m_socket_server
->
stopSessions
();
globalTransporterRegistry
.
stop_clients
();
/**
* Stop transporter communication with other nodes
*/
globalTransporterRegistry
.
stopSending
();
globalTransporterRegistry
.
stopSending
();
globalTransporterRegistry
.
stopReceiving
();
globalTransporterRegistry
.
stopReceiving
();
/**
* Remove all transporters
*/
globalTransporterRegistry
.
removeAll
();
globalTransporterRegistry
.
removeAll
();
#ifdef VM_TRACE
#ifdef VM_TRACE
...
...
ndb/src/kernel/vm/Emulator.hpp
View file @
ce6ffc3d
...
@@ -55,7 +55,8 @@ struct EmulatorData {
...
@@ -55,7 +55,8 @@ struct EmulatorData {
class
WatchDog
*
theWatchDog
;
class
WatchDog
*
theWatchDog
;
class
ThreadConfig
*
theThreadConfig
;
class
ThreadConfig
*
theThreadConfig
;
class
SimBlockList
*
theSimBlockList
;
class
SimBlockList
*
theSimBlockList
;
class
SocketServer
*
m_socket_server
;
/**
/**
* Constructor
* Constructor
*
*
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment