refact
This commit is contained in:
parent
d5af05860e
commit
8b608cd3b7
|
@ -17,6 +17,7 @@
|
||||||
#define _TD_VNODE_IMPL_H_
|
#define _TD_VNODE_IMPL_H_
|
||||||
|
|
||||||
#include "os.h"
|
#include "os.h"
|
||||||
|
#include "trequest.h"
|
||||||
|
|
||||||
#include "meta.h"
|
#include "meta.h"
|
||||||
#include "tq.h"
|
#include "tq.h"
|
||||||
|
|
|
@ -30,6 +30,10 @@ typedef struct SVnodeOptions SVnodeOptions;
|
||||||
SVnode *vnodeOpen(const char *path, const SVnodeOptions *pVnodeOptions);
|
SVnode *vnodeOpen(const char *path, const SVnodeOptions *pVnodeOptions);
|
||||||
void vnodeClose(SVnode *pVnode);
|
void vnodeClose(SVnode *pVnode);
|
||||||
void vnodeDestroy(const char *path);
|
void vnodeDestroy(const char *path);
|
||||||
|
int vnodeProcessWriteReqs(SVnode *pVnode, SReqBatch *pReqBatch);
|
||||||
|
int vnodeApplyWriteReqs(SVnode *pVnode, SReqBatch *pReqBatch);
|
||||||
|
int vnodeProcessReadReq(SVnode *pVnode, SRequest *pReq);
|
||||||
|
int vnodeProcessSyncReq(SVnode *pVnode, SRequest *pReq);
|
||||||
|
|
||||||
/* ------------------------ SVnodeOptions ------------------------ */
|
/* ------------------------ SVnodeOptions ------------------------ */
|
||||||
void vnodeOptionsInit(SVnodeOptions *);
|
void vnodeOptionsInit(SVnodeOptions *);
|
||||||
|
|
|
@ -13,5 +13,14 @@
|
||||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||||
*/
|
*/
|
||||||
|
|
||||||
#define _DEFAULT_SOURCE
|
#include "vnodeDef.h"
|
||||||
#include "vnodeWrite.h"
|
|
||||||
|
int vnodeProcessWriteReqs(SVnode *pVnode, SReqBatch *pReqBatch) {
|
||||||
|
/* TODO */
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
int vnodeApplyWriteReqs(SVnode *pVnode, SReqBatch *pReqBatch) {
|
||||||
|
/* TODO */
|
||||||
|
return 0;
|
||||||
|
}
|
Loading…
Reference in New Issue