(file) Return to MessageQueueService.h CVS log (file) (dir) Up to [Pegasus] / pegasus / src / Pegasus / Common

Diff for /pegasus/src/Pegasus/Common/MessageQueueService.h between version 1.16.2.1 and 1.21

version 1.16.2.1, 2002/03/04 11:57:39 version 1.21, 2002/03/11 14:58:54
Line 60 
Line 60 
  
       virtual ~MessageQueueService(void);       virtual ~MessageQueueService(void);
  
       virtual void handle_heartbeat_request(AsyncRequest *req);  
       virtual void handle_heartbeat_reply(AsyncReply *rep);  
   
       virtual void handle_AsyncIoctl(AsyncIoctl *req);  
       virtual void handle_CimServiceStart(CimServiceStart *req);  
       virtual void handle_CimServiceStop(CimServiceStop *req);  
       virtual void handle_CimServicePause(CimServicePause *req);  
       virtual void handle_CimServiceResume(CimServiceResume *req);  
   
       virtual void handle_AsyncOperationStart(AsyncOperationStart *req);  
       virtual void handle_AsyncOperationResult(AsyncOperationResult *rep);  
       virtual void handle_AsyncLegacyOperationStart(AsyncLegacyOperationStart *req);  
       virtual void handle_AsyncLegacyOperationResult(AsyncLegacyOperationResult *rep);  
   
       virtual Boolean isAsync(void) {  return true;  }       virtual Boolean isAsync(void) {  return true;  }
  
       virtual Boolean accept_async(AsyncOpNode *op);  
       virtual Boolean messageOK(const Message *msg) ;  
   
       virtual void enqueue(Message *) throw(IPCException);       virtual void enqueue(Message *) throw(IPCException);
  
       AsyncReply *SendWait(AsyncRequest *request);       AsyncReply *SendWait(AsyncRequest *request);
       Boolean SendAsync(AsyncOpNode *op,       Boolean SendAsync(AsyncOpNode *op,
                         Uint32 destination,                         Uint32 destination,
                         void (*callback)(AsyncOpNode *, MessageQueue *, void *), void *);                          void (*callback)(AsyncOpNode *, MessageQueue *, void *),
       void ReplyAsync(AsyncOpNode *op, Uint32 destination);                          MessageQueue *callback_q,
                           void *callback_ptr);
       Boolean  SendForget(Message *msg);       Boolean  SendForget(Message *msg);
       void ForwardRequest(AsyncOpNode *, MessageQueue *);        Boolean ForwardOp(AsyncOpNode *, Uint32 destination);
       void ForwardResponse(AsyncOpNode *, MessageQueue *);  
  
       void _completeAsyncResponse(AsyncRequest *request,  
                                  AsyncReply *reply,  
                                  Uint32 state,  
                                  Uint32 flag);  
       Boolean register_service(String name, Uint32 capabilities, Uint32 mask);       Boolean register_service(String name, Uint32 capabilities, Uint32 mask);
       Boolean update_service(Uint32 capabilities, Uint32 mask);       Boolean update_service(Uint32 capabilities, Uint32 mask);
       Boolean deregister_service(void);       Boolean deregister_service(void);
       virtual void _shutdown_incoming_queue(void);       virtual void _shutdown_incoming_queue(void);
   
       void find_services(String name,       void find_services(String name,
                          Uint32 capabilities,                          Uint32 capabilities,
                          Uint32 mask,                          Uint32 mask,
Line 110 
Line 91 
       Uint32 _mask;       Uint32 _mask;
       AtomicInt _die;       AtomicInt _die;
    protected:    protected:
         virtual Boolean accept_async(AsyncOpNode *op);
         virtual Boolean messageOK(const Message *msg) ;
       virtual void handleEnqueue(void) = 0;       virtual void handleEnqueue(void) = 0;
       virtual void handleEnqueue(Message *) = 0;       virtual void handleEnqueue(Message *) = 0;
       Boolean _enqueueResponse(Message *, Message *);       Boolean _enqueueResponse(Message *, Message *);
Line 118 
Line 101 
       virtual void _handle_async_callback(AsyncOpNode *operation);       virtual void _handle_async_callback(AsyncOpNode *operation);
       virtual void _make_response(Message *req, Uint32 code);       virtual void _make_response(Message *req, Uint32 code);
  
   
         virtual void handle_heartbeat_request(AsyncRequest *req);
         virtual void handle_heartbeat_reply(AsyncReply *rep);
   
         virtual void handle_AsyncIoctl(AsyncIoctl *req);
         virtual void handle_CimServiceStart(CimServiceStart *req);
         virtual void handle_CimServiceStop(CimServiceStop *req);
         virtual void handle_CimServicePause(CimServicePause *req);
         virtual void handle_CimServiceResume(CimServiceResume *req);
   
         virtual void handle_AsyncOperationStart(AsyncOperationStart *req);
         virtual void handle_AsyncOperationResult(AsyncOperationResult *rep);
         virtual void handle_AsyncLegacyOperationStart(AsyncLegacyOperationStart *req);
         virtual void handle_AsyncLegacyOperationResult(AsyncLegacyOperationResult *rep);
   
         void _completeAsyncResponse(AsyncRequest *request,
                                    AsyncReply *reply,
                                    Uint32 state,
                                    Uint32 flag);
         void _complete_op_node(AsyncOpNode *, Uint32, Uint32, Uint32);
   
   
       static cimom *_meta_dispatcher;       static cimom *_meta_dispatcher;
       static AtomicInt _service_count;       static AtomicInt _service_count;
       static Mutex _meta_dispatcher_mutex;       static Mutex _meta_dispatcher_mutex;
  
   
    private:    private:
  
       DQueue<AsyncOpNode> _pending;       DQueue<AsyncOpNode> _pending;
       AsyncDQueue<AsyncOpNode> _incoming;       AsyncDQueue<AsyncOpNode> _incoming;
         AsyncDQueue<AsyncOpNode> _callback;
  
       static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL _req_proc(void *);       static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL _req_proc(void *);
         static void _sendwait_callback(AsyncOpNode *, MessageQueue *, void *);
       AtomicInt _incoming_queue_shutdown;       AtomicInt _incoming_queue_shutdown;
   
       Thread _req_thread;       Thread _req_thread;
   
       struct timeval _default_op_timeout;       struct timeval _default_op_timeout;
   
       static AtomicInt _xid;       static AtomicInt _xid;
         friend class cimom;
   
   
   
 }; };
  
 PEGASUS_NAMESPACE_END PEGASUS_NAMESPACE_END

Legend:
Removed from v.1.16.2.1  
changed lines
  Added in v.1.21
No CVS admin address has been configured
 Powered by
ViewCVS 0.9.2