|
|
| 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); |