/* -*- C++ -*- */ // Handle_L_Pipe.i,v 4.9 2003/12/30 23:18:59 shuston Exp #include "ace/Get_Opt.h" #include "ace/OS_NS_stdio.h" #include "ace/OS_NS_string.h" ACE_INLINE Handle_L_Pipe::~Handle_L_Pipe (void) { } ACE_INLINE Handle_L_Pipe::Handle_L_Pipe (void) { } ACE_INLINE int Handle_L_Pipe::open (const ACE_UNIX_Addr &suap, int async) { if (this->ACE_LSOCK_Acceptor::open (suap) == -1) return -1; else if (async && this->ACE_LSOCK_Acceptor::enable (ACE_SIGIO) == -1) return -1; else return 0; } ACE_INLINE int Handle_L_Pipe::info (char **strp, size_t length) const { char buf[BUFSIZ]; ACE_UNIX_Addr sa; if (ACE_LSOCK_Acceptor::get_local_addr (sa) == -1) return -1; ACE_OS::sprintf (buf, "%s %s", sa.get_path_name (), "# tests local pipe\n"); if (*strp == 0 && (*strp = ACE_OS::strdup (buf)) == 0) return -1; else ACE_OS::strncpy (*strp, buf, length); return ACE_OS::strlen (buf); } ACE_INLINE int Handle_L_Pipe::init (int argc, char *argv[]) { ACE_UNIX_Addr sup; const char *r = Handle_L_Pipe::DEFAULT_RENDEZVOUS; ACE_Get_Opt get_opt (argc, argv, "r:", 0); for (int c; (c = get_opt ()) != -1; ) switch (c) { case 'r': r = get_opt.opt_arg (); break; default: break; } ACE_OS::strncpy (this->rendezvous, r, MAXPATHLEN); ACE_OS::unlink (this->rendezvous); sup.set (this->rendezvous); if (this->open (sup) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "open"), -1); else if (ACE_Reactor::instance ()->register_handler (this, ACE_Event_Handler::ACCEPT_MASK) == -1) ACE_ERROR_RETURN ((LM_ERROR, "registering service with ACE_Reactor\n"), -1); return 0; } ACE_INLINE int Handle_L_Pipe::fini (void) { return ACE_Reactor::instance ()->remove_handler (this, ACE_Event_Handler::ACCEPT_MASK); } ACE_INLINE int Handle_L_Pipe::get_handle (void) const { return ACE_LSOCK_Acceptor::get_handle (); } ACE_INLINE int Handle_L_Pipe::handle_close (ACE_HANDLE, ACE_Reactor_Mask) { this->ACE_LSOCK_Acceptor::close (); return ACE_OS::unlink (this->rendezvous); }