smb_fio.c

/*
  Copyright 2009-2010, jimmikaelkael
  Licenced under Academic Free License version 3.0
*/
 
#include "types.h"
#include "defs.h"
#include "irx.h"
#include "intrman.h"
#include "iomanX.h"
#include "io_common.h"
#include "sifman.h"
#include "stdio.h"
#include "sysclib.h"
#include "thbase.h"
#include "thsemap.h"
#include "errno.h"
#include "ps2smb.h"
 
#include "smb_fio.h"
#include "smb.h"
#include "auth.h"
#include "debug.h"
 
int smbman_io_sema;
 
IOMANX_RETURN_VALUE_IMPL(EIO);
 
// driver ops func tab
static iop_device_ops_t smbman_ops = {
    &smb_init, // init
    &smb_deinit, // deinit
    IOMANX_RETURN_VALUE(EIO), // format
    &smb_open, // open
    &smb_close, // close
    &smb_read, // read
    &smb_write, // write
    &smb_lseek, // lseek
    IOMANX_RETURN_VALUE(EIO), // ioctl
    &smb_remove, // remove
    &smb_mkdir, // mkdir
    &smb_rmdir, // rmdir
    &smb_dopen, // dopen
    &smb_dclose, // dclose
    &smb_dread, // dread
    &smb_getstat, // getstat
    IOMANX_RETURN_VALUE(EIO), // chstat
    &smb_rename, // rename
    &smb_chdir, // chdir
    IOMANX_RETURN_VALUE(EIO), // sync
    IOMANX_RETURN_VALUE(EIO), // mount
    IOMANX_RETURN_VALUE(EIO), // umount
    &smb_lseek64, // lseek64
    &smb_devctl, // devctl
    IOMANX_RETURN_VALUE(EIO), // symlink
    IOMANX_RETURN_VALUE(EIO), // readlink
    IOMANX_RETURN_VALUE(EIO), // ioctl2
};
 
// driver descriptor
static iop_device_t smbdev = {
    "smb",
    IOP_DT_FS | IOP_DT_FSEXT,
    1,
    "SMB",
    &smbman_ops,
};
 
#define SMB_NAME_MAX 256
 
typedef struct
{
    iop_file_t *f;
    int smb_fid;
    s64 filesize;
    s64 position;
    u32 mode;
    char name[SMB_NAME_MAX];
} FHANDLE;
 
#define MAX_FDHANDLES 32
FHANDLE smbman_fdhandles[MAX_FDHANDLES];
 
#define SMB_SEARCH_BUF_MAX 4096
#define SMB_PATH_MAX       1024
 
static ShareEntry_t ShareList;
static u8 SearchBuf[SMB_SEARCH_BUF_MAX];
static char smb_curdir[SMB_PATH_MAX];
static char smb_curpath[SMB_PATH_MAX];
static char smb_secpath[SMB_PATH_MAX];
 
static int keepalive_mutex  = -1;
static int keepalive_inited = 0;
static int keepalive_locked = 1;
static int keepalive_tid;
static iop_sys_clock_t keepalive_sysclock;
 
static int UID = -1;
static int TID = -1;
 
static smbLogOn_in_t glogon_info;
static smbOpenShare_in_t gopenshare_info;
 
static int smb_LogOn(smbLogOn_in_t *logon);
static int smb_OpenShare(smbOpenShare_in_t *openshare);
 
//-------------------------------------------------------------------------
// Timer Interrupt handler for Echoing the server every 3 seconds, when
// not already doing IO, and counting after an IO operation has finished
//
static unsigned int timer_intr_handler(void *args)
{
    iSignalSema(keepalive_mutex);
    iSetAlarm(&keepalive_sysclock, timer_intr_handler, NULL);
 
    return (unsigned int)args;
}
 
//-------------------------------------------------------------------------
static void keepalive_deinit(void)
{
    int oldstate;
 
    // Cancel the alarm
    if (keepalive_inited) {
        CpuSuspendIntr(&oldstate);
        CancelAlarm(timer_intr_handler, NULL);
        CpuResumeIntr(oldstate);
        keepalive_inited = 0;
    }
}
 
//-------------------------------------------------------------------------
static void keepalive_init(void)
{
    // set up the alarm
    if ((!keepalive_inited) && (!keepalive_locked)) {
        keepalive_deinit();
        SetAlarm(&keepalive_sysclock, timer_intr_handler, NULL);
        keepalive_inited = 1;
    }
}
 
//-------------------------------------------------------------------------
static void keepalive_lock(void)
{
    keepalive_locked = 1;
}
 
//-------------------------------------------------------------------------
static void keepalive_unlock(void)
{
    keepalive_locked = 0;
}
 
//-------------------------------------------------------------------------
static void smb_io_lock(void)
{
    keepalive_deinit();
 
    WaitSema(smbman_io_sema);
}
 
//-------------------------------------------------------------------------
static void smb_io_unlock(void)
{
    SignalSema(smbman_io_sema);
 
    keepalive_init();
}
 
//-------------------------------------------------------------------------
static void keepalive_thread(void *args)
{
    int opened_share = 0;
 
    (void)args;
 
    while (1) {
        int r;
 
        // wait for keepalive mutex
        WaitSema(keepalive_mutex);
 
        // ensure no IO is already processing
        WaitSema(smbman_io_sema);
 
        // echo the SMB server
        r = smb_Echo("PS2 KEEPALIVE ECHO", 18);
        if (r < 0) {
            keepalive_lock();
 
            if (TID != -1)
                opened_share = 1;
 
            if (UID != -1) {
                r = smb_LogOn((smbLogOn_in_t *)&glogon_info);
                if (r == 0) {
                    if (opened_share)
                        smb_OpenShare((smbOpenShare_in_t *)&gopenshare_info);
                }
            }
 
            keepalive_unlock();
        }
 
        SignalSema(smbman_io_sema);
    }
}
 
//--------------------------------------------------------------
int smb_init(iop_device_t *dev)
{
    iop_thread_t thread;
 
    (void)dev;
 
    // create a mutex for IO ops
    smbman_io_sema = CreateMutex(IOP_MUTEX_UNLOCKED);
 
    // create a mutex for keep alive
    keepalive_mutex = CreateMutex(IOP_MUTEX_LOCKED);
 
    // set the keepalive timer (3 seconds)
    USec2SysClock(3000 * 1000, &keepalive_sysclock);
 
    // starting the keepalive thead
    thread.attr      = TH_C;
    thread.option    = 0;
    thread.thread    = (void *)keepalive_thread;
    thread.stacksize = 0x600;
    thread.priority  = 0x64;
 
    keepalive_tid = CreateThread(&thread);
    StartThread(keepalive_tid, NULL);
 
    return 0;
}
 
//--------------------------------------------------------------
int smb_initdev(void)
{
    int i;
 
    DelDrv(smbdev.name);
    if (AddDrv((iop_device_t *)&smbdev))
        return 1;
 
    for (i = 0; i < MAX_FDHANDLES; i++) {
        FHANDLE *fh;
 
        fh           = (FHANDLE *)&smbman_fdhandles[i];
        fh->f        = NULL;
        fh->smb_fid  = -1;
        fh->filesize = 0;
        fh->position = 0;
        fh->mode     = 0;
    }
 
    return 0;
}
 
//--------------------------------------------------------------
int smb_deinit(iop_device_t *dev)
{
    (void)dev;
 
    keepalive_deinit();
    DeleteThread(keepalive_tid);
 
    DeleteSema(smbman_io_sema);
 
    DeleteSema(keepalive_mutex);
    keepalive_mutex = -1;
 
    return 0;
}
 
//--------------------------------------------------------------
static FHANDLE *smbman_getfilefreeslot(void)
{
    int i;
 
    for (i = 0; i < MAX_FDHANDLES; i++) {
        FHANDLE *fh;
 
        fh = (FHANDLE *)&smbman_fdhandles[i];
        if (fh->f == NULL)
            return fh;
    }
 
    return 0;
}
 
//--------------------------------------------------------------
static char *prepare_path(const char *path, char *full_path, int max_path)
{
    const char *p, *p2;
    int i;
 
    // Reserve space for 2 backslashes and a NULL.
    strncpy(full_path, smb_curdir, max_path - 3);
    strcat(full_path, "\\");
 
    // Skip all leading slashes and backslashes.
    p = path;
    while ((*p == '\\') || (*p == '/'))
        p++;
 
    // Locate the end of the path, ignoring any trailing slashes and backslashes.
    p2 = &path[strlen(path)];
    while ((*p2 == '\\') || (*p2 == '/'))
        p2--;
 
    // Copy path. Reserve space for a backslash and a NULL
    for (i = strlen(full_path); (p <= p2) && (max_path - i - 2 > 0); p++, i++) { // Convert all slashes along the path to backslashes.
        full_path[i] = (*p == '/') ? '\\' : *p;
    }
 
    // Append a backslash and null-terminate.
    full_path[i]     = '\\';
    full_path[i + 1] = '\0';
 
    return full_path;
}
 
//--------------------------------------------------------------
int smb_open(iop_file_t *f, const char *filename, int flags, int mode)
{
    int r = 0;
    FHANDLE *fh;
    s64 filesize;
 
    (void)mode;
 
    if (!filename)
        return -ENOENT;
 
    if ((UID == -1) || (TID == -1))
        return -ENOTCONN;
 
    char *path = prepare_path(filename, smb_curpath, SMB_PATH_MAX);
 
    smb_io_lock();
 
    fh = smbman_getfilefreeslot();
    if (fh) {
        r = smb_OpenAndX(UID, TID, path, &filesize, flags);
        if (r >= 0) {
            f->privdata  = fh;
            fh->f        = f;
            fh->smb_fid  = r;
            fh->mode     = flags;
            fh->filesize = filesize;
            fh->position = 0;
            if (fh->mode & O_TRUNC)
                fh->filesize = 0;
            else if (fh->mode & O_APPEND)
                fh->position = filesize;
            strncpy(fh->name, path, SMB_NAME_MAX);
            r = 0;
        }
    } else
        r = -EMFILE;
 
    smb_io_unlock();
 
    return r;
}
 
//--------------------------------------------------------------
int smb_close(iop_file_t *f)
{
    FHANDLE *fh = (FHANDLE *)f->privdata;
    int r       = 0;
 
    if ((UID == -1) || (TID == -1) || (fh->smb_fid == -1))
        return -EBADF;
 
    smb_io_lock();
 
    if (fh) {
        if (fh->mode != O_DIROPEN) {
            r = smb_Close(UID, TID, fh->smb_fid);
            if (r != 0) {
                goto io_unlock;
            }
        }
        memset(fh, 0, sizeof(FHANDLE));
        fh->smb_fid = -1;
        r           = 0;
    }
 
io_unlock:
    smb_io_unlock();
 
    return r;
}
 
//--------------------------------------------------------------
void smb_closeAll(void)
{
    int i;
 
    for (i = 0; i < MAX_FDHANDLES; i++) {
        FHANDLE *fh;
 
        fh = (FHANDLE *)&smbman_fdhandles[i];
        if (fh->smb_fid != -1)
            smb_Close(UID, TID, fh->smb_fid);
    }
}
 
//--------------------------------------------------------------
int smb_lseek(iop_file_t *f, int pos, int where)
{
    return (int)smb_lseek64(f, pos, where);
}
 
//--------------------------------------------------------------
int smb_read(iop_file_t *f, void *buf, int size)
{
    FHANDLE *fh = (FHANDLE *)f->privdata;
    int r;
 
    if ((UID == -1) || (TID == -1) || (fh->smb_fid == -1))
        return -EBADF;
 
    if ((fh->position + size) > fh->filesize)
        size = fh->filesize - fh->position;
 
    smb_io_lock();
 
    r = smb_ReadFile(UID, TID, fh->smb_fid, fh->position, buf, size);
    if (r > 0) {
        fh->position += r;
    }
 
    smb_io_unlock();
 
    return r;
}
 
//--------------------------------------------------------------
int smb_write(iop_file_t *f, void *buf, int size)
{
    FHANDLE *fh = (FHANDLE *)f->privdata;
    int r;
 
    if ((UID == -1) || (TID == -1) || (fh->smb_fid == -1))
        return -EBADF;
 
    if ((!(fh->mode & O_RDWR)) && (!(fh->mode & O_WRONLY)))
        return -EACCES;
 
    smb_io_lock();
 
    r = smb_WriteFile(UID, TID, fh->smb_fid, fh->position, buf, size);
    if (r > 0) {
        fh->position += r;
        if (fh->position > fh->filesize)
            fh->filesize += fh->position - fh->filesize;
    }
 
    smb_io_unlock();
 
    return r;
}
 
//--------------------------------------------------------------
int smb_remove(iop_file_t *f, const char *filename)
{
    int r;
 
    (void)f;
 
    if (!filename)
        return -ENOENT;
 
    if ((UID == -1) || (TID == -1))
        return -ENOTCONN;
 
    char *path = prepare_path(filename, smb_curpath, SMB_PATH_MAX);
 
    smb_io_lock();
 
    DPRINTF("smb_remove: filename=%s\n", filename);
 
    r = smb_Delete(UID, TID, path);
 
    smb_io_unlock();
 
    return r;
}
 
//--------------------------------------------------------------
int smb_mkdir(iop_file_t *f, const char *dirname, int mode)
{
    int r;
 
    (void)f;
    (void)mode;
 
    if (!dirname)
        return -ENOENT;
 
    if ((UID == -1) || (TID == -1))
        return -ENOTCONN;
 
    char *path = prepare_path(dirname, smb_curpath, SMB_PATH_MAX);
 
    smb_io_lock();
 
    r = smb_ManageDirectory(UID, TID, path, SMB_COM_CREATE_DIRECTORY);
 
    smb_io_unlock();
 
    return r;
}
 
//--------------------------------------------------------------
int smb_rmdir(iop_file_t *f, const char *dirname)
{
    int r;
    PathInformation_t info;
 
    (void)f;
 
    if (!dirname)
        return -ENOENT;
 
    if ((UID == -1) || (TID == -1))
        return -ENOTCONN;
 
    char *path = prepare_path(dirname, smb_curpath, SMB_PATH_MAX);
 
    smb_io_lock();
 
    r = smb_QueryPathInformation(UID, TID, &info, path);
    if (r < 0) {
        goto io_unlock;
    }
    if (!(info.FileAttributes & EXT_ATTR_DIRECTORY)) {
        r = -ENOTDIR;
        goto io_unlock;
    }
 
    r = smb_ManageDirectory(UID, TID, path, SMB_COM_DELETE_DIRECTORY);
 
io_unlock:
    smb_io_unlock();
 
    return r;
}
 
//--------------------------------------------------------------
static void FileTimeToDate(u64 FileTime, u8 *datetime)
{
    u8 daysPerMonth[12] = {31, 28, 31, 30, 31, 30, 31, 31, 30, 31, 30, 31};
    int i;
    u64 time;
    u16 years, days;
    u8 leapdays, months, hours, minutes, seconds;
 
    time = FileTime / 10000000; // convert to seconds from 100-nanosecond intervals
 
    years = (u16)(time / ((u64)60 * 60 * 24 * 365)); // hurray for interger division
    time -= years * ((u64)60 * 60 * 24 * 365);       // truncate off the years
 
    leapdays = (years / 4) - (years / 100) + (years / 400);
    years += 1601; // add base year from FILETIME struct;
 
    days = (u16)(time / (60 * 60 * 24));
    time -= (unsigned int)days * (60 * 60 * 24);
    days -= leapdays;
 
    if ((years % 4) == 0 && ((years % 100) != 0 || (years % 400) == 0))
        daysPerMonth[1]++;
 
    months = 0;
    for (i = 0; i < 12; i++) {
        if (days > daysPerMonth[i]) {
            days -= daysPerMonth[i];
            months++;
        } else
            break;
    }
 
    if (months >= 12) {
        months -= 12;
        years++;
    }
    hours = (u8)(time / (60 * 60));
    time -= (u16)hours * (60 * 60);
 
    minutes = (u8)(time / 60);
    time -= minutes * 60;
 
    seconds = (u8)(time);
 
    datetime[0] = 0;
    datetime[1] = seconds;
    datetime[2] = minutes;
    datetime[3] = hours;
    datetime[4] = days + 1;
    datetime[5] = months + 1;
    datetime[6] = (u8)(years & 0xFF);
    datetime[7] = (u8)((years >> 8) & 0xFF);
}
 
static void smb_statFiller(const PathInformation_t *info, iox_stat_t *stat)
{
    FileTimeToDate(info->Created, stat->ctime);
    FileTimeToDate(info->LastAccess, stat->atime);
    FileTimeToDate(info->Change, stat->mtime);
 
    stat->size   = (int)(info->EndOfFile & 0xffffffff);
    stat->hisize = (int)((info->EndOfFile >> 32) & 0xffffffff);
 
    stat->mode = (info->FileAttributes & EXT_ATTR_DIRECTORY) ? FIO_S_IFDIR : FIO_S_IFREG;
}
 
//--------------------------------------------------------------
int smb_dopen(iop_file_t *f, const char *dirname)
{
    int r = 0;
    PathInformation_t info;
    FHANDLE *fh;
 
    if (!dirname)
        return -ENOENT;
 
    if ((UID == -1) || (TID == -1))
        return -ENOTCONN;
 
    char *path = prepare_path(dirname, smb_curpath, SMB_PATH_MAX);
 
    smb_io_lock();
 
    // test if the dir exists
    r = smb_QueryPathInformation(UID, TID, &info, path);
    if (r < 0) {
        goto io_unlock;
    }
 
    if (!(info.FileAttributes & EXT_ATTR_DIRECTORY)) {
        r = -ENOTDIR;
        goto io_unlock;
    }
 
    fh = smbman_getfilefreeslot();
    if (fh) {
        f->privdata  = fh;
        fh->f        = f;
        fh->mode     = O_DIROPEN;
        fh->filesize = 0;
        fh->position = 0;
 
        strncpy(fh->name, path, 255);
        if (fh->name[strlen(fh->name) - 1] != '\\')
            strcat(fh->name, "\\");
        strcat(fh->name, "*");
 
        r = 0;
    } else
        r = -EMFILE;
 
io_unlock:
    smb_io_unlock();
 
    return r;
}
 
//--------------------------------------------------------------
int smb_dclose(iop_file_t *f)
{
    return smb_close(f);
}
 
//--------------------------------------------------------------
int smb_dread(iop_file_t *f, iox_dirent_t *dirent)
{
    FHANDLE *fh = (FHANDLE *)f->privdata;
    int r;
 
    if ((UID == -1) || (TID == -1))
        return -ENOTCONN;
 
    smb_io_lock();
 
    memset((void *)dirent, 0, sizeof(iox_dirent_t));
 
    SearchInfo_t *info = (SearchInfo_t *)SearchBuf;
 
    if (fh->smb_fid == -1) {
        r = smb_FindFirstNext2(UID, TID, fh->name, TRANS2_FIND_FIRST2, info);
        if (r < 0) {
            goto io_unlock;
        }
        fh->smb_fid = info->SID;
        r           = 1;
    } else {
        info->SID = fh->smb_fid;
        r         = smb_FindFirstNext2(UID, TID, NULL, TRANS2_FIND_NEXT2, info);
        if (r < 0) {
            goto io_unlock;
        }
        r = 1;
    }
 
    if (r == 1) {
        smb_statFiller(&info->fileInfo, &dirent->stat);
        strncpy(dirent->name, info->FileName, SMB_NAME_MAX);
    }
 
io_unlock:
    smb_io_unlock();
 
    return r;
}
 
//--------------------------------------------------------------
int smb_getstat(iop_file_t *f, const char *filename, iox_stat_t *stat)
{
    int r;
    PathInformation_t info;
 
    (void)f;
 
    if (!filename)
        return -ENOENT;
 
    if ((UID == -1) || (TID == -1))
        return -ENOTCONN;
 
    char *path = prepare_path(filename, smb_curpath, SMB_PATH_MAX);
 
    smb_io_lock();
 
    memset((void *)stat, 0, sizeof(iox_stat_t));
 
    r = smb_QueryPathInformation(UID, TID, &info, path);
    if (r < 0) {
        goto io_unlock;
    }
 
    smb_statFiller(&info, stat);
 
io_unlock:
    smb_io_unlock();
 
    return r;
}
 
//--------------------------------------------------------------
int smb_rename(iop_file_t *f, const char *oldname, const char *newname)
{
    int r;
 
    (void)f;
 
    if ((!oldname) || (!newname))
        return -ENOENT;
 
    if ((UID == -1) || (TID == -1))
        return -ENOTCONN;
 
    char *oldpath = prepare_path(oldname, smb_curpath, SMB_PATH_MAX);
    char *newpath = prepare_path(newname, smb_secpath, SMB_PATH_MAX);
 
    smb_io_lock();
 
    DPRINTF("smb_rename: oldname=%s newname=%s\n", oldname, newname);
 
    r = smb_Rename(UID, TID, oldpath, newpath);
 
    smb_io_unlock();
 
    return r;
}
 
//--------------------------------------------------------------
int smb_chdir(iop_file_t *f, const char *dirname)
{
    int r = 0, i;
    PathInformation_t info;
 
    (void)f;
 
    if (!dirname)
        return -ENOENT;
 
    if ((UID == -1) || (TID == -1))
        return -ENOTCONN;
 
    char *path = prepare_path(dirname, smb_curpath, SMB_PATH_MAX);
 
    smb_io_lock();
 
    if ((path[strlen(path) - 2] == '.') && (path[strlen(path) - 1] == '.')) {
        char *p = (char *)smb_curdir;
        for (i = strlen(p) - 1; i >= 0; i--) {
            if (p[i] == '\\') {
                p[i] = 0;
                break;
            }
        }
    } else if (path[strlen(path) - 1] == '.') {
        smb_curdir[0] = 0;
    } else {
        r = smb_QueryPathInformation(UID, TID, &info, path);
        if (r < 0) {
            goto io_unlock;
        }
 
        if (!(info.FileAttributes & EXT_ATTR_DIRECTORY)) {
            r = -ENOTDIR;
            goto io_unlock;
        }
 
        strncpy(smb_curdir, path, sizeof(smb_curdir) - 1);
    }
 
io_unlock:
    smb_io_unlock();
 
    return r;
}
 
//--------------------------------------------------------------
s64 smb_lseek64(iop_file_t *f, s64 pos, int where)
{
    s64 r;
    FHANDLE *fh = (FHANDLE *)f->privdata;
 
    smb_io_lock();
 
    switch (where) {
        case SEEK_CUR:
            r = fh->position + pos;
            if (r > fh->filesize) {
                r = -EINVAL;
                goto io_unlock;
            }
            break;
        case SEEK_SET:
            r = pos;
            if (fh->filesize < pos) {
                r = -EINVAL;
                goto io_unlock;
            }
            break;
        case SEEK_END:
            r = fh->filesize;
            break;
        default:
            r = -EINVAL;
            goto io_unlock;
    }
 
    fh->position = r;
 
io_unlock:
    smb_io_unlock();
 
    return r;
}
 
//--------------------------------------------------------------
void DMA_sendEE(void *buf, int size, void *EE_addr)
{
    SifDmaTransfer_t dmat;
    int oldstate, id;
 
    dmat.dest = (void *)EE_addr;
    dmat.size = size;
    dmat.src  = (void *)buf;
    dmat.attr = 0;
 
    id = 0;
    while (!id) {
        CpuSuspendIntr(&oldstate);
        id = sceSifSetDma(&dmat, 1);
        CpuResumeIntr(oldstate);
    }
    while (sceSifDmaStat(id) >= 0)
        ;
}
 
//--------------------------------------------------------------
static void smb_GetPasswordHashes(smbGetPasswordHashes_in_t *in, smbGetPasswordHashes_out_t *out)
{
    LM_Password_Hash((const unsigned char *)in->password, (unsigned char *)out->LMhash);
    NTLM_Password_Hash((const unsigned char *)in->password, (unsigned char *)out->NTLMhash);
}
 
//--------------------------------------------------------------
static int smb_LogOff(void);
 
static int smb_LogOn(smbLogOn_in_t *logon)
{
    u32 capabilities;
    int r;
 
    if (UID != -1) {
        smb_LogOff();
    }
 
    r = smb_Connect(logon->serverIP, logon->serverPort);
    if (r < 0)
        return -SMB_DEVCTL_LOGON_ERR_CONN;
 
    r = smb_NegotiateProtocol(&capabilities);
    if (r < 0)
        return -SMB_DEVCTL_LOGON_ERR_PROT;
 
    r = smb_SessionSetupAndX(logon->User, logon->Password, logon->PasswordType, capabilities);
    if (r < 0)
        return -SMB_DEVCTL_LOGON_ERR_LOGON;
 
    UID = r;
 
    memcpy((void *)&glogon_info, (void *)logon, sizeof(smbLogOn_in_t));
 
    keepalive_unlock();
 
    return 0;
}
 
//--------------------------------------------------------------
static int smb_LogOff(void)
{
    int r;
 
    if (UID == -1)
        return -ENOTCONN;
 
    if (TID != -1) {
        smb_closeAll();
        smb_TreeDisconnect(UID, TID);
        TID = -1;
    }
 
    r = smb_LogOffAndX(UID);
    if (r < 0)
        return r;
 
    UID = -1;
 
    keepalive_lock();
 
    smb_Disconnect();
 
    return 0;
}
 
//--------------------------------------------------------------
static int smb_GetShareList(smbGetShareList_in_t *getsharelist)
{
    int i, r, sharecount, shareindex;
    char tree_str[64];
    server_specs_t *specs;
 
    specs = (server_specs_t *)getServerSpecs();
 
    if (TID != -1) {
        smb_TreeDisconnect(UID, TID);
        TID = -1;
    }
 
    // Tree Connect on IPC slot
    sprintf(tree_str, "\\\\%s\\IPC$", specs->ServerIP);
    r = smb_TreeConnectAndX(UID, tree_str, NULL, 0);
    if (r < 0)
        return r;
 
    TID = r;
 
    if (UID == -1)
        return -ENOTCONN;
 
    // does a 1st enum to count shares (+IPC)
    r = smb_NetShareEnum(UID, TID, (ShareEntry_t *)&ShareList, 0, 0);
    if (r < 0)
        return r;
 
    sharecount = r;
    shareindex = 0;
 
    // now we list the following shares if any
    for (i = 0; i < sharecount; i++) {
 
        r = smb_NetShareEnum(UID, TID, (ShareEntry_t *)&ShareList, i, 1);
        if (r < 0)
            return r;
 
        // if the entry is not IPC, we send it on EE, and increment shareindex
        if ((strcmp(ShareList.ShareName, "IPC$")) && (shareindex < getsharelist->maxent)) {
            DMA_sendEE((void *)&ShareList, sizeof(ShareList), (void *)(getsharelist->EE_addr + (shareindex * sizeof(ShareEntry_t))));
            shareindex++;
        }
    }
 
    // disconnect the tree
    r = smb_TreeDisconnect(UID, TID);
    if (r < 0)
        return r;
 
    TID = -1;
 
    // return the number of shares
    return shareindex;
}
 
//--------------------------------------------------------------
static int smb_OpenShare(smbOpenShare_in_t *openshare)
{
    int r;
    char tree_str[274];
    server_specs_t *specs;
 
    specs = (server_specs_t *)getServerSpecs();
 
    if (TID != -1) {
        smb_TreeDisconnect(UID, TID);
        TID = -1;
    }
 
    sprintf(tree_str, "\\\\%s\\%s", specs->ServerIP, openshare->ShareName);
    r = smb_TreeConnectAndX(UID, tree_str, openshare->Password, openshare->PasswordType);
    if (r < 0)
        return r;
 
    TID = r;
 
    memcpy((void *)&gopenshare_info, (void *)openshare, sizeof(smbOpenShare_in_t));
 
    return 0;
}
 
//--------------------------------------------------------------
static int smb_CloseShare(void)
{
    int r;
 
    if (TID == -1)
        return -ENOTCONN;
 
    smb_closeAll();
 
    r = smb_TreeDisconnect(UID, TID);
    if (r < 0)
        return r;
 
    TID = -1;
 
    return 0;
}
 
//--------------------------------------------------------------
static int smb_EchoServer(smbEcho_in_t *echo)
{
    return smb_Echo(echo->echo, echo->len);
}
 
//--------------------------------------------------------------
static int smb_QueryDiskInfo(smbQueryDiskInfo_out_t *querydiskinfo)
{
    if ((UID == -1) || (TID == -1))
        return -ENOTCONN;
 
    return smb_QueryInformationDisk(UID, TID, querydiskinfo);
}
 
//--------------------------------------------------------------
int smb_devctl(iop_file_t *f, const char *devname, int cmd, void *arg, unsigned int arglen, void *bufp, unsigned int buflen)
{
    int r = 0;
 
    (void)f;
    (void)devname;
    (void)arglen;
    (void)buflen;
 
    smb_io_lock();
 
    switch (cmd) {
 
        case SMB_DEVCTL_GETPASSWORDHASHES:
            smb_GetPasswordHashes((smbGetPasswordHashes_in_t *)arg, (smbGetPasswordHashes_out_t *)bufp);
            r = 0;
            break;
 
        case SMB_DEVCTL_LOGON:
            r = smb_LogOn((smbLogOn_in_t *)arg);
            break;
 
        case SMB_DEVCTL_LOGOFF:
            r = smb_LogOff();
            break;
 
        case SMB_DEVCTL_GETSHARELIST:
            r = smb_GetShareList((smbGetShareList_in_t *)arg);
            break;
 
        case SMB_DEVCTL_OPENSHARE:
            r = smb_OpenShare((smbOpenShare_in_t *)arg);
            break;
 
        case SMB_DEVCTL_CLOSESHARE:
            r = smb_CloseShare();
            break;
 
        case SMB_DEVCTL_ECHO:
            r = smb_EchoServer((smbEcho_in_t *)arg);
            break;
 
        case SMB_DEVCTL_QUERYDISKINFO:
            r = smb_QueryDiskInfo((smbQueryDiskInfo_out_t *)bufp);
            break;
 
        default:
            r = -EINVAL;
    }
 
    smb_io_unlock();
 
    return r;
}