lihao/skynet
1
0
Fork 0
mirror of https://github.com/cloudwu/skynet.git synced 2026-07-24 20:23:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

add assert

Browse Source
This commit is contained in:
云风
2012-09-17 21:43:53 +08:00
parent e8104199de
commit 1aa89d8672
2 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
lualib-src/lua-skynet.c
View File

@@ -198,6 +198,9 @@ _sendname(lua_State *L, struct skynet_context * context, const char * dest) {
default: default:
luaL_error(L, "skynet.send invalid param %s", lua_type(L,4)); luaL_error(L, "skynet.send invalid param %s", lua_type(L,4));
} }
if (session < 0) {
luaL_error(L, "skynet.send session (%d) < 0", session);
}
lua_pushinteger(L,session); lua_pushinteger(L,session);
return 1; return 1;
} }
@@ -266,6 +269,9 @@ _send(lua_State *L) {
default: default:
luaL_error(L, "skynet.send invalid param %s", lua_type(L,4)); luaL_error(L, "skynet.send invalid param %s", lua_type(L,4));
} }
if (session < 0) {
luaL_error(L, "skynet.send session (%d) < 0", session);
}
lua_pushinteger(L,session); lua_pushinteger(L,session);
return 1; return 1;
} }

4
lualib-src/trace_service.c
View File

@@ -87,7 +87,7 @@ trace_register(struct trace_pool *p, int session) {
return; return;
} }
int hash = session % HASH_SIZE; int hash = session % HASH_SIZE;
assert(t->session == 0 && session !=0); assert(t->session == 0 && session > 0);
t->session = session; t->session = session;
t->prev = NULL; t->prev = NULL;
t->next = p->slot[hash]; t->next = p->slot[hash];
@@ -114,7 +114,7 @@ trace_yield(struct trace_pool *p) {
void void
trace_switch(struct trace_pool *p, int session) { trace_switch(struct trace_pool *p, int session) {
assert(p->current == NULL); assert(p->current == NULL && session > 0);
struct trace_info *t = p->slot[session % HASH_SIZE]; struct trace_info *t = p->slot[session % HASH_SIZE];
struct trace_info *prev = NULL; struct trace_info *prev = NULL;
while (t) { while (t) {