[BACK]Return to client.c CVS log [TXT] [DIR] Up to [ELWIX - Embedded LightWeight unIX -] / mqtt / src

Diff for /mqtt/src/client.c between versions 1.1.2.9 and 1.1.2.11

version 1.1.2.9, 2011/12/24 17:30:29 version 1.1.2.11, 2012/01/05 10:01:20
Line 83  CloseClient(int sock) Line 83  CloseClient(int sock)
         } else          } else
                 ioVERBOSE(3) printf("Sended DISCONNECT %d bytes\n", siz);                  ioVERBOSE(3) printf("Sended DISCONNECT %d bytes\n", siz);
   
           shutdown(sock, SHUT_RDWR);
         close(sock);          close(sock);
         return siz;          return siz;
 }  }
Line 127  KAClient(int sock) Line 128  KAClient(int sock)
                 ioVERBOSE(3) printf("Received %d bytes\n", siz);                  ioVERBOSE(3) printf("Received %d bytes\n", siz);
   
         return (u_char) mqtt_readPINGRESP(args->msg);          return (u_char) mqtt_readPINGRESP(args->msg);
   }
   
   void *
   OpenFile(void)
   {
           int f, siz = 0;
           void *mem;
   
           if (!args->isFile)
                   return NULL;
   
           f = open(AIT_GET_STR(&args->Value), O_RDONLY);
           if (f == -1) {
                   printf("Error:: in open file #%d - %s\n", errno, strerror(errno));
                   return NULL;
           }
           mem = mmap(NULL, siz, PROT_READ, MAP_PRIVATE, f, 0);
           if (mem == MAP_FAILED) {
                   printf("Error:: in map file #%d - %s\n", errno, strerror(errno));
                   close(f);
                   return NULL;
           } else
                   close(f);
   
           AIT_SET_PTR(&args->Value, mem, siz);
           return mem;
   }
   
   void
   CloseFile(void)
   {
           if (args->isFile) {
                   munmap(AIT_GET_PTR(&args->Value), AIT_LEN(&args->Value));
                   AIT_FREE_VAL(&args->Value);
           }
 }  }
Removed from v.1.1.2.9  
changed lines
  Added in v.1.1.2.11

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>