tcpcomm_remote.c

Pegasus is an open-source implementationof the DMTF CIM and WBEM standards. It is designed to be por

	}
	TRACE_CRITICAL(("up-call connect to broker failed."));
	return (NULL);
    };
    (__sft)->serialize_CMPIObjectPath(socket, cop); {
	CMPIStatus __rc = (__sft)->deserialize_CMPIStatus(socket, broker);
	if ((rc))
	    *(rc) = __rc;
    };
    r = (__sft)->deserialize_CMPIArray(socket, broker);
    close(socket);
    return (r) ? native_new_CMPIEnumeration(r, NULL) : NULL;
}



static CMPIInstance *TCPCOMM_getInstance(CONST CMPIBroker * broker,
					 CONST CMPIContext * context,
					 CONST CMPIObjectPath * cop,
					 CONST char **properties, CMPIStatus * rc)
{
    CMPIInstance *i;
    int socket = __broker_connect(broker, context, __FUNCTION__);
    TRACE_NORMAL(("Executing remote MB call."));
    if (socket < 0) {
	if ((rc)) {
	    (rc)->rc = CMPI_RC_ERR_FAILED;
	    (rc)->msg = CMNewString((broker), "cannot connect to CIMOM", NULL);
	}
	TRACE_CRITICAL(("up-call connect to broker failed."));
	return (NULL);
    };
    (__sft)->serialize_CMPIObjectPath(socket, cop);
    socketcomm_serialize_props(socket, (__sft), (char **)properties); {
	CMPIStatus __rc = (__sft)->deserialize_CMPIStatus(socket, broker);
	if ((rc))
	    *(rc) = __rc;
    };
    i = (__sft)->deserialize_CMPIInstance(socket, broker);
    close(socket);
    return i;
}



static CMPIObjectPath *TCPCOMM_createInstance(CONST CMPIBroker * broker,
					      CONST CMPIContext * context,
					      CONST CMPIObjectPath * cop,
					      CONST CMPIInstance * instance,
					      CMPIStatus * rc)
{
    CMPIObjectPath *o;
    int socket = __broker_connect(broker, context, __FUNCTION__);
    TRACE_NORMAL(("Executing remote MB call."));
    if (socket < 0) {
	if ((rc)) {
	    (rc)->rc = CMPI_RC_ERR_FAILED;
	    (rc)->msg = CMNewString((broker), "cannot connect to CIMOM", NULL);
	}
	TRACE_CRITICAL(("up-call connect to broker failed."));
	return (NULL);
    };
    (__sft)->serialize_CMPIObjectPath(socket, cop);
    (__sft)->serialize_CMPIInstance(socket, instance); {
	CMPIStatus __rc = (__sft)->deserialize_CMPIStatus(socket, broker);
	if ((rc))
	    *(rc) = __rc;
    };
    o = (__sft)->deserialize_CMPIObjectPath(socket, broker);
    close(socket);
    return o;
}



static CMPIStatus TCPCOMM_setInstance(CONST CMPIBroker * broker,
				      CONST CMPIContext * context,
				      CONST CMPIObjectPath * cop,
				      CONST CMPIInstance * instance,
				      CONST char **properties)
{
    CMPIStatus __rc, *rc = &__rc;
    int socket = __broker_connect(broker, context, __FUNCTION__);
    TRACE_NORMAL(("Executing remote MB call."));
    if (socket < 0) {
	if ((rc)) {
	    (rc)->rc = CMPI_RC_ERR_FAILED;
	    (rc)->msg = CMNewString((broker), "cannot connect to CIMOM", NULL);
	}
	TRACE_CRITICAL(("up-call connect to broker failed."));
	return (__rc);
    };
    (__sft)->serialize_CMPIObjectPath(socket, cop);
    (__sft)->serialize_CMPIInstance(socket, instance);
    socketcomm_serialize_props(socket, (__sft), (char **)properties); {
	CMPIStatus __rc = (__sft)->deserialize_CMPIStatus(socket, broker);
	if ((rc))
	    *(rc) = __rc;
    };
    close(socket);
    return __rc;
}



static CMPIStatus TCPCOMM_deleteInstance(CONST CMPIBroker * broker,
					 CONST CMPIContext * context,
					 CONST CMPIObjectPath * cop)
{
    CMPIStatus __rc, *rc = &__rc;
    int socket = __broker_connect(broker, context, __FUNCTION__);
    TRACE_NORMAL(("Executing remote MB call."));
    if (socket < 0) {
	if ((rc)) {
	    (rc)->rc = CMPI_RC_ERR_FAILED;
	    (rc)->msg = CMNewString((broker), "cannot connect to CIMOM", NULL);
	}
	TRACE_CRITICAL(("up-call connect to broker failed."));
	return (__rc);
    };
    (__sft)->serialize_CMPIObjectPath(socket, cop); {
	CMPIStatus __rc = (__sft)->deserialize_CMPIStatus(socket, broker);
	if ((rc))
	    *(rc) = __rc;
    };
    close(socket);
    return __rc;
}



static CMPIEnumeration *TCPCOMM_execQuery(CONST CMPIBroker * broker,
					  CONST CMPIContext * context,
					  CONST CMPIObjectPath * cop, const char *query,
					  const char *lang, CMPIStatus * rc)
{
    CMPIArray *r;
    int socket = __broker_connect(broker, context, __FUNCTION__);
    TRACE_NORMAL(("Executing remote MB call."));
    if (socket < 0) {
	if ((rc)) {
	    (rc)->rc = CMPI_RC_ERR_FAILED;
	    (rc)->msg = CMNewString((broker), "cannot connect to CIMOM", NULL);
	}
	TRACE_CRITICAL(("up-call connect to broker failed."));
	return (NULL);
    };
    (__sft)->serialize_CMPIObjectPath(socket, cop);
    (__sft)->serialize_string(socket, query);
    (__sft)->serialize_string(socket, lang); {
	CMPIStatus __rc = (__sft)->deserialize_CMPIStatus(socket, broker);
	if ((rc))
	    *(rc) = __rc;
    };
    r = (__sft)->deserialize_CMPIArray(socket, broker);
    close(socket);
    return (r) ? native_new_CMPIEnumeration(r, NULL) : NULL;
}



static CMPIEnumeration *TCPCOMM_enumInstances(CONST CMPIBroker * broker,
					      CONST CMPIContext * context,
					      CONST CMPIObjectPath * cop,
					      CONST char **properties,
					      CMPIStatus * rc)
{
    CMPIArray *r;
    int socket = __broker_connect(broker, context, __FUNCTION__);
    TRACE_NORMAL(("Executing remote MB call."));
    if (socket < 0) {
	if ((rc)) {
	    (rc)->rc = CMPI_RC_ERR_FAILED;
	    (rc)->msg = CMNewString((broker), "cannot connect to CIMOM", NULL);
	}
	TRACE_CRITICAL(("up-call connect to broker failed."));
	return (NULL);
    };
    (__sft)->serialize_CMPIObjectPath(socket, cop);
    socketcomm_serialize_props(socket, (__sft), (char **)properties); {
	CMPIStatus __rc = (__sft)->deserialize_CMPIStatus(socket, broker);
	if ((rc))
	    *(rc) = __rc;
    };
    r = (__sft)->deserialize_CMPIArray(socket, broker);
    close(socket);
    return (r) ? native_new_CMPIEnumeration(r, NULL) : NULL;
}



static CMPIEnumeration *TCPCOMM_associators(CONST CMPIBroker * broker,
					    CONST CMPIContext * context,
					    CONST CMPIObjectPath * cop,
					    const char *assocClass, const char *resultClass,
					    const char *role, const char *resultRole,
					    CONST char **properties, CMPIStatus * rc)
{
    CMPIArray *r;
    int socket = __broker_connect(broker, context, __FUNCTION__);
    TRACE_NORMAL(("Executing remote MB call."));
    if (socket < 0) {
	if ((rc)) {
	    (rc)->rc = CMPI_RC_ERR_FAILED;
	    (rc)->msg = CMNewString((broker), "cannot connect to CIMOM", NULL);
	}
	TRACE_CRITICAL(("up-call connect to broker failed."));
	return (NULL);
    };
    (__sft)->serialize_CMPIObjectPath(socket, cop);
    (__sft)->serialize_string(socket, assocClass);
    (__sft)->serialize_string(socket, resultClass);
    (__sft)->serialize_string(socket, role);
    (__sft)->serialize_string(socket, resultRole);
    socketcomm_serialize_props(socket, (__sft), (char **)properties); {
	CMPIStatus __rc = (__sft)->deserialize_CMPIStatus(socket, broker);
	if ((rc))
	    *(rc) = __rc;
    };
    r = (__sft)->deserialize_CMPIArray(socket, broker);
    close(socket);
    return (r) ? native_new_CMPIEnumeration(r, NULL) : NULL;
}



static CMPIEnumeration *TCPCOMM_associatorNames(CONST CMPIBroker * broker,
						CONST CMPIContext * context,
						CONST CMPIObjectPath * cop,
						const char *assocClass,
						const char *resultClass, const char *role,
						const char *resultRole,
						CMPIStatus * rc)
{
    CMPIArray *r;
    int socket = __broker_connect(broker, context, __FUNCTION__);
    TRACE_NORMAL(("Executing remote MB call."));
    if (socket < 0) {
	if ((rc)) {
	    (rc)->rc = CMPI_RC_ERR_FAILED;
	    (rc)->msg = CMNewString((broker), "cannot connect to CIMOM", NULL);
	}
	TRACE_CRITICAL(("up-call connect to broker failed."));
	return (NULL);
    };
    (__sft)->serialize_CMPIObjectPath(socket, cop);
    (__sft)->serialize_string(socket, assocClass);
    (__sft)->serialize_string(socket, resultClass);
    (__sft)->serialize_string(socket, role);
    (__sft)->serialize_string(socket, resultRole); {
	CMPIStatus __rc = (__sft)->deserialize_CMPIStatus(socket, broker);
	if ((rc))
	    *(rc) = __rc;
    };
    r = (__sft)->deserialize_CMPIArray(socket, broker);
    close(socket);
    return (r) ? native_new_CMPIEnumeration(r, NULL) : NULL;
}



static CMPIEnumeration *TCPCOMM_references(CONST CMPIBroker * broker,
					   CONST CMPIContext * context,
					   CONST CMPIObjectPath * cop,
					   const char *resultClass, const char *role,
					   CONST char **properties, CMPIStatus * rc)
{
    CMPIArray *r;
    int socket = __broker_connect(broker, context, __FUNCTION__);
    TRACE_NORMAL(("Executing remote MB call."));
    if (socket < 0) {
	if ((rc)) {
	    (rc)->rc = CMPI_RC_ERR_FAILED;
	    (rc)->msg = CMNewString((broker), "cannot connect to CIMOM", NULL);
	}
	TRACE_CRITICAL(("up-call connect to broker failed."));
	return (NULL);
    };
    (__sft)->serialize_CMPIObjectPath(socket, cop);
    (__sft)->serialize_string(socket, resultClass);
    (__sft)->serialize_string(socket, role);
    socketcomm_serialize_props(socket, (__sft), (char **)properties); {
	CMPIStatus __rc = (__sft)->deserialize_CMPIStatus(socket, broker);
	if ((rc))
	    *(rc) = __rc;
    };
    r = (__sft)->deserialize_CMPIArray(socket, broker);
    close(socket);
    return (r) ? native_new_CMPIEnumeration(r, NULL) : NULL;
}



static CMPIEnumeration *TCPCOMM_referenceNames(CONST CMPIBroker * broker,
					       CONST CMPIContext * context,
					       CONST CMPIObjectPath * cop,
					       const char *resultClass, const char *role,
					       CMPIStatus * rc)
{
    CMPIArray *r;
    int socket = __broker_connect(broker, context, __FUNCTION__);
    TRACE_NORMAL(("Executing remote MB call."));
    if (socket < 0) {
	if ((rc)) {
	    (rc)->rc = CMPI_RC_ERR_FAILED;
	    (rc)->msg = CMNewString((broker), "cannot connect to CIMOM", NULL);
	}
	TRACE_CRITICAL(("up-call connect to broker failed."));
	return (NULL);
    };
    (__sft)->serialize_CMPIObjectPath(socket, cop);
    (__sft)->serialize_string(socket, resultClass);
    (__sft)->serialize_string(socket, role); {
	CMPIStatus __rc = (__sft)->deserialize_CMPIStatus(socket, broker);
	if ((rc))
	    *(rc) = __rc;
    };
    r = (__sft)->deserialize_CMPIArray(socket, broker);
    close(socket);
    return (r) ? native_new_CMPIEnumeration(r, NULL) : NULL;
}



static CMPIData TCPCOMM_invokeMethod(CONST CMPIBroker * broker, CONST CMPIContext * context,
				     CONST CMPIObjectPath * cop, const char *method,
				     CONST CMPIArgs * in, CMPIArgs * out,
				     CMPIStatus * rc)
{
    CMPIArgs *tmp;
    CMPIData result = { CMPI_null, CMPI_badValue, { 0 } };
    int socket = __broker_connect(broker, context, __FUNCTION__);
    TRACE_NORMAL(("Executing remote MB call."));
    if (socket < 0) {
	if ((rc)) {
	    (rc)->rc = CMPI_RC_ERR_FAILED;
	    (rc)->msg = CMNewString((broker), "cannot connect to CIMOM", NULL);
	}
	TRACE_CRITICAL(("up-call connect to broker failed."));
	return (result);
    };
    (__sft)->serialize_CMPIObjectPath(socket, cop);
    (__sft)->serialize_string(socket, method);
    (__sft)->serialize_CMPIArgs(socket, in); {
	CMPIStatus __rc = (__sft)->deserialize_CMPIStatus(socket, broker);
	if ((rc))
	    *(rc) = __rc;
    };
    tmp = (__sft)->deserialize_CMPIArgs(socket, broker);
    socketcomm_copy_args(tmp, out);
    result = (__sft)->deserialize_CMPIData(socket, broker);
    close(socket);
    return result;
}



static CMPIStatus TCPCOMM_setProperty(CONST CMPIBroker * broker,
				      CONST CMPIContext * context,
				      CONST CMPIObjectPath * cop, const char *name,
				      CONST CMPIValue * value, CONST CMPIType type)
{
    CMPIStatus __rc, *rc = &__rc;
    int socket = __broker_connect(broker, context, __FUNCTION__);
    TRACE_NORMAL(("Executing remote MB call."));
    if (socket < 0) {
	if ((rc)) {
	    (rc)->rc = CMPI_RC_ERR_FAILED;
	    (rc)->msg = CMNewString((broker), "cannot connect to CIMOM", NULL);
	}
	TRACE_CRITICAL(("up-call connect to broker failed."));
	return (__rc);
    };
    (__sft)->serialize_CMPIObjectPath(socket, cop);
    (__sft)->serialize_string(socket, name);
    (__sft)->serialize_CMPIType(socket, type);
    (__sft)->serialize_CMPIValue(socket, type, value); {
	CMPIStatus __rc = (__sft)->deserialize_CMPIStatus(socket, broker);
	if ((rc))
	    *(rc) = __rc;
    };
    close(socket);
    return __rc;
}



static CMPIData TCPCOMM_getProperty(CONST CMPIBroker * broker, CONST CMPIContext * context,
				    CONST CMPIObjectPath * cop, const char *name,
				    CMPIStatus * rc)
{
    CMPIData result = { CMPI_null, CMPI_badValue, { 0 }  };
    int socket = __broker_connect(broker, context, __FUNCTION__);
    TRACE_NORMAL(("Executing remote MB call."));
    if (socket < 0) {
	if ((rc)) {
	    (rc)->rc = CMPI_RC_ERR_FAILED;
	    (rc)->msg = CMNewString((broker), "cannot connect to CIMOM", NULL);
	}
	TRACE_CRITICAL(("up-call connect to broker failed."));
	return (result);
    };
    (__sft)->serialize_CMPIObjectPath(socket, cop);
    (__sft)->serialize_string(socket, name); {
	CMPIStatus __rc = (__sft)->deserialize_CMPIStatus(socket, broker);
	if ((rc))
	    *(rc) = __rc;
    };
    result = (__sft)->deserialize_CMPIData(socket, broker);
    close(socket);
    return result;
}


#ifndef CMPI_VER_100
CMPIArray *TCPCOMM_getKeyNames(CMPIBroker * broker,
				     CMPIContext * context,
				     CMPIObjectPath * cop, CMPIStatus * rc)
{
    CMPIArray *result;
    int socket = __broker_connect(broker, context, __FUNCTION__);