tsdbFSet.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 "dev.h"

int32_t tsdbFileSetCreate(int32_t fid, struct SFileSet **ppSet) {
  int32_t code = 0;

  ppSet[0] = taosMemoryCalloc(1, sizeof(struct SFileSet));
  if (ppSet[0] == NULL) {
    code = TSDB_CODE_OUT_OF_MEMORY;
    goto _exit;
  }
  ppSet[0]->fid = fid;
  ppSet[0]->nextid = 1;  // TODO

_exit:
  return code;
}

int32_t tsdbFileSetEdit(struct SFileSet *pSet, struct SFileOp *pOp) {
  int32_t code = 0;
  int32_t lino;

  switch (pOp->op) {
    case TSDB_FOP_CREATE: {
      struct STFile **ppFile;
      switch (pOp->nState.type) {
        case TSDB_FTYPE_HEAD: {
          ppFile = &pSet->fHead;
        } break;
        case TSDB_FTYPE_DATA: {
          ppFile = &pSet->fData;
        } break;
        case TSDB_FTYPE_SMA: {
          ppFile = &pSet->fSma;
        } break;
        case TSDB_FTYPE_TOMB: {
          ppFile = &pSet->fTomb;
        } break;
        case TSDB_FTYPE_STT: {
          // ppFile = &pSet->lStt[0].fStt;
        } break;
        default: {
          ASSERTS(0, "Invalid file type");
        } break;
      }

      TSDB_CHECK_CODE(                                   //
          code = tsdbTFileCreate(&pOp->nState, ppFile),  //
          lino,                                          //
          _exit);
    } break;

    case TSDB_FOP_DELETE: {
      ASSERTS(0, "TODO: Not implemented yet");
    } break;
    case TSDB_FOP_TRUNCATE: {
      ASSERTS(0, "TODO: Not implemented yet");
    } break;
    case TSDB_FOP_EXTEND: {
      ASSERTS(0, "TODO: Not implemented yet");
    } break;
    default: {
      ASSERTS(0, "Invalid file operation");
    } break;
  }

_exit:
  return code;
}

int32_t tsdbFileSetToJson(SJson *pJson, const struct SFileSet *pSet) {
  int32_t code = 0;

  ASSERTS(0, "TODO: Not implemented yet");

_exit:
  return code;
}

int32_t tsdbEditFileSet(struct SFileSet *pFileSet, const struct SFileOp *pOp) {
  int32_t code = 0;
  ASSERTS(0, "TODO: Not implemented yet");
  // TODO
  return code;
}