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
0d1f3920
Commit
0d1f3920
authored
Jan 30, 2007
by
jonas@perch.ndb.mysql.com
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
ndb -
two small fixes for TC 1) use static syntax 2) fix attlen handling in unique index
parent
6b738220
Changes
1
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
15 additions
and
15 deletions
+15
-15
storage/ndb/src/kernel/blocks/dbtc/DbtcMain.cpp
storage/ndb/src/kernel/blocks/dbtc/DbtcMain.cpp
+15
-15
No files found.
storage/ndb/src/kernel/blocks/dbtc/DbtcMain.cpp
View file @
0d1f3920
...
@@ -2523,7 +2523,7 @@ void Dbtc::execTCKEYREQ(Signal* signal)
...
@@ -2523,7 +2523,7 @@ void Dbtc::execTCKEYREQ(Signal* signal)
ApiConnectRecord
*
const
regApiPtr
=
&
localApiConnectRecord
[
TapiIndex
];
ApiConnectRecord
*
const
regApiPtr
=
&
localApiConnectRecord
[
TapiIndex
];
apiConnectptr
.
p
=
regApiPtr
;
apiConnectptr
.
p
=
regApiPtr
;
Uint32
TstartFlag
=
tcKeyReq
->
getStartFlag
(
Treqinfo
);
Uint32
TstartFlag
=
TcKeyReq
::
getStartFlag
(
Treqinfo
);
Uint32
TexecFlag
=
TcKeyReq
::
getExecuteFlag
(
Treqinfo
);
Uint32
TexecFlag
=
TcKeyReq
::
getExecuteFlag
(
Treqinfo
);
Uint8
isIndexOp
=
regApiPtr
->
isIndexOp
;
Uint8
isIndexOp
=
regApiPtr
->
isIndexOp
;
...
@@ -2693,14 +2693,14 @@ void Dbtc::execTCKEYREQ(Signal* signal)
...
@@ -2693,14 +2693,14 @@ void Dbtc::execTCKEYREQ(Signal* signal)
/* */
/* */
/* ---------------------------------------------------------------------- */
/* ---------------------------------------------------------------------- */
UintR
TapiVersionNo
=
tcKeyReq
->
getAPIVersion
(
tcKeyReq
->
attrLen
);
UintR
TapiVersionNo
=
TcKeyReq
::
getAPIVersion
(
tcKeyReq
->
attrLen
);
UintR
Tlqhkeyreqrec
=
regApiPtr
->
lqhkeyreqrec
;
UintR
Tlqhkeyreqrec
=
regApiPtr
->
lqhkeyreqrec
;
regApiPtr
->
lqhkeyreqrec
=
Tlqhkeyreqrec
+
1
;
regApiPtr
->
lqhkeyreqrec
=
Tlqhkeyreqrec
+
1
;
regCachePtr
->
apiVersionNo
=
TapiVersionNo
;
regCachePtr
->
apiVersionNo
=
TapiVersionNo
;
UintR
TapiConnectptrIndex
=
apiConnectptr
.
i
;
UintR
TapiConnectptrIndex
=
apiConnectptr
.
i
;
UintR
TsenderData
=
tcKeyReq
->
senderData
;
UintR
TsenderData
=
tcKeyReq
->
senderData
;
UintR
TattrLen
=
tcKeyReq
->
getAttrinfoLen
(
tcKeyReq
->
attrLen
);
UintR
TattrLen
=
TcKeyReq
::
getAttrinfoLen
(
tcKeyReq
->
attrLen
);
UintR
TattrinfoCount
=
c_counters
.
cattrinfoCount
;
UintR
TattrinfoCount
=
c_counters
.
cattrinfoCount
;
regTcPtr
->
apiConnect
=
TapiConnectptrIndex
;
regTcPtr
->
apiConnect
=
TapiConnectptrIndex
;
...
@@ -2726,15 +2726,15 @@ void Dbtc::execTCKEYREQ(Signal* signal)
...
@@ -2726,15 +2726,15 @@ void Dbtc::execTCKEYREQ(Signal* signal)
UintR
TtabptrIndex
=
localTabptr
.
i
;
UintR
TtabptrIndex
=
localTabptr
.
i
;
UintR
TtableSchemaVersion
=
tcKeyReq
->
tableSchemaVersion
;
UintR
TtableSchemaVersion
=
tcKeyReq
->
tableSchemaVersion
;
Uint8
TOperationType
=
tcKeyReq
->
getOperationType
(
Treqinfo
);
Uint8
TOperationType
=
TcKeyReq
::
getOperationType
(
Treqinfo
);
regCachePtr
->
tableref
=
TtabptrIndex
;
regCachePtr
->
tableref
=
TtabptrIndex
;
regCachePtr
->
schemaVersion
=
TtableSchemaVersion
;
regCachePtr
->
schemaVersion
=
TtableSchemaVersion
;
regTcPtr
->
operation
=
TOperationType
;
regTcPtr
->
operation
=
TOperationType
;
Uint8
TSimpleFlag
=
tcKeyReq
->
getSimpleFlag
(
Treqinfo
);
Uint8
TSimpleFlag
=
TcKeyReq
::
getSimpleFlag
(
Treqinfo
);
Uint8
TDirtyFlag
=
tcKeyReq
->
getDirtyFlag
(
Treqinfo
);
Uint8
TDirtyFlag
=
TcKeyReq
::
getDirtyFlag
(
Treqinfo
);
Uint8
TInterpretedFlag
=
tcKeyReq
->
getInterpretedFlag
(
Treqinfo
);
Uint8
TInterpretedFlag
=
TcKeyReq
::
getInterpretedFlag
(
Treqinfo
);
Uint8
TDistrKeyFlag
=
tcKeyReq
->
getDistributionKeyFlag
(
Treqinfo
);
Uint8
TDistrKeyFlag
=
TcKeyReq
::
getDistributionKeyFlag
(
Treqinfo
);
Uint8
TNoDiskFlag
=
TcKeyReq
::
getNoDiskFlag
(
Treqinfo
);
Uint8
TNoDiskFlag
=
TcKeyReq
::
getNoDiskFlag
(
Treqinfo
);
Uint8
TexecuteFlag
=
TexecFlag
;
Uint8
TexecuteFlag
=
TexecFlag
;
...
@@ -2750,10 +2750,10 @@ void Dbtc::execTCKEYREQ(Signal* signal)
...
@@ -2750,10 +2750,10 @@ void Dbtc::execTCKEYREQ(Signal* signal)
Uint32
TkeyIndex
;
Uint32
TkeyIndex
;
Uint32
*
TOptionalDataPtr
=
(
Uint32
*
)
&
tcKeyReq
->
scanInfo
;
Uint32
*
TOptionalDataPtr
=
(
Uint32
*
)
&
tcKeyReq
->
scanInfo
;
{
{
Uint32
TDistrGHIndex
=
tcKeyReq
->
getScanIndFlag
(
Treqinfo
);
Uint32
TDistrGHIndex
=
TcKeyReq
::
getScanIndFlag
(
Treqinfo
);
Uint32
TDistrKeyIndex
=
TDistrGHIndex
;
Uint32
TDistrKeyIndex
=
TDistrGHIndex
;
Uint32
TscanInfo
=
tcKeyReq
->
getTakeOverScanInfo
(
TOptionalDataPtr
[
0
]);
Uint32
TscanInfo
=
TcKeyReq
::
getTakeOverScanInfo
(
TOptionalDataPtr
[
0
]);
regCachePtr
->
scanTakeOverInd
=
TDistrGHIndex
;
regCachePtr
->
scanTakeOverInd
=
TDistrGHIndex
;
regCachePtr
->
scanInfo
=
TscanInfo
;
regCachePtr
->
scanInfo
=
TscanInfo
;
...
@@ -2775,7 +2775,7 @@ void Dbtc::execTCKEYREQ(Signal* signal)
...
@@ -2775,7 +2775,7 @@ void Dbtc::execTCKEYREQ(Signal* signal)
regCachePtr
->
keydata
[
2
]
=
Tdata3
;
regCachePtr
->
keydata
[
2
]
=
Tdata3
;
regCachePtr
->
keydata
[
3
]
=
Tdata4
;
regCachePtr
->
keydata
[
3
]
=
Tdata4
;
TkeyLength
=
tcKeyReq
->
getKeyLength
(
Treqinfo
);
TkeyLength
=
TcKeyReq
::
getKeyLength
(
Treqinfo
);
Uint32
TAIDataIndex
;
Uint32
TAIDataIndex
;
if
(
TkeyLength
>
8
)
{
if
(
TkeyLength
>
8
)
{
TAIDataIndex
=
TkeyIndex
+
8
;
TAIDataIndex
=
TkeyIndex
+
8
;
...
@@ -2788,7 +2788,7 @@ void Dbtc::execTCKEYREQ(Signal* signal)
...
@@ -2788,7 +2788,7 @@ void Dbtc::execTCKEYREQ(Signal* signal)
}
//if
}
//if
Uint32
*
TAIDataPtr
=
&
TOptionalDataPtr
[
TAIDataIndex
];
Uint32
*
TAIDataPtr
=
&
TOptionalDataPtr
[
TAIDataIndex
];
titcLenAiInTckeyreq
=
tcKeyReq
->
getAIInTcKeyReq
(
Treqinfo
);
titcLenAiInTckeyreq
=
TcKeyReq
::
getAIInTcKeyReq
(
Treqinfo
);
regCachePtr
->
keylen
=
TkeyLength
;
regCachePtr
->
keylen
=
TkeyLength
;
regCachePtr
->
lenAiInTckeyreq
=
titcLenAiInTckeyreq
;
regCachePtr
->
lenAiInTckeyreq
=
titcLenAiInTckeyreq
;
regCachePtr
->
currReclenAi
=
titcLenAiInTckeyreq
;
regCachePtr
->
currReclenAi
=
titcLenAiInTckeyreq
;
...
@@ -2859,14 +2859,14 @@ void Dbtc::execTCKEYREQ(Signal* signal)
...
@@ -2859,14 +2859,14 @@ void Dbtc::execTCKEYREQ(Signal* signal)
}
//switch
}
//switch
}
//if
}
//if
Uint32
TabortOption
=
tcKeyReq
->
getAbortOption
(
Treqinfo
);
Uint32
TabortOption
=
TcKeyReq
::
getAbortOption
(
Treqinfo
);
regTcPtr
->
m_execAbortOption
=
TabortOption
;
regTcPtr
->
m_execAbortOption
=
TabortOption
;
/*-------------------------------------------------------------------------
/*-------------------------------------------------------------------------
* Check error handling per operation
* Check error handling per operation
* If CommitFlag is set state accordingly and check for early abort
* If CommitFlag is set state accordingly and check for early abort
*------------------------------------------------------------------------*/
*------------------------------------------------------------------------*/
if
(
tcKeyReq
->
getCommitFlag
(
Treqinfo
)
==
1
)
{
if
(
TcKeyReq
::
getCommitFlag
(
Treqinfo
)
==
1
)
{
ndbrequire
(
TexecuteFlag
);
ndbrequire
(
TexecuteFlag
);
regApiPtr
->
apiConnectstate
=
CS_REC_COMMITTING
;
regApiPtr
->
apiConnectstate
=
CS_REC_COMMITTING
;
}
else
{
}
else
{
...
@@ -11492,7 +11492,7 @@ void Dbtc::execTCINDXREQ(Signal* signal)
...
@@ -11492,7 +11492,7 @@ void Dbtc::execTCINDXREQ(Signal* signal)
// If operation is readTupleExclusive or updateTuple then read index
// If operation is readTupleExclusive or updateTuple then read index
// table with exclusive lock
// table with exclusive lock
Uint32
indexLength
=
TcKeyReq
::
getKeyLength
(
tcIndxRequestInfo
);
Uint32
indexLength
=
TcKeyReq
::
getKeyLength
(
tcIndxRequestInfo
);
Uint32
attrLength
=
tcIndxReq
->
attrLen
;
Uint32
attrLength
=
TcKeyReq
::
getAttrinfoLen
(
tcIndxReq
->
attrLen
)
;
indexOp
->
expectedKeyInfo
=
indexLength
;
indexOp
->
expectedKeyInfo
=
indexLength
;
Uint32
includedIndexLength
=
MIN
(
indexLength
,
indexBufSize
);
Uint32
includedIndexLength
=
MIN
(
indexLength
,
indexBufSize
);
indexOp
->
expectedAttrInfo
=
attrLength
;
indexOp
->
expectedAttrInfo
=
attrLength
;
...
...
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