--- mqtt/src/client.c	2011/12/24 17:30:29	1.1.2.9
+++ 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;
 }
@@ -127,4 +128,39 @@ KAClient(int sock)
 		ioVERBOSE(3) printf("Received %d bytes\n", siz);
 
 	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);
+	}
 }