version 1.12.2.3, 2011/10/11 18:18:08
|
version 1.12.2.4, 2012/02/15 17:47:06
|
|
|
OP_DeleteQualifier, | OP_DeleteQualifier, |
OP_EnumerateQualifiers, | OP_EnumerateQualifiers, |
OP_InvokeMethod, | OP_InvokeMethod, |
|
// EXP_PULL_BEGIN |
OP_OpenEnumerateInstances, | OP_OpenEnumerateInstances, |
OP_OpenEnumerateInstancePaths, | OP_OpenEnumerateInstancePaths, |
OP_OpenReferenceInstances, | OP_OpenReferenceInstances, |
|
|
OP_PullInstancePaths, | OP_PullInstancePaths, |
OP_CloseEnumeration, | OP_CloseEnumeration, |
OP_EnumerationCount, | OP_EnumerationCount, |
|
// EXP_PULL_END |
OP_Count | OP_Count |
}; | }; |
| |
|
|
return OP_CreateInstance; | return OP_CreateInstance; |
if (_EQUAL(s, "CreateClass")) | if (_EQUAL(s, "CreateClass")) |
return OP_CreateClass; | return OP_CreateClass; |
|
//EXP_PULL_BEGIN |
if (_EQUAL(s, "CloseEnumeration")) | if (_EQUAL(s, "CloseEnumeration")) |
return OP_CloseEnumeration; | return OP_CloseEnumeration; |
|
// EXP_PULL_END |
break; | break; |
case 'D': | case 'D': |
if (_EQUAL(s, "DeleteInstance")) | if (_EQUAL(s, "DeleteInstance")) |
|
|
if (_EQUAL(s, "ModifyClass")) | if (_EQUAL(s, "ModifyClass")) |
return OP_ModifyClass; | return OP_ModifyClass; |
break; | break; |
|
// EXP_PULL_BEGIN |
case 'O': | case 'O': |
if (_EQUAL(s, "OpenEnumerateInstances")) | if (_EQUAL(s, "OpenEnumerateInstances")) |
return OP_OpenEnumerateInstances; | return OP_OpenEnumerateInstances; |
|
|
if (_EQUAL(s, "PullInstancePaths")) | if (_EQUAL(s, "PullInstancePaths")) |
return OP_PullInstancePaths; | return OP_PullInstancePaths; |
break; | break; |
|
// EXP_PULL_END |
case 'R': | case 'R': |
if (_EQUAL(s, "References")) | if (_EQUAL(s, "References")) |
return OP_References; | return OP_References; |
|
|
msg->binaryRequest = true; | msg->binaryRequest = true; |
return msg; | return msg; |
} | } |
// KS_PULL_BEGIN |
// EXP_PULL_BEGIN |
//============================================================================== | //============================================================================== |
// | // |
// OpenEnumerateInstances | // OpenEnumerateInstances |
|
|
| |
return request.release(); | return request.release(); |
} | } |
|
|
// For the pull Response messages the interface is the message and the, | // For the pull Response messages the interface is the message and the, |
// not just the responseData. | // not just the responseData. |
static void _encodeOpenEnumerateInstancesResponseBody( | static void _encodeOpenEnumerateInstancesResponseBody( |
|
|
msg->binaryRequest=true; | msg->binaryRequest=true; |
return msg; | return msg; |
} | } |
|
|
//============================================================================== | //============================================================================== |
// | // |
// OpenEnumerateInstancesPaths | // OpenEnumerateInstancesPaths |
|
|
Uint32 flags, | Uint32 flags, |
const String& messageId) | const String& messageId) |
{ | { |
/* See ../Server/CIMOperationRequestDecoder.cpp */ |
/* See ../ |
|
Server/CIMOperationRequestDecoder.cpp */ |
| |
STAT_GETSTARTTIME | STAT_GETSTARTTIME |
| |
|
|
return msg; | return msg; |
} | } |
| |
// KS_PULL_END |
// EXP_PULL_END |
| |
| |
//============================================================================== | //============================================================================== |
|
|
case OP_ExecQuery: | case OP_ExecQuery: |
return _decodeExecQueryRequest( | return _decodeExecQueryRequest( |
in, queueId, returnQueueId, messageId); | in, queueId, returnQueueId, messageId); |
|
//EXP_PULL_BEGIN |
case OP_OpenEnumerateInstances: | case OP_OpenEnumerateInstances: |
return _decodeOpenEnumerateInstancesRequest( | return _decodeOpenEnumerateInstancesRequest( |
in, queueId, returnQueueId, flags, messageId); | in, queueId, returnQueueId, flags, messageId); |
|
|
return _decodeEnumerationCountRequest( | return _decodeEnumerationCountRequest( |
in, queueId, returnQueueId, flags, messageId); | in, queueId, returnQueueId, flags, messageId); |
break; | break; |
|
//EXP_PULL_END |
default: | default: |
// Unexpected message type | // Unexpected message type |
PEGASUS_ASSERT(0); | PEGASUS_ASSERT(0); |
|
|
#if defined(ENABLE_VALIDATION) | #if defined(ENABLE_VALIDATION) |
buf.setValidate(true); | buf.setValidate(true); |
#endif | #endif |
|
|
Uint32 flags; | Uint32 flags; |
String messageId; | String messageId; |
Operation operation; | Operation operation; |
|
|
case OP_ExecQuery: | case OP_ExecQuery: |
msg = _decodeExecQueryResponse(buf, messageId); | msg = _decodeExecQueryResponse(buf, messageId); |
break; | break; |
|
//EXP_PULL_BEGIN |
case OP_OpenEnumerateInstances: | case OP_OpenEnumerateInstances: |
msg = _decodeOpenEnumerateInstancesResponse(buf, messageId); | msg = _decodeOpenEnumerateInstancesResponse(buf, messageId); |
break; | break; |
|
|
case OP_CloseEnumeration: | case OP_CloseEnumeration: |
msg = _decodeCloseEnumerationResponse(buf, messageId); | msg = _decodeCloseEnumerationResponse(buf, messageId); |
break; | break; |
|
//EXP_PULL_END |
default: | default: |
// Unexpected message type | // Unexpected message type |
PEGASUS_ASSERT(0); | PEGASUS_ASSERT(0); |
|
|
(CIMExecQueryRequestMessage*)msg, name); | (CIMExecQueryRequestMessage*)msg, name); |
break; | break; |
} | } |
|
|
|
//EXP_PULL_BEGIN |
case CIM_OPEN_ENUMERATE_INSTANCES_REQUEST_MESSAGE: | case CIM_OPEN_ENUMERATE_INSTANCES_REQUEST_MESSAGE: |
{ | { |
_encodeOpenEnumerateInstancesRequest(buf, | _encodeOpenEnumerateInstancesRequest(buf, |
|
|
(CIMEnumerationCountRequestMessage*)msg, name); | (CIMEnumerationCountRequestMessage*)msg, name); |
break; | break; |
} | } |
|
//EXP_PULL_END |
| |
default: | default: |
// Unexpected message type | // Unexpected message type |
|
|
| |
case CIM_EXEC_QUERY_RESPONSE_MESSAGE: | case CIM_EXEC_QUERY_RESPONSE_MESSAGE: |
{ | { |
_encodeExecQueryResponseBody(buf, |
_encodeExecQueryResponseBody( |
|
buf, |
((CIMExecQueryResponseMessage*)msg)->getResponseData(), | ((CIMExecQueryResponseMessage*)msg)->getResponseData(), |
name); | name); |
break; | break; |
} | } |
| |
|
//EXP_PULL_BEGIN |
case CIM_OPEN_ENUMERATE_INSTANCES_RESPONSE_MESSAGE: | case CIM_OPEN_ENUMERATE_INSTANCES_RESPONSE_MESSAGE: |
{ | { |
_encodeOpenEnumerateInstancesResponseBody(buf, | _encodeOpenEnumerateInstancesResponseBody(buf, |
|
|
name); | name); |
break; | break; |
} | } |
|
//EXP_PULL_END |
| |
default: | default: |
// Unexpected message type | // Unexpected message type |