remove malloc hook when disable jemalloc

fix makefile for better platform support

Makefile

@@ -5,7 +5,7 @@ CSERVICE_PATH ?= cservice
 
 SKYNET_BUILD_PATH ?= .
 
-CFLAGS = -g -O2 -Wall -I$(LUA_INC) $(MYCFLAGS)
+CFLAGS = -g -O2 -Wall -I$(LUA_INC) $(MYCFLAGS) $(SKYNET_DEFINES)
 
 # lua
 
@@ -22,8 +22,11 @@ JEMALLOC_STATICLIB := 3rd/jemalloc/lib/libjemalloc_pic.a
 JEMALLOC_INC := 3rd/jemalloc/include/jemalloc
 
 all : jemalloc
+	
 .PHONY : jemalloc
 
+MALLOC_STATICLIB := $(JEMALLOC_STATICLIB)
+
 $(JEMALLOC_STATICLIB) : 3rd/jemalloc/Makefile
 	cd 3rd/jemalloc && $(MAKE) CC=$(CC) 
 
@@ -33,7 +36,7 @@ $(JEMALLOC_STATICLIB) : 3rd/jemalloc/Makefile
 3rd/jemalloc/Makefile : | 3rd/jemalloc/autogen.sh
 	cd 3rd/jemalloc && ./autogen.sh --with-jemalloc-prefix=je_ --disable-valgrind
 
-jemalloc : $(JEMALLOC_STATICLIB)
+jemalloc : $(MALLOC_STATICLIB)
 
 # skynet
 
@@ -50,8 +53,8 @@ all : \
   $(foreach v, $(CSERVICE), $(CSERVICE_PATH)/$(v).so) \
   $(foreach v, $(LUA_CLIB), $(LUA_CLIB_PATH)/$(v).so) 
 
-$(SKYNET_BUILD_PATH)/skynet : $(foreach v, $(SKYNET_SRC), skynet-src/$(v)) $(LUA_LIB) $(JEMALLOC_STATICLIB)
-	$(CC) $(CFLAGS) -o $@ $^ -Iskynet-src -I$(JEMALLOC_INC) $(LDFLAGS) $(EXPORT) $(LIBS)
+$(SKYNET_BUILD_PATH)/skynet : $(foreach v, $(SKYNET_SRC), skynet-src/$(v)) $(LUA_LIB) $(MALLOC_STATICLIB)
+	$(CC) $(CFLAGS) -o $@ $^ -Iskynet-src -I$(JEMALLOC_INC) $(LDFLAGS) $(EXPORT) $(SKYNET_LIBS) 
 
 $(LUA_CLIB_PATH) :
 	mkdir $(LUA_CLIB_PATH)

lualib/mongo.lua

@@ -39,9 +39,7 @@ local client_meta = {
 
 		return "[mongo client : " .. self.host .. port_string .."]"
 	end,
-	__gc = function(self)
-		self:disconnect()
-	end
+	-- DO NOT need disconnect, because channel will shutdown during gc
 }
 
 local mongo_db = {}

lualib/redis.lua

@@ -9,9 +9,7 @@ local redis = {}
 local command = {}
 local meta = {
 	__index = command,
-	__gc = function(self)
-		self[1]:close()
-	end,
+	-- DO NOT close channel in __gc
 }
 
 ---------- redis response

lualib/socket.lua

@@ -30,6 +30,11 @@ local function suspend(s)
 	assert(not s.co)
 	s.co = coroutine.running()
 	skynet.wait()
+	-- wakeup closing corouting every time suspend,
+	-- because socket.close() will wait last socket buffer operation before clear the buffer.
+	if s.closing then
+		skynet.wakeup(s.closing)
+	end
 end
 
 -- read skynet_socket.h for these macro
@@ -37,7 +42,7 @@ end
 socket_message[1] = function(id, size, data)
 	local s = socket_pool[id]
 	if s == nil then
-		print("socket: drop package from " .. id)
+		skynet.error("socket: drop package from " .. id)
 		driver.drop(data, size)
 		return
 	end
@@ -95,13 +100,14 @@ end
 socket_message[5] = function(id)
 	local s = socket_pool[id]
 	if s == nil then
-		print("socket: error on unknown", id)
+		skynet.error("socket: error on unknown", id)
 		return
 	end
 	if s.connected then
-		print("socket: error on", id)
+		skynet.error("socket: error on", id)
 	end
 	s.connected = false
+
 	wakeup(s)
 end
 
@@ -175,7 +181,8 @@ function socket.close(id)
 		-- notice: call socket.close in __gc should be carefully,
 		-- because skynet.wait never return in __gc, so driver.clear may not be called
 		if s.co then
-			-- reading this socket on another coroutine
+			-- reading this socket on another coroutine, so don't shutdown (clear the buffer) immediatel
+			-- wait reading coroutine read the buffer.
 			assert(not s.closing)
 			s.closing = coroutine.running()
 			skynet.wait()
@@ -189,13 +196,6 @@ function socket.close(id)
 	socket_pool[id] = nil
 end
 
-local function close_socket(s)
-	if s.closing then
-		skynet.wakeup(s.closing)
-	end
-	return driver.readall(s.buffer, buffer_pool)
-end
-
 function socket.read(id, sz)
 	local s = socket_pool[id]
 	assert(s)
@@ -204,7 +204,7 @@ function socket.read(id, sz)
 		return ret
 	end
 	if not s.connected then
-		return false, close_socket(s)
+		return false, driver.readall(s.buffer, buffer_pool)
 	end
 
 	assert(not s.read_required)
@@ -214,7 +214,7 @@ function socket.read(id, sz)
 	if ret then
 		return ret
 	else
-		return false, close_socket(s)
+		return false, driver.readall(s.buffer, buffer_pool)
 	end
 end
 
@@ -222,14 +222,14 @@ function socket.readall(id)
 	local s = socket_pool[id]
 	assert(s)
 	if not s.connected then
-		local r = close_socket(s)
+		local r = driver.readall(s.buffer, buffer_pool)
 		return r ~= "" and r
 	end
 	assert(not s.read_required)
 	s.read_required = true
 	suspend(s)
 	assert(s.connected == false)
-	return close_socket(s)
+	return driver.readall(s.buffer, buffer_pool)
 end
 
 function socket.readline(id, sep)
@@ -241,7 +241,7 @@ function socket.readline(id, sep)
 		return ret
 	end
 	if not s.connected then
-		return false, close_socket(s)
+		return false, driver.readall(s.buffer, buffer_pool)
 	end
 	assert(not s.read_required)
 	s.read_required = sep
@@ -249,7 +249,7 @@ function socket.readline(id, sep)
 	if s.connected then
 		return driver.readline(s.buffer, buffer_pool, sep)
 	else
-		return false, close_socket(s)
+		return false, driver.readall(s.buffer, buffer_pool)
 	end
 end
 
@@ -261,9 +261,6 @@ function socket.block(id)
 	assert(not s.read_required)
 	s.read_required = 0
 	suspend(s)
-	if not s.connected and s.closing then
-		skynet.wakeup(s.closing)
-	end
 	return s.connected
 end
 

lualib/socketchannel.lua

@@ -27,8 +27,8 @@ function socket_channel.channel(desc)
 		__host = assert(desc.host),
 		__port = assert(desc.port),
 		__auth = desc.auth,
-		__response = desc.response,
-		__request = {},	-- request seq { response func or session }
+		__response = desc.response,	-- It's for session mode
+		__request = {},	-- request seq { response func or session }	-- It's for order mode
 		__thread = {}, -- coroutine seq or session->coroutine map
 		__result = {}, -- response result { coroutine -> result }
 		__result_data = {},
@@ -51,72 +51,101 @@ local function close_channel_socket(self)
 end
 
 local function wakeup_all(self, errmsg)
-	for i = 1, #self.__thread do
-		local co = self.__thread[i]
-		self.__thread[i] = nil
-		self.__result[co] = socket_error
-		self.__result_data[co] = errmsg
-		skynet.wakeup(co)
+	if self.__response then
+		for k,co in pairs(self.__thread) do
+			self.__thread[k] = nil
+			self.__result[co] = socket_error
+			self.__result_data[co] = errmsg
+			skynet.wakeup(co)
+		end
+	else
+		for i = 1, #self.__request do
+			self.__request[i] = nil
+		end
+		for i = 1, #self.__thread do
+			local co = self.__thread[i]
+			self.__thread[i] = nil
+			self.__result[co] = socket_error
+			self.__result_data[co] = errmsg
+			skynet.wakeup(co)
+		end
 	end
 end
 
-local function dispatch_response(self)
+
+
+local function dispatch_by_session(self)
 	local response = self.__response
-	if response then
-		-- response() return session
-		while self.__sock do
-			local ok , session, result_ok, result_data = pcall(response, self.__sock)
-			if ok and session then
-				local co = self.__thread[session]
-				self.__thread[session] = nil
-				if co then
-					self.__result[co] = result_ok
-					self.__result_data[co] = result_data
-					skynet.wakeup(co)
-				else
-					print("socket: unknown session :", session)
-				end
+	-- response() return session
+	while self.__sock do
+		local ok , session, result_ok, result_data = pcall(response, self.__sock)
+		if ok and session then
+			local co = self.__thread[session]
+			self.__thread[session] = nil
+			if co then
+				self.__result[co] = result_ok
+				self.__result_data[co] = result_data
+				skynet.wakeup(co)
+			else
+				skynet.error("socket: unknown session :", session)
+			end
+		else
+			close_channel_socket(self)
+			local errormsg
+			if session ~= socket_error then
+				errormsg = session
+			end
+			wakeup_all(self, errormsg)
+		end
+	end
+end
+
+local function pop_response(self)
+	return table.remove(self.__request, 1), table.remove(self.__thread, 1)
+end
+
+local function push_response(self, response, co)
+	if self.__response then
+		-- response is session
+		self.__thread[response] = co
+	else
+		-- response is a function, push it to __request
+		table.insert(self.__request, response)
+		table.insert(self.__thread, co)
+	end
+end
+
+local function dispatch_by_order(self)
+	while self.__sock do
+		local func, co = pop_response(self)
+		if func == nil then
+			if not socket.block(self.__sock[1]) then
+				close_channel_socket(self)
+				wakeup_all(self)
+			end
+		else
+			local ok, result_ok, result_data = pcall(func, self.__sock)
+			if ok then
+				self.__result[co] = result_ok
+				self.__result_data[co] = result_data
+				skynet.wakeup(co)
 			else
 				close_channel_socket(self)
-				local errormsg
-				if session ~= socket_error then
-					errormsg = session
-				end
-				for k,co in pairs(self.__thread) do
-					-- throw error (errormsg)
-					self.__thread[k] = nil
-					self.__result[co] = socket_error
-					self.__result_data[co] = errormsg
-					skynet.wakeup(co)
+				local errmsg
+				if result ~= socket_error then
+					errmsg = result_ok
 				end
+				wakeup_all(self, errmsg)
 			end
 		end
+	end
+end
+
+local function dispatch_function(self)
+	if self.__response then
+		return dispatch_by_session
 	else
-		-- pop response function from __request
-		while self.__sock do
-			local func = table.remove(self.__request, 1)
-			if func == nil then
-				if not socket.block(self.__sock[1]) then
-					close_channel_socket(self)
-					wakeup_all(self)
-				end
-			else
-				local ok, result_ok, result_data = pcall(func, self.__sock)
-				if ok then
-					local co = table.remove(self.__thread, 1)
-					self.__result[co] = result_ok
-					self.__result_data[co] = result_data
-					skynet.wakeup(co)
-				else
-					close_channel_socket(self)
-					local errmsg
-					if result ~= socket_error then
-						errmsg = result_ok
-					end
-					wakeup_all(self, errmsg)
-				end
-			end
-		end
+		return dispatch_by_order
 	end
 end
 
@@ -128,14 +157,14 @@ local function connect_once(self)
 	end
 	self.__authcoroutine = coroutine.running()
 	self.__sock = setmetatable( {fd} , channel_socket_meta )
-	skynet.fork(dispatch_response, self)
+	skynet.fork(dispatch_function(self), self)
 
 	if self.__auth then
 		local ok , message = pcall(self.__auth, self)
 		if not ok then
 			close_channel_socket(self)
 			if message ~= socket_error then
-				print("socket: auth failed", message)
+				skynet.error("socket: auth failed", message)
 			end
 		end
 		self.__authcoroutine = false
@@ -150,12 +179,15 @@ local function try_connect(self , once)
 	local t = 100
 	while not self.__closed do
 		if connect_once(self) then
+			if not once then
+				skynet.error("socket: connect to", self.__host, self.__port)
+			end
 			return
 		elseif once then
 			error(string.format("Connect to %s:%d failed", self.__host, self.__port))
 		end
 		if t > 1000 then
-			print("socket: try to reconnect", self.__host, self.__port)
+			skynet.error("socket: try to reconnect", self.__host, self.__port)
 			skynet.sleep(t)
 			t = 0
 		else
@@ -179,6 +211,7 @@ local function block_connect(self, once)
 	if self.__closed then
 		return false
 	end
+
 	if #self.__connecting > 0 then
 		-- connecting in other coroutine
 		local co = coroutine.running()
@@ -187,7 +220,6 @@ local function block_connect(self, once)
 		-- check connection again
 		return block_connect(self, once)
 	end
-
 	self.__connecting[1] = true
 	try_connect(self, once)
 	self.__connecting[1] = nil
@@ -209,10 +241,30 @@ function channel:connect(once)
 	return block_connect(self, once)
 end
 
+local function wait_for_response(self, response)
+	local co = coroutine.running()
+	push_response(self, response, co)
+	skynet.wait()
+
+	local result = self.__result[co]
+	self.__result[co] = nil
+	local result_data = self.__result_data[co]
+	self.__result_data[co] = nil
+
+	if result == socket_error then
+		error(socket_error)
+	else
+		assert(result, result_data)
+		return result_data
+	end
+end
+
 function channel:request(request, response)
 	assert(block_connect(self))
 
 	if not socket.write(self.__sock[1], request) then
+		close_channel_socket(self)
+		wakeup_all(self)
 		error(socket_error)
 	end
 
@@ -221,59 +273,13 @@ function channel:request(request, response)
 		return
 	end
 
-	local co = coroutine.running()
-
-	if self.__response then
-		-- response is session
-		self.__thread[response] = co
-	else
-		-- response is a function, push it to __request
-		table.insert(self.__request, response)
-		table.insert(self.__thread, co)
-	end
-	skynet.wait()
-
-	local result = self.__result[co]
-	self.__result[co] = nil
-	local result_data = self.__result_data[co]
-	self.__result_data[co] = nil
-
-	if result == socket_error then
-		if result_data then
-			print("socket: dispatch", request, result_data)
-		end
-		error(socket_error)
-	else
-		assert(result, result_data)
-		return result_data
-	end
+	return wait_for_response(self, response)
 end
 
 function channel:response(response)
 	assert(block_connect(self))
 
-	assert(type(response) == "function")
-
-	local co = coroutine.running()
-	table.insert(self.__request, response)
-	table.insert(self.__thread, co)
-
-	skynet.wait()
-
-	local result = self.__result[co]
-	self.__result[co] = nil
-	local result_data = self.__result_data[co]
-	self.__result_data[co] = nil
-
-	if result == socket_error then
-		if result_data then
-			print("socket: dispatch", request, result_data)
-		end
-		error(socket_error)
-	else
-		assert(result, result_data)
-		return result_data
-	end
+	return wait_for_response(self, response)
 end
 
 function channel:close()

platform.mk

@@ -5,30 +5,37 @@ CC ?= gcc
 
 .PHONY : none $(PLATS) clean all cleanall
 
-ifneq ($(PLAT), none)
+#ifneq ($(PLAT), none)
 
 .PHONY : default
 
 default :
 	$(MAKE) $(PLAT)
 
-endif
+#endif
 
 none :
 	@echo "Please do 'make PLATFORM' where PLATFORM is one of these:"
 	@echo "   $(PLATS)"
 
-LIBS := -lpthread -lm
+SKYNET_LIBS := -lpthread -lm
 SHARED := -fPIC --shared
 EXPORT := -Wl,-E
 
-$(PLATS) : all 
-
 linux : PLAT = linux
 macosx : PLAT = macosx
 freebsd : PLAT = freebsd
 
-macosx linux : LIBS += -ldl
 macosx : SHARED := -fPIC -dynamiclib -Wl,-undefined,dynamic_lookup
 macosx : EXPORT :=
-linux freebsd : LIBS += -lrt
+macosx linux : SKYNET_LIBS += -ldl
+linux freebsd : SKYNET_LIBS += -lrt
+
+# Turn off jemalloc and malloc hook on macosx
+
+macosx : MALLOC_STATICLIB :=
+macosx : SKYNET_DEFINES :=-DNOUSE_JEMALLOC
+
+
+linux macosx freebsd :
+	$(MAKE) all PLAT=$@ SKYNET_LIBS="$(SKYNET_LIBS)" SHARED="$(SHARED)" EXPORT="$(EXPORT)" MALLOC_STATICLIB="$(MALLOC_STATICLIB)" SKYNET_DEFINES="$(SKYNET_DEFINES)"

skynet-src/malloc_hook.c

@@ -1,18 +1,16 @@
 #include <stdio.h>
 #include <string.h>
 #include <assert.h>
+#include <stdlib.h>
 
 #include "malloc_hook.h"
-#include "jemalloc.h"
-
 #include "skynet.h"
 
-
 static size_t _used_memory = 0;
 static size_t _memory_block = 0;
 typedef struct _mem_data {
-    uint32_t handle;
-    ssize_t allocated;
+	uint32_t handle;
+	ssize_t allocated;
 } mem_data;
 
 #define SLOT_SIZE 0x10000
@@ -20,13 +18,18 @@ typedef struct _mem_data {
 
 static mem_data mem_stats[SLOT_SIZE];
 
+
+#ifndef NOUSE_JEMALLOC
+
+#include "jemalloc.h"
+
 static ssize_t*
 get_allocated_field(uint32_t handle) {
-    int h = (int)(handle & (SLOT_SIZE - 1));
-    mem_data *data = &mem_stats[h];
+	int h = (int)(handle & (SLOT_SIZE - 1));
+	mem_data *data = &mem_stats[h];
 	uint32_t old_handle = data->handle;
 	ssize_t old_alloc = data->allocated;
-    if(old_handle == 0 || old_alloc <= 0) {
+	if(old_handle == 0 || old_alloc <= 0) {
 		// data->allocated may less than zero, because it may not count at start.
 		if(!__sync_bool_compare_and_swap(&data->handle, old_handle, handle)) {
 			return 0;
@@ -34,150 +37,174 @@ get_allocated_field(uint32_t handle) {
 		if (old_alloc < 0) {
 			__sync_bool_compare_and_swap(&data->allocated, old_alloc, 0);
 		}
-    }
-    if(data->handle != handle) {
-        return 0;
-    }
-    return &data->allocated;
+	}
+	if(data->handle != handle) {
+		return 0;
+	}
+	return &data->allocated;
 }
 
 inline static void 
 update_xmalloc_stat_alloc(uint32_t handle, size_t __n) {
-    __sync_add_and_fetch(&_used_memory, __n);
-    __sync_add_and_fetch(&_memory_block, 1); 
-    ssize_t* allocated = get_allocated_field(handle);
-    if(allocated) {
-        __sync_add_and_fetch(allocated, __n);
-    }
+	__sync_add_and_fetch(&_used_memory, __n);
+	__sync_add_and_fetch(&_memory_block, 1); 
+	ssize_t* allocated = get_allocated_field(handle);
+	if(allocated) {
+		__sync_add_and_fetch(allocated, __n);
+	}
 }
 
 inline static void
 update_xmalloc_stat_free(uint32_t handle, size_t __n) {
-    __sync_sub_and_fetch(&_used_memory, __n);
-    __sync_sub_and_fetch(&_memory_block, 1);
-    ssize_t* allocated = get_allocated_field(handle);
-    if(allocated) {
-        __sync_sub_and_fetch(allocated, __n);
-    }
+	__sync_sub_and_fetch(&_used_memory, __n);
+	__sync_sub_and_fetch(&_memory_block, 1);
+	ssize_t* allocated = get_allocated_field(handle);
+	if(allocated) {
+		__sync_sub_and_fetch(allocated, __n);
+	}
 }
 
 inline static void*
 fill_prefix(char* ptr) {
-    uint32_t handle = skynet_current_handle();
-    size_t size = je_malloc_usable_size(ptr);
-    uint32_t *p = (uint32_t *)(ptr + size - sizeof(uint32_t));
-    memcpy(p, &handle, sizeof(handle));
+	uint32_t handle = skynet_current_handle();
+	size_t size = je_malloc_usable_size(ptr);
+	uint32_t *p = (uint32_t *)(ptr + size - sizeof(uint32_t));
+	memcpy(p, &handle, sizeof(handle));
 
 	update_xmalloc_stat_alloc(handle, size);
-    return ptr;
+	return ptr;
 }
 
 inline static void*
 clean_prefix(char* ptr) {
-    size_t size = je_malloc_usable_size(ptr);
-    uint32_t *p = (uint32_t *)(ptr + size - sizeof(uint32_t));
-    uint32_t handle;
-    memcpy(&handle, p, sizeof(handle));
-    update_xmalloc_stat_free(handle, size);
-    return ptr;
+	size_t size = je_malloc_usable_size(ptr);
+	uint32_t *p = (uint32_t *)(ptr + size - sizeof(uint32_t));
+	uint32_t handle;
+	memcpy(&handle, p, sizeof(handle));
+	update_xmalloc_stat_free(handle, size);
+	return ptr;
 }
 
 static void malloc_oom(size_t size) {
-    fprintf(stderr, "xmalloc: Out of memory trying to allocate %zu bytes\n",
-        size);
-    fflush(stderr);
-    abort();
+	fprintf(stderr, "xmalloc: Out of memory trying to allocate %zu bytes\n",
+		size);
+	fflush(stderr);
+	abort();
 }
 
-size_t
-malloc_used_memory(void) {
-    return _used_memory;
+void 
+memory_info_dump(void) {
+	je_malloc_stats_print(0,0,0);
 }
 
-size_t
-malloc_memory_block(void) {
-    return _memory_block;
+size_t 
+mallctl_int64(const char* name, size_t* newval) {
+	size_t v = 0;
+	size_t len = sizeof(v);
+	if(newval) {
+		je_mallctl(name, &v, &len, newval, sizeof(size_t));
+	} else {
+		je_mallctl(name, &v, &len, NULL, 0);
+	}
+	// printf("name: %s, value: %zd\n", name, v);
+	return v;
 }
 
-void memory_info_dump(void) {
-    je_malloc_stats_print(0,0,0);
+int 
+mallctl_opt(const char* name, int* newval) {
+	int v = 0;
+	size_t len = sizeof(v);
+	if(newval) {
+		int ret = je_mallctl(name, &v, &len, newval, sizeof(int));
+		if(ret == 0) {
+			printf("set new value(%d) for (%s) succeed\n", *newval, name);
+		} else {
+			printf("set new value(%d) for (%s) failed: error -> %d\n", *newval, name, ret);
+		}
+	} else {
+		je_mallctl(name, &v, &len, NULL, 0);
+	}
+
+	return v;
 }
 
-size_t mallctl_int64(const char* name, size_t* newval) {
-    size_t v = 0;
-    size_t len = sizeof(v);
-    if(newval) {
-        je_mallctl(name, &v, &len, newval, sizeof(size_t));
-    } else {
-        je_mallctl(name, &v, &len, NULL, 0);
-    }
-    // printf("name: %s, value: %zd\n", name, v);
-    return v;
-}
-
-int mallctl_opt(const char* name, int* newval) {
-    int    v   = 0;
-    size_t len = sizeof(v);
-    if(newval) {
-        int ret = je_mallctl(name, &v, &len, newval, sizeof(int));
-        if(ret == 0) {
-            printf("set new value(%d) for (%s) succeed\n", *newval, name);
-        } else {
-            printf("set new value(%d) for (%s) failed: error -> %d\n", *newval, name, ret);
-        }
-    } else {
-        je_mallctl(name, &v, &len, NULL, 0);
-    }
-
-    return v;
-}
-
-void
-dump_c_mem() {
-    int i;
-    size_t total = 0;
-    printf("dump all service mem:\n");
-    for(i=0; i<SLOT_SIZE; i++) {
-        mem_data* data = &mem_stats[i];
-        if(data->handle != 0 && data->allocated != 0) {
-            total += data->allocated;
-            printf("0x%x -> %zdkb\n", data->handle, data->allocated >> 10);
-        }
-    }
-    printf("+total: %zdkb\n",total >> 10);
-}
-
-// hook : malloc, realloc, memalign, free, calloc
+// hook : malloc, realloc, free, calloc
 
 void *
 skynet_malloc(size_t size) {
-    void* ptr = je_malloc(size + PREFIX_SIZE);
-    if(!ptr) malloc_oom(size);
-    return fill_prefix(ptr);
+	void* ptr = je_malloc(size + PREFIX_SIZE);
+	if(!ptr) malloc_oom(size);
+	return fill_prefix(ptr);
 }
 
 void *
 skynet_realloc(void *ptr, size_t size) {
-    if (ptr == NULL) return skynet_malloc(size);
+	if (ptr == NULL) return skynet_malloc(size);
 
-    void* rawptr = clean_prefix(ptr);
-    void *newptr = je_realloc(rawptr, size+PREFIX_SIZE);
-    if(!newptr) malloc_oom(size);
-    return fill_prefix(newptr);
+	void* rawptr = clean_prefix(ptr);
+	void *newptr = je_realloc(rawptr, size+PREFIX_SIZE);
+	if(!newptr) malloc_oom(size);
+	return fill_prefix(newptr);
 }
 
 void
 skynet_free(void *ptr) {
-    if (ptr == NULL) return;
-    void* rawptr = clean_prefix(ptr);
-    je_free(rawptr);
+	if (ptr == NULL) return;
+	void* rawptr = clean_prefix(ptr);
+	je_free(rawptr);
 }
 
 void *
 skynet_calloc(size_t nmemb,size_t size) {
-    void* ptr = je_calloc(nmemb + ((PREFIX_SIZE+size-1)/size), size );
-    if(!ptr) malloc_oom(size);
-    return fill_prefix(ptr);
+	void* ptr = je_calloc(nmemb + ((PREFIX_SIZE+size-1)/size), size );
+	if(!ptr) malloc_oom(size);
+	return fill_prefix(ptr);
+}
+
+#else
+
+void 
+memory_info_dump(void) {
+	skynet_error(NULL, "No jemalloc");
+}
+
+size_t 
+mallctl_int64(const char* name, size_t* newval) {
+	skynet_error(NULL, "No jemalloc : mallctl_int64 %s.", name);
+	return 0;
+}
+
+int 
+mallctl_opt(const char* name, int* newval) {
+	skynet_error(NULL, "No jemalloc : mallctl_opt %s.", name);
+	return 0;
+}
+
+#endif
+
+size_t
+malloc_used_memory(void) {
+	return _used_memory;
+}
+
+size_t
+malloc_memory_block(void) {
+	return _memory_block;
+}
+
+void
+dump_c_mem() {
+	int i;
+	size_t total = 0;
+	printf("dump all service mem:\n");
+	for(i=0; i<SLOT_SIZE; i++) {
+		mem_data* data = &mem_stats[i];
+		if(data->handle != 0 && data->allocated != 0) {
+			total += data->allocated;
+			printf("0x%x -> %zdkb\n", data->handle, data->allocated >> 10);
+		}
+	}
+	printf("+total: %zdkb\n",total >> 10);
 }
 
 char *
@@ -198,3 +225,8 @@ skynet_lalloc(void *ud, void *ptr, size_t osize, size_t nsize) {
 	}
 }
 
+void
+malloc_inithook(void) {
+	memset(mem_stats, 0, sizeof(mem_stats));
+}
+

skynet-src/skynet_malloc.h

@@ -3,12 +3,12 @@
 
 #include <stddef.h>
 
-#ifdef SKYNET_MALLOC_RENAME
+#ifdef NOUSE_JEMALLOC
 
-#define malloc skynet_malloc
-#define calloc skynet_calloc
-#define realloc skynet_realloc
-#define free skynet_free
+#define skynet_malloc malloc
+#define skynet_calloc calloc
+#define skynet_realloc realloc
+#define skynet_free free
 
 #endif