| version 1.1.2.4, 2011/12/01 08:15:25 | version 1.1.2.6, 2011/12/01 14:41:11 | 
| Line 1 | Line 1 | 
 | #include "global.h" | #include "global.h" | 
 |  |  | 
 |  |  | 
| static int | static void * | 
| startSession(int s, const char *csAddr) | startSession(sched_task_t *task) | 
 | { | { | 
| return 0; | mqtt_msg_t *buf; | 
|  | mqtt_cb_t cbs[MQTT_TYPE_MAX + 1] = { 0 }; | 
|  | int ret = 0; | 
|  |  | 
|  | FTRACE(4); | 
|  |  | 
|  | buf = mqtt_msgAlloc(USHRT_MAX); | 
|  | if (!buf) { | 
|  | syslog(LOG_ERR, "Error:: allocate message buf (%d) #%d - %s", (int) TASK_FD(task), | 
|  | mqtt_GetErrno(), mqtt_GetError()); | 
|  | goto end; | 
|  | } | 
|  |  | 
|  | if (recv(TASK_FD(task), buf->msg_base, buf->msg_len, 0) == -1) { | 
|  | syslog(LOG_ERR, "Error:: recv(%d) #%d - %s", (int) TASK_FD(task), | 
|  | errno, strerror(errno)); | 
|  | mqtt_msgFree(&buf, 42); | 
|  | goto end; | 
|  | } | 
|  |  | 
|  | ret = mqttDispatcher(cbs, buf); | 
|  |  | 
|  | mqtt_msgFree(&buf, 42); | 
|  |  | 
|  | switch (ret) { | 
|  | case -1: | 
|  | syslog(LOG_ERR, "Error:: in MQTT protocol #%d - %s", mqtt_GetErrno(), mqtt_GetError()); | 
|  | break; | 
|  | default: | 
|  | return NULL; | 
|  | } | 
|  | end:    /* close client connection */ | 
|  | close(TASK_FD(task)); | 
|  | VERB(1) syslog(LOG_DEBUG, "Close client %s with socket=%d", | 
|  | (char*) TASK_ARG(task), (int) TASK_FD(task)); | 
|  | if (TASK_ARG(task)) | 
|  | free(TASK_ARG(task)); | 
|  | return NULL; | 
 | } | } | 
 |  |  | 
 | /* ----------------------------------------------------------------------- */ | /* ----------------------------------------------------------------------- */ | 
 |  |  | 
 |  | static void * | 
 |  | thrSched(void *arg __unused) | 
 |  | { | 
 |  | FTRACE(1); | 
 |  |  | 
 |  | schedRun(root, (intptr_t*) &Kill); | 
 |  | pthread_exit(NULL); | 
 |  | } | 
 |  |  | 
 | int | int | 
 | Run(int sock) | Run(int sock) | 
 | { | { | 
 | io_sockaddr_t sa; | io_sockaddr_t sa; | 
 | socklen_t sslen = sizeof sa.ss; | socklen_t sslen = sizeof sa.ss; | 
 | int cli; | int cli; | 
| char szAddr[STRSIZ] = { 0 }; | char *str = NULL, szAddr[STRSIZ] = { 0 }; | 
|  | pthread_t tid; | 
 |  |  | 
 | FTRACE(1); | FTRACE(1); | 
 |  |  | 
 |  | if (pthread_create(&tid, NULL, thrSched, NULL)) { | 
 |  | syslog(LOG_ERR, "Error:: thread scheduler #%d - %s", errno, strerror(errno)); | 
 |  | return -1; | 
 |  | } else | 
 |  | pthread_detach(tid); | 
 |  | VERB(2) syslog(LOG_DEBUG, "Run scheduler management thread"); | 
 |  |  | 
 | if (listen(sock, SOMAXCONN) == -1) { | if (listen(sock, SOMAXCONN) == -1) { | 
 | syslog(LOG_ERR, "Error:: listen(%d) #%d - %s\n", sock, errno, strerror(errno)); | syslog(LOG_ERR, "Error:: listen(%d) #%d - %s\n", sock, errno, strerror(errno)); | 
 |  | pthread_cancel(tid); | 
 | return -1; | return -1; | 
 | } | } | 
 |  |  | 
| Line 50  Run(int sock) | Line 105  Run(int sock) | 
 | sa.sa.sa_family); | sa.sa.sa_family); | 
 | continue; | continue; | 
 | } | } | 
| syslog(LOG_DEBUG, "Connected client with socket=%d from %s", cli, szAddr); | str = strdup(szAddr); | 
|  | syslog(LOG_DEBUG, "Connected client with socket=%d from %s", cli, str); | 
 | } | } | 
 |  |  | 
| if (startSession(cli, szAddr)) { | if (!schedRead(root, startSession, str, cli)) { | 
 | close(cli); | close(cli); | 
 | VERB(1) syslog(LOG_DEBUG, "Terminated client with socket=%d", cli); | VERB(1) syslog(LOG_DEBUG, "Terminated client with socket=%d", cli); | 
| continue; | if (str) | 
|  | free(str); | 
 | } | } | 
 | } | } | 
 |  |  |