/usr/include/Ice/IncomingAsync.h is in libzeroc-ice-dev 3.7.0-5.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 | // **********************************************************************
//
// Copyright (c) 2003-2017 ZeroC, Inc. All rights reserved.
//
// This copy of Ice is licensed to you under the terms described in the
// ICE_LICENSE file included in this distribution.
//
// **********************************************************************
#ifndef ICE_INCOMING_ASYNC_H
#define ICE_INCOMING_ASYNC_H
#include <Ice/IncomingAsyncF.h>
#include <Ice/Incoming.h>
#ifndef ICE_CPP11_MAPPING
namespace Ice
{
class ICE_API AMDCallback : public Ice::LocalObject
{
public:
virtual ~AMDCallback();
virtual void ice_exception(const ::std::exception&) = 0;
virtual void ice_exception() = 0;
};
}
#endif
namespace IceInternal
{
//
// We need virtual inheritance from AMDCallback, because we use multiple
// inheritance from Ice::AMDCallback for generated AMD code.
//
class ICE_API IncomingAsync : public IncomingBase,
#ifdef ICE_CPP11_MAPPING
public ::std::enable_shared_from_this<IncomingAsync>
#else
public virtual Ice::AMDCallback
#endif
{
public:
IncomingAsync(Incoming&);
#ifdef ICE_CPP11_MAPPING
static std::shared_ptr<IncomingAsync> create(Incoming&);
std::function<void()> response()
{
auto self = shared_from_this();
return [self]()
{
self->writeEmptyParams();
self->completed();
};
}
template<class T>
std::function<void(const T&)> response()
{
auto self = shared_from_this();
return [self](const T& marshaledResult)
{
self->setMarshaledResult(marshaledResult);
self->completed();
};
}
std::function<void(std::exception_ptr)> exception()
{
auto self = shared_from_this();
return [self](std::exception_ptr ex) { self->completed(ex); };
}
#else
virtual void ice_exception(const ::std::exception&);
virtual void ice_exception();
#endif
void kill(Incoming&);
void completed();
#ifdef ICE_CPP11_MAPPING
void completed(std::exception_ptr);
#endif
private:
void checkResponseSent();
bool _responseSent;
//
// We need a separate ConnectionIPtr, because IncomingBase only
// holds a ConnectionI* for optimization.
//
const ResponseHandlerPtr _responseHandlerCopy;
};
}
#ifndef ICE_CPP11_MAPPING
namespace Ice
{
class ICE_API AMD_Object_ice_invoke : public virtual Ice::AMDCallback
{
public:
virtual ~AMD_Object_ice_invoke();
virtual void ice_response(bool, const std::vector<Ice::Byte>&) = 0;
virtual void ice_response(bool, const std::pair<const Ice::Byte*, const Ice::Byte*>&) = 0;
};
}
namespace IceAsync
{
namespace Ice
{
class ICE_API AMD_Object_ice_invoke : public ::Ice::AMD_Object_ice_invoke, public IceInternal::IncomingAsync
{
public:
AMD_Object_ice_invoke(IceInternal::Incoming&);
virtual void ice_response(bool, const std::vector< ::Ice::Byte>&);
virtual void ice_response(bool, const std::pair<const ::Ice::Byte*, const ::Ice::Byte*>&);
};
}
}
#endif
#endif
|