mirror of https://github.com/m-labs/artiq.git
parent
ef2af8c331
commit
ef8f60c78d
|
@ -475,7 +475,6 @@ void send_rpc(int service, const char *tag, ...)
|
||||||
{
|
{
|
||||||
struct msg_rpc_send request;
|
struct msg_rpc_send request;
|
||||||
|
|
||||||
request.now = now;
|
|
||||||
if(service != 0)
|
if(service != 0)
|
||||||
request.type = MESSAGE_TYPE_RPC_SEND;
|
request.type = MESSAGE_TYPE_RPC_SEND;
|
||||||
else
|
else
|
||||||
|
|
|
@ -87,7 +87,6 @@ struct msg_watchdog_clear {
|
||||||
|
|
||||||
struct msg_rpc_send {
|
struct msg_rpc_send {
|
||||||
int type;
|
int type;
|
||||||
long long int now;
|
|
||||||
int service;
|
int service;
|
||||||
const char *tag;
|
const char *tag;
|
||||||
va_list args;
|
va_list args;
|
||||||
|
|
|
@ -983,12 +983,6 @@ static int process_kmsg(struct msg_base *umsg)
|
||||||
case MESSAGE_TYPE_RPC_BATCH: {
|
case MESSAGE_TYPE_RPC_BATCH: {
|
||||||
struct msg_rpc_send *msg = (struct msg_rpc_send *)umsg;
|
struct msg_rpc_send *msg = (struct msg_rpc_send *)umsg;
|
||||||
|
|
||||||
/*
|
|
||||||
* save now in case the RPC stops the kernel
|
|
||||||
* (e.g. pause with preemption)
|
|
||||||
*/
|
|
||||||
now = msg->now;
|
|
||||||
|
|
||||||
if(!send_rpc_request(msg->service, msg->tag, msg->args)) {
|
if(!send_rpc_request(msg->service, msg->tag, msg->args)) {
|
||||||
core_log("Failed to send RPC request (service %d, tag %s)\n",
|
core_log("Failed to send RPC request (service %d, tag %s)\n",
|
||||||
msg->service, msg->tag);
|
msg->service, msg->tag);
|
||||||
|
|
Loading…
Reference in New Issue