Subversion Repositories freemyipod

//

//

//    Copyright 2010 TheSeven

//

//

//    This file is part of emCORE.

//

//    emCORE is free software: you can redistribute it and/or

//    modify it under the terms of the GNU General Public License as

//    published by the Free Software Foundation, either version 2 of the

//    License, or (at your option) any later version.

//

//    emCORE is distributed in the hope that it will be useful,

//    but WITHOUT ANY WARRANTY; without even the implied warranty of

//    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.

//    See the GNU General Public License for more details.

//

//    You should have received a copy of the GNU General Public License along

//    with emCORE.  If not, see <http://www.gnu.org/licenses/>.

//

//

#include "global.h"

#include "usbdebug.h"

#include "panic.h"

#include "usb.h"

#include "thread.h"

#include "console.h"

#include "util.h"

#include "contextswitch.h"

#include "power.h"

#include "mmu.h"

#include "shutdown.h"

#include "execimage.h"

#ifdef HAVE_I2C

#include "i2c.h"

#endif

#ifdef HAVE_BOOTFLASH

#include "bootflash.h"

#endif

#ifdef HAVE_HWKEYAES

#include "hwkeyaes.h"

#endif

#ifdef HAVE_HMACSHA1

#include "hmacsha1.h"

#endif

#ifdef USB_HAVE_TARGET_SPECIFIC_REQUESTS

#include "usbtarget.h"

#endif

#ifdef HAVE_STORAGE

#include "storage.h"

#include "disk.h"

#include "file.h"

#include "dir.h"

#include "libc/include/errno.h"

#endif

static uint32_t dbgbuf[16] CACHEALIGN_ATTR;

enum dbgstate_t

{

    DBGSTATE_IDLE = 0,

    DBGSTATE_SETUP,

    DBGSTATE_WRITE_MEM,

    DBGSTATE_WRITE_CONSOLE,

    DBGSTATE_ASYNC,

    DBGSTATE_RESPOND,

    DBGSTATE_READ_CONSOLE,

};

static struct scheduler_thread dbgthread_handle IBSS_ATTR;

static uint32_t dbgstack[0x200] STACK_ATTR;

struct wakeup dbgwakeup IBSS_ATTR;

static bool dbgenabled IBSS_ATTR;

static bool dbgbusy IBSS_ATTR;

static const struct usb_instance* dbgusb IBSS_ATTR;

static enum dbgstate_t dbgstate IBSS_ATTR;

static void* dbgmemaddr IBSS_ATTR;

static uint32_t dbgmemlen IBSS_ATTR;

static char dbgconsendbuf[4096];

static char dbgconrecvbuf[1024];

static int dbgconsendreadidx IBSS_ATTR;

static int dbgconsendwriteidx IBSS_ATTR;

static int dbgconrecvreadidx IBSS_ATTR;

static int dbgconrecvwriteidx IBSS_ATTR;

static struct wakeup dbgconsendwakeup IBSS_ATTR;

static struct wakeup dbgconrecvwakeup IBSS_ATTR;

static bool dbgconsoleattached IBSS_ATTR;

static const char dbgconoverflowstr[] = "\n\n[overflowed]\n\n";

extern int _poolstart;   // These aren't ints at all, but gcc complains about void types being

extern int _poolend;     // used here, and we only need the address, so just make it happy...

void reset() __attribute__((noreturn));

void usbdebug_enable(const struct usb_instance* data, int interface, int altsetting)

{

    dbgusb = data;

    dbgstate = DBGSTATE_IDLE;

    dbgenabled = true;

}

void usbdebug_disable(const struct usb_instance* data, int interface, int altsetting)

{

    dbgenabled = false;

    dbgstate = DBGSTATE_IDLE;

}

bool usbdebug_handle_data(const struct usb_instance* data, union usb_endpoint_number epnum, int bytesleft)

{

    union usb_endpoint_number ep0in = { .number = 0, .direction = USB_ENDPOINT_DIRECTION_IN };

    union usb_endpoint_number ep0out = { .number = 0, .direction = USB_ENDPOINT_DIRECTION_OUT };

    uint32_t* buf = (uint32_t*)data->buffer->raw;

    usb_ep0_start_rx(dbgusb, false, 0, NULL);

    switch (dbgstate)

    {

    case DBGSTATE_SETUP:

        switch (buf[0])

        {

        case 1:  // GET INFO

            dbgbuf[0] = 1;

            switch (buf[1])

            {

            case 0:  // GET VERSION INFO

                dbgbuf[1] = VERSION_SVN_INT;

                dbgbuf[2] = VERSION_MAJOR | (VERSION_MINOR << 8) | (VERSION_PATCH << 16) | (2 << 24);

                dbgbuf[3] = PLATFORM_ID;

                break;

            case 1:  // GET USER MEMORY INFO

                dbgbuf[1] = (uint32_t)&_poolstart;

                dbgbuf[2] = (uint32_t)&_poolend;

                break;

            default:

                dbgbuf[0] = 2;

            }

            break;

        case 4:  // READ MEMORY

            dbgbuf[0] = 1;

            dbgmemaddr = (void*)buf[1];

            dbgmemlen = buf[2];

            break;

        case 5:  // WRITE MEMORY

        {

            dbgmemaddr = (void*)buf[1];

            dbgmemlen = buf[2];

            int len = MIN(48, dbgmemlen);

            dbgmemlen -= len;

            memcpy(dbgmemaddr, &buf[4], len);

            if (dbgmemlen)

            {

                dbgmemaddr += len;

                dbgstate = DBGSTATE_WRITE_MEM;

                usb_ep0_start_rx(dbgusb, true, MIN(64, dbgmemlen), usbdebug_handle_data);

                return true;

            }

            dbgbuf[0] = 1;

            break;

        }

        case 10:  // READ CONSOLE

            dbgmemaddr = (void*)buf[1];

            dbgstate = DBGSTATE_READ_CONSOLE;

            usb_set_stall(dbgusb, ep0out, true);

            usb_ep0_start_tx(dbgusb, NULL, 0, NULL);

            return true;

            break;

        case 11:  // WRITE CONSOLE

        {

            int total = 0;

            int bytes = dbgconrecvreadidx - dbgconrecvwriteidx - 1;

            if (bytes < 0) bytes += sizeof(dbgconrecvbuf);

            if (bytes)

            {

                if (bytes > buf[1]) bytes = buf[1];

                total = bytes;

                if (bytes > 48) bytes = 48;

                int writebytes = bytes;

                char* readptr = (char*)&buf[4];

                if (dbgconrecvwriteidx + bytes >= sizeof(dbgconrecvbuf))

                {

                    writebytes = sizeof(dbgconrecvbuf) - dbgconrecvwriteidx;

                    memcpy(&dbgconrecvbuf[dbgconrecvwriteidx], readptr, writebytes);

                    dbgconrecvwriteidx = 0;

                    readptr = &readptr[writebytes];

                    writebytes = bytes - writebytes;

                }

                if (writebytes) memcpy(&dbgconrecvbuf[dbgconrecvwriteidx], readptr, writebytes);

                dbgconrecvwriteidx += writebytes;

                wakeup_signal(&dbgconrecvwakeup);

            }

            dbgbuf[0] = 1;

            dbgbuf[1] = total;

            dbgbuf[2] = sizeof(dbgconrecvbuf);

            if (total > 48)

            {

                dbgmemlen = total - 48;

                dbgstate = DBGSTATE_WRITE_CONSOLE;

                usb_ep0_start_rx(dbgusb, true, MIN(64, dbgmemlen), usbdebug_handle_data);

                return true;

            }

            dbgbuf[3] = dbgconrecvreadidx - dbgconrecvwriteidx - 1;

            break;

        }

        case 15:  // GET PROCESS INFO

            dbgbuf[0] = 1;

            dbgbuf[1] = SCHEDULER_THREAD_INFO_VERSION;

            dbgbuf[2] = (uint32_t)head_thread;

            break;

        case 16:  // FREEZE SCHEDULER

            dbgbuf[1] = scheduler_freeze(buf[1]);

            scheduler_switch(NULL, NULL);

            dbgbuf[0] = 1;

            break;

        case 17:  // SUSPEND THREAD

            if (buf[1])

            {

                if (thread_suspend((struct scheduler_thread*)(buf[2])) == ALREADY_SUSPENDED)

                    dbgbuf[1] = 1;

                else dbgbuf[1] = 0;

            }

            else

            {

                if (thread_resume((struct scheduler_thread*)(buf[2])) == ALREADY_RESUMED)

                    dbgbuf[1] = 0;

                else dbgbuf[1] = 1;

            }

            dbgbuf[0] = 1;

            break;

        case 18:  // KILL THREAD

            thread_terminate((struct scheduler_thread*)(buf[1]));

            dbgbuf[0] = 1;

            break;

        case 19:  // CREATE THREAD

            dbgbuf[0] = 1;

            dbgbuf[1] = (uint32_t)thread_create(NULL, (const char*)(buf[1]), (const void*)(buf[2]),

                                                (char*)(buf[3]), buf[4], (enum thread_type)buf[5],

                                                buf[6], buf[7], (void*)buf[8], (void*)buf[9],

                                                (void*)buf[10], (void*)buf[11]);

            break;

        case 20:  // FLUSH CACHE

            clean_dcache();

            invalidate_icache();

            buf[0] = 1;

            break;

        case 2:  // RESET

            if (!buf[1]) reset();

        default:

            if (!dbgbusy)

            {

                memcpy(dbgbuf, buf, 64);

                dbgstate = DBGSTATE_ASYNC;

                dbgbusy = 1;

                wakeup_signal(&dbgwakeup);

                return true;

            }

            buf[0] = 3;

            break;

        }

        break;

    case DBGSTATE_WRITE_MEM:

    {

        int len = MIN(64 - bytesleft, dbgmemlen);

        dbgmemlen -= len;

        memcpy(dbgmemaddr, buf, len);

        if (dbgmemlen && !bytesleft)

        {

            dbgmemaddr += len;

            usb_ep0_start_rx(dbgusb, true, MIN(64, dbgmemlen), usbdebug_handle_data);

            return true;

        }

        dbgbuf[0] = 1;

        break;

    }

    case DBGSTATE_WRITE_CONSOLE:

    {

        int bytes = MIN(64 - bytesleft, dbgmemlen);

        dbgmemlen -= bytes;

        if (bytes)

        {

            int writebytes = bytes;

            char* readptr = (char*)buf;

            if (dbgconrecvwriteidx + bytes >= sizeof(dbgconrecvbuf))

            {

                writebytes = sizeof(dbgconrecvbuf) - dbgconrecvwriteidx;

                memcpy(&dbgconrecvbuf[dbgconrecvwriteidx], readptr, writebytes);

                dbgconrecvwriteidx = 0;

                readptr = &readptr[writebytes];

                writebytes = bytes - writebytes;

            }

            if (writebytes) memcpy(&dbgconrecvbuf[dbgconrecvwriteidx], readptr, writebytes);

            dbgconrecvwriteidx += writebytes;

            wakeup_signal(&dbgconrecvwakeup);

            if (dbgmemlen && !bytesleft)

            {

                usb_ep0_start_rx(dbgusb, true, MIN(64, dbgmemlen), usbdebug_handle_data);

                return true;

            }

        }

        dbgbuf[3] = dbgconrecvreadidx - dbgconrecvwriteidx - 1;

        if (dbgbuf[3] < 0) dbgbuf[3] += sizeof(dbgconrecvbuf);

    }

    default: break;

    }

    dbgstate = DBGSTATE_RESPOND;

    usb_set_stall(dbgusb, ep0out, true);

    usb_ep0_start_tx(dbgusb, NULL, 0, NULL);

    return true;

}

bool read_console_callback(const struct usb_instance* data, union usb_endpoint_number epnum, int bytesleft)

{

    if (bytesleft || !dbgmemaddr)

    {

        usb_ep0_start_rx(dbgusb, true, 0, usb_ep0_ack_callback);

        if (!dbgmemaddr) usb_ep0_start_tx(dbgusb, NULL, 0, usb_ep0_short_tx_callback);

        dbgusb->state->ep0_tx_ptr = NULL;

        return false;

    }

    dbgconsoleattached = true;

    int bytes = MIN(64, dbgmemlen);

    if (bytes)

    {

        int readbytes = bytes;

        char* outptr = (char*)dbgbuf;

        if (dbgconsendreadidx + bytes >= sizeof(dbgconsendbuf))

        {

            readbytes = sizeof(dbgconsendbuf) - dbgconsendreadidx;

            memcpy(outptr, &dbgconsendbuf[dbgconsendreadidx], readbytes);

            dbgconsendreadidx = 0;

            outptr = &outptr[readbytes];

            readbytes = bytes - readbytes;

        }

        if (readbytes) memcpy(outptr, &dbgconsendbuf[dbgconsendreadidx], readbytes);

        dbgconsendreadidx += readbytes;

        wakeup_signal(&dbgconsendwakeup);

        dbgmemlen -= bytes;

    }

    bytes = MIN(64, (int)dbgmemaddr);

    dbgmemaddr -= bytes;

    if (dbgmemaddr)

    {

        usb_ep0_start_tx(dbgusb, dbgbuf, bytes,

                         bytes < 64 ? usb_ep0_short_tx_callback : read_console_callback);

    }

    else usb_ep0_start_tx(dbgusb, dbgbuf, bytes, NULL);

    return true;

}

int usbdebug_handle_setup(const struct usb_instance* data, int interface, union usb_ep0_buffer* request, const void** response)

{

    int size = -1;

    union usb_endpoint_number ep0out = { .number = 0, .direction = USB_ENDPOINT_DIRECTION_OUT };

    switch (request->setup.bmRequestType.type)

    {

    case USB_SETUP_BMREQUESTTYPE_TYPE_VENDOR:

        switch (request->setup.bRequest.raw)

        {

        case 0x00:

            switch (data->buffer->setup.bmRequestType.direction)

            {

            case USB_SETUP_BMREQUESTTYPE_DIRECTION_OUT:

                dbgstate = DBGSTATE_SETUP;

                dbgmemlen = 0;

                usb_ep0_start_rx(dbgusb, true, 64, usbdebug_handle_data);

                return -3;

            case USB_SETUP_BMREQUESTTYPE_DIRECTION_IN:

                switch (dbgstate)

                {

                case DBGSTATE_RESPOND:

                {

                    dbgmemlen = MIN(dbgmemlen, data->buffer->setup.wLength - 16);

                    int len = MIN(48, dbgmemlen);

                    if (len) memcpy(&dbgbuf[4], dbgmemaddr, len);

                    dbgmemlen -= len;

                    if (dbgmemlen)

                    {

                        usb_ep0_start_rx(dbgusb, false, 0, NULL);

                        dbgusb->state->ep0_tx_ptr = dbgmemaddr + 48;

                        dbgusb->state->ep0_tx_len = dbgmemlen;

                        usb_ep0_start_tx(dbgusb, dbgbuf, len + 16,

                                         len < 48 ? usb_ep0_short_tx_callback : usb_ep0_tx_callback);

                        return -3;

                    }

                    dbgstate = DBGSTATE_IDLE;

                    *response = dbgbuf;

                    return len + 16;

                }

                case DBGSTATE_READ_CONSOLE:

                {

                    dbgmemaddr = (void*)MIN((int)dbgmemaddr, data->buffer->setup.wLength - 16);

                    dbgconsoleattached = true;

                    dbgmemlen = dbgconsendwriteidx - dbgconsendreadidx;

                    if (dbgmemlen < 0) dbgmemlen += sizeof(dbgconsendbuf);

                    int used = dbgmemlen;

                    if (dbgmemlen > (int)dbgmemaddr) dbgmemlen = (int)dbgmemaddr;

                    int bytes = MIN(48, dbgmemlen);

                    dbgbuf[0] = 1;

                    dbgbuf[1] = dbgmemlen;

                    dbgbuf[2] = sizeof(dbgconsendbuf);

                    dbgbuf[3] = used - dbgmemlen;

                    if (bytes)

                    {

                        int readbytes = bytes;

                        char* outptr = (char*)&dbgbuf[4];

                        if (dbgconsendreadidx + bytes >= sizeof(dbgconsendbuf))

                        {

                            readbytes = sizeof(dbgconsendbuf) - dbgconsendreadidx;

                            memcpy(outptr, &dbgconsendbuf[dbgconsendreadidx], readbytes);

                            dbgconsendreadidx = 0;

                            outptr = &outptr[readbytes];

                            readbytes = bytes - readbytes;

                        }

                        if (readbytes) memcpy(outptr, &dbgconsendbuf[dbgconsendreadidx], readbytes);

                        dbgconsendreadidx += readbytes;

                        wakeup_signal(&dbgconsendwakeup);

                    }

                    dbgmemlen -= bytes;

                    bytes = MIN(48, (int)dbgmemaddr);

                    dbgmemaddr -= bytes;

                    if (dbgmemaddr)

                    {

                        dbgusb->state->ep0_tx_ptr = (void*)true;

                        usb_ep0_start_rx(dbgusb, false, 0, NULL);

                        usb_ep0_start_tx(dbgusb, dbgbuf, bytes + 16,

                                         bytes < 48 ? usb_ep0_short_tx_callback : read_console_callback);

                        return -3;

                    }

                    dbgstate = DBGSTATE_IDLE;

                    *response = dbgbuf;

                    return bytes + 16;

                }

                default: return -2;

                }

                break;

            }

            break;

        default: break;

        }

        break;

        default: break;

    }

    return size;

}

void dbgthread(void* arg0, void* arg1, void* arg2, void* arg3)

{

    struct scheduler_thread* t;

    while (1)

    {

        wakeup_wait(&dbgwakeup, TIMEOUT_BLOCK);

        for (t = head_thread; t; t = t->thread_next)

            if (t->state == THREAD_DEFUNCT)

            {

                if (t->block_type == THREAD_DEFUNCT_STKOV)

                {

                    if (t->name) cprintf(1, "\n*PANIC*\nStack overflow! (%s)\n", t->name);

                    else cprintf(1, "\n*PANIC*\nStack overflow! (%08X)\n", t);

                }

                t->state = THREAD_DEFUNCT_ACK;

            }

        uint32_t mode = enter_critical_section();

        uint32_t buf[16];

        if (dbgstate == DBGSTATE_ASYNC)

        {

            memcpy(buf, dbgbuf, 64);

            leave_critical_section(mode);

            void* addr = &buf[4];

            int len = 0;

            switch (buf[0])

            {

                case 2:  // RESET

                    shutdown(false);

                    reset();

                case 3:  // POWER OFF

                    if (buf[1]) shutdown(true);

                    power_off();

                    buf[0] = 1;

                    break;

#ifdef HAVE_I2C

                case 8:  // READ I2C

                    len = buf[1] >> 24;

                    i2c_recv(buf[1] & 0xff, (buf[1] >> 8) & 0xff, (buf[1] >> 16) & 0xff,

                             (uint8_t*)&buf[4], len);

                    buf[0] = 1;

                    break;

                case 9:  // WRITE I2C

                    i2c_send(buf[1] & 0xff, (buf[1] >> 8) & 0xff, (buf[1] >> 16) & 0xff,

                             (uint8_t*)&buf[4], buf[1] >> 24);

                    buf[0] = 1;

                    break;

#endif

                case 12:  // CWRITE

                    cwrite(buf[1], (const char*)&buf[4], buf[2]);

                    buf[0] = 1;

                    break;

                case 13:  // CREAD

                    buf[0] = 1;

                    buf[1] = cread(buf[1], (char*)&buf[4], buf[2], 0);

                    break;

                case 14:  // CFLUSH

                    cflush(buf[1]);

                    buf[0] = 1;

                    break;

                case 21:  // EXECIMAGE

                {

                    int argc = buf[2] >> 24;

                    if (!buf[3])

                    {

                        buf[3] = (uint32_t)&buf[4];

                        int i;

                        for (i = 0; i < argc; i++) buf[i + 4] += buf[3];

                    }

                    buf[0] = 1;

                    buf[1] = (uint32_t)execimage((void*)buf[1], buf[2] & 0x10000, argc, (const char* const*)buf[3]);

                    break;

                }

#ifdef HAVE_BOOTFLASH

                case 22:  // READ BOOT FLASH

                    bootflash_readraw((void*)buf[1], buf[2], buf[3]);

                    buf[0] = 1;

                    break;

                case 23:  // WRITE BOOT FLASH

                    bootflash_writeraw((void*)buf[1], buf[2], buf[3]);

                    buf[0] = 1;

                    break;

#endif

                case 24:  // EXECFIRMWARE

                    shutdown(false);

                    execfirmware((void*)buf[1], (void*)buf[2], (size_t)buf[3]);

                    buf[0] = 1;

                    break;

#ifdef HAVE_HWKEYAES

                case 25:  // HWKEYAES

                    hwkeyaes((enum hwkeyaes_direction)((uint8_t*)buf)[4], ((uint16_t*)buf)[3], (void*)buf[2], buf[3]);

                    buf[0] = 1;

                    break;

#endif

#ifdef HAVE_HMACSHA1

                case 26:  // HMACSHA1

                    hmacsha1((void*)buf[1], buf[2], (void*)buf[3]);

                    buf[0] = 1;

                    break;

#endif

#ifdef HAVE_STORAGE

                case 27:  // STORAGE_GET_INFO

                    buf[0] = 1;

                    storage_get_info(buf[1], (struct storage_info*)&buf[4]);

                    buf[1] = 1;

                    len = (sizeof(struct storage_info) + 3) / 4 * 4;

                    break;

                case 28:  // STORAGE_READ_SECTORS_MD

                    buf[0] = 1;

                    buf[1] = (uint32_t)storage_read_sectors_md(buf[1], buf[2] | (((uint64_t)(buf[3]) << 32)),

                                                               buf[4], (void*)(buf[5]));

                    break;

                case 29:  // STORAGE_WRITE_SECTORS_MD

                    buf[0] = 1;

                    buf[1] = (uint32_t)storage_write_sectors_md(buf[1], buf[2] | (((uint64_t)(buf[3]) << 32)),

                                                                buf[4], (void*)(buf[5]));

                    break;

                case 30:  // FILE_OPEN

                {

                    buf[0] = 1;

                    if (!buf[3]) buf[3] = (uint32_t)&buf[4];

                    int fd = file_open((char*)buf[3], (int)buf[1]);

                    if (fd > 0) reown_file(fd, KERNEL_OWNER(KERNEL_OWNER_USB_MONITOR));

                    buf[1] = (uint32_t)fd;

                    break;

                }

                case 31:  // FILESIZE

                    buf[0] = 1;

                    buf[1] = (uint32_t)filesize((int)buf[1]);

                    break;

                case 32:  // READ

                    buf[0] = 1;

                    buf[1] = (uint32_t)read((int)buf[1], (void*)buf[2], (size_t)buf[3]);

                    break;

                case 33:  // WRITE

                    buf[0] = 1;

                    buf[1] = (uint32_t)write((int)buf[1], (void*)buf[2], (size_t)buf[3]);

                    break;

                case 34:  // LSEEK

                    buf[0] = 1;

                    buf[1] = (uint32_t)lseek((int)buf[1], (off_t)buf[2], (int)buf[3]);

                    break;

                case 35:  // FTRUNCATE

                    buf[0] = 1;

                    buf[1] = (uint32_t)ftruncate((int)buf[1], (off_t)buf[2]);

                    break;

                case 36:  // FSYNC

                    buf[0] = 1;

                    buf[1] = (uint32_t)fsync((int)buf[1]);

                    break;

                case 37:  // CLOSE

                    buf[0] = 1;

                    buf[1] = (uint32_t)close((int)buf[1]);

                    break;

                case 38:  // CLOSE_MONITOR_FILES

                    buf[0] = 1;

                    buf[1] = (uint32_t)close_all_of_process(KERNEL_OWNER(KERNEL_OWNER_USB_MONITOR));

                    break;

                case 39:  // RELEASE_FILES

                    buf[0] = 1;

                    buf[1] = (uint32_t)release_files((int)buf[1]);

                    break;

                case 40:  // REMOVE

                    buf[0] = 1;

                    if (!buf[3]) buf[3] = (uint32_t)&buf[4];

                    buf[1] = (uint32_t)remove((char*)buf[3]);

                    break;

                case 41:  // RENAME

                    buf[0] = 1;

                    buf[1] = (uint32_t)rename((char*)buf[2], (char*)buf[3]);

                    break;

                case 42:  // OPENDIR

                {

                    buf[0] = 1;

                    if (!buf[3]) buf[3] = (uint32_t)&buf[4];

                    DIR* dir = opendir((char*)buf[3]);

                    if (dir > 0) reown_dir(dir, KERNEL_OWNER(KERNEL_OWNER_USB_MONITOR));

                    buf[1] = (uint32_t)dir;

                    break;

                }

                case 43:  // READDIR

                    buf[0] = 1;

                    buf[3] = (uint32_t)readdir((DIR*)buf[1]);

                    buf[1] = 1;

                    buf[2] = MAX_PATH;

                    break;

                case 44:  // CLOSEDIR

                    buf[0] = 1;

                    buf[1] = (uint32_t)closedir((DIR*)buf[1]);

                    break;

                case 45:  // CLOSE_MONITOR_DIRS

                    buf[0] = 1;

                    buf[1] = (uint32_t)closedir_all_of_process(KERNEL_OWNER(KERNEL_OWNER_USB_MONITOR));

                    break;

                case 46:  // RELEASE_DIRS

                    buf[0] = 1;

                    buf[1] = (uint32_t)release_dirs((int)buf[1]);

                    break;

                case 47:  // MKDIR

                    buf[0] = 1;

                    if (!buf[3]) buf[3] = (uint32_t)&buf[4];

                    buf[1] = (uint32_t)mkdir((char*)buf[3]);

                    break;

                case 48:  // RMDIR

                    buf[0] = 1;

                    if (!buf[3]) buf[3] = (uint32_t)&buf[4];

                    buf[1] = (uint32_t)rmdir((char*)buf[3]);

                    break;

                case 49:  // ERRNO

                    buf[0] = 1;

                    buf[1] = (uint32_t)errno;

                    break;

#ifdef HAVE_HOTSWAP

                case 50:  // DISK_MOUNT

                    buf[0] = 1;

                    buf[1] = (uint32_t)disk_mount((int)buf[1]);

                    break;

                case 51:  // DISK_UNMOUNT

                    buf[0] = 1;

                    buf[1] = (uint32_t)disk_unmount((int)buf[1]);

                    break;

#endif

                case 58:  // FAT_ENABLE_FLUSHING

                    buf[0] = 1;

                    fat_enable_flushing((bool)buf[1]);

                    break;

                case 59:  // FAT_SIZE

                    buf[0] = 1;

                    fat_size_mv(buf[1], &buf[1], &buf[2]);

                    break;

#endif

                case 52:  // MALLOC

                    buf[0] = 1;

                    buf[1] = (uint32_t)malloc((size_t)buf[1]);

                    if (buf[1]) reownalloc(buf[1], KERNEL_OWNER(KERNEL_OWNER_USB_MONITOR));

                    break;

                case 53:  // MEMALIGN

                    buf[0] = 1;

                    buf[1] = (uint32_t)memalign((size_t)buf[1], (size_t)buf[2]);

                    if (buf[1]) reownalloc(buf[1], KERNEL_OWNER(KERNEL_OWNER_USB_MONITOR));

                    break;

                case 54:  // REALLOC

                    buf[0] = 1;

                    buf[1] = (uint32_t)realloc((void*)buf[1], (size_t)buf[2]);

                    break;

                case 55:  // REOWNALLOC

                    buf[0] = 1;

                    reownalloc((void*)buf[1], (void*)buf[2]);

                    break;

                case 56:  // FREE

                    buf[0] = 1;

                    free((void*)buf[1]);

                    break;

                case 57:  // FREE MONITOR ALLOCATIONS

                    buf[0] = 1;

                    buf[1] = (uint32_t)free_all_of_thread(KERNEL_OWNER(KERNEL_OWNER_USB_MONITOR));

                    break;

#ifdef HAVE_RTC

                case 60:  // RTC READ

                    buf[0] = 1;

                    rtc_read_datetime((struct rtc_datetime*)&buf[1]);

                    break;

                case 61:  // RTC WRITE

                    buf[0] = 1;

                    rtc_write_datetime((const struct rtc_datetime*)&buf[1]);

                    break;

#endif

                default:

#ifdef USB_HAVE_TARGET_SPECIFIC_REQUESTS

                    if (buf[0] >= 0xffff0000)

                        len = usb_target_handle_request(buf, sizeof(buf), &addr);

                    else buf[0] = 2;

#else

                    buf[0] = 2;

#endif

                    break;

            }

            mode = enter_critical_section();

            if (dbgstate == DBGSTATE_ASYNC)

            {

                usb_ep0_start_tx(dbgusb, NULL, 0, NULL);

                dbgstate = DBGSTATE_RESPOND;

                dbgmemaddr = addr;

                dbgmemlen = len;

                memcpy(dbgbuf, buf, 16);

            }

        }

        dbgbusy = false;

        leave_critical_section(mode);

    }

}

void usbdebug_init(void)

{

    wakeup_init(&dbgwakeup);

    dbgconsendreadidx = 0;

    dbgconsendwriteidx = 0;

    dbgconrecvreadidx = 0;

    dbgconrecvwriteidx = 0;

    wakeup_init(&dbgconsendwakeup);

    wakeup_init(&dbgconrecvwakeup);

    dbgenabled = false;

    dbgbusy = false;

    dbgstate = DBGSTATE_IDLE;

    dbgconsoleattached = false;

    thread_create(&dbgthread_handle, "monitor worker", dbgthread, dbgstack,

                  sizeof(dbgstack), CORE_THREAD, 255, true, NULL, NULL, NULL, NULL);

}

int dbgconsole_getfree() ICODE_ATTR;

int dbgconsole_getfree()

{

    int free = dbgconsendreadidx - dbgconsendwriteidx - 1;

    if (free < 0) free += sizeof(dbgconsendbuf);

    return free;

}

int dbgconsole_makespace(int length, bool safe) ICODE_ATTR;

int dbgconsole_makespace(int length, bool safe)

{

    int free = dbgconsole_getfree();

    while (!free && dbgconsoleattached && !safe)

    {

        dbgconsoleattached = false;

        wakeup_wait(&dbgconsendwakeup, 2000000);

        free = dbgconsole_getfree();

    }

    if (free) return free > length ? length : free;

    if (length > sizeof(dbgconsendbuf) - 17) length = sizeof(dbgconsendbuf) - 17;

    uint32_t mode = enter_critical_section();

    dbgconsendreadidx += length;

    if (dbgconsendreadidx >= sizeof(dbgconsendbuf))

        dbgconsendreadidx -= sizeof(dbgconsendbuf);

    int offset = 0;

    int idx = dbgconsendreadidx;

    if (idx + 16 >= sizeof(dbgconsendbuf))

    {

        offset = sizeof(dbgconsendbuf) - dbgconsendreadidx;

        memcpy(&dbgconsendbuf[dbgconsendreadidx], dbgconoverflowstr, offset);

        idx = 0;

    }

    if (offset != 16) memcpy(&dbgconsendbuf[idx], &dbgconoverflowstr[offset], 16 - offset);

    leave_critical_section(mode);

    return length;

}

void dbgconsole_putc_internal(char string, bool safe)

{

    dbgconsole_makespace(1, safe);

    dbgconsendbuf[dbgconsendwriteidx++] = string;

    if (dbgconsendwriteidx >= sizeof(dbgconsendbuf))

        dbgconsendwriteidx -= sizeof(dbgconsendbuf);

}

void dbgconsole_putc(char string)

{

    dbgconsole_putc_internal(string, false);

}

void dbgconsole_sputc(char string)

{

    dbgconsole_putc_internal(string, true);

}

void dbgconsole_write_internal(const char* string, size_t length, bool safe)

{

    while (length)

    {

        int space = dbgconsole_makespace(length, safe);

        if (dbgconsendwriteidx + space >= sizeof(dbgconsendbuf))

        {

            int bytes = sizeof(dbgconsendbuf) - dbgconsendwriteidx;

            memcpy(&dbgconsendbuf[dbgconsendwriteidx], string, bytes);

            dbgconsendwriteidx = 0;

            string = &string[bytes];

            space -= bytes;

            length -= bytes;

        }

        if (space) memcpy(&dbgconsendbuf[dbgconsendwriteidx], string, space);

        dbgconsendwriteidx += space;

        string = &string[space];

        length -= space;

    }

}

void dbgconsole_write(const char* string, size_t length)

{

    dbgconsole_write_internal(string, length, false);

}

void dbgconsole_swrite(const char* string, size_t length)

{

    dbgconsole_write_internal(string, length, true);

}

void dbgconsole_puts(const char* string)

{

    dbgconsole_write(string, strlen(string));

}

void dbgconsole_sputs(const char* string)

{

    dbgconsole_swrite(string, strlen(string));

}

int dbgconsole_getavailable() ICODE_ATTR;

int dbgconsole_getavailable()

{

    int available = dbgconrecvwriteidx - dbgconrecvreadidx;

    if (available < 0) available += sizeof(dbgconrecvbuf);

    return available;

}

int dbgconsole_getc(int timeout)

{

    if (!dbgconsole_getavailable())

    {

        wakeup_wait(&dbgconrecvwakeup, TIMEOUT_NONE);

        if (!dbgconsole_getavailable())

        {

            wakeup_wait(&dbgconrecvwakeup, timeout);

            if (!dbgconsole_getavailable()) return -1;

        }

    }

    int byte = dbgconrecvbuf[dbgconrecvreadidx++];

    if (dbgconrecvreadidx >= sizeof(dbgconrecvbuf))

        dbgconrecvreadidx -= sizeof(dbgconrecvbuf);

    return byte;

}

int dbgconsole_read(char* buffer, size_t length, int timeout)

{

    if (!length) return 0;

    int available = dbgconsole_getavailable();

    if (!available)

    {

        wakeup_wait(&dbgconrecvwakeup, TIMEOUT_NONE);

        int available = dbgconsole_getavailable();

        if (!available)

        {

            wakeup_wait(&dbgconrecvwakeup, timeout);

            int available = dbgconsole_getavailable();

            if (!available) return 0;

        }

    }

    if (available > length) available = length;

    int left = available;

    if (dbgconrecvreadidx + available >= sizeof(dbgconrecvbuf))

    {

        int bytes = sizeof(dbgconrecvbuf) - dbgconrecvreadidx;

        memcpy(buffer, &dbgconrecvbuf[dbgconrecvreadidx], bytes);

        dbgconrecvreadidx = 0;

        buffer = &buffer[bytes];

        left -= bytes;

    }

    if (left) memcpy(buffer, &dbgconrecvbuf[dbgconrecvreadidx], left);

    dbgconrecvreadidx += left;

    return available;

}