version 1.12.2.8, 2012/11/19 15:48:45
|
version 1.12.2.9, 2012/11/19 15:54:47
|
Line 525 end:
|
Line 525 end:
|
|
|
/* ------------------------------------------------------ */ |
/* ------------------------------------------------------ */ |
|
|
static void * | inline void |
closeBLOBClient(sched_task_t *task) | rpc_freeBLOBCli(rpc_cli_t * __restrict c) |
{ |
{ |
rpc_cli_t *c = TASK_ARG(task); |
|
rpc_srv_t *s = c->cli_parent; |
rpc_srv_t *s = c->cli_parent; |
|
|
schedCancelby(TASK_ROOT(task), taskMAX, CRITERIA_ARG, TASK_ARG(task), NULL); | schedCancelby(s->srv_blob.root, taskMAX, CRITERIA_ARG, c, NULL); |
|
|
/* close client socket */ |
|
if (TASK_VAL(task)) |
|
shutdown(c->cli_sock, SHUT_RDWR); |
|
close(c->cli_sock); |
|
|
|
/* free buffer */ |
/* free buffer */ |
AIT_FREE_VAL(&c->cli_buf); |
AIT_FREE_VAL(&c->cli_buf); |
|
|
io_arrayDel(s->srv_blob.clients, c->cli_id, 0); |
io_arrayDel(s->srv_blob.clients, c->cli_id, 0); |
if (c) |
if (c) |
io_free(c); |
io_free(c); |
|
} |
|
|
|
|
|
static void * |
|
closeBLOBClient(sched_task_t *task) |
|
{ |
|
int sock = ((rpc_cli_t*) TASK_ARG(task))->cli_sock; |
|
|
|
rpc_freeBLOBCli(TASK_ARG(task)); |
|
|
|
/* close client socket */ |
|
shutdown(sock, SHUT_RDWR); |
|
close(sock); |
return NULL; |
return NULL; |
} |
} |
|
|