--- mqtt/src/client.c 2011/12/29 14:13:13 1.1.2.10 +++ mqtt/src/client.c 2012/01/05 10:01:20 1.1.2.11 @@ -83,6 +83,7 @@ CloseClient(int sock) } else ioVERBOSE(3) printf("Sended DISCONNECT %d bytes\n", siz); + shutdown(sock, SHUT_RDWR); close(sock); return siz; } @@ -129,24 +130,37 @@ KAClient(int sock) return (u_char) mqtt_readPINGRESP(args->msg); } -FILE * +void * OpenFile(void) { + int f, siz = 0; + void *mem; + if (!args->isFile) return NULL; - args->isFile = fopen(AIT_GET_STR(&args->Value), "r"); - if (!args->isFile) { + 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); - return args->isFile; + AIT_SET_PTR(&args->Value, mem, siz); + return mem; } void CloseFile(void) { - if (args->isFile) - fclose(args->isFile); + if (args->isFile) { + munmap(AIT_GET_PTR(&args->Value), AIT_LEN(&args->Value)); + AIT_FREE_VAL(&args->Value); + } }