version 1.2, 2012/01/27 15:05:38
|
version 1.2.2.1, 2012/01/27 15:18:12
|
Line 65 finiSession(struct tagSession *sess, int preservSock)
|
Line 65 finiSession(struct tagSession *sess, int preservSock)
|
while ((store = TAILQ_FIRST(&sess->sess_sndqueue))) { |
while ((store = TAILQ_FIRST(&sess->sess_sndqueue))) { |
TAILQ_REMOVE(&sess->sess_sndqueue, store, st_node); |
TAILQ_REMOVE(&sess->sess_sndqueue, store, st_node); |
|
|
if (store->st_subscr.sub_topic._base) | if (store->st_subscr.sub_topic.msg_base) |
free(store->st_subscr.sub_topic._base); | free(store->st_subscr.sub_topic.msg_base); |
if (store->st_subscr.sub_value._base) | if (store->st_subscr.sub_value.msg_base) |
free(store->st_subscr.sub_value._base); | free(store->st_subscr.sub_value.msg_base); |
|
|
free(store); |
free(store); |
} |
} |
Line 211 thrSession(struct tagSession *sess)
|
Line 211 thrSession(struct tagSession *sess)
|
while ((store = TAILQ_FIRST(&sess->sess_sndqueue))) { |
while ((store = TAILQ_FIRST(&sess->sess_sndqueue))) { |
TAILQ_REMOVE(&sess->sess_sndqueue, store, st_node); |
TAILQ_REMOVE(&sess->sess_sndqueue, store, st_node); |
|
|
if (store->st_subscr.sub_topic._base) | if (store->st_subscr.sub_topic.msg_base) |
free(store->st_subscr.sub_topic._base); | free(store->st_subscr.sub_topic.msg_base); |
if (store->st_subscr.sub_value._base) | if (store->st_subscr.sub_value.msg_base) |
free(store->st_subscr.sub_value._base); | free(store->st_subscr.sub_value.msg_base); |
|
|
free(store); |
free(store); |
} |
} |