more

ac7bcea2 · Hongze Cheng · e43aad8b · ac7bcea2
隐藏空白更改
内联并排

Showing with 3 addition and 1 deletion

source/dnode/vnode/impl/src/vnodeWrite.c source/dnode/vnode/impl/src/vnodeWrite.c +3 -1

未找到文件。
--- a/source/dnode/vnode/impl/src/vnodeWrite.c
+++ b/source/dnode/vnode/impl/src/vnodeWrite.c
@@ -72,7 +72,9 @@ int vnodeProcessWMsgs(SVnode *pVnode, SArray *pMsgs) {
          }
          break;
        case TSDB_MSG_TYPE_SUBMIT:
-          /* code */
+          if (tsdbInsertData(pVnode->pTsdb, (SSubmitMsg *)ptr) < 0) {
+            // TODO: handle error
+          }
          break;
        default:
          break;