source: branches/samba-3.0/source/ndpsmb/os2api.c@ 635

#define INCL_LONGLONG
#define INCL_DOS
#define INCL_DOSPROCESS
#define INCL_DOSPROFILE
#define INCL_DOSMISC
#define INCL_DOSMODULEMGR
//_SMB_H
#include <os2.h>
#include <stdio.h>
#include <stdlib.h>
#include <errno.h>
#include <types.h>
#include <InnoTekLIBC/backend.h>
#define PRINTF_ATTRIBUTE(a1, a2) __attribute__ ((format (__printf__, a1, a2)))
#include "local.h"
#include "xfile.h"
#include "pstring.h"
#include "debug.h"

APIRET (APIENTRY * xDosPerfSysCall)(ULONG ulCommand, ULONG ulParm1, ULONG ulParm2, ULONG ulParm3) = NULL;
APIRET (APIENTRY * xDosQuerySysState)(ULONG func, ULONG arg1, ULONG pid, ULONG _res_, PVOID buf, ULONG bufsz) = NULL;
HMODULE doscalls = 0;

int os2_init(void)
{
        HMODULE dllhandle;
        int rc = 0;
        char failname[CCHMAXPATH+1];
        if (doscalls == 0) 
        {
                rc = DosLoadModule(failname, sizeof(failname), "DOSCALL1", &doscalls);
                if (rc)
                {
                        DEBUG(0,("Cant load DOSCALL1: %s (%d)\n", failname, rc));
                        return rc;
                }
                rc = DosQueryProcAddr(doscalls, 976, NULL, (PFN *)&xDosPerfSysCall);
                if (rc)
                {
                        DEBUG(0,("Cant load xDosPerfSysCall (%d)\n", rc));
                        xDosPerfSysCall = NULL;
                }
                rc = DosQueryProcAddr(doscalls, 368, NULL, (PFN *)&xDosQuerySysState);
                if (rc)
                {
                        DEBUG(0,("Cant load xDosQuerySysState (%d)\n", rc));
                        xDosQuerySysState = NULL;
                }
        }
        return 0;
}

int os2_ftruncate(int fd, off_t size)
{
        // We call there __libc_Back_ioFileSizeSet directly instead of 
        // ftruncate to force it not to zero expanding files to optimize
        // samba performance when copying files
        int rc = __libc_Back_ioFileSizeSet(fd, size, 0);
        if (rc < 0)
        {
                errno = -rc;
                return -1;
        }
        return 0;
}

#define   CMD_KI_RDCNT    (0x63)

typedef struct _CPUUTIL {
    ULONG ulTimeLow;            /* Low 32 bits of time stamp      */
    ULONG ulTimeHigh;           /* High 32 bits of time stamp     */
    ULONG ulIdleLow;            /* Low 32 bits of idle time       */
    ULONG ulIdleHigh;           /* High 32 bits of idle time      */
    ULONG ulBusyLow;            /* Low 32 bits of busy time       */
    ULONG ulBusyHigh;           /* High 32 bits of busy time      */
    ULONG ulIntrLow;            /* Low 32 bits of interrupt time  */
    ULONG ulIntrHigh;           /* High 32 bits of interrupt time */
} CPUUTIL;

// very simple random data gatherer derived from openssl
void os2_randget(char * buffer, int length)
{
        QWORD qwTime;
        ULONG SysVars[QSV_FOREGROUND_PROCESS];
        int done = 0;

        if (!buffer || length <= 0)
        {
                return;
        }

        DosTmrQueryTime(&qwTime);
        memcpy(buffer, &qwTime, sizeof(qwTime) > length ? length : sizeof(qwTime));
        done += sizeof(qwTime);
        if (done >= length)
        {
                return;
        }

        if (xDosPerfSysCall) 
        {
                CPUUTIL util;
                if (xDosPerfSysCall(CMD_KI_RDCNT, (ULONG)&util, 0, 0) == 0) 
                {
                        memcpy(buffer + done, &util, sizeof(util) > length - done ? length - done : sizeof(util));
                        done += sizeof(util);
                        if (done >= length)
                        {
                                return;
                        }
                }
        }

#if 0
        if (xDosQuerySysState) 
        {
                char *tmp = (char *)malloc(256 * 1024);
                if (tmp)
                {
                        if (xDosQuerySysState(0x1F, 0, 0, 0, tmp, 256 * 1024) == 0)
                        {
                                memcpy(buffer + done, tmp, 256 * 1024 > length - done ? length - done : 256 * 1024);
                                done += 256 * 1024;
                        }
                        free(tmp);
                }
        }
        if (done >= length)
        {
                return;
        }
#endif

        DosQuerySysInfo(1, QSV_FOREGROUND_PROCESS, SysVars, sizeof(SysVars));
        memcpy(buffer + done, SysVars, sizeof(SysVars) > length - done ? length - done : sizeof(SysVars));
}

#include <InnoTekLIBC/tcpip.h>
#undef close
int debug_close(char * file, char * function, int line, int h )
{
        int os2socket = -1;
        PLIBCSOCKETFH   pFHSocket = __libc_TcpipFH(h);  
        if (pFHSocket) os2socket = pFHSocket->iSocket;
        DEBUG(0,("close(%d (%d)) on %s:%s(%d)\n", h, os2socket, file, function, line));
        return close(h);
}