00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013 #ifndef ACE_TIMER_HASH_T_H
00014 #define ACE_TIMER_HASH_T_H
00015 #include "ace/pre.h"
00016
00017 #include "ace/Timer_Queue_T.h"
00018
00019 #if !defined (ACE_LACKS_PRAGMA_ONCE)
00020 # pragma once
00021 #endif
00022
00023 #include "ace/Free_List.h"
00024
00025 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
00026
00027
00028 template <class TYPE, class FUNCTOR, class ACE_LOCK, class BUCKET>
00029 class ACE_Timer_Hash_T;
00030
00031
00032
00033
00034
00035
00036
00037
00038
00039 template <class TYPE, class FUNCTOR, class ACE_LOCK>
00040 class ACE_Timer_Hash_Upcall
00041 {
00042 public:
00043 typedef ACE_Timer_Queue_T<ACE_Event_Handler *,
00044 ACE_Timer_Hash_Upcall<TYPE, FUNCTOR, ACE_LOCK>,
00045 ACE_Null_Mutex>
00046 TIMER_QUEUE;
00047
00048
00049
00050 ACE_Timer_Hash_Upcall (void);
00051
00052
00053 ACE_Timer_Hash_Upcall (ACE_Timer_Queue_T<TYPE, FUNCTOR, ACE_LOCK> *timer_hash);
00054
00055
00056 int registration (TIMER_QUEUE &timer_queue,
00057 ACE_Event_Handler *handler,
00058 const void *arg);
00059
00060
00061 int preinvoke (TIMER_QUEUE &timer_queue,
00062 ACE_Event_Handler *handler,
00063 const void *arg,
00064 int recurring_timer,
00065 const ACE_Time_Value &cur_time,
00066 const void *&upcall_act);
00067
00068
00069 int timeout (TIMER_QUEUE &timer_queue,
00070 ACE_Event_Handler *handler,
00071 const void *arg,
00072 int recurring_timer,
00073 const ACE_Time_Value &cur_time);
00074
00075
00076 int postinvoke (TIMER_QUEUE &timer_queue,
00077 ACE_Event_Handler *handler,
00078 const void *arg,
00079 int recurring_timer,
00080 const ACE_Time_Value &cur_time,
00081 const void *upcall_act);
00082
00083
00084 int cancel_type (TIMER_QUEUE &timer_queue,
00085 ACE_Event_Handler *handler,
00086 int dont_call,
00087 int &requires_reference_counting);
00088
00089
00090 int cancel_timer (TIMER_QUEUE &timer_queue,
00091 ACE_Event_Handler *handler,
00092 int dont_call,
00093 int requires_reference_counting);
00094
00095
00096
00097 int deletion (TIMER_QUEUE &timer_queue,
00098 ACE_Event_Handler *handler,
00099 const void *arg);
00100
00101 private:
00102
00103 ACE_Timer_Queue_T<TYPE, FUNCTOR, ACE_LOCK> *timer_hash_;
00104
00105
00106 ACE_UNIMPLEMENTED_FUNC (ACE_Timer_Hash_Upcall (const ACE_Timer_Hash_Upcall<TYPE, FUNCTOR, ACE_LOCK> &))
00107 ACE_UNIMPLEMENTED_FUNC (void operator= (const ACE_Timer_Hash_Upcall<TYPE, FUNCTOR, ACE_LOCK> &))
00108 };
00109
00110
00111
00112
00113
00114
00115
00116
00117
00118
00119 template <class TYPE, class FUNCTOR, class ACE_LOCK, class BUCKET>
00120 class ACE_Timer_Hash_Iterator_T : public ACE_Timer_Queue_Iterator_T <TYPE, FUNCTOR, ACE_LOCK>
00121 {
00122 public:
00123
00124 ACE_Timer_Hash_Iterator_T (ACE_Timer_Hash_T<TYPE, FUNCTOR, ACE_LOCK, BUCKET> &);
00125
00126
00127 virtual void first (void);
00128
00129
00130 virtual void next (void);
00131
00132
00133 virtual int isdone (void) const;
00134
00135
00136 virtual ACE_Timer_Node_T<TYPE> *item (void);
00137
00138 protected:
00139
00140 ACE_Timer_Hash_T<TYPE, FUNCTOR, ACE_LOCK, BUCKET> &timer_hash_;
00141
00142
00143 size_t position_;
00144
00145
00146 ACE_Timer_Queue_Iterator_T<TYPE, ACE_Timer_Hash_Upcall<TYPE, FUNCTOR, ACE_LOCK>, ACE_Null_Mutex> *iter_;
00147 };
00148
00149
00150
00151
00152
00153
00154
00155
00156
00157
00158
00159 template <class TYPE, class FUNCTOR, class ACE_LOCK, class BUCKET>
00160 class ACE_Timer_Hash_T : public ACE_Timer_Queue_T<TYPE, FUNCTOR, ACE_LOCK>
00161 {
00162 public:
00163
00164 typedef ACE_Timer_Hash_Iterator_T<TYPE, FUNCTOR, ACE_LOCK, BUCKET>
00165 HASH_ITERATOR;
00166
00167
00168 friend class ACE_Timer_Hash_Iterator_T<TYPE, FUNCTOR, ACE_LOCK, BUCKET>;
00169
00170
00171 typedef ACE_Timer_Queue_T<TYPE, FUNCTOR, ACE_LOCK> INHERITED;
00172
00173
00174
00175
00176
00177
00178
00179
00180 ACE_Timer_Hash_T (size_t table_size,
00181 FUNCTOR *upcall_functor = 0,
00182 ACE_Free_List<ACE_Timer_Node_T <TYPE> > *freelist = 0);
00183
00184
00185
00186
00187
00188
00189
00190
00191 ACE_Timer_Hash_T (FUNCTOR *upcall_functor = 0, ACE_Free_List<ACE_Timer_Node_T <TYPE> > *freelist = 0);
00192
00193
00194 virtual ~ACE_Timer_Hash_T (void);
00195
00196
00197 virtual int is_empty (void) const;
00198
00199
00200
00201 virtual const ACE_Time_Value &earliest_time (void) const;
00202
00203
00204
00205
00206
00207
00208
00209
00210 virtual int reset_interval (long timer_id,
00211 const ACE_Time_Value &interval);
00212
00213
00214
00215
00216
00217
00218 virtual int cancel (const TYPE &type,
00219 int dont_call_handle_close = 1);
00220
00221
00222
00223
00224
00225
00226
00227
00228
00229
00230 virtual int cancel (long timer_id,
00231 const void **act = 0,
00232 int dont_call_handle_close = 1);
00233
00234
00235
00236
00237
00238
00239 virtual int expire (void);
00240
00241
00242
00243
00244
00245
00246 virtual int expire (const ACE_Time_Value ¤t_time);
00247
00248
00249 virtual ACE_Timer_Queue_Iterator_T<TYPE, FUNCTOR, ACE_LOCK> &iter (void);
00250
00251
00252 virtual ACE_Timer_Node_T<TYPE> *remove_first (void);
00253
00254
00255 virtual void dump (void) const;
00256
00257
00258 virtual ACE_Timer_Node_T<TYPE> *get_first (void);
00259
00260 private:
00261
00262
00263
00264
00265
00266
00267
00268
00269
00270
00271
00272
00273 virtual long schedule_i (const TYPE &type,
00274 const void *act,
00275 const ACE_Time_Value &future_time,
00276 const ACE_Time_Value &interval);
00277
00278
00279 virtual int dispatch_info_i (const ACE_Time_Value ¤t_time,
00280 ACE_Timer_Node_Dispatch_Info_T<TYPE> &info);
00281
00282
00283 virtual void reschedule (ACE_Timer_Node_T<TYPE> *);
00284
00285
00286 void find_new_earliest (void);
00287
00288
00289 size_t size_;
00290
00291
00292 BUCKET **table_;
00293
00294
00295 size_t table_size_;
00296
00297
00298 ACE_Timer_Hash_Upcall<TYPE, FUNCTOR, ACE_LOCK> table_functor_;
00299
00300
00301 size_t earliest_position_;
00302
00303
00304 HASH_ITERATOR *iterator_;
00305
00306 #if defined (ACE_WIN64)
00307
00308
00309 ptrdiff_t pointer_base_;
00310 #endif
00311
00312
00313 ACE_UNIMPLEMENTED_FUNC (ACE_Timer_Hash_T (const ACE_Timer_Hash_T<TYPE, FUNCTOR, ACE_LOCK, BUCKET> &))
00314 ACE_UNIMPLEMENTED_FUNC (void operator= (const ACE_Timer_Hash_T<TYPE, FUNCTOR, ACE_LOCK, BUCKET> &))
00315 };
00316
00317 ACE_END_VERSIONED_NAMESPACE_DECL
00318
00319 #if defined (ACE_TEMPLATES_REQUIRE_SOURCE) && !defined(ACE_HAS_BROKEN_HPUX_TEMPLATES)
00320 #include "ace/Timer_Hash_T.cpp"
00321 #endif
00322
00323 #if defined (ACE_TEMPLATES_REQUIRE_PRAGMA)
00324 #pragma implementation ("Timer_Hash_T.cpp")
00325 #endif
00326
00327 #include "ace/post.h"
00328 #endif