[td-255]refactor.
This commit is contained in:
parent
258c221a44
commit
c0aff8098d
|
@ -4407,7 +4407,7 @@ SVgroupsInfo* tscVgroupInfoClone(SVgroupsInfo *vgroupList) {
|
||||||
}
|
}
|
||||||
|
|
||||||
size_t size = sizeof(SVgroupsInfo) + sizeof(SVgroupMsg) * vgroupList->numOfVgroups;
|
size_t size = sizeof(SVgroupsInfo) + sizeof(SVgroupMsg) * vgroupList->numOfVgroups;
|
||||||
SVgroupsInfo* pNew = calloc(1, size);
|
SVgroupsInfo* pNew = malloc(size);
|
||||||
if (pNew == NULL) {
|
if (pNew == NULL) {
|
||||||
return NULL;
|
return NULL;
|
||||||
}
|
}
|
||||||
|
@ -4422,7 +4422,6 @@ SVgroupsInfo* tscVgroupInfoClone(SVgroupsInfo *vgroupList) {
|
||||||
pNewVInfo->numOfEps = pvInfo->numOfEps;
|
pNewVInfo->numOfEps = pvInfo->numOfEps;
|
||||||
|
|
||||||
for(int32_t j = 0; j < pvInfo->numOfEps; ++j) {
|
for(int32_t j = 0; j < pvInfo->numOfEps; ++j) {
|
||||||
// pNewVInfo->epAddr[j].fqdn = strdup(pvInfo->epAddr[j].fqdn);
|
|
||||||
pNewVInfo->epAddr[j].port = pvInfo->epAddr[j].port;
|
pNewVInfo->epAddr[j].port = pvInfo->epAddr[j].port;
|
||||||
tstrncpy(pNewVInfo->epAddr[j].fqdn, pvInfo->epAddr[j].fqdn, TSDB_FQDN_LEN);
|
tstrncpy(pNewVInfo->epAddr[j].fqdn, pvInfo->epAddr[j].fqdn, TSDB_FQDN_LEN);
|
||||||
}
|
}
|
||||||
|
|
|
@ -775,12 +775,7 @@ typedef struct {
|
||||||
typedef struct {
|
typedef struct {
|
||||||
int32_t numOfVgroups;
|
int32_t numOfVgroups;
|
||||||
SVgroupMsg vgroups[];
|
SVgroupMsg vgroups[];
|
||||||
} SVgroupsInfo;
|
} SVgroupsMsg, SVgroupsInfo;
|
||||||
|
|
||||||
typedef struct {
|
|
||||||
int32_t numOfVgroups;
|
|
||||||
SVgroupMsg vgroups[];
|
|
||||||
} SVgroupsMsg;
|
|
||||||
|
|
||||||
typedef struct STableMetaMsg {
|
typedef struct STableMetaMsg {
|
||||||
int32_t contLen;
|
int32_t contLen;
|
||||||
|
|
Loading…
Reference in New Issue