version 1.17.4.5, 2013/08/21 12:59:12
|
version 1.17.4.6, 2013/08/21 13:01:44
|
Line 609 static void *
|
Line 609 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 701 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; |