Skip to content
Snippets Groups Projects
Select Git revision
  • 30dd23aa7f2c7f142bab66d189f7f479091cf161
  • wip-bootstrap default
  • dualcore
  • ch3/leds
  • ch3/time
  • master
6 results

pybstdio.c

Blame
  • pybstdio.c 6.01 KiB
    /*
     * This file is part of the Micro Python project, http://micropython.org/
     *
     * The MIT License (MIT)
     *
     * Copyright (c) 2013, 2014 Damien P. George
     *
     * Permission is hereby granted, free of charge, to any person obtaining a copy
     * of this software and associated documentation files (the "Software"), to deal
     * in the Software without restriction, including without limitation the rights
     * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
     * copies of the Software, and to permit persons to whom the Software is
     * furnished to do so, subject to the following conditions:
     *
     * The above copyright notice and this permission notice shall be included in
     * all copies or substantial portions of the Software.
     *
     * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
     * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
     * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
     * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
     * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
     * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
     * THE SOFTWARE.
     */
    
    #include <stdio.h>
    #include <stdint.h>
    #include <string.h>
    #include <errno.h>
    
    #include "mpconfig.h"
    #include "misc.h"
    #include "qstr.h"
    #include "misc.h"
    #include "obj.h"
    #include "stream.h"
    #include MICROPY_HAL_H
    #include "usb.h"
    #include "uart.h"
    #include "pybstdio.h"
    
    // TODO make stdin, stdout and stderr writable objects so they can
    // be changed by Python code.  This requires some changes, as these
    // objects are in a read-only module (py/modsys.c).
    
    // stdio is repeated on this UART object if it's not null
    pyb_uart_obj_t *pyb_stdio_uart = NULL;
    
    void stdout_tx_str(const char *str) {
        stdout_tx_strn(str, strlen(str));
    }
    
    void stdout_tx_strn(const char *str, mp_uint_t len) {
        if (pyb_stdio_uart != PYB_UART_NONE) {
            uart_tx_strn(pyb_stdio_uart, str, len);
        }
    #if 0 && defined(USE_HOST_MODE) && MICROPY_HW_HAS_LCD
        lcd_print_strn(str, len);
    #endif
        if (usb_vcp_is_enabled()) {
            usb_vcp_send_strn(str, len);
        }
    }
    
    void stdout_tx_strn_cooked(const char *str, mp_uint_t len) {
        // send stdout to UART and USB CDC VCP
        if (pyb_stdio_uart != PYB_UART_NONE) {
            uart_tx_strn_cooked(pyb_stdio_uart, str, len);
        }
        if (usb_vcp_is_enabled()) {
            usb_vcp_send_strn_cooked(str, len);
        }
    }
    
    int stdin_rx_chr(void) {
        for (;;) {
    #if 0
    #ifdef USE_HOST_MODE
            pyb_usb_host_process();
            int c = pyb_usb_host_get_keyboard();
            if (c != 0) {
                return c;
            }
    #endif
    #endif
    
            byte c;
            if (usb_vcp_recv_byte(&c) != 0) {
                return c;
            } else if (pyb_stdio_uart != PYB_UART_NONE && uart_rx_any(pyb_stdio_uart)) {
                return uart_rx_char(pyb_stdio_uart);
            }
            __WFI();
        }
    }
    
    /******************************************************************************/
    // Micro Python bindings
    
    #define STDIO_FD_IN  (0)
    #define STDIO_FD_OUT (1)
    #define STDIO_FD_ERR (2)
    
    typedef struct _pyb_stdio_obj_t {
        mp_obj_base_t base;
        int fd;
    } pyb_stdio_obj_t;
    
    void stdio_obj_print(void (*print)(void *env, const char *fmt, ...), void *env, mp_obj_t self_in, mp_print_kind_t kind) {
        pyb_stdio_obj_t *self = self_in;
        print(env, "<io.FileIO %d>", self->fd);
    }
    
    STATIC mp_uint_t stdio_read(mp_obj_t self_in, void *buf, mp_uint_t size, int *errcode) {
        pyb_stdio_obj_t *self = self_in;
        if (self->fd == STDIO_FD_IN) {
            for (uint i = 0; i < size; i++) {
                int c = stdin_rx_chr();
                if (c == '\r') {
                    c = '\n';
                }
                ((byte*)buf)[i] = c;
            }
            return size;
        } else {
            *errcode = EPERM;
            return MP_STREAM_ERROR;
        }
    }
    
    STATIC mp_uint_t stdio_write(mp_obj_t self_in, const void *buf, mp_uint_t size, int *errcode) {
        pyb_stdio_obj_t *self = self_in;
        if (self->fd == STDIO_FD_OUT || self->fd == STDIO_FD_ERR) {
            stdout_tx_strn_cooked(buf, size);
            return size;
        } else {
            *errcode = EPERM;
            return MP_STREAM_ERROR;
        }
    }
    
    mp_obj_t stdio_obj___exit__(uint n_args, const mp_obj_t *args) {
        return mp_const_none;
    }
    static MP_DEFINE_CONST_FUN_OBJ_VAR_BETWEEN(stdio_obj___exit___obj, 4, 4, stdio_obj___exit__);
    
    // TODO gc hook to close the file if not already closed
    
    STATIC const mp_map_elem_t stdio_locals_dict_table[] = {
        { MP_OBJ_NEW_QSTR(MP_QSTR_read), (mp_obj_t)&mp_stream_read_obj },
        { MP_OBJ_NEW_QSTR(MP_QSTR_readall), (mp_obj_t)&mp_stream_readall_obj },
        { MP_OBJ_NEW_QSTR(MP_QSTR_readline), (mp_obj_t)&mp_stream_unbuffered_readline_obj},
        { MP_OBJ_NEW_QSTR(MP_QSTR_write), (mp_obj_t)&mp_stream_write_obj },
        { MP_OBJ_NEW_QSTR(MP_QSTR_close), (mp_obj_t)&mp_identity_obj },
        { MP_OBJ_NEW_QSTR(MP_QSTR___del__), (mp_obj_t)&mp_identity_obj },
        { MP_OBJ_NEW_QSTR(MP_QSTR___enter__), (mp_obj_t)&mp_identity_obj },
        { MP_OBJ_NEW_QSTR(MP_QSTR___exit__), (mp_obj_t)&stdio_obj___exit___obj },
    };
    
    STATIC MP_DEFINE_CONST_DICT(stdio_locals_dict, stdio_locals_dict_table);
    
    STATIC const mp_stream_p_t stdio_obj_stream_p = {
        .read = stdio_read,
        .write = stdio_write,
        .is_text = true,
    };
    
    STATIC const mp_obj_type_t stdio_obj_type = {
        { &mp_type_type },
        .name = MP_QSTR_FileIO,
        // TODO .make_new?
        .print = stdio_obj_print,
        .getiter = mp_identity,
        .iternext = mp_stream_unbuffered_iter,
        .stream_p = &stdio_obj_stream_p,
        .locals_dict = (mp_obj_t)&stdio_locals_dict,
    };
    
    /// \moduleref sys
    /// \constant stdin - standard input (connected to USB VCP, and optional UART object)
    /// \constant stdout - standard output (connected to USB VCP, and optional UART object)
    /// \constant stderr - standard error (connected to USB VCP, and optional UART object)
    const pyb_stdio_obj_t mp_sys_stdin_obj = {{&stdio_obj_type}, .fd = STDIO_FD_IN};
    const pyb_stdio_obj_t mp_sys_stdout_obj = {{&stdio_obj_type}, .fd = STDIO_FD_OUT};
    const pyb_stdio_obj_t mp_sys_stderr_obj = {{&stdio_obj_type}, .fd = STDIO_FD_ERR};