getCtxFromFile(): fixed resource leaks in errorcase
[util-vserver.git] / util-vserver / lib / getvserverctx.c
index 5334a5c..6a0e2c1 100644 (file)
@@ -23,6 +23,7 @@
 #include "vserver.h"
 #include "pathconfig.h"
 #include "compat-c99.h"
+#include "lib_internal/util.h"
 
 #include <sys/types.h>
 #include <sys/stat.h>
 #include <string.h>
 #include <unistd.h>
 
+#ifdef VC_ENABLE_API_COMPAT
+#include <fcntl.h>
+
+static xid_t
+extractLegacyXID(char const *dir, char const *basename)
+{
+  size_t       l1 = strlen(dir);
+  size_t       l2 = strlen(basename);
+  char         path[l1 + l2 + sizeof("/.ctx")];
+  char *       ptr = path;
+  int          fd;
+  ssize_t      len;
+  xid_t                result = VC_NOXID;
+
+  ptr    = Xmemcpy(ptr, dir, l1);
+  *ptr++ = '/';
+  ptr    = Xmemcpy(ptr, basename, l2);
+  ptr    = Xmemcpy(ptr, ".ctx",    5);
+
+  fd = open(path, O_RDONLY);
+  if (fd==-1) return VC_NOXID;
+
+  len = lseek(fd, 0, SEEK_END);
+
+  if (len!=-1 && lseek(fd, 0, SEEK_SET)!=-1) {
+    char       buf[len+2];
+    char const *pos = 0;
+
+    buf[0] = '\n';
+    
+    if (read(fd, buf+1, len+1)==len) {
+      buf[len+1] = '\0';
+      pos        = strstr(buf, "\nS_CONTEXT=");
+    }
+
+    if (pos) pos += 11;
+    if (*pos>='1' && *pos<='9')
+      result = atoi(pos);
+  }
+
+  close(fd);
+  return result;
+}
+#else
+static xid_t
+extractLegacyXID(char const UNUSED *dir, char const UNUSED *basename)
+{
+  return VC_NOXID;
+}
+#endif
+
+
 static xid_t
 getCtxFromFile(char const *pathname)
 {
@@ -39,23 +92,28 @@ getCtxFromFile(char const *pathname)
 
   fd = open(pathname, O_RDONLY);
 
-  if (fd==-1 ||
-      (len=lseek(fd, 0, SEEK_END))==-1 ||
+  if (fd==-1) return VC_NOCTX;
+  if ((len=lseek(fd, 0, SEEK_END))==-1 ||
       (len>50) ||
-      (lseek(fd, 0, SEEK_SET)==-1))
+      (lseek(fd, 0, SEEK_SET)==-1)) {
+    close(fd);
     return VC_NOCTX;
+  }
 
   {
   char         buf[len+1];
   char         *errptr;
   xid_t                res;
   
-  if (TEMP_FAILURE_RETRY(read(fd, buf, len+1))!=len)
-    return VC_NOCTX;
+  if (TEMP_FAILURE_RETRY(read(fd, buf, len+1))!=len) res = VC_NOCTX;
+  else {
+    buf[len] = '\0';
 
-  res = strtol(buf, &errptr, 10);
-  if (*errptr!='\0' && *errptr!='\n') return VC_NOCTX;
+    res = strtol(buf, &errptr, 10);
+    if (*errptr!='\0' && *errptr!='\n') res = VC_NOCTX;
+  }
 
+  close(fd);
   return res;
   }
 }
@@ -73,7 +131,8 @@ vc_getVserverCtx(char const *id, vcCfgStyle style, bool honor_static, bool *is_r
 
   switch (style) {
     case vcCFG_NONE            :  return VC_NOCTX;
-    case vcCFG_LEGACY          :  return VC_NOCTX;     // todo
+    case vcCFG_LEGACY          :
+      return extractLegacyXID(DEFAULT_PKGSTATEDIR, id);
     case vcCFG_RECENT_SHORT    :
     case vcCFG_RECENT_FULL     : {
       size_t           idx = 0;
@@ -87,7 +146,31 @@ vc_getVserverCtx(char const *id, vcCfgStyle style, bool honor_static, bool *is_r
       memcpy(buf+idx, "/run", 5);      // appends '\0' too
       
       res = getCtxFromFile(buf);
-      if (is_running) *is_running = res!=VC_NOCTX;
+
+       // when context information could be read, we have to verify that
+       // it belongs to a running vserver and the both vservers are
+       // identically
+      if (res!=VC_NOCTX) {
+       char                    *cur_name;
+       struct vc_vx_info       info;
+
+         // determine the vserver which is associated with the xid
+         // resp. skip this step when the context does not exist
+       cur_name = (vc_get_vx_info(res, &info)!=-1 ?
+                   vc_getVserverByCtx_Internal(res, &style, 0, false) : 0);
+
+       buf[idx] = '\0';        // cut off the '/run' from the vserver name
+       res      = ((cur_name!=0 &&
+                    vc_compareVserverById(buf,      vcCFG_RECENT_FULL,
+                                         cur_name, vcCFG_RECENT_FULL)==0)
+                   ? res
+                   : VC_NOCTX);        // correct the value of 'res'
+         
+       free(cur_name);
+      }
+      
+      if (is_running)                  // fill 'is_running' information...
+       *is_running = res!=VC_NOCTX;
       
       if (res==VC_NOCTX && honor_static) {
        memcpy(buf+idx, "/context", 9); // appends '\0' too