artiq/soc/runtime/corecom_serial.c

198 lines
4.0 KiB
C
Raw Normal View History

2014-08-28 16:56:48 +08:00
#include <stdarg.h>
#include <crc.h>
#include <uart.h>
#include <generated/csr.h>
#include "corecom.h"
/* host to device */
2014-08-28 16:56:48 +08:00
enum {
MSGTYPE_REQUEST_IDENT = 1,
MSGTYPE_LOAD_OBJECT,
MSGTYPE_RUN_KERNEL,
};
/* device to host */
enum {
MSGTYPE_LOG = 1,
MSGTYPE_MESSAGE_UNRECOGNIZED,
MSGTYPE_IDENT,
MSGTYPE_OBJECT_LOADED,
MSGTYPE_INCORRECT_LENGTH,
MSGTYPE_CRC_FAILED,
MSGTYPE_OBJECT_UNRECOGNIZED,
MSGTYPE_KERNEL_FINISHED,
2014-09-21 23:36:10 +08:00
MSGTYPE_KERNEL_EXCEPTION,
MSGTYPE_KERNEL_STARTUP_FAILED,
MSGTYPE_RPC_REQUEST,
2014-08-28 16:56:48 +08:00
};
static int receive_int(void)
{
2014-09-05 12:03:22 +08:00
unsigned int r;
int i;
r = 0;
for(i=0;i<4;i++) {
r <<= 8;
r |= (unsigned char)uart_read();
}
return r;
2014-08-28 16:56:48 +08:00
}
static char receive_char(void)
{
2014-09-05 12:03:22 +08:00
return uart_read();
2014-08-28 16:56:48 +08:00
}
static void send_int(int x)
{
2014-09-05 12:03:22 +08:00
int i;
2014-08-28 16:56:48 +08:00
2014-09-05 12:03:22 +08:00
for(i=0;i<4;i++) {
uart_write((x & 0xff000000) >> 24);
x <<= 8;
}
2014-08-28 16:56:48 +08:00
}
static void send_sint(short int i)
{
2014-09-05 12:03:22 +08:00
uart_write((i >> 8) & 0xff);
uart_write(i & 0xff);
2014-08-28 16:56:48 +08:00
}
static void send_char(char c)
{
2014-09-05 12:03:22 +08:00
uart_write(c);
2014-08-28 16:56:48 +08:00
}
static void receive_sync(void)
{
2014-09-05 12:03:22 +08:00
char c;
int recognized;
recognized = 0;
while(recognized < 4) {
c = uart_read();
if(c == 0x5a)
recognized++;
else
recognized = 0;
}
2014-08-28 16:56:48 +08:00
}
static void receive_and_load_object(object_loader load_object)
2014-08-28 16:56:48 +08:00
{
int length;
int i;
unsigned char buffer[256*1024];
unsigned int crc;
length = receive_int();
if(length > sizeof(buffer)) {
send_char(MSGTYPE_INCORRECT_LENGTH);
return;
}
crc = receive_int();
for(i=0;i<length;i++)
buffer[i] = receive_char();
if(crc32(buffer, length) != crc) {
send_char(MSGTYPE_CRC_FAILED);
return;
}
if(load_object(buffer, length))
send_char(MSGTYPE_OBJECT_LOADED);
else
send_char(MSGTYPE_OBJECT_UNRECOGNIZED);
2014-08-28 16:56:48 +08:00
}
static void receive_and_run_kernel(kernel_runner run_kernel)
2014-08-28 16:56:48 +08:00
{
2014-09-05 12:03:22 +08:00
int length;
int i;
char kernel_name[256];
2014-09-21 23:36:10 +08:00
int r, eid;
length = receive_int();
if(length > (sizeof(kernel_name)-1)) {
send_char(MSGTYPE_INCORRECT_LENGTH);
return;
}
for(i=0;i<length;i++)
kernel_name[i] = receive_char();
kernel_name[length] = 0;
2014-09-21 23:36:10 +08:00
r = run_kernel(kernel_name, &eid);
switch(r) {
case KERNEL_RUN_FINISHED:
send_char(MSGTYPE_KERNEL_FINISHED);
break;
case KERNEL_RUN_EXCEPTION:
send_char(MSGTYPE_KERNEL_EXCEPTION);
send_int(eid);
break;
case KERNEL_RUN_STARTUP_FAILED:
send_char(MSGTYPE_KERNEL_STARTUP_FAILED);
break;
default:
corecom_log("BUG: run_kernel returned unexpected value '%d'", r);
break;
}
}
void corecom_serve(object_loader load_object, kernel_runner run_kernel)
{
2014-09-05 12:03:22 +08:00
char msgtype;
while(1) {
receive_sync();
msgtype = receive_char();
if(msgtype == MSGTYPE_REQUEST_IDENT) {
send_char(MSGTYPE_IDENT);
2014-09-05 12:03:22 +08:00
send_int(0x41524f52); /* "AROR" - ARTIQ runtime on OpenRISC */
send_int(1000000000000LL/identifier_frequency_read()); /* RTIO clock period in picoseconds */
} else if(msgtype == MSGTYPE_LOAD_OBJECT)
receive_and_load_object(load_object);
else if(msgtype == MSGTYPE_RUN_KERNEL)
receive_and_run_kernel(run_kernel);
else
send_char(MSGTYPE_MESSAGE_UNRECOGNIZED);
2014-09-05 12:03:22 +08:00
}
2014-08-28 16:56:48 +08:00
}
int corecom_rpc(int rpc_num, int n_args, ...)
2014-08-28 16:56:48 +08:00
{
2014-09-05 12:03:22 +08:00
send_char(MSGTYPE_RPC_REQUEST);
send_sint(rpc_num);
send_char(n_args);
va_list args;
va_start(args, n_args);
while(n_args--)
send_int(va_arg(args, int));
va_end(args);
return receive_int();
2014-08-28 16:56:48 +08:00
}
void corecom_log(const char *fmt, ...)
2014-08-28 16:56:48 +08:00
{
va_list args;
int len;
char outbuf[256];
int i;
va_start(args, fmt);
len = vscnprintf(outbuf, sizeof(outbuf), fmt, args);
va_end(args);
send_char(MSGTYPE_LOG);
send_sint(len);
for(i=0;i<len;i++)
send_char(outbuf[i]);
2014-08-28 16:56:48 +08:00
}