// ********************************************************************** // // Copyright (c) 2003-2008 ZeroC, Inc. All rights reserved. // // This copy of Ice-E is licensed to you under the terms described in the // ICEE_LICENSE file included in this distribution. // // ********************************************************************** #include #include #include #include using namespace std; using namespace Ice; using namespace IceInternal; IceUtil::Shared* IceInternal::upCast(Object* p) { return p; } bool Ice::Object::operator==(const Object& r) const { return this == &r; } bool Ice::Object::operator<(const Object& r) const { return this < &r; } Int Ice::Object::ice_hash() const { return static_cast(reinterpret_cast(this) >> 4); } static const string __Ice__Object_ids[] = { "::Ice::Object" }; bool Ice::Object::ice_isA(const string& s, const Current&) const { return s == __Ice__Object_ids[0]; } void Ice::Object::ice_ping(const Current&) const { // Nothing to do. } vector Ice::Object::ice_ids(const Current&) const { return vector(&__Ice__Object_ids[0], &__Ice__Object_ids[1]); } const string& Ice::Object::ice_id(const Current&) const { return __Ice__Object_ids[0]; } const ::std::string& Ice::Object::ice_staticId() { return __Ice__Object_ids[0]; } ObjectPtr Ice::Object::ice_clone() const { throw CloneNotImplementedException(__FILE__, __LINE__); } DispatchStatus Ice::Object::___ice_isA(Incoming& __inS, const Current& __current) { BasicStream* __is = __inS.is(); BasicStream* __os = __inS.os(); string __id; __is->read(__id, false); bool __ret = ice_isA(__id, __current); __os->write(__ret); return DispatchOK; } DispatchStatus Ice::Object::___ice_ping(Incoming&, const Current& __current) { ice_ping(__current); return DispatchOK; } DispatchStatus Ice::Object::___ice_ids(Incoming& __inS, const Current& __current) { BasicStream* __os = __inS.os(); vector __ret = ice_ids(__current); __os->write(&__ret[0], &__ret[0] + __ret.size(), false); return DispatchOK; } DispatchStatus Ice::Object::___ice_id(Incoming& __inS, const Current& __current) { BasicStream* __os = __inS.os(); string __ret = ice_id(__current); __os->write(__ret, false); return DispatchOK; } string Ice::Object::__all[] = { "ice_id", "ice_ids", "ice_isA", "ice_ping" }; DispatchStatus Ice::Object::__dispatch(Incoming& in, const Current& current) { pair r = equal_range(__all, __all + sizeof(__all) / sizeof(string), current.operation); if(r.first == r.second) { throw OperationNotExistException(__FILE__, __LINE__, current.id, current.facet, current.operation); } switch(r.first - __all) { case 0: { return ___ice_id(in, current); } case 1: { return ___ice_ids(in, current); } case 2: { return ___ice_isA(in, current); } case 3: { return ___ice_ping(in, current); } } assert(false); throw OperationNotExistException(__FILE__, __LINE__, current.id, current.facet, current.operation); } static const char* operationModeToString(OperationMode mode) { switch(mode) { case Normal: return "::Ice::Normal"; case Nonmutating: return "::Ice::Nonmutating"; case Idempotent: return "::Ice::Idempotent"; } return "???"; } void Ice::Object::__invalidMode(OperationMode expected, OperationMode received) { assert(expected != received); if(expected == Idempotent && received == Nonmutating) { // // Fine: typically an old client still using the deprecated nonmutating keyword // // // Note that expected == Nonmutating and received == Idempotent is not ok: // the server may still use the deprecated nonmutating keyword to detect updates // and the client should not break this (deprecated) feature. // } else { Ice::MarshalException ex(__FILE__, __LINE__); ex.reason = Ice::printfToString("unexpected operation mode. expected = %s received = %s", operationModeToString(expected), operationModeToString(received)); throw ex; } } DispatchStatus Ice::Blobject::__dispatch(Incoming& in, const Current& current) { vector inParams; vector outParams; Int sz = in.is()->getReadEncapsSize(); in.is()->readBlob(inParams, sz); bool ok = ice_invoke(inParams, outParams, current); in.os()->writeBlob(outParams); if(ok) { return DispatchOK; } else { return DispatchUserException; } }