spacing
[iotcloud.git] / src / server / iotquery.cpp
index 191ffc4..8fc9fad 100644 (file)
@@ -16,197 +16,196 @@ const char * iotcloudroot_str="IOTCLOUD_ROOT";
 const char * length_str="CONTENT_LENGTH";
 
 IoTQuery::IoTQuery(FCGX_Request *request) :
 const char * length_str="CONTENT_LENGTH";
 
 IoTQuery::IoTQuery(FCGX_Request *request) :
-  request(request),
-  data(NULL),
-  directory(NULL),
-  uri(NULL),
-  query(NULL),
-  method(NULL),
-  iotcloudroot(NULL),
-  dir(NULL),
-  length(0),
-  firstentry(0),
-  lastentry(0),
-  requestsequencenumber(0),
-  numqueueentries(DEFAULT_SIZE),
-  fd(-1)
-{
+       request(request),
+       data(NULL),
+       directory(NULL),
+       uri(NULL),
+       query(NULL),
+       method(NULL),
+       iotcloudroot(NULL),
+       dir(NULL),
+       length(0),
+       firstentry(0),
+       lastentry(0),
+       requestsequencenumber(0),
+       numqueueentries(DEFAULT_SIZE),
+       fd(-1) {
 }
 
 IoTQuery::~IoTQuery() {
 }
 
 IoTQuery::~IoTQuery() {
-  if (fd >= 0)
-    close(fd);
-  if (directory)
-    delete directory;
-  if (data)
-    delete data;
-  if (dir != NULL)
-    closedir(dir);
+       if (fd >= 0)
+               close(fd);
+       if (directory)
+               delete directory;
+       if (data)
+               delete data;
+       if (dir != NULL)
+               closedir(dir);
 }
 
 bool IoTQuery::checkDirectory() {
 }
 
 bool IoTQuery::checkDirectory() {
-  struct stat s;
-  int err=stat(directory, &s);
-  if (-1 == err)
-    return false;
-  return S_ISDIR(s.st_mode);
+       struct stat s;
+       int err=stat(directory, &s);
+       if (-1 == err)
+               return false;
+       return S_ISDIR(s.st_mode);
 }
 
 void IoTQuery::decodeQuery() {
 }
 
 void IoTQuery::decodeQuery() {
-  int len=strlen(query);
-  char * str=new char[len+1];
-  memcpy(str, query, len+1);
-  char *tok_ptr=str;
-  
-  /* Parse commands */
-  char *command=strsep(&tok_ptr, "&");
-  if (strncmp(command, "putslot", 7) == 0)
-    reqPutSlot = true;
-
-  if (strncmp(command, "getslot", 7) == 0)
-    reqGetSlot = true;
-  
-  /* Load Sequence Number for request */
-  char *sequencenumber_str = strsep(&tok_ptr, "&");
-
-  if (sequencenumber_str != NULL)
-    requestsequencenumber = strtol(sequencenumber_str, NULL, 10);
-
-  /* Update size if we get request */
-  char * numqueueentries_str = tok_ptr;
-  if (numqueueentries_str != NULL)
-    numqueueentries = strtol(numqueueentries_str, NULL, 10);
-  
-  delete str;
+       int len=strlen(query);
+       char * str=new char[len+1];
+       memcpy(str, query, len+1);
+       char *tok_ptr=str;
+
+       /* Parse commands */
+       char *command=strsep(&tok_ptr, "&");
+       if (strncmp(command, "putslot", 7) == 0)
+               reqPutSlot = true;
+
+       if (strncmp(command, "getslot", 7) == 0)
+               reqGetSlot = true;
+
+       /* Load Sequence Number for request */
+       char *sequencenumber_str = strsep(&tok_ptr, "&");
+
+       if (sequencenumber_str != NULL)
+               requestsequencenumber = strtol(sequencenumber_str, NULL, 10);
+
+       /* Update size if we get request */
+       char * numqueueentries_str = tok_ptr;
+       if (numqueueentries_str != NULL)
+               numqueueentries = strtol(numqueueentries_str, NULL, 10);
+
+       delete str;
 }
 
 void IoTQuery::getSlot() {
 }
 
 void IoTQuery::getSlot() {
-  
+
 }
 
 void IoTQuery::putSlot() {
 }
 
 void IoTQuery::putSlot() {
-  
+
 }
 
 void IoTQuery::processQuery() {
 }
 
 void IoTQuery::processQuery() {
-  getQuery();
-  getDirectory();
-  readData();
-  
-  if (strncmp(method, "POST", 4) != 0)
-    return;
-  
-  if (directory == NULL ||
-      !checkDirectory())
-    return;
-  
-  if (!openStatusFile())
-    return;
-  
-  flock(fd, LOCK_EX);
-
-  decodeQuery();
-
-  if (reqGetSlot)
-    getSlot();
-  else if (reqPutSlot)
-    putSlot();
-  else return;
+       getQuery();
+       getDirectory();
+       readData();
+
+       if (strncmp(method, "POST", 4) != 0)
+               return;
+
+       if (directory == NULL ||
+                       !checkDirectory())
+               return;
+
+       if (!openStatusFile())
+               return;
+
+       flock(fd, LOCK_EX);
+
+       decodeQuery();
+
+       if (reqGetSlot)
+               getSlot();
+       else if (reqPutSlot)
+               putSlot();
+       else return;
 }
 
 void IoTQuery::readData() {
 }
 
 void IoTQuery::readData() {
-  if (length) {
-    data = new char[length+1];
-    memset(data, 0, length+1);
-    cin.read(data, length);
-  }
-  do {
-    char dummy;
-    cin >> dummy;
-  } while (!cin.eof());
+       if (length) {
+               data = new char[length+1];
+               memset(data, 0, length+1);
+               cin.read(data, length);
+       }
+       do {
+               char dummy;
+               cin >> dummy;
+       } while (!cin.eof());
 }
 
 void IoTQuery::getQuery() {
 }
 
 void IoTQuery::getQuery() {
-  uri = FCGX_GetParam(uri_str, request->envp);
-  query = FCGX_GetParam(query_str, request->envp);
-  method = FCGX_GetParam(method_str, request->envp);
-  iotcloudroot = FCGX_GetParam(iotcloudroot_str, request->envp);
-
-  char * reqlength = FCGX_GetParam(length_str, request->envp);
-  if (length) {
-    length=strtol(reqlength, NULL, 10);
-  } else {
-    length=0;
-  }
+       uri = FCGX_GetParam(uri_str, request->envp);
+       query = FCGX_GetParam(query_str, request->envp);
+       method = FCGX_GetParam(method_str, request->envp);
+       iotcloudroot = FCGX_GetParam(iotcloudroot_str, request->envp);
+
+       char * reqlength = FCGX_GetParam(length_str, request->envp);
+       if (length) {
+               length=strtol(reqlength, NULL, 10);
+       } else {
+               length=0;
+       }
 }
 
 void IoTQuery::getDirectory() {
 }
 
 void IoTQuery::getDirectory() {
-  char * split = strchr((char *)uri, '?');
-  if (split == NULL)
-    return;
-  int split_len = (int) (split-uri);
-  int rootdir_len = strlen(iotcloudroot);
-  int directory_len = split_len + rootdir_len + 1;
-  directory = new char[directory_len];
-  memcpy(directory, iotcloudroot, rootdir_len);
-  memcpy(directory + rootdir_len, uri, split_len);
-  directory[directory_len]=0;
+       char * split = strchr((char *)uri, '?');
+       if (split == NULL)
+               return;
+       int split_len = (int) (split-uri);
+       int rootdir_len = strlen(iotcloudroot);
+       int directory_len = split_len + rootdir_len + 1;
+       directory = new char[directory_len];
+       memcpy(directory, iotcloudroot, rootdir_len);
+       memcpy(directory + rootdir_len, uri, split_len);
+       directory[directory_len]=0;
 }
 
 int doread(int fd, void *ptr, size_t count, off_t offset) {
 }
 
 int doread(int fd, void *ptr, size_t count, off_t offset) {
-  do {
-    size_t bytesread=pread(fd, ptr, count, offset);
-    if (bytesread==count) {
-      return 1;
-    } else if (bytesread==0) {
-      return 0;
-    }
-  } while(1);  
+       do {
+               size_t bytesread=pread(fd, ptr, count, offset);
+               if (bytesread==count) {
+                       return 1;
+               } else if (bytesread==0) {
+                       return 0;
+               }
+       } while(1);
 }
 
 void IoTQuery::updateStatusFile() {
 }
 
 void IoTQuery::updateStatusFile() {
-  pwrite(fd, &numqueueentries, sizeof(numqueueentries), OFFSET_MAX);
-  pwrite(fd, &firstentry, sizeof(firstentry), OFFSET_FIRST);
-  pwrite(fd, &lastentry, sizeof(lastentry), OFFSET_LAST);
+       pwrite(fd, &numqueueentries, sizeof(numqueueentries), OFFSET_MAX);
+       pwrite(fd, &firstentry, sizeof(firstentry), OFFSET_FIRST);
+       pwrite(fd, &lastentry, sizeof(lastentry), OFFSET_LAST);
 }
 
 bool IoTQuery::openStatusFile() {
 }
 
 bool IoTQuery::openStatusFile() {
-  char statusfile[]="queuestatus";
-  int len=strlen(directory);
-
-  char * filename=new char[len+sizeof(statusfile)+2];
-  memcpy(filename, directory, len);
-  filename[len]='/';
-  memcpy(filename+len+1, statusfile, sizeof(statusfile));
-  filename[len+sizeof(statusfile)+1]=0;
-  fd=open(filename, O_CREAT| O_RDWR, S_IRUSR| S_IWUSR);
-  delete filename;
-
-  if (fd < 0)
-    return false;
-  
-  int size;
-  int needwrite=0;
-  if (doread(fd, &size, sizeof(size), OFFSET_MAX))
-    numqueueentries=size;
-  else
-    needwrite=1;
-
-  long entry;
-  if (doread(fd, &entry, sizeof(entry), OFFSET_FIRST))
-    firstentry=entry;
-  else
-    needwrite=1;
-
-  if (doread(fd, &entry, sizeof(entry), OFFSET_LAST))
-    lastentry=entry;
-  else
-    needwrite=1;
-      
-  if (needwrite)
-    updateStatusFile();
-  
-  return true;
+       char statusfile[]="queuestatus";
+       int len=strlen(directory);
+
+       char * filename=new char[len+sizeof(statusfile)+2];
+       memcpy(filename, directory, len);
+       filename[len]='/';
+       memcpy(filename+len+1, statusfile, sizeof(statusfile));
+       filename[len+sizeof(statusfile)+1]=0;
+       fd=open(filename, O_CREAT| O_RDWR, S_IRUSR| S_IWUSR);
+       delete filename;
+
+       if (fd < 0)
+               return false;
+
+       int size;
+       int needwrite=0;
+       if (doread(fd, &size, sizeof(size), OFFSET_MAX))
+               numqueueentries=size;
+       else
+               needwrite=1;
+
+       long entry;
+       if (doread(fd, &entry, sizeof(entry), OFFSET_FIRST))
+               firstentry=entry;
+       else
+               needwrite=1;
+
+       if (doread(fd, &entry, sizeof(entry), OFFSET_LAST))
+               lastentry=entry;
+       else
+               needwrite=1;
+
+       if (needwrite)
+               updateStatusFile();
+
+       return true;
 }
 
 }
 
-                                                  
+