version 1.17.4.5, 2013/08/21 12:59:12
|
version 1.17.4.7, 2013/08/21 13:02:33
|
Line 494 rxUDPPacket(sched_task_t *task)
|
Line 494 rxUDPPacket(sched_task_t *task)
|
socklen_t salen; |
socklen_t salen; |
struct timespec ts = { DEF_RPC_TIMEOUT, 0 }; |
struct timespec ts = { DEF_RPC_TIMEOUT, 0 }; |
|
|
memset(buf, 0, AIT_LEN(bufz)); |
|
memset(&rpcbuf, 0, sizeof rpcbuf); |
memset(&rpcbuf, 0, sizeof rpcbuf); |
|
|
/* receive connect packet */ |
/* receive connect packet */ |
Line 609 static void *
|
Line 608 static void *
|
txBLOB(sched_task_t *task) |
txBLOB(sched_task_t *task) |
{ |
{ |
rpc_cli_t *c = TASK_ARG(task); |
rpc_cli_t *c = TASK_ARG(task); |
u_char *buf = AIT_GET_BUF(&c->cli_buf); | u_char *buf = AIT_GET_BUF(array(c->cli_buf, 0, ait_val_t*)); |
int wlen = sizeof(struct tagBLOBHdr); |
int wlen = sizeof(struct tagBLOBHdr); |
|
|
/* send reply */ |
/* send reply */ |
Line 701 rxBLOB(sched_task_t *task)
|
Line 700 rxBLOB(sched_task_t *task)
|
} |
} |
|
|
end: |
end: |
memcpy(AIT_ADDR(&c->cli_buf), &blob, sizeof blob); | memcpy(AIT_ADDR(array(c->cli_buf, 0, ait_val_t*)), &blob, sizeof blob); |
schedWrite(TASK_ROOT(task), txBLOB, TASK_ARG(task), TASK_FD(task), NULL, 0); |
schedWrite(TASK_ROOT(task), txBLOB, TASK_ARG(task), TASK_FD(task), NULL, 0); |
schedReadSelf(task); |
schedReadSelf(task); |
return NULL; |
return NULL; |