// ********************************************************************** // // Copyright (c) 2001 // MutableRealms, Inc. // Huntsville, AL, USA // // All Rights Reserved // // ********************************************************************** #include #include #include #include #include #include #include #include using namespace std; using namespace Ice; using namespace IceInternal; IceInternal::NonRepeatable::NonRepeatable(const NonRepeatable& ex) { _ex = auto_ptr(dynamic_cast(ex.get()->ice_clone())); } IceInternal::NonRepeatable::NonRepeatable(const ::Ice::LocalException& ex) { _ex = auto_ptr(dynamic_cast(ex.ice_clone())); } const ::Ice::LocalException* IceInternal::NonRepeatable::get() const { assert(_ex.get()); return _ex.get(); } IceInternal::Outgoing::Outgoing(const ConnectionPtr& connection, const ReferencePtr& ref, bool sendProxy, const string& operation, bool nonmutating, const Context& context) : _connection(connection), _reference(ref), _state(StateUnsent), _is(ref->instance), _os(ref->instance) { switch (_reference->mode) { case Reference::ModeTwoway: case Reference::ModeOneway: case Reference::ModeDatagram: { _connection->prepareRequest(this); break; } case Reference::ModeBatchOneway: case Reference::ModeBatchDatagram: { _connection->prepareBatchRequest(this); break; } } _os.write(sendProxy); if (sendProxy) { ObjectPrx proxy = _reference->instance->proxyFactory()->referenceToProxy(_reference); _os.write(proxy); } else { _reference->identity.__write(&_os); _os.write(_reference->facet); } _os.write(operation); _os.write(nonmutating); _os.write(Int(context.size())); Context::const_iterator p; for (p = context.begin(); p != context.end(); ++p) { _os.write(p->first); _os.write(p->second); } // // Input and output parameters are always sent in an // encapsulation, which makes it possible to forward oneway // requests as blobs. // _os.startWriteEncaps(); } IceInternal::Outgoing::~Outgoing() { if (_state == StateUnsent && (_reference->mode == Reference::ModeBatchOneway || _reference->mode == Reference::ModeBatchDatagram)) { _connection->abortBatchRequest(); } } bool IceInternal::Outgoing::invoke() { _os.endWriteEncaps(); switch (_reference->mode) { case Reference::ModeTwoway: { bool timedOut = false; { IceUtil::Monitor::Lock sync(*this); _connection->sendRequest(this, false); _state = StateInProgress; Int timeout = _connection->timeout(); while (_state == StateInProgress) { if (timeout >= 0) { timedwait(timeout); if (_state == StateInProgress) { timedOut = true; _state = StateLocalException; _exception = auto_ptr(new TimeoutException(__FILE__, __LINE__)); } } else { wait(); } } } if (timedOut) { // // Must be called outside the synchronization of this // object. // _connection->exception(*_exception.get()); } if (_exception.get()) { // // A CloseConnectionException indicates graceful // server shutdown, and is therefore always repeatable // without violating "at-most-once". That's because by // sending a close connection message, the server // guarantees that all outstanding requests can safely // be repeated. // if(dynamic_cast(_exception.get())) { _exception->ice_throw(); } // // Throw the exception wrapped in a NonRepeatable, to // indicate that the request cannot be resent without // potentially violating the "at-most-once" principle. // throw NonRepeatable(*_exception.get()); } if (_state == StateException) { return false; } if (_state == StateLocationForward) { ObjectPrx p; _is.read(p); throw LocationForward(p); } if (_state == StateProxyRequested) { throw ProxyRequested(); } assert(_state == StateOK); break; } case Reference::ModeOneway: case Reference::ModeDatagram: { _connection->sendRequest(this, true); _state = StateInProgress; break; } case Reference::ModeBatchOneway: case Reference::ModeBatchDatagram: { // // The state must be set to StateInProgress before calling // finishBatchRequest, because otherwise if // finishBatchRequest raises an exception, the destructor // of this class will call abortBatchRequest, and calling // both finishBatchRequest and abortBatchRequest is // illegal. // _state = StateInProgress; _connection->finishBatchRequest(this); break; } } return true; } void IceInternal::Outgoing::finished(BasicStream& is) { IceUtil::Monitor::Lock sync(*this); if (_state == StateInProgress) { _is.swap(is); Byte status; _is.read(status); switch (static_cast(status)) { case DispatchOK: { // // Input and output parameters are always sent in an // encapsulation, which makes it possible to forward // oneway requests as blobs. // _is.startReadEncaps(); _state = StateOK; break; } case DispatchUserException: { // // Input and output parameters are always sent in an // encapsulation, which makes it possible to forward // oneway requests as blobs. // _is.startReadEncaps(); _state = StateException; break; } case DispatchLocationForward: { _state = StateLocationForward; break; } case DispatchProxyRequested: { _state = StateProxyRequested; break; } case DispatchObjectNotExist: { _state = StateLocalException; _exception = auto_ptr(new ObjectNotExistException(__FILE__, __LINE__)); break; } case DispatchFacetNotExist: { _state = StateLocalException; _exception = auto_ptr(new FacetNotExistException(__FILE__, __LINE__)); break; } case DispatchOperationNotExist: { _state = StateLocalException; _exception = auto_ptr(new OperationNotExistException(__FILE__, __LINE__)); break; } case DispatchUnknownLocalException: { _state = StateLocalException; _exception = auto_ptr(new UnknownLocalException(__FILE__, __LINE__)); break; } case DispatchUnknownUserException: { _state = StateLocalException; _exception = auto_ptr(new UnknownUserException(__FILE__, __LINE__)); break; } case DispatchUnknownException: { _state = StateLocalException; _exception = auto_ptr(new UnknownException(__FILE__, __LINE__)); break; } default: { _state = StateLocalException; _exception = auto_ptr(new UnknownReplyStatusException(__FILE__, __LINE__)); break; } } notify(); } } void IceInternal::Outgoing::finished(const LocalException& ex) { IceUtil::Monitor::Lock sync(*this); if (_state == StateInProgress) { _state = StateLocalException; _exception = auto_ptr(dynamic_cast(ex.ice_clone())); notify(); } } BasicStream* IceInternal::Outgoing::is() { return &_is; } BasicStream* IceInternal::Outgoing::os() { return &_os; }