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
|
//
// Copyright (c) ZeroC, Inc. All rights reserved.
//
#ifndef ICE_BATCH_REQUEST_INTERCEPTOR_H
#define ICE_BATCH_REQUEST_INTERCEPTOR_H
#include <IceUtil/Shared.h>
#include <Ice/ProxyF.h>
namespace Ice
{
/**
* Represents an invocation on a proxy configured for batch-oneway or batch-datagram.
* \headerfile Ice/Ice.h
*/
class BatchRequest
{
public:
virtual ~BatchRequest()
{
}
/**
* Queues the request for an eventual flush.
*/
virtual void enqueue() const = 0;
/**
* Obtains the size of the request.
* @return The number of bytes consumed by the request.
*/
virtual int getSize() const = 0;
/**
* Obtains the name of the operation.
* @return The operation name.
*/
virtual const std::string& getOperation() const = 0;
/**
* Obtains the proxy on which the batch request was invoked.
* @return The originating proxy.
*/
virtual const Ice::ObjectPrxPtr& getProxy() const = 0;
};
#ifndef ICE_CPP11_MAPPING
/**
* The base class for a batch request interceptor. Subclasses must implement enqueue.
* The interceptor can be installed via InitializationData.
* \headerfile Ice/Ice.h
*/
class BatchRequestInterceptor : public IceUtil::Shared
{
public:
/**
* Called by the Ice run time to enqueue a batch request.
* @param req An object representing the batch request.
* @param count The number of requests currently in the queue.
* @param size The number of bytes consumed by the requests currently in the queue.
*/
virtual void enqueue(const BatchRequest& req, int count, int size) = 0;
};
typedef IceUtil::Handle<BatchRequestInterceptor> BatchRequestInterceptorPtr;
#endif
}
#endif
|
