From 27db6cfd676bc238a640adfb5471c8b6df954c8c Mon Sep 17 00:00:00 2001
From: kailixu <klxu@taosdata.com>
Date: Tue, 15 Aug 2023 14:25:31 +0800
Subject: [PATCH] enh: disable udf/stream for mnd on windows

---
 source/dnode/mnode/impl/src/mndDb.c     | 6 ++++++
 source/dnode/mnode/impl/src/mndFunc.c   | 4 ++++
 source/dnode/mnode/impl/src/mndSma.c    | 4 ++++
 source/dnode/mnode/impl/src/mndStream.c | 4 ++++
 4 files changed, 18 insertions(+)

diff --git a/source/dnode/mnode/impl/src/mndDb.c b/source/dnode/mnode/impl/src/mndDb.c
index 1bd629e56f..fdefe9e5b1 100644
--- a/source/dnode/mnode/impl/src/mndDb.c
+++ b/source/dnode/mnode/impl/src/mndDb.c
@@ -668,6 +668,12 @@ static int32_t mndProcessCreateDbReq(SRpcMsg *pReq) {
   }
 
   mInfo("db:%s, start to create, vgroups:%d", createReq.db, createReq.numOfVgroups);
+#ifdef WINDOWS
+  if (taosArrayGetSize(createReq.pRetensions) > 0) {
+    code = TSDB_CODE_PAR_INVALID_PLATFORM;
+    goto _OVER;
+  }
+#endif
   if (mndCheckDbPrivilege(pMnode, pReq->info.conn.user, MND_OPER_CREATE_DB, NULL) != 0) {
     goto _OVER;
   }
diff --git a/source/dnode/mnode/impl/src/mndFunc.c b/source/dnode/mnode/impl/src/mndFunc.c
index 4ffc7a20c2..5f4ac830cd 100644
--- a/source/dnode/mnode/impl/src/mndFunc.c
+++ b/source/dnode/mnode/impl/src/mndFunc.c
@@ -361,6 +361,10 @@ static int32_t mndProcessCreateFuncReq(SRpcMsg *pReq) {
   }
 
   mInfo("func:%s, start to create, size:%d", createReq.name, createReq.codeLen);
+#ifdef WINDOWS
+  code = TSDB_CODE_PAR_INVALID_PLATFORM;
+  goto _OVER;
+#endif
   if (mndCheckOperPrivilege(pMnode, pReq->info.conn.user, MND_OPER_CREATE_FUNC) != 0) {
     goto _OVER;
   }
diff --git a/source/dnode/mnode/impl/src/mndSma.c b/source/dnode/mnode/impl/src/mndSma.c
index b84297f6bf..ff3f66efaf 100644
--- a/source/dnode/mnode/impl/src/mndSma.c
+++ b/source/dnode/mnode/impl/src/mndSma.c
@@ -655,6 +655,10 @@ _OVER:
 }
 
 static int32_t mndCheckCreateSmaReq(SMCreateSmaReq *pCreate) {
+#ifdef WINDOWS
+  terrno = TSDB_CODE_PAR_INVALID_PLATFORM;
+  return -1;
+#endif
   terrno = TSDB_CODE_MND_INVALID_SMA_OPTION;
   if (pCreate->name[0] == 0) return -1;
   if (pCreate->stb[0] == 0) return -1;
diff --git a/source/dnode/mnode/impl/src/mndStream.c b/source/dnode/mnode/impl/src/mndStream.c
index a0d53ec780..d6bb8c167f 100644
--- a/source/dnode/mnode/impl/src/mndStream.c
+++ b/source/dnode/mnode/impl/src/mndStream.c
@@ -253,6 +253,10 @@ static void mndShowStreamTrigger(char *dst, SStreamObj *pStream) {
 }
 
 static int32_t mndCheckCreateStreamReq(SCMCreateStreamReq *pCreate) {
+#ifdef WINDOWS
+  terrno = TSDB_CODE_PAR_INVALID_PLATFORM;
+  return -1;
+#endif
   if (pCreate->name[0] == 0 || pCreate->sql == NULL || pCreate->sql[0] == 0 || pCreate->sourceDB[0] == 0 ||
       pCreate->targetStbFullName[0] == 0) {
     terrno = TSDB_CODE_MND_INVALID_STREAM_OPTION;