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
ca86dcdf
Commit
ca86dcdf
authored
Apr 26, 2006
by
jonas@perch.ndb.mysql.com
Browse files
Options
Browse Files
Download
Plain Diff
Merge joreland@bk-internal.mysql.com:/home/bk/mysql-5.1-new-ndb
into perch.ndb.mysql.com:/home/jonas/src/mysql-5.1-new-ndb
parents
0e8ccc1b
1c9dc67e
Changes
5
Hide whitespace changes
Inline
Side-by-side
Showing
5 changed files
with
12 additions
and
10 deletions
+12
-10
storage/ndb/include/util/SocketServer.hpp
storage/ndb/include/util/SocketServer.hpp
+1
-1
storage/ndb/src/common/util/SocketServer.cpp
storage/ndb/src/common/util/SocketServer.cpp
+2
-2
storage/ndb/src/kernel/blocks/dbtup/DbtupExecQuery.cpp
storage/ndb/src/kernel/blocks/dbtup/DbtupExecQuery.cpp
+2
-1
storage/ndb/test/ndbapi/testDict.cpp
storage/ndb/test/ndbapi/testDict.cpp
+6
-6
support-files/mysql.spec.sh
support-files/mysql.spec.sh
+1
-0
No files found.
storage/ndb/include/util/SocketServer.hpp
View file @
ca86dcdf
...
@@ -75,7 +75,7 @@ public:
...
@@ -75,7 +75,7 @@ public:
/**
/**
* Constructor / Destructor
* Constructor / Destructor
*/
*/
SocketServer
(
int
maxSessions
=
32
);
SocketServer
(
unsigned
maxSessions
=
~
(
unsigned
)
0
);
~
SocketServer
();
~
SocketServer
();
/**
/**
...
...
storage/ndb/src/common/util/SocketServer.cpp
View file @
ca86dcdf
...
@@ -27,7 +27,7 @@
...
@@ -27,7 +27,7 @@
#define DEBUG(x) ndbout << x << endl;
#define DEBUG(x) ndbout << x << endl;
SocketServer
::
SocketServer
(
int
maxSessions
)
:
SocketServer
::
SocketServer
(
unsigned
maxSessions
)
:
m_sessions
(
10
),
m_sessions
(
10
),
m_services
(
5
)
m_services
(
5
)
{
{
...
@@ -136,7 +136,7 @@ SocketServer::setup(SocketServer::Service * service,
...
@@ -136,7 +136,7 @@ SocketServer::setup(SocketServer::Service * service,
}
}
DBUG_PRINT
(
"info"
,(
"bound to %u"
,
ntohs
(
servaddr
.
sin_port
)));
DBUG_PRINT
(
"info"
,(
"bound to %u"
,
ntohs
(
servaddr
.
sin_port
)));
if
(
listen
(
sock
,
m_maxSessions
)
==
-
1
){
if
(
listen
(
sock
,
m_maxSessions
>
32
?
32
:
m_maxSessions
)
==
-
1
){
DBUG_PRINT
(
"error"
,(
"listen() - %d - %s"
,
DBUG_PRINT
(
"error"
,(
"listen() - %d - %s"
,
errno
,
strerror
(
errno
)));
errno
,
strerror
(
errno
)));
NDB_CLOSE_SOCKET
(
sock
);
NDB_CLOSE_SOCKET
(
sock
);
...
...
storage/ndb/src/kernel/blocks/dbtup/DbtupExecQuery.cpp
View file @
ca86dcdf
...
@@ -3130,6 +3130,7 @@ Dbtup::nr_delete(Signal* signal, Uint32 senderData,
...
@@ -3130,6 +3130,7 @@ Dbtup::nr_delete(Signal* signal, Uint32 senderData,
}
}
PagePtr
disk_page
=
*
(
PagePtr
*
)
&
m_pgman
.
m_ptr
;
PagePtr
disk_page
=
*
(
PagePtr
*
)
&
m_pgman
.
m_ptr
;
disk_page_set_dirty
(
disk_page
);
preq
.
m_callback
.
m_callbackFunction
=
preq
.
m_callback
.
m_callbackFunction
=
safe_cast
(
&
Dbtup
::
nr_delete_logbuffer_callback
);
safe_cast
(
&
Dbtup
::
nr_delete_logbuffer_callback
);
...
@@ -3164,7 +3165,7 @@ Dbtup::nr_delete_page_callback(Signal* signal,
...
@@ -3164,7 +3165,7 @@ Dbtup::nr_delete_page_callback(Signal* signal,
Ptr
<
GlobalPage
>
gpage
;
Ptr
<
GlobalPage
>
gpage
;
m_global_page_pool
.
getPtr
(
gpage
,
page_id
);
m_global_page_pool
.
getPtr
(
gpage
,
page_id
);
PagePtr
pagePtr
=
*
(
PagePtr
*
)
&
gpage
;
PagePtr
pagePtr
=
*
(
PagePtr
*
)
&
gpage
;
disk_page_set_dirty
(
pagePtr
);
Dblqh
::
Nr_op_info
op
;
Dblqh
::
Nr_op_info
op
;
op
.
m_ptr_i
=
userpointer
;
op
.
m_ptr_i
=
userpointer
;
op
.
m_disk_ref
.
m_page_no
=
pagePtr
.
p
->
m_page_no
;
op
.
m_disk_ref
.
m_page_no
=
pagePtr
.
p
->
m_page_no
;
...
...
storage/ndb/test/ndbapi/testDict.cpp
View file @
ca86dcdf
...
@@ -109,7 +109,7 @@ int runCreateTheTable(NDBT_Context* ctx, NDBT_Step* step){
...
@@ -109,7 +109,7 @@ int runCreateTheTable(NDBT_Context* ctx, NDBT_Step* step){
const
NdbDictionary
::
Table
*
pTab
=
ctx
->
getTab
();
const
NdbDictionary
::
Table
*
pTab
=
ctx
->
getTab
();
// Try to create table in db
// Try to create table in db
if
(
pTab
->
createTableInDb
(
pNdb
)
!=
0
){
if
(
NDBT_Tables
::
createTable
(
pNdb
,
pTab
->
getName
()
)
!=
0
){
return
NDBT_FAILED
;
return
NDBT_FAILED
;
}
}
...
@@ -151,7 +151,7 @@ int runCreateTableWhenDbIsFull(NDBT_Context* ctx, NDBT_Step* step){
...
@@ -151,7 +151,7 @@ int runCreateTableWhenDbIsFull(NDBT_Context* ctx, NDBT_Step* step){
}
}
// Try to create table in db
// Try to create table in db
if
(
pTab
->
createTableInDb
(
pNdb
)
==
0
){
if
(
NDBT_Tables
::
createTable
(
pNdb
,
pTab
->
getName
()
)
==
0
){
result
=
NDBT_FAILED
;
result
=
NDBT_FAILED
;
}
}
...
@@ -203,7 +203,7 @@ int runCreateAndDrop(NDBT_Context* ctx, NDBT_Step* step){
...
@@ -203,7 +203,7 @@ int runCreateAndDrop(NDBT_Context* ctx, NDBT_Step* step){
ndbout
<<
i
<<
": "
;
ndbout
<<
i
<<
": "
;
// Try to create table in db
// Try to create table in db
if
(
pTab
->
createTableInDb
(
pNdb
)
!=
0
){
if
(
NDBT_Tables
::
createTable
(
pNdb
,
pTab
->
getName
()
)
!=
0
){
return
NDBT_FAILED
;
return
NDBT_FAILED
;
}
}
...
@@ -254,7 +254,8 @@ int runCreateAndDropWithData(NDBT_Context* ctx, NDBT_Step* step){
...
@@ -254,7 +254,8 @@ int runCreateAndDropWithData(NDBT_Context* ctx, NDBT_Step* step){
while
(
i
<
loops
){
while
(
i
<
loops
){
ndbout
<<
i
<<
": "
;
ndbout
<<
i
<<
": "
;
// Try to create table in db
// Try to create table in db
if
(
pTab
->
createTableInDb
(
pNdb
)
!=
0
){
if
(
NDBT_Tables
::
createTable
(
pNdb
,
pTab
->
getName
())
!=
0
){
return
NDBT_FAILED
;
return
NDBT_FAILED
;
}
}
...
@@ -336,7 +337,7 @@ int runCreateAndDropDuring(NDBT_Context* ctx, NDBT_Step* step){
...
@@ -336,7 +337,7 @@ int runCreateAndDropDuring(NDBT_Context* ctx, NDBT_Step* step){
Ndb
*
pNdb
=
GETNDB
(
step
);
Ndb
*
pNdb
=
GETNDB
(
step
);
g_debug
<<
"Creating table"
<<
endl
;
g_debug
<<
"Creating table"
<<
endl
;
if
(
pTab
->
createTableInDb
(
pNdb
)
!=
0
){
if
(
NDBT_Tables
::
createTable
(
pNdb
,
pTab
->
getName
()
)
!=
0
){
g_err
<<
"createTableInDb failed"
<<
endl
;
g_err
<<
"createTableInDb failed"
<<
endl
;
result
=
NDBT_FAILED
;
result
=
NDBT_FAILED
;
continue
;
continue
;
...
@@ -357,7 +358,6 @@ int runCreateAndDropDuring(NDBT_Context* ctx, NDBT_Step* step){
...
@@ -357,7 +358,6 @@ int runCreateAndDropDuring(NDBT_Context* ctx, NDBT_Step* step){
g_debug
<<
"Dropping table"
<<
endl
;
g_debug
<<
"Dropping table"
<<
endl
;
if
(
pNdb
->
getDictionary
()
->
dropTable
(
pTab2
->
getName
())
!=
0
){
if
(
pNdb
->
getDictionary
()
->
dropTable
(
pTab2
->
getName
())
!=
0
){
g_err
<<
"Failed to drop "
<<
pTab2
->
getName
()
<<
" in db"
<<
endl
;
g_err
<<
"Failed to drop "
<<
pTab2
->
getName
()
<<
" in db"
<<
endl
;
result
=
NDBT_FAILED
;
result
=
NDBT_FAILED
;
...
...
support-files/mysql.spec.sh
View file @
ca86dcdf
...
@@ -641,6 +641,7 @@ fi
...
@@ -641,6 +641,7 @@ fi
%attr
(
755, root, root
)
%
{
_bindir
}
/ndb_desc
%attr
(
755, root, root
)
%
{
_bindir
}
/ndb_desc
%attr
(
755, root, root
)
%
{
_bindir
}
/ndb_show_tables
%attr
(
755, root, root
)
%
{
_bindir
}
/ndb_show_tables
%attr
(
755, root, root
)
%
{
_bindir
}
/ndb_test_platform
%attr
(
755, root, root
)
%
{
_bindir
}
/ndb_test_platform
%attr
(
755, root, root
)
%
{
_bindir
}
/ndb_config
%files ndb-extra
%files ndb-extra
%defattr
(
-,root,root,0755
)
%defattr
(
-,root,root,0755
)
...
...
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