/* -*- C++ -*- */ // $Id$ // ============================================================================ // // = LIBRARY // ace // // = FILENAME // XtReactor.h // // = AUTHOR // Eric C. Newton's , // Kirill Rybaltchenko , and // Douglas C. Schmidt // // ============================================================================ #ifndef ACE_XTREACTOR_H #define ACE_XTREACTOR_H #include "ace/Select_Reactor.h" #if !defined (ACE_LACKS_PRAGMA_ONCE) # pragma once #endif /* ACE_LACKS_PRAGMA_ONCE */ #if defined (ACE_HAS_XT) //#define String XtString #include /**/ //#undef String class ACE_Export ACE_XtReactorID { // = TITLE // This little class is necessary due to the way that Microsoft // implements sockets to be pointers rather than indices. public: XtInputId id_; // Magic cookie. ACE_HANDLE handle_; // Underlying handle. ACE_XtReactorID *next_; // Pointer to next node in the linked list. }; class ACE_Export ACE_XtReactor : public ACE_Select_Reactor { // = TITLE // An object-oriented event demultiplexor and event handler // dispatcher that uses the X Toolkit functions. public: // = Initialization and termination methods. ACE_XtReactor (XtAppContext context = 0, size_t size = DEFAULT_SIZE, int restart = 0, ACE_Sig_Handler * = 0); virtual ~ACE_XtReactor (void); XtAppContext context (void) const; void context (XtAppContext); // = Timer operations. virtual long schedule_timer (ACE_Event_Handler *handler, const void *arg, const ACE_Time_Value &delta_time, const ACE_Time_Value &interval); virtual int cancel_timer (ACE_Event_Handler *handler, int dont_call_handle_close = 1); virtual int cancel_timer (long timer_id, const void **arg = 0, int dont_call_handle_close = 1); protected: // = Register timers/handles with Xt. virtual int register_handler_i (ACE_HANDLE handle, ACE_Event_Handler *handler, ACE_Reactor_Mask mask); // Register a single . virtual int register_handler_i (const ACE_Handle_Set &handles, ACE_Event_Handler *handler, ACE_Reactor_Mask mask); // Register a set of . virtual int remove_handler_i (ACE_HANDLE handle, ACE_Reactor_Mask mask); // Remove the associated with this . virtual int remove_handler_i (const ACE_Handle_Set &handles, ACE_Reactor_Mask); // Remove a set of . virtual void remove_XtInput (ACE_HANDLE handle); // Removes an Xt handle. virtual int wait_for_multiple_events (ACE_Select_Reactor_Handle_Set &, ACE_Time_Value *); // Wait for events to occur. virtual int XtWaitForMultipleEvents (int, ACE_Select_Reactor_Handle_Set &, ACE_Time_Value *); //Wait for Xt events to occur. XtAppContext context_; ACE_XtReactorID *ids_; XtIntervalId timeout_; private: void reset_timeout (void); // = Integrate with the X callback function mechanism. static void TimerCallbackProc (XtPointer closure, XtIntervalId *id); static void InputCallbackProc (XtPointer closure, int* source, XtInputId *id); ACE_XtReactor (const ACE_XtReactor &); ACE_XtReactor &operator = (const ACE_XtReactor &); // Deny access since member-wise won't work... }; #endif /* ACE_HAS_XT */ #endif /* ACE_XTREACTOR_H */