summaryrefslogtreecommitdiffstats
path: root/fluent-bit/lib/wasm-micro-runtime-WAMR-1.2.2/samples/gui/wasm-runtime-wgl/src/platform/linux/iwasm_main.c
diff options
context:
space:
mode:
Diffstat (limited to 'fluent-bit/lib/wasm-micro-runtime-WAMR-1.2.2/samples/gui/wasm-runtime-wgl/src/platform/linux/iwasm_main.c')
-rw-r--r--fluent-bit/lib/wasm-micro-runtime-WAMR-1.2.2/samples/gui/wasm-runtime-wgl/src/platform/linux/iwasm_main.c564
1 files changed, 0 insertions, 564 deletions
diff --git a/fluent-bit/lib/wasm-micro-runtime-WAMR-1.2.2/samples/gui/wasm-runtime-wgl/src/platform/linux/iwasm_main.c b/fluent-bit/lib/wasm-micro-runtime-WAMR-1.2.2/samples/gui/wasm-runtime-wgl/src/platform/linux/iwasm_main.c
deleted file mode 100644
index 61c7bb39d..000000000
--- a/fluent-bit/lib/wasm-micro-runtime-WAMR-1.2.2/samples/gui/wasm-runtime-wgl/src/platform/linux/iwasm_main.c
+++ /dev/null
@@ -1,564 +0,0 @@
-
-#ifndef CONNECTION_UART
-#include <netdb.h>
-#include <netinet/in.h>
-#include <sys/socket.h>
-#include <arpa/inet.h>
-#else
-#include <termios.h>
-#endif
-
-#include <arpa/inet.h>
-#include <unistd.h>
-#include <getopt.h>
-#include <stdlib.h>
-#include <strings.h>
-#include <sys/types.h>
-#include <fcntl.h>
-#include <pthread.h>
-#include <signal.h>
-#include <unistd.h>
-#include <strings.h>
-
-#include "runtime_lib.h"
-#include "runtime_timer.h"
-#include "native_interface.h"
-#include "app_manager_export.h"
-#include "bh_platform.h"
-#include "runtime_sensor.h"
-#include "bi-inc/attr_container.h"
-#include "module_wasm_app.h"
-#include "wasm_export.h"
-#include "wgl.h"
-
-#include "lv_drivers/display/monitor.h"
-#include "lv_drivers/indev/mouse.h"
-
-#define MAX 2048
-
-#ifndef CONNECTION_UART
-#define SA struct sockaddr
-static char *host_address = "127.0.0.1";
-static int port = 8888;
-#else
-static char *uart_device = "/dev/ttyS2";
-static int baudrate = B115200;
-#endif
-
-extern bool
-init_sensor_framework();
-extern void
-exit_sensor_framework();
-extern void
-exit_connection_framework();
-extern int
-aee_host_msg_callback(void *msg, uint32_t msg_len);
-extern bool
-init_connection_framework();
-
-#ifndef CONNECTION_UART
-int listenfd = -1;
-int sockfd = -1;
-static pthread_mutex_t sock_lock = PTHREAD_MUTEX_INITIALIZER;
-#else
-int uartfd = -1;
-#endif
-
-#ifndef CONNECTION_UART
-static bool server_mode = false;
-
-// Function designed for chat between client and server.
-void *
-func(void *arg)
-{
- char buff[MAX];
- int n;
- struct sockaddr_in servaddr;
-
- while (1) {
- if (sockfd != -1)
- close(sockfd);
- // socket create and verification
- sockfd = socket(AF_INET, SOCK_STREAM, 0);
- if (sockfd == -1) {
- printf("socket creation failed...\n");
- return NULL;
- }
- else
- printf("Socket successfully created..\n");
- bzero(&servaddr, sizeof(servaddr));
- // assign IP, PORT
- servaddr.sin_family = AF_INET;
- servaddr.sin_addr.s_addr = inet_addr(host_address);
- servaddr.sin_port = htons(port);
-
- // connect the client socket to server socket
- if (connect(sockfd, (SA *)&servaddr, sizeof(servaddr)) != 0) {
- printf("connection with the server failed...\n");
- sleep(10);
- continue;
- }
- else {
- printf("connected to the server..\n");
- }
-
- // infinite loop for chat
- for (;;) {
- bzero(buff, MAX);
-
- // read the message from client and copy it in buffer
- n = read(sockfd, buff, sizeof(buff));
- // print buffer which contains the client contents
- // fprintf(stderr, "recieved %d bytes from host: %s", n, buff);
-
- // socket disconnected
- if (n <= 0)
- break;
-
- aee_host_msg_callback(buff, n);
- }
- }
-
- // After chatting close the socket
- close(sockfd);
-}
-
-static bool
-host_init()
-{
- return true;
-}
-
-int
-host_send(void *ctx, const char *buf, int size)
-{
- int ret;
-
- if (pthread_mutex_trylock(&sock_lock) == 0) {
- if (sockfd == -1) {
- pthread_mutex_unlock(&sock_lock);
- return 0;
- }
-
- ret = write(sockfd, buf, size);
-
- pthread_mutex_unlock(&sock_lock);
- return ret;
- }
-
- return -1;
-}
-
-void
-host_destroy()
-{
- if (server_mode)
- close(listenfd);
-
- pthread_mutex_lock(&sock_lock);
- close(sockfd);
- pthread_mutex_unlock(&sock_lock);
-}
-
-/* clang-format off */
-host_interface interface = {
- .init = host_init,
- .send = host_send,
- .destroy = host_destroy
-};
-/* clang-format on */
-
-void *
-func_server_mode(void *arg)
-{
- int clilent;
- struct sockaddr_in serv_addr, cli_addr;
- int n;
- char buff[MAX];
- struct sigaction sa;
-
- sa.sa_handler = SIG_IGN;
- sa.sa_flags = 0;
- sigemptyset(&sa.sa_mask);
- sigaction(SIGPIPE, &sa, 0);
-
- /* First call to socket() function */
- listenfd = socket(AF_INET, SOCK_STREAM, 0);
-
- if (listenfd < 0) {
- perror("ERROR opening socket");
- exit(1);
- }
-
- /* Initialize socket structure */
- bzero((char *)&serv_addr, sizeof(serv_addr));
-
- serv_addr.sin_family = AF_INET;
- serv_addr.sin_addr.s_addr = INADDR_ANY;
- serv_addr.sin_port = htons(port);
-
- /* Now bind the host address using bind() call.*/
- if (bind(listenfd, (struct sockaddr *)&serv_addr, sizeof(serv_addr)) < 0) {
- perror("ERROR on binding");
- exit(1);
- }
-
- listen(listenfd, 5);
- clilent = sizeof(cli_addr);
-
- while (1) {
- pthread_mutex_lock(&sock_lock);
-
- sockfd = accept(listenfd, (struct sockaddr *)&cli_addr, &clilent);
-
- pthread_mutex_unlock(&sock_lock);
-
- if (sockfd < 0) {
- perror("ERROR on accept");
- exit(1);
- }
-
- printf("connection established!\n");
-
- for (;;) {
- bzero(buff, MAX);
-
- // read the message from client and copy it in buffer
- n = read(sockfd, buff, sizeof(buff));
-
- // socket disconnected
- if (n <= 0) {
- pthread_mutex_lock(&sock_lock);
- close(sockfd);
- sockfd = -1;
- pthread_mutex_unlock(&sock_lock);
-
- sleep(2);
- break;
- }
-
- aee_host_msg_callback(buff, n);
- }
- }
-}
-
-#else
-static int
-parse_baudrate(int baud)
-{
- switch (baud) {
- case 9600:
- return B9600;
- case 19200:
- return B19200;
- case 38400:
- return B38400;
- case 57600:
- return B57600;
- case 115200:
- return B115200;
- case 230400:
- return B230400;
- case 460800:
- return B460800;
- case 500000:
- return B500000;
- case 576000:
- return B576000;
- case 921600:
- return B921600;
- case 1000000:
- return B1000000;
- case 1152000:
- return B1152000;
- case 1500000:
- return B1500000;
- case 2000000:
- return B2000000;
- case 2500000:
- return B2500000;
- case 3000000:
- return B3000000;
- case 3500000:
- return B3500000;
- case 4000000:
- return B4000000;
- default:
- return -1;
- }
-}
-static bool
-uart_init(const char *device, int baudrate, int *fd)
-{
- int uart_fd;
- struct termios uart_term;
-
- uart_fd = open(device, O_RDWR | O_NOCTTY);
-
- if (uart_fd <= 0)
- return false;
-
- memset(&uart_term, 0, sizeof(uart_term));
- uart_term.c_cflag = baudrate | CS8 | CLOCAL | CREAD;
- uart_term.c_iflag = IGNPAR;
- uart_term.c_oflag = 0;
-
- /* set noncanonical mode */
- uart_term.c_lflag = 0;
- uart_term.c_cc[VTIME] = 30;
- uart_term.c_cc[VMIN] = 1;
- tcflush(uart_fd, TCIFLUSH);
-
- if (tcsetattr(uart_fd, TCSANOW, &uart_term) != 0) {
- close(uart_fd);
- return false;
- }
-
- *fd = uart_fd;
-
- return true;
-}
-
-static void *
-func_uart_mode(void *arg)
-{
- int n;
- char buff[MAX];
-
- if (!uart_init(uart_device, baudrate, &uartfd)) {
- printf("open uart fail! %s\n", uart_device);
- return NULL;
- }
-
- for (;;) {
- bzero(buff, MAX);
-
- n = read(uartfd, buff, sizeof(buff));
-
- if (n <= 0) {
- close(uartfd);
- uartfd = -1;
- break;
- }
-
- aee_host_msg_callback(buff, n);
- }
-
- return NULL;
-}
-
-static int
-uart_send(void *ctx, const char *buf, int size)
-{
- int ret;
-
- ret = write(uartfd, buf, size);
-
- return ret;
-}
-
-static void
-uart_destroy()
-{
- close(uartfd);
-}
-
-/* clang-format off */
-static host_interface interface = {
- .send = uart_send,
- .destroy = uart_destroy
-};
-/* clang-format on */
-
-#endif
-
-static char global_heap_buf[270 * 1024] = { 0 };
-
-/* clang-format off */
-static void showUsage()
-{
-#ifndef CONNECTION_UART
- printf("Usage:\n");
- printf("\nWork as TCP server mode:\n");
- printf("\tvgl_wasm_runtime -s|--server_mode -p|--port <Port>\n");
- printf("where\n");
- printf("\t<Port> represents the port that would be listened on and the default is 8888\n");
- printf("\nWork as TCP client mode:\n");
- printf("\tvgl_wasm_runtime -a|--host_address <Host Address> -p|--port <Port>\n");
- printf("where\n");
- printf("\t<Host Address> represents the network address of host and the default is 127.0.0.1\n");
- printf("\t<Port> represents the listen port of host and the default is 8888\n");
-#else
- printf("Usage:\n");
- printf("\tvgl_wasm_runtime -u <Uart Device> -b <Baudrate>\n\n");
- printf("where\n");
- printf("\t<Uart Device> represents the UART device name and the default is /dev/ttyS2\n");
- printf("\t<Baudrate> represents the UART device baudrate and the default is 115200\n");
-#endif
-}
-/* clang-format on */
-
-static bool
-parse_args(int argc, char *argv[])
-{
- int c;
-
- while (1) {
- int optIndex = 0;
- static struct option longOpts[] = {
-#ifndef CONNECTION_UART
- { "server_mode", no_argument, NULL, 's' },
- { "host_address", required_argument, NULL, 'a' },
- { "port", required_argument, NULL, 'p' },
-#else
- { "uart", required_argument, NULL, 'u' },
- { "baudrate", required_argument, NULL, 'b' },
-#endif
- { "help", required_argument, NULL, 'h' },
- { 0, 0, 0, 0 }
- };
-
- c = getopt_long(argc, argv, "sa:p:u:b:h", longOpts, &optIndex);
- if (c == -1)
- break;
-
- switch (c) {
-#ifndef CONNECTION_UART
- case 's':
- server_mode = true;
- break;
- case 'a':
- host_address = optarg;
- printf("host address: %s\n", host_address);
- break;
- case 'p':
- port = atoi(optarg);
- printf("port: %d\n", port);
- break;
-#else
- case 'u':
- uart_device = optarg;
- printf("uart device: %s\n", uart_device);
- break;
- case 'b':
- baudrate = parse_baudrate(atoi(optarg));
- printf("uart baudrate: %s\n", optarg);
- break;
-#endif
- case 'h':
- showUsage();
- return false;
- default:
- showUsage();
- return false;
- }
- }
-
- return true;
-}
-
-/**
- * Initialize the Hardware Abstraction Layer (HAL) for the Littlev graphics
- * library
- */
-static void
-hal_init(void)
-{
- /* Use the 'monitor' driver which creates window on PC's monitor to simulate
- * a display*/
- monitor_init();
-
- /*Create a display buffer*/
- static lv_disp_buf_t disp_buf1;
- static lv_color_t buf1_1[480 * 10];
- lv_disp_buf_init(&disp_buf1, buf1_1, NULL, 480 * 10);
-
- /*Create a display*/
- lv_disp_drv_t disp_drv;
-
- /*Basic initialization*/
- memset(&disp_drv, 0, sizeof(disp_drv));
- lv_disp_drv_init(&disp_drv);
- disp_drv.buffer = &disp_buf1;
- disp_drv.flush_cb = monitor_flush;
- // disp_drv.hor_res = 200;
- // disp_drv.ver_res = 100;
- lv_disp_drv_register(&disp_drv);
-
- /* Add the mouse as input device
- * Use the 'mouse' driver which reads the PC's mouse*/
- mouse_init();
- lv_indev_drv_t indev_drv;
- lv_indev_drv_init(&indev_drv); /*Basic initialization*/
- indev_drv.type = LV_INDEV_TYPE_POINTER;
- indev_drv.read_cb =
- mouse_read; /*This function will be called periodically (by the library)
- to get the mouse position and state*/
- lv_indev_drv_register(&indev_drv);
-}
-
-// Driver function
-int
-iwasm_main(int argc, char *argv[])
-{
- RuntimeInitArgs init_args;
- korp_tid tid;
-
- if (!parse_args(argc, argv))
- return -1;
-
- memset(&init_args, 0, sizeof(RuntimeInitArgs));
-
- init_args.mem_alloc_type = Alloc_With_Pool;
- init_args.mem_alloc_option.pool.heap_buf = global_heap_buf;
- init_args.mem_alloc_option.pool.heap_size = sizeof(global_heap_buf);
-
- /* initialize runtime environment */
- if (!wasm_runtime_full_init(&init_args)) {
- printf("Init runtime environment failed.\n");
- return -1;
- }
-
- if (!init_connection_framework()) {
- goto fail1;
- }
-
- wgl_init();
-
- hal_init();
-
- if (!init_sensor_framework()) {
- goto fail2;
- }
-
- /* timer manager */
- if (!init_wasm_timer()) {
- goto fail3;
- }
-
-#ifndef CONNECTION_UART
- if (server_mode)
- os_thread_create(&tid, func_server_mode, NULL,
- BH_APPLET_PRESERVED_STACK_SIZE);
- else
- os_thread_create(&tid, func, NULL, BH_APPLET_PRESERVED_STACK_SIZE);
-#else
- os_thread_create(&tid, func_uart_mode, NULL,
- BH_APPLET_PRESERVED_STACK_SIZE);
-#endif
-
- app_manager_startup(&interface);
-
- exit_wasm_timer();
-
-fail3:
- exit_sensor_framework();
-
-fail2:
- wgl_exit();
- exit_connection_framework();
-
-fail1:
- wasm_runtime_destroy();
- return -1;
-}
generated by cgit v1.2.3 (git 2.39.1) at 2024-09-19 21:03:57 +0000