--- mqtt/src/dl.c	2011/11/23 00:42:16	1.1.2.1
+++ mqtt/src/dl.c	2011/11/23 01:07:18	1.1.2.2
@@ -70,3 +70,21 @@ mqttUnloadRTLM(int modtype)
 {
 	dlclose((modtype ? pub_rtlm : acc_rtlm));
 }
+
+inline int
+mqttMkDir(sl_config *cfg)
+{
+	char *str;
+
+	if (!cfg)
+		return -1;
+
+	str = CFG(cfg_GetAttribute(cfg, CFG("mqttd"), CFG("statedir")));
+	if (!str)
+		return -1;
+
+	if (mkdir(str, 0600) == -1 && errno != EEXIST)
+		return -1;
+
+	return 0;
+}