ntoskrnl/ke/queue.c

   1 /*
   2  *  ReactOS kernel
   3  *  Copyright (C) 1998, 1999, 2000, 2001, 2002 ReactOS Team
   4  *
   5  *  This program is free software; you can redistribute it and/or modify
   6  *  it under the terms of the GNU General Public License as published by
   7  *  the Free Software Foundation; either version 2 of the License, or
   8  *  (at your option) any later version.
   9  *
  10  *  This program is distributed in the hope that it will be useful,
  11  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  12  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  13  *  GNU General Public License for more details.
  14  *
  15  *  You should have received a copy of the GNU General Public License
  16  *  along with this program; if not, write to the Free Software
  17  *  Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  18  */
  19 /* $Id$
  20  *
  21  * PROJECT:         ReactOS kernel
  22  * FILE:            ntoskrnl/ke/queue.c
  23  * PURPOSE:         Implements kernel queues
  24  * PROGRAMMER:      Eric Kohl (ekohl@rz-online.de)
  25  * UPDATE HISTORY:
  26  *                  Created 04/01/2002
  27  */
  28
  29 /* INCLUDES *****************************************************************/
  30
  31 #include <ddk/ntddk.h>
  32 #include <internal/ke.h>
  33 #include <internal/id.h>
  34
  35 #define NDEBUG
  36 #include <internal/debug.h>
  37
  38 /* FUNCTIONS *****************************************************************/
  39
  40 VOID STDCALL
  41 KeInitializeQueue(IN PKQUEUE Queue,
  42                   IN ULONG Count OPTIONAL)
  43 {
  44   KeInitializeDispatcherHeader(&Queue->Header,
  45                                InternalQueueType,
  46                                sizeof(KQUEUE)/sizeof(ULONG),
  47                                0);
  48   InitializeListHead(&Queue->EntryListHead);
  49   InitializeListHead(&Queue->ThreadListEntry);
  50   Queue->CurrentCount = 0;
  51   Queue->MaximumCount = (Count == 0) ? (ULONG) KeNumberProcessors : Count;
  52 }
  53
  54
  55 LONG STDCALL
  56 KeReadStateQueue(IN PKQUEUE Queue)
  57 {
  58   return(Queue->Header.SignalState);
  59 }
  60
  61
  62 LONG STDCALL
  63 KeInsertHeadQueue(IN PKQUEUE Queue,
  64                   IN PLIST_ENTRY Entry)
  65 {
  66   UNIMPLEMENTED;
  67   return 0;
  68 }
  69
  70
  71 LONG STDCALL
  72 KeInsertQueue(IN PKQUEUE Queue,
  73               IN PLIST_ENTRY Entry)
  74 {
  75   UNIMPLEMENTED;
  76   return 0;
  77 }
  78
  79
  80 PLIST_ENTRY STDCALL
  81 KeRemoveQueue(IN PKQUEUE Queue,
  82               IN KPROCESSOR_MODE WaitMode,
  83               IN PLARGE_INTEGER Timeout OPTIONAL)
  84 {
  85   UNIMPLEMENTED;
  86   return NULL;
  87 }
  88
  89
  90 PLIST_ENTRY STDCALL
  91 KeRundownQueue(IN PKQUEUE Queue)
  92 {
  93   UNIMPLEMENTED;
  94   return NULL;
  95 }
  96
  97 /* EOF */