version 1.1, 2002/01/19 02:37:51
|
version 1.7.16.1, 2006/02/10 16:13:07
|
|
|
//%///////////////////////////////////////////////////////////////////////////// |
//%2006//////////////////////////////////////////////////////////////////////// |
// | // |
// Copyright (c) 2000, 2001 The Open group, BMC Software, Tivoli Systems, IBM |
// Copyright (c) 2000, 2001, 2002 BMC Software; Hewlett-Packard Development |
|
// Company, L.P.; IBM Corp.; The Open Group; Tivoli Systems. |
|
// Copyright (c) 2003 BMC Software; Hewlett-Packard Development Company, L.P.; |
|
// IBM Corp.; EMC Corporation, The Open Group. |
|
// Copyright (c) 2004 BMC Software; Hewlett-Packard Development Company, L.P.; |
|
// IBM Corp.; EMC Corporation; VERITAS Software Corporation; The Open Group. |
|
// Copyright (c) 2005 Hewlett-Packard Development Company, L.P.; IBM Corp.; |
|
// EMC Corporation; VERITAS Software Corporation; The Open Group. |
|
// Copyright (c) 2006 Hewlett-Packard Development Company, L.P.; IBM Corp.; |
|
// EMC Corporation; Symantec Corporation; The Open Group. |
// | // |
// Permission is hereby granted, free of charge, to any person obtaining a copy | // Permission is hereby granted, free of charge, to any person obtaining a copy |
// of this software and associated documentation files (the "Software"), to | // of this software and associated documentation files (the "Software"), to |
|
|
PEGASUS_NAMESPACE_BEGIN | PEGASUS_NAMESPACE_BEGIN |
| |
RepositoryQueue::RepositoryQueue(void) | RepositoryQueue::RepositoryQueue(void) |
: MessageQueue("RepositoryQueue", true) |
Base("RepositoryQueue", MessageQueue::getNextQueueId()) |
{ | { |
|
|
} | } |
| |
RepositoryQueue::~RepositoryQueue(void) | RepositoryQueue::~RepositoryQueue(void) |
{ | { |
} | } |
| |
void RepositoryQueue::handleEnqueue(void) |
|
{ |
|
Message * message = dequeue(); |
|
| |
PEGASUS_ASSERT(message != 0); |
void RepositoryQueue::handleEnqueue(Message *message) |
|
{ |
|
if( ! message ) |
|
return; |
| |
switch(message->getType()) | switch(message->getType()) |
{ | { |
|
|
delete message; | delete message; |
} | } |
| |
|
|
|
void RepositoryQueue::handleEnqueue(void) |
|
{ |
|
Message * message = dequeue(); |
|
|
|
PEGASUS_ASSERT(message != 0); |
|
if(message) |
|
handleEnqueue(message); |
|
|
|
|
|
} |
|
|
void RepositoryQueue::handleGetClassRequest(const Message * message) | void RepositoryQueue::handleGetClassRequest(const Message * message) |
{ | { |
} | } |