#3387

Committed 27 Mar 2024 09:42AM UTC coverage: 66.241% (+0.3%) from 65.961%

Build # #3387

Build Type

push

travis-ci

Committed by

web-flow

Commit Message

Merge pull request #25198 from taosdata/fix/arbencode

fix: arb encode error

Run Details

92134 of 173159 branches covered (53.21%)

Branch coverage included in aggregate %.

2 of 2 new or added lines in 1 file covered. (100.0%)

312 existing lines in 81 files now uncovered.

163737 of 213111 relevant lines covered (76.83%)

2757393.62 hits per line

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

69.3

/source/libs/scheduler/src/schStatus.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/>.
 */

#include "catalog.h"
#include "command.h"
#include "query.h"
#include "schInt.h"
#include "tmsg.h"
#include "tref.h"
#include "trpc.h"

int32_t schSwitchJobStatus(SSchJob* pJob, int32_t status, void* param) {
  int32_t code = 0;
  SCH_ERR_JRET(schUpdateJobStatus(pJob, status));

  switch (status) {
    case JOB_TASK_STATUS_INIT:
      break;
    case JOB_TASK_STATUS_EXEC:
      SCH_ERR_JRET(schExecJob(pJob, (SSchedulerReq*)param));
      break;
    case JOB_TASK_STATUS_PART_SUCC:
      SCH_ERR_JRET(schProcessOnJobPartialSuccess(pJob));
      break;
    case JOB_TASK_STATUS_FETCH:
      SCH_ERR_JRET(schJobFetchRows(pJob));
      break;
    case JOB_TASK_STATUS_SUCC:
      break;
    case JOB_TASK_STATUS_FAIL:
      SCH_RET(schProcessOnJobFailure(pJob, (param ? *(int32_t*)param : 0)));
      break;
    case JOB_TASK_STATUS_DROP:
      schProcessOnJobDropped(pJob, *(int32_t*)param);

      if (taosRemoveRef(schMgmt.jobRef, pJob->refId)) {
        SCH_JOB_ELOG("remove job from job list failed, refId:0x%" PRIx64, pJob->refId);
      } else {
        SCH_JOB_DLOG("job removed from jobRef list, refId:0x%" PRIx64, pJob->refId);
      }
      break;
    default: {
      SCH_JOB_ELOG("unknown job status %d", status);
      SCH_RET(TSDB_CODE_SCH_STATUS_ERROR);
    }
  }

  return TSDB_CODE_SUCCESS;

_return:

  SCH_RET(schProcessOnJobFailure(pJob, code));
}

int32_t schHandleOpBeginEvent(int64_t jobId, SSchJob** job, SCH_OP_TYPE type, SSchedulerReq* pReq) {
  SSchJob* pJob = schAcquireJob(jobId);
  if (NULL == pJob) {
    qDebug("Acquire sch job failed, may be dropped, jobId:0x%" PRIx64, jobId);
    SCH_ERR_RET(TSDB_CODE_SCH_JOB_NOT_EXISTS);
  }

  *job = pJob;

  SCH_RET(schProcessOnOpBegin(pJob, type, pReq));
}

int32_t schHandleOpEndEvent(SSchJob* pJob, SCH_OP_TYPE type, SSchedulerReq* pReq, int32_t errCode) {
  int32_t code = errCode;

  if (NULL == pJob) {
    schDirectPostJobRes(pReq, errCode);
    SCH_RET(code);
  }

  schProcessOnOpEnd(pJob, type, pReq, errCode);

  if (TSDB_CODE_SCH_IGNORE_ERROR == errCode) {
    code = pJob->errCode;
  }

  schReleaseJob(pJob->refId);

  return code;
}

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	#include "catalog.h"
17	#include "command.h"
18	#include "query.h"
19	#include "schInt.h"
20	#include "tmsg.h"
21	#include "tref.h"
22	#include "trpc.h"
23
24	int32_t schSwitchJobStatus(SSchJob* pJob, int32_t status, void* param) {	10,963,437✔
25	int32_t code = 0;	10,963,437✔
26	SCH_ERR_JRET(schUpdateJobStatus(pJob, status));	10,963,437!
27
28	switch (status) {	10,963,453!
29	case JOB_TASK_STATUS_INIT:	2,395,292✔
30	break;	2,395,292✔
31	case JOB_TASK_STATUS_EXEC:	2,395,292✔
32	SCH_ERR_JRET(schExecJob(pJob, (SSchedulerReq*)param));	2,395,292!
33	break;	2,395,170✔
34	case JOB_TASK_STATUS_PART_SUCC:	2,384,817✔
35	SCH_ERR_JRET(schProcessOnJobPartialSuccess(pJob));	2,384,817!
36	break;	2,384,817✔
37	case JOB_TASK_STATUS_FETCH:	749,304✔
38	SCH_ERR_JRET(schJobFetchRows(pJob));	749,304!
39	break;	749,302✔
40	case JOB_TASK_STATUS_SUCC:	633,110✔
41	break;	633,110✔
42	case JOB_TASK_STATUS_FAIL:	10,353✔
43	SCH_RET(schProcessOnJobFailure(pJob, (param ? (int32_t)param : 0)));	10,353!
44	break;
45	case JOB_TASK_STATUS_DROP:	2,395,288✔
46	schProcessOnJobDropped(pJob, (int32_t)param);	2,395,288✔
47
48	if (taosRemoveRef(schMgmt.jobRef, pJob->refId)) {	2,395,287!
49	SCH_JOB_ELOG("remove job from job list failed, refId:0x%" PRIx64, pJob->refId);	×
50	} else {
51	SCH_JOB_DLOG("job removed from jobRef list, refId:0x%" PRIx64, pJob->refId);	2,395,288✔
52	}
53	break;	2,395,288✔
UNCOV 54	default: {	×
UNCOV 55	SCH_JOB_ELOG("unknown job status %d", status);	×
56	SCH_RET(TSDB_CODE_SCH_STATUS_ERROR);	×
57	}
58	}
59
60	return TSDB_CODE_SUCCESS;	10,952,979✔
61
62	_return:	130✔
63
64	SCH_RET(schProcessOnJobFailure(pJob, code));	130!
65	}
66
67	int32_t schHandleOpBeginEvent(int64_t jobId, SSchJob** job, SCH_OP_TYPE type, SSchedulerReq* pReq) {	3,158,200✔
68	SSchJob* pJob = schAcquireJob(jobId);	3,158,200✔
69	if (NULL == pJob) {	3,158,202✔
70	qDebug("Acquire sch job failed, may be dropped, jobId:0x%" PRIx64, jobId);	54!
71	SCH_ERR_RET(TSDB_CODE_SCH_JOB_NOT_EXISTS);	54!
72	}
73
74	*job = pJob;	3,158,148✔
75
76	SCH_RET(schProcessOnOpBegin(pJob, type, pReq));	3,158,148!
77	}
78
79	int32_t schHandleOpEndEvent(SSchJob* pJob, SCH_OP_TYPE type, SSchedulerReq* pReq, int32_t errCode) {	3,158,200✔
80	int32_t code = errCode;	3,158,200✔
81
82	if (NULL == pJob) {	3,158,200✔
83	schDirectPostJobRes(pReq, errCode);	54✔
84	SCH_RET(code);	54!
85	}
86
87	schProcessOnOpEnd(pJob, type, pReq, errCode);	3,158,146✔
88
89	if (TSDB_CODE_SCH_IGNORE_ERROR == errCode) {	3,158,148✔
90	code = pJob->errCode;	122✔
91	}
92
93	schReleaseJob(pJob->refId);	3,158,148✔
94
95	return code;	3,158,146✔
96	}

taosdata / TDengine / #3387

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