nbcmdqueue.c File Reference

#include "netapi32.h"

Include dependency graph for nbcmdqueue.c:

Go to the source code of this file.

Classes
struct	NBCmdQueue

Macros
#define	CANCEL_EVENT_PTR(ncb)   (PHANDLE)((ncb)->ncb_reserve)
#define	NEXT_PTR(ncb)   (PNCB *)((ncb)->ncb_reserve + sizeof(HANDLE))

Functions
	WINE_DEFAULT_DEBUG_CHANNEL (netbios)
struct NBCmdQueue *	NBCmdQueueCreate (HANDLE heap)
UCHAR	NBCmdQueueAdd (struct NBCmdQueue *queue, PNCB ncb)
static PNCB *	NBCmdQueueFindNBC (struct NBCmdQueue *queue, PNCB ncb)
UCHAR	NBCmdQueueCancel (struct NBCmdQueue *queue, PNCB ncb)
UCHAR	NBCmdQueueComplete (struct NBCmdQueue *queue, PNCB ncb, UCHAR retcode)
UCHAR	NBCmdQueueCancelAll (struct NBCmdQueue *queue)
void	NBCmdQueueDestroy (struct NBCmdQueue *queue)

Macro Definition Documentation

CANCEL_EVENT_PTR

#define CANCEL_EVENT_PTR

(

ncb

)

(PHANDLE)((ncb)->ncb_reserve)

Definition at line 29 of file nbcmdqueue.c.

NEXT_PTR

#define NEXT_PTR

(

ncb

)

(PNCB *)((ncb)->ncb_reserve + sizeof(HANDLE))

Definition at line 30 of file nbcmdqueue.c.

Function Documentation

NBCmdQueueAdd()

UCHAR NBCmdQueueAdd	(	struct NBCmdQueue *	queue,
		PNCB	ncb
	)

Definition at line 70 of file nbcmdqueue.c.

{
    UCHAR ret;
 
    TRACE(": queue %p, ncb %p\n", queue, ncb);
 
    if (!queue)
        return NRC_BADDR;
    if (!ncb)
        return NRC_INVADDRESS;
 
    *CANCEL_EVENT_PTR(ncb) = NULL;
    EnterCriticalSection(&queue->cs);
    *NEXT_PTR(ncb) = queue->head;
    queue->head = ncb;
    ret = NRC_GOODRET;
    LeaveCriticalSection(&queue->cs);
    TRACE("returning 0x%02x\n", ret);
    return ret;
}

Referenced by nbDispatch().

NBCmdQueueCancel()

UCHAR NBCmdQueueCancel	(	struct NBCmdQueue *	queue,
		PNCB	ncb
	)

Definition at line 106 of file nbcmdqueue.c.

{
    UCHAR ret;
    PNCB *spot;
 
    TRACE(": queue %p, ncb %p\n", queue, ncb);
 
    if (!queue)
        return NRC_BADDR;
    if (!ncb)
        return NRC_INVADDRESS;
 
    EnterCriticalSection(&queue->cs);
    spot = NBCmdQueueFindNBC(queue, ncb);
    if (spot)
    {
        *CANCEL_EVENT_PTR(*spot) = CreateEventW(NULL, FALSE, FALSE, NULL);
        WaitForSingleObject(*CANCEL_EVENT_PTR(*spot), INFINITE);
        CloseHandle(*CANCEL_EVENT_PTR(*spot));
        *spot = *NEXT_PTR(*spot);
        if (ncb->ncb_retcode == NRC_CMDCAN)
            ret = NRC_CMDCAN;
        else
            ret = NRC_CANOCCR;
    }
    else
        ret = NRC_INVADDRESS;
    LeaveCriticalSection(&queue->cs);
    TRACE("returning 0x%02x\n", ret);
    return ret;
}

Referenced by nbCancel(), and NBCmdQueueCancelAll().

NBCmdQueueCancelAll()

UCHAR NBCmdQueueCancelAll

(

struct NBCmdQueue *

queue

)

Definition at line 167 of file nbcmdqueue.c.

{
    UCHAR ret;
 
    TRACE(": queue %p\n", queue);
 
    if (!queue)
        return NRC_BADDR;
 
    EnterCriticalSection(&queue->cs);
    while (queue->head)
    {
        TRACE(": waiting for ncb %p (command 0x%02x)\n", queue->head,
         queue->head->ncb_command);
        NBCmdQueueCancel(queue, queue->head);
    }
    LeaveCriticalSection(&queue->cs);
    ret = NRC_GOODRET;
    TRACE("returning 0x%02x\n", ret);
    return ret;
}

Referenced by NBCmdQueueDestroy(), nbReset(), and nbShutdownAdapter().

NBCmdQueueComplete()

UCHAR NBCmdQueueComplete	(	struct NBCmdQueue *	queue,
		PNCB	ncb,
		UCHAR	retcode
	)

Definition at line 138 of file nbcmdqueue.c.

{
    UCHAR ret;
    PNCB *spot;
 
    TRACE(": queue %p, ncb %p\n", queue, ncb);
 
    if (!queue)
        return NRC_BADDR;
    if (!ncb)
        return NRC_INVADDRESS;
 
    EnterCriticalSection(&queue->cs);
    spot = NBCmdQueueFindNBC(queue, ncb);
    if (spot)
    {
        if (*CANCEL_EVENT_PTR(*spot))
            SetEvent(*CANCEL_EVENT_PTR(*spot));
        else
            *spot = *NEXT_PTR(*spot);
        ret = NRC_GOODRET;
    }
    else
        ret = NRC_INVADDRESS;
    LeaveCriticalSection(&queue->cs);
    TRACE("returning 0x%02x\n", ret);
    return ret;
}

Referenced by nbDispatch().

NBCmdQueueCreate()

struct NBCmdQueue * NBCmdQueueCreate

(

HANDLE

heap

)

Definition at line 53 of file nbcmdqueue.c.

{
    struct NBCmdQueue *queue;
 
    if (heap == NULL)
        heap = GetProcessHeap();
    queue = HeapAlloc(heap, 0, sizeof(struct NBCmdQueue));
    if (queue)
    {
        queue->heap = heap;
        InitializeCriticalSection(&queue->cs);
        queue->cs.DebugInfo->Spare[0] = (DWORD_PTR)(__FILE__ ": NBCmdQueue.cs");
        queue->head = NULL;
    }
    return queue;
}

Referenced by NetBIOSRegisterAdapter().

NBCmdQueueDestroy()

void NBCmdQueueDestroy

(

struct NBCmdQueue *

queue

)

Definition at line 189 of file nbcmdqueue.c.

{
    TRACE(": queue %p\n", queue);
 
    if (queue)
    {
        NBCmdQueueCancelAll(queue);
        queue->cs.DebugInfo->Spare[0] = 0;
        DeleteCriticalSection(&queue->cs);
        HeapFree(queue->heap, 0, queue);
    }
}

Referenced by nbShutdownAdapter().

NBCmdQueueFindNBC()

static PNCB * NBCmdQueueFindNBC ( struct NBCmdQueue *  queue, PNCB  ncb  )

static

Definition at line 91 of file nbcmdqueue.c.

{
    PNCB *ret;
 
    if (!queue || !ncb)
        ret = NULL;
    else
    {
        ret = &queue->head;
        while (ret && *ret != ncb)
            ret = NEXT_PTR(*ret);
    }
    return ret;
}

Referenced by NBCmdQueueCancel(), and NBCmdQueueComplete().

WINE_DEFAULT_DEBUG_CHANNEL()

WINE_DEFAULT_DEBUG_CHANNEL

(

netbios

)