|
version 1.63, 2004/07/30 01:24:03
|
version 1.64, 2004/08/12 10:47:44
|
|
|
|
| // Adrian Schuur (schuur@de.ibm.com) | // Adrian Schuur (schuur@de.ibm.com) |
| // Seema Gupta (gseema@in.ibm.com for PEP135) | // Seema Gupta (gseema@in.ibm.com for PEP135) |
| // Chip Vincent (cvincent@us.ibm.com) | // Chip Vincent (cvincent@us.ibm.com) |
| |
// Alagaraja Ramasubramanian (alags_raj@in.ibm.com) for Bug#1090 |
| // | // |
| //%///////////////////////////////////////////////////////////////////////////// | //%///////////////////////////////////////////////////////////////////////////// |
| | |
|
|
|
| // whether this response is the last one expected | // whether this response is the last one expected |
| Boolean appendResponse(CIMResponseMessage* response) | Boolean appendResponse(CIMResponseMessage* response) |
| { | { |
| _appendResponseMutex.lock(pegasus_thread_self()); |
AutoMutex autoMut(_appendResponseMutex); |
| _responseList.append(response); | _responseList.append(response); |
| Boolean returnValue = (totalIssued() == numberResponses()); | Boolean returnValue = (totalIssued() == numberResponses()); |
| _appendResponseMutex.unlock(); |
|
| return returnValue; | return returnValue; |
| } | } |
| | |
|
|
|
| CIMResponseMessage* getResponse(const Uint32& pos) | CIMResponseMessage* getResponse(const Uint32& pos) |
| { | { |
| CIMResponseMessage *tmp; | CIMResponseMessage *tmp; |
| _appendResponseMutex.lock(pegasus_thread_self()); |
AutoMutex autoMut(_appendResponseMutex); |
| tmp = _responseList[pos]; | tmp = _responseList[pos]; |
| _appendResponseMutex.unlock(); |
|
| return tmp; | return tmp; |
| | |
| } | } |
|
|
|
| { | { |
| CIMResponseMessage* tmp; | CIMResponseMessage* tmp; |
| | |
| _appendResponseMutex.lock(pegasus_thread_self()); |
AutoMutex autoMut(_appendResponseMutex); |
| tmp = _responseList[pos]; | tmp = _responseList[pos]; |
| _responseList.remove(pos); | _responseList.remove(pos); |
| _appendResponseMutex.unlock(); |
|
| return tmp; | return tmp; |
| | |
| } | } |
|
|
|
| | |
| void deleteResponse(const Uint32&pos) | void deleteResponse(const Uint32&pos) |
| { | { |
| _appendResponseMutex.lock(pegasus_thread_self()); |
AutoMutex autoMut(_appendResponseMutex); |
| delete _responseList[pos]; | delete _responseList[pos]; |
| _responseList.remove(pos); | _responseList.remove(pos); |
| _appendResponseMutex.unlock(); |
|
| } | } |
| | |
| Uint32 getRequestType(){ return _msgRequestType;} | Uint32 getRequestType(){ return _msgRequestType;} |
Return to
CIMOperationRequestDispatcher.h
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Server