version 1.5.2.1, 2013/01/18 10:17:22
|
version 1.5.2.2, 2013/07/16 14:34:58
|
Line 56 initSession(int sock, ait_val_t * __restrict v)
|
Line 56 initSession(int sock, ait_val_t * __restrict v)
|
struct tagSession *sess = NULL; |
struct tagSession *sess = NULL; |
const char *str; |
const char *str; |
|
|
ETRACE(5); | ETRACE(); |
|
|
if (!v) |
if (!v) |
return NULL; |
return NULL; |
Line 110 finiSession(struct tagSession *sess)
|
Line 110 finiSession(struct tagSession *sess)
|
{ |
{ |
struct tagStore *store; |
struct tagStore *store; |
|
|
ETRACE(5); | ETRACE(); |
|
|
if (!sess) |
if (!sess) |
return; |
return; |
Line 160 leaveClient(sched_task_t *task)
|
Line 160 leaveClient(sched_task_t *task)
|
struct tagSession *sess; |
struct tagSession *sess; |
int ret; |
int ret; |
|
|
ETRACE(4); | ETRACE(); |
|
|
assert(task); |
assert(task); |
|
|
Line 186 dispatchSession(sched_task_t *task)
|
Line 186 dispatchSession(sched_task_t *task)
|
int ret, len = 0; |
int ret, len = 0; |
struct tagSession *sess; |
struct tagSession *sess; |
|
|
ETRACE(2); | ETRACE(); |
|
|
assert(task); |
assert(task); |
|
|
Line 269 startSession(sched_task_t *task)
|
Line 269 startSession(sched_task_t *task)
|
struct timespec ts = { RETAIN_TIMEOUT, 0 }; |
struct timespec ts = { RETAIN_TIMEOUT, 0 }; |
intptr_t sock; |
intptr_t sock; |
|
|
ETRACE(4); | ETRACE(); |
|
|
assert(task); |
assert(task); |
|
|
Line 397 acceptClient(sched_task_t *task)
|
Line 397 acceptClient(sched_task_t *task)
|
ait_val_t *v; |
ait_val_t *v; |
char str[STRSIZ]; |
char str[STRSIZ]; |
|
|
ETRACE(4); | ETRACE(); |
|
|
assert(task); |
assert(task); |
|
|
Line 438 Run(int sock)
|
Line 438 Run(int sock)
|
struct tagSession *sess; |
struct tagSession *sess; |
struct timespec pl = { 0, 100000000 }; |
struct timespec pl = { 0, 100000000 }; |
|
|
ETRACE(1); | ETRACE(); |
|
|
if (mqtt_srv_Listen(sock, 0, 1) == -1) { |
if (mqtt_srv_Listen(sock, 0, 1) == -1) { |
ELIBERR(mqtt); |
ELIBERR(mqtt); |