blob: 0314f43bb00d9e383806b60c7dc8eecf3d69c6ca (
plain)
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
|
/* -*- C++ -*- */
//=============================================================================
/**
* @file Time_Request_Reply.h
*
* $Id$
*
* Define the format used to exchange messages between the
* ACE_Time_Server and clerks.
*
* @author Prashant Jain
*/
//=============================================================================
#ifndef ACE_TIME_REQUEST_REPLY_H
#define ACE_TIME_REQUEST_REPLY_H
#include "ace/pre.h"
#include "ace/Time_Value.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "ace/SString.h"
/**
* @class ACE_Time_Request
*
* @brief Message format for delivering requests to the ACE_Time Server.
*
* This class is implemented to minimize data copying.
* In particular, all marshaling is done in situ...
*/
class ACE_Export ACE_Time_Request
{
public:
enum Constants
{
/// Request message types.
TIME_UPDATE = 01,
/// Class-specific constant values.
MAX_TIME_LEN = MAXPATHLEN + 1
};
/// Default constructor.
ACE_Time_Request (void);
/**
* Create a ACE_Time_Request message.
* @param msg_type Type of request.
* @param time Time.
* @param timeout Max time waiting for request.
*/
ACE_Time_Request (ACE_INT32 msg_type,
const ACE_UINT32 time,
ACE_Time_Value *timeout = 0);
/**
* Initialize length_ in order to ensure correct byte ordering before a
* request is sent.
* @deprecated This method is a no-op.
*/
void init (void);
// Get the fixed size of message
ssize_t size (void) const;
/// Get the type of the message.
ACE_INT32 msg_type (void) const;
/// Set the type of the message.
void msg_type (ACE_INT32);
/// Get the time
ACE_UINT32 time (void) const;
// Set the time
void time (ACE_UINT32 t);
/// Get the blocking semantics.
ACE_UINT32 block_forever (void) const;
/// Set the blocking semantics.
void block_forever (ACE_UINT32);
/// Get the timeout.
ACE_Time_Value timeout (void) const;
/// Set the timeout.
void timeout (const ACE_Time_Value& timeout);
/// Encode the message before transmission.
int encode (void *&);
/// Decode message after reception.
int decode (void);
/// Print out the values of the message for debugging purposes.
void dump (void) const;
private:
// = The 5 fields in the <Transfer> struct are transmitted to the server.
// The remaining 2 fields are not tranferred -- they are used only on
// the server-side to simplify lookups.
struct Transfer
{
/// Type of the request (i.e., <TIME_UPDATE>)
ACE_INT32 msg_type_;
/// Indicates if we should block forever. If 0, then sec_timeout_
/// and usec_timeout_ indicates how long we should wait.
ACE_UINT32 block_forever_;
/// Max seconds willing to wait for name if not blocking forever.
ACE_UINT32 sec_timeout_;
/// Max micro seconds to wait for name if not blocking forever.
ACE_UINT32 usec_timeout_;
/// The data portion contains <time_>
ACE_UINT32 time_;
};
/// Transfer buffer.
Transfer transfer_;
/// Time
ACE_UINT32 time_;
};
#include "ace/post.h"
#endif /* ACE_TIME_REQUEST_REPLY_H */
|
