#3531

Committed 19 Nov 2024 10:42AM UTC coverage: 60.213% (-0.006%) from 60.219%

Build # #3531

Build Type

push

travis-ci

Committed by

web-flow

Commit Message

Merge pull request #28777 from taosdata/fix/3.0/TD-32366

fix:TD-32366/stmt add geometry datatype check

Run Details

118529 of 252344 branches covered (46.97%)

Branch coverage included in aggregate %.

7 of 48 new or added lines in 3 files covered. (14.58%)

2282 existing lines in 115 files now uncovered.

199096 of 275161 relevant lines covered (72.36%)

6067577.83 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

72.92

/source/libs/sync/src/syncRequestVoteReply.c

/*
 * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
 *
 * This program is free software: you can use, redistribute, and/or modify
 * it under the terms of the GNU Affero General Public License, version 3
 * or later ("AGPL"), as published by the Free Software Foundation.
 *
 * This program is distributed in the hope that it will be useful, but WITHOUT
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
 * FITNESS FOR A PARTICULAR PURPOSE.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program. If not, see <http://www.gnu.org/licenses/>.
 */

#define _DEFAULT_SOURCE
#include "syncRequestVoteReply.h"
#include "syncMessage.h"
#include "syncRaftStore.h"
#include "syncUtil.h"
#include "syncVoteMgr.h"

// TLA+ Spec
// HandleRequestVoteResponse(i, j, m) ==
//    \* This tallies votes even when the current state is not Candidate, but
//    \* they won't be looked at, so it doesn't matter.
//    /\ m.mterm = currentTerm[i]
//    /\ votesResponded' = [votesResponded EXCEPT ![i] =
//                              votesResponded[i] \cup {j}]
//    /\ \/ /\ m.mvoteGranted
//          /\ votesGranted' = [votesGranted EXCEPT ![i] =
//                                  votesGranted[i] \cup {j}]
//          /\ voterLog' = [voterLog EXCEPT ![i] =
//                              voterLog[i] @@ (j :> m.mlog)]
//       \/ /\ ~m.mvoteGranted
//          /\ UNCHANGED <<votesGranted, voterLog>>
//    /\ Discard(m)
//    /\ UNCHANGED <<serverVars, votedFor, leaderVars, logVars>>
//

int32_t syncNodeOnRequestVoteReply(SSyncNode* ths, const SRpcMsg* pRpcMsg) {
  int32_t               ret = 0;
  SyncRequestVoteReply* pMsg = pRpcMsg->pCont;

  // if already drop replica, do not process
  if (!syncNodeInRaftGroup(ths, &(pMsg->srcId))) {
    syncLogRecvRequestVoteReply(ths, pMsg, "not in my config");

    TAOS_RETURN(TSDB_CODE_SYN_MISMATCHED_SIGNATURE);
  }
  SyncTerm currentTerm = raftStoreGetTerm(ths);
  // drop stale response
  if (pMsg->term < currentTerm) {
    syncLogRecvRequestVoteReply(ths, pMsg, "drop stale response");

    TAOS_RETURN(TSDB_CODE_SYN_WRONG_TERM);
  }

  if (pMsg->term > currentTerm) {
    syncLogRecvRequestVoteReply(ths, pMsg, "error term");
    syncNodeStepDown(ths, pMsg->term);

    TAOS_RETURN(TSDB_CODE_SYN_WRONG_TERM);
  }

  syncLogRecvRequestVoteReply(ths, pMsg, "");
  if (pMsg->term != currentTerm) return TSDB_CODE_SYN_INTERNAL_ERROR;

  // This tallies votes even when the current state is not Candidate,
  // but they won't be looked at, so it doesn't matter.
  if (ths->state == TAOS_SYNC_STATE_CANDIDATE) {
    if (ths->pVotesRespond->term != pMsg->term) {
      sNError(ths, "vote respond error vote-respond-mgr term:%" PRIu64 ", msg term:%" PRIu64 "",
              ths->pVotesRespond->term, pMsg->term);

      TAOS_RETURN(TSDB_CODE_SYN_WRONG_TERM);
    }

    votesRespondAdd(ths->pVotesRespond, pMsg);
    if (pMsg->voteGranted) {
      // add vote
      voteGrantedVote(ths->pVotesGranted, pMsg);

      // maybe to leader
      if (voteGrantedMajority(ths->pVotesGranted)) {
        if (!ths->pVotesGranted->toLeader) {
          syncNodeCandidate2Leader(ths);

          // prevent to leader again!
          ths->pVotesGranted->toLeader = true;
        }
      }
    } else {
      ;
      // do nothing
      // UNCHANGED <<votesGranted, voterLog>>
    }
  }

  TAOS_RETURN(TSDB_CODE_SUCCESS);
}

1	/*
2	* Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
3	*
4	* This program is free software: you can use, redistribute, and/or modify
5	* it under the terms of the GNU Affero General Public License, version 3
6	* or later ("AGPL"), as published by the Free Software Foundation.
7	*
8	* This program is distributed in the hope that it will be useful, but WITHOUT
9	* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
10	* FITNESS FOR A PARTICULAR PURPOSE.
11	*
12	* You should have received a copy of the GNU Affero General Public License
13	* along with this program. If not, see <http://www.gnu.org/licenses/>.
14	*/
15
16	#define _DEFAULT_SOURCE
17	#include "syncRequestVoteReply.h"
18	#include "syncMessage.h"
19	#include "syncRaftStore.h"
20	#include "syncUtil.h"
21	#include "syncVoteMgr.h"
22
23	// TLA+ Spec
24	// HandleRequestVoteResponse(i, j, m) ==
25	// \* This tallies votes even when the current state is not Candidate, but
26	// \* they won't be looked at, so it doesn't matter.
27	// /\ m.mterm = currentTerm[i]
28	// /\ votesResponded' = [votesResponded EXCEPT ![i] =
29	// votesResponded[i] \cup {j}]
30	// /\ \/ /\ m.mvoteGranted
31	// /\ votesGranted' = [votesGranted EXCEPT ![i] =
32	// votesGranted[i] \cup {j}]
33	// /\ voterLog' = [voterLog EXCEPT ![i] =
34	// voterLog[i] @@ (j :> m.mlog)]
35	// \/ /\ ~m.mvoteGranted
36	// /\ UNCHANGED <<votesGranted, voterLog>>
37	// /\ Discard(m)
38	// /\ UNCHANGED <<serverVars, votedFor, leaderVars, logVars>>
39	//
40
41	int32_t syncNodeOnRequestVoteReply(SSyncNode* ths, const SRpcMsg* pRpcMsg) {	2,025✔
42	int32_t ret = 0;	2,025✔
43	SyncRequestVoteReply* pMsg = pRpcMsg->pCont;	2,025✔
44
45	// if already drop replica, do not process
46	if (!syncNodeInRaftGroup(ths, &(pMsg->srcId))) {	2,025!
47	syncLogRecvRequestVoteReply(ths, pMsg, "not in my config");	×
48
49	TAOS_RETURN(TSDB_CODE_SYN_MISMATCHED_SIGNATURE);	×
50	}
51	SyncTerm currentTerm = raftStoreGetTerm(ths);	2,025✔
52	// drop stale response
53	if (pMsg->term < currentTerm) {	2,025!
UNCOV 54	syncLogRecvRequestVoteReply(ths, pMsg, "drop stale response");	×
55
UNCOV 56	TAOS_RETURN(TSDB_CODE_SYN_WRONG_TERM);	×
57	}
58
59	if (pMsg->term > currentTerm) {	2,025✔
60	syncLogRecvRequestVoteReply(ths, pMsg, "error term");	28✔
61	syncNodeStepDown(ths, pMsg->term);	28✔
62
63	TAOS_RETURN(TSDB_CODE_SYN_WRONG_TERM);	28✔
64	}
65
66	syncLogRecvRequestVoteReply(ths, pMsg, "");	1,997✔
67	if (pMsg->term != currentTerm) return TSDB_CODE_SYN_INTERNAL_ERROR;	1,997!
68
69	// This tallies votes even when the current state is not Candidate,
70	// but they won't be looked at, so it doesn't matter.
71	if (ths->state == TAOS_SYNC_STATE_CANDIDATE) {	1,997✔
72	if (ths->pVotesRespond->term != pMsg->term) {	1,218!
73	sNError(ths, "vote respond error vote-respond-mgr term:%" PRIu64 ", msg term:%" PRIu64 "",	×
74	ths->pVotesRespond->term, pMsg->term);
75
76	TAOS_RETURN(TSDB_CODE_SYN_WRONG_TERM);	×
77	}
78
79	votesRespondAdd(ths->pVotesRespond, pMsg);	1,218✔
80	if (pMsg->voteGranted) {	1,218✔
81	// add vote
82	voteGrantedVote(ths->pVotesGranted, pMsg);	1,079✔
83
84	// maybe to leader
85	if (voteGrantedMajority(ths->pVotesGranted)) {	1,079✔
86	if (!ths->pVotesGranted->toLeader) {	991!
87	syncNodeCandidate2Leader(ths);	991✔
88
89	// prevent to leader again!
90	ths->pVotesGranted->toLeader = true;	991✔
91	}
92	}
93	} else {
94	;
95	// do nothing
96	// UNCHANGED <<votesGranted, voterLog>>
97	}
98	}
99
100	TAOS_RETURN(TSDB_CODE_SUCCESS);	1,997✔
101	}

taosdata / TDengine / #3531

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous