version 1.34, 2003/10/02 00:11:38
|
version 1.37, 2003/11/07 19:18:46
|
|
|
//%///////////////////////////////////////////////////////////////////////////// |
//%2003//////////////////////////////////////////////////////////////////////// |
// | // |
// Copyright (c) 2000, 2001, 2002 BMC Software, Hewlett-Packard Company, IBM, |
// Copyright (c) 2000, 2001, 2002 BMC Software, Hewlett-Packard Development |
// The Open Group, Tivoli Systems |
// 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. |
// | // |
// 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 |
|
|
static QueueTable _queueTable(256); | static QueueTable _queueTable(256); |
static Mutex q_table_mut ; | static Mutex q_table_mut ; |
| |
|
void MessageQueue::remove_myself(Uint32 qid) |
|
{ |
|
q_table_mut.lock(pegasus_thread_self()); |
|
|
|
_queueTable.remove(qid); |
|
q_table_mut.unlock(); |
|
} |
|
|
|
|
Uint32 MessageQueue::getNextQueueId() throw(IPCException) | Uint32 MessageQueue::getNextQueueId() throw(IPCException) |
{ | { |
static Uint32 _nextQueueId = 2; | static Uint32 _nextQueueId = 2; |
|
|
PEG_METHOD_EXIT(); | PEG_METHOD_EXIT(); |
} | } |
| |
void MessageQueue::enqueue(Message* message) throw(IPCException) |
void MessageQueue::enqueue(Message* message) |
{ | { |
PEG_METHOD_ENTER(TRC_MESSAGEQUEUESERVICE,"MessageQueue::enqueue()"); | PEG_METHOD_ENTER(TRC_MESSAGEQUEUESERVICE,"MessageQueue::enqueue()"); |
| |