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
e28ad144
Commit
e28ad144
authored
Dec 22, 2004
by
tomas@poseidon.ndb.mysql.com
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
added some debug printouts
parent
890a97c7
Changes
1
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
12 additions
and
2 deletions
+12
-2
ndb/src/common/transporter/Transporter.cpp
ndb/src/common/transporter/Transporter.cpp
+12
-2
No files found.
ndb/src/common/transporter/Transporter.cpp
View file @
e28ad144
...
@@ -37,6 +37,7 @@ Transporter::Transporter(TransporterRegistry &t_reg,
...
@@ -37,6 +37,7 @@ Transporter::Transporter(TransporterRegistry &t_reg,
m_packer
(
_signalId
,
_checksum
),
m_packer
(
_signalId
,
_checksum
),
m_transporter_registry
(
t_reg
)
m_transporter_registry
(
t_reg
)
{
{
DBUG_ENTER
(
"Transporter::Transporter"
);
if
(
rHostName
&&
strlen
(
rHostName
)
>
0
){
if
(
rHostName
&&
strlen
(
rHostName
)
>
0
){
strncpy
(
remoteHostName
,
rHostName
,
sizeof
(
remoteHostName
));
strncpy
(
remoteHostName
,
rHostName
,
sizeof
(
remoteHostName
));
Ndb_getInAddr
(
&
remoteHostAddress
,
rHostName
);
Ndb_getInAddr
(
&
remoteHostAddress
,
rHostName
);
...
@@ -55,6 +56,11 @@ Transporter::Transporter(TransporterRegistry &t_reg,
...
@@ -55,6 +56,11 @@ Transporter::Transporter(TransporterRegistry &t_reg,
if
(
strlen
(
lHostName
)
>
0
)
if
(
strlen
(
lHostName
)
>
0
)
Ndb_getInAddr
(
&
localHostAddress
,
lHostName
);
Ndb_getInAddr
(
&
localHostAddress
,
lHostName
);
DBUG_PRINT
(
"info"
,(
"rId=%d lId=%d isServer=%d rHost=%s lHost=%s r_port=%d"
,
remoteNodeId
,
localNodeId
,
isServer
,
remoteHostName
,
localHostName
,
r_port
));
byteOrder
=
_byteorder
;
byteOrder
=
_byteorder
;
compressionUsed
=
_compression
;
compressionUsed
=
_compression
;
checksumUsed
=
_checksum
;
checksumUsed
=
_checksum
;
...
@@ -68,6 +74,7 @@ Transporter::Transporter(TransporterRegistry &t_reg,
...
@@ -68,6 +74,7 @@ Transporter::Transporter(TransporterRegistry &t_reg,
else
else
m_socket_client
=
new
SocketClient
(
remoteHostName
,
r_port
,
m_socket_client
=
new
SocketClient
(
remoteHostName
,
r_port
,
new
SocketAuthSimple
(
"ndbd"
,
"ndbd passwd"
));
new
SocketAuthSimple
(
"ndbd"
,
"ndbd passwd"
));
DBUG_VOID_RETURN
;
}
}
Transporter
::~
Transporter
(){
Transporter
::~
Transporter
(){
...
@@ -77,8 +84,11 @@ Transporter::~Transporter(){
...
@@ -77,8 +84,11 @@ Transporter::~Transporter(){
bool
bool
Transporter
::
connect_server
(
NDB_SOCKET_TYPE
sockfd
)
{
Transporter
::
connect_server
(
NDB_SOCKET_TYPE
sockfd
)
{
DBUG_ENTER
(
"Transporter::connect_server"
);
if
(
m_connected
)
if
(
m_connected
)
return
true
;
// TODO assert(0);
{
DBUG_RETURN
(
true
);
// TODO assert(0);
}
bool
res
=
connect_server_impl
(
sockfd
);
bool
res
=
connect_server_impl
(
sockfd
);
if
(
res
){
if
(
res
){
...
@@ -86,7 +96,7 @@ Transporter::connect_server(NDB_SOCKET_TYPE sockfd) {
...
@@ -86,7 +96,7 @@ Transporter::connect_server(NDB_SOCKET_TYPE sockfd) {
m_errorCount
=
0
;
m_errorCount
=
0
;
}
}
return
res
;
DBUG_RETURN
(
res
)
;
}
}
bool
bool
...
...
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