Category

Development Platform
Home > SourceCode/Document > Internet-Socket-Network > TCP/IP Stack > View Code
TTY_IO.cpp
Package: ACE-5.4.tar.gz　[view]
Upload User: wintxp
Upload Date: 2009-12-21
Package Size: 7842k
Code Size: 14k
Category:

TCP/IP Stack

Development Platform:

Unix_Linux

TTY_IO.cpp：Code Content
  1. // TTY_IO.cpp,v 4.38 2003/11/01 11:15:18 dhinton Exp
  3. #include "ace/TTY_IO.h"
  4. #include "ace/OS_NS_string.h"
  5. #include "ace/OS_NS_strings.h"
  6. #include "ace/os_include/os_termios.h"
  7. #include "ace/OS_NS_errno.h"
  9. ACE_RCSID (ace,
  10.            TTY_IO,
  11.            "TTY_IO.cpp,v 4.38 2003/11/01 11:15:18 dhinton Exp")
  13. ACE_TTY_IO::Serial_Params::Serial_Params (void)
  14. {
  15.   ACE_OS::memset (this, 0, sizeof *this);
  16. }
  18. // Interface for reading/writing serial device parameters
  20. int
  21. ACE_TTY_IO::control (Control_Mode cmd,
  22.                      Serial_Params *arg) const
  23. {
  24. #if defined (ACE_HAS_TERM_IOCTLS)
  25. #if defined(TCGETS)
  26.   struct termios devpar;
  27. #elif defined(TCGETA)
  28.   struct termio devpar;
  29. #else
  30.   errno = ENOSYS;
  31.   return -1;
  32. #endif
  33.   u_long c_iflag;
  34.   u_long c_oflag;
  35.   u_long c_cflag;
  36.   u_long c_lflag;
  37.   // u_long c_line;
  38.   u_char ivmin_cc4;
  39.   u_char ivtime_cc5;
  41.   c_iflag=0;
  42.   c_oflag=0;
  43.   c_cflag=0;
  44.   c_lflag=0;
  45.   // c_line=0;
  47.   // Get default device parameters.
  49. #if defined (TCGETS)
  50.     if (this->ACE_IO_SAP::control (TCGETS, (void *) &devpar) == -1)
  51. #elif defined (TCGETA)
  52.     if (this->ACE_IO_SAP::control (TCGETA, (void *) &devpar) == -1)
  53. #else
  54.     errno = ENOSYS;
  55. #endif /* TCGETS */
  56.       return -1;
  58.   u_int newbaudrate = 0;
  60.   switch (cmd)
  61.     {
  62.     case SETPARAMS:
  63.       switch (arg->baudrate)
  64.         {
  65. #if defined (B0)
  66. case 0:       newbaudrate = B0;       break;
  67. #endif /* B0 */
  68. #if defined (B50)
  69. case 50:      newbaudrate = B50;      break;
  70. #endif /* B50 */
  71. #if defined (B75)
  72. case 75:      newbaudrate = B75;      break;
  73. #endif /* B75 */
  74. #if defined (B110)
  75. case 110:     newbaudrate = B110;     break;
  76. #endif /* B110 */
  77. #if defined (B134)
  78. case 134:     newbaudrate = B134;     break;
  79. #endif /* B134 */
  80. #if defined (B150)
  81. case 150:     newbaudrate = B150;     break;
  82. #endif /* B150 */
  83. #if defined (B200)
  84. case 200:     newbaudrate = B200;     break;
  85. #endif /* B200 */
  86. #if defined (B300)
  87.         case 300:     newbaudrate = B300;     break;
  88. #endif /* B300 */
  89. #if defined (B600)
  90.         case 600:     newbaudrate = B600;     break;
  91. #endif /* B600 */
  92. #if defined (B1200)
  93.         case 1200:    newbaudrate = B1200;    break;
  94. #endif /* B1200 */
  95. #if defined (B1800)
  96. case 1800:    newbaudrate = B1800;    break;
  97. #endif /* B1800 */
  98. #if defined (B2400)
  99.         case 2400:    newbaudrate = B2400;    break;
  100. #endif /* B2400 */
  101. #if defined (B4800)
  102.         case 4800:    newbaudrate = B4800;    break;
  103. #endif /* B4800 */
  104. #if defined (B9600)
  105.         case 9600:    newbaudrate = B9600;    break;
  106. #endif /* B9600 */
  107. #if defined (B19200)
  108.         case 19200:   newbaudrate = B19200;   break;
  109. #endif /* B19200 */
  110. #if defined (B38400)
  111.         case 38400:   newbaudrate = B38400;   break;
  112. #endif /* B38400 */
  113. #if defined (B56000)
  114. case 56000:   newbaudrate = B56000;   break;
  115. #endif /* B56000 */
  116. #if defined (B57600)
  117.         case 57600:   newbaudrate = B57600;   break;
  118. #endif /* B57600 */
  119. #if defined (B76800)
  120. case 76800:   newbaudrate = B76800;   break;
  121. #endif /* B76800 */
  122. #if defined (B115200)
  123.         case 115200:  newbaudrate = B115200;  break;
  124. #endif /* B115200 */
  125. #if defined (B128000)
  126. case 128000:  newbaudrate = B128000;  break;
  127. #endif /* B128000 */
  128. #if defined (B153600)
  129. case 153600:  newbaudrate = B153600;  break;
  130. #endif /* B153600 */
  131. #if defined (B230400)
  132. case 230400:  newbaudrate = B230400;  break;
  133. #endif /* B230400 */
  134. #if defined (B307200)
  135. case 307200:  newbaudrate = B307200;  break;
  136. #endif /* B307200 */
  137. #if defined (B256000)
  138. case 256000:  newbaudrate = B256000;  break;
  139. #endif /* B256000 */
  140. #if defined (B460800)
  141. case 460800:  newbaudrate = B460800;  break;
  142. #endif /* B460800 */
  143. #if defined (B500000)
  144. case 500000:  newbaudrate = B500000;  break;
  145. #endif /* B500000 */
  146. #if defined (B576000)
  147. case 576000:  newbaudrate = B576000;  break;
  148. #endif /* B576000 */
  149. #if defined (B921600)
  150. case 921600:  newbaudrate = B921600;  break;
  151. #endif /* B921600 */
  152. #if defined (B1000000)
  153. case 1000000: newbaudrate = B1000000; break;
  154. #endif /* B1000000 */
  155. #if defined (B1152000)
  156. case 1152000: newbaudrate = B1152000; break;
  157. #endif /* B1152000 */
  158. #if defined (B1500000)
  159. case 1500000: newbaudrate = B1500000; break;
  160. #endif /* B1500000 */
  161. #if defined (B2000000)
  162. case 2000000: newbaudrate = B2000000; break;
  163. #endif /* B2000000 */
  164. #if defined (B2500000)
  165. case 2500000: newbaudrate = B2500000; break;
  166. #endif /* B2500000 */
  167. #if defined (B3000000)
  168. case 3000000: newbaudrate = B3000000; break;
  169. #endif /* B3000000 */
  170. #if defined (B3500000)
  171. case 3500000: newbaudrate = B3500000; break;
  172. #endif /* B3500000 */
  173. #if defined (B4000000)
  174. case 4000000: newbaudrate = B4000000; break;
  175. #endif /* B4000000 */
  176.         default:
  177.           return -1;
  178.         }
  180. #if defined(ACE_USES_NEW_TERMIOS_STRUCT)
  181.       // @@ Can you really have different input and output baud
  182.       // rates?!
  183.       devpar.c_ispeed = newbaudrate;
  184.       devpar.c_ospeed = newbaudrate;
  185. #else
  186.       c_cflag |= newbaudrate;
  187. #endif /* ACE_USES_NEW_TERMIOS_STRUCT */
  189.       switch (arg->databits)
  190.         {
  191.         case   5:
  192.           c_cflag |= CS5;
  193.           break;
  194.         case   6:
  195.           c_cflag |= CS6;
  196.           break;
  197.         case   7:
  198.           c_cflag |= CS7;
  199.           break;
  200.         case   8:
  201.           c_cflag |= CS8;
  202.           break;
  203.         default:
  204.           return -1;
  205.         }
  207.       switch (arg->stopbits)
  208.         {
  209.         case   1:
  210.           break;
  211.         case   2:
  212.           c_cflag |= CSTOPB;
  213.           break;
  214.         default:
  215.           return -1;
  216.         }
  217.       if (arg->parityenb)
  218.         {
  219.           c_cflag |= PARENB;
  220.           if (ACE_OS::strcasecmp (arg->paritymode, "odd") == 0)
  221.             c_cflag |= PARODD;
  222.         }
  224. #if defined (CRTSCTS)
  225.           // 6/22/00 MLS add rtsenb to if statement
  226.       if ((arg->ctsenb)||(arg->rtsenb)) /* enable CTS/RTS protocoll */
  227.         c_cflag |= CRTSCTS;
  228. #endif /* CRTSCTS */
  229. #if defined (NEW_RTSCTS)
  230.       // 8/30/00 MLS add rtsenb to if statement to support new termios
  231.       if ((arg->ctsenb)||(arg->rtsenb)) /* enable CTS/RTS protocoll */
  232.         c_cflag |= NEW_RTSCTS;
  233. #endif /* CRTSCTS */
  234. #if defined (CREAD)
  235.       if (arg->rcvenb) /* enable receiver */
  236.         c_cflag |= CREAD;
  237. #endif /* CREAD */
  240. #if defined (HUPCL)
  241.       // Cause DTR to be drop after port close MS 7/24/2000;
  242.       c_cflag |= HUPCL;
  243. #endif /* HUPCL */
  245. #if defined (CLOCAL)
  246.       // if device is not a modem set to local device MS  7/24/2000
  247.       if(!arg->modem)
  248.         c_cflag |= CLOCAL;
  249. #endif /* CLOCAL */
  251.       c_oflag = 0;
  252.       c_iflag = IGNPAR | INPCK;
  253.       if (arg->databits < 8)
  254.         c_iflag |= ISTRIP;
  255. #if defined (IGNBRK)
  256.       // if device is not a modem set to ignore break points MS  7/24/2000
  257.       if(!arg->modem)
  258.         c_iflag |= IGNBRK;
  259. #endif /* IGNBRK */
  260.           // 6/22/00 MLS add enable xon/xoff
  261. #if defined (IXON)
  262.       if (arg->xinenb) /* enable XON/XOFF output*/
  263.         c_iflag |= IXON;
  264. #endif /* IXON */
  265. #if defined (IXOFF)
  266.       if (arg->xoutenb) /* enable XON/XOFF input*/
  267.         c_iflag |= IXOFF;
  268. #endif /* IXOFF */
  269.       c_lflag = 0;
  271.       ivmin_cc4 = (u_char) arg->readmincharacters;
  272.       ivtime_cc5= (u_char) (arg->readtimeoutmsec / 100);
  273.       devpar.c_iflag = c_iflag;
  274.       devpar.c_oflag = c_oflag;
  275.       devpar.c_cflag = c_cflag;
  276.       devpar.c_lflag = c_lflag;
  277.       devpar.c_cc[ACE_VMIN] = ivmin_cc4;
  278.       devpar.c_cc[ACE_VTIME] = ivtime_cc5;
  280. #if defined(TIOCMGET)
  281.       // ensure DTR is enabled
  282.       int status;
  283.       this->ACE_IO_SAP::control (TIOCMGET, &status);
  285.        if (arg->dtrdisable)
  286.          status &= ~TIOCM_DTR;
  287.        else
  288.          status |= TIOCM_DTR;
  290.       this->ACE_IO_SAP::control (TIOCMSET,&status);
  291. #endif /* definded (TIOCMGET) */
  293. #if defined(TCSETS)
  294.       return this->ACE_IO_SAP::control (TCSETS,
  295.                                         (void *) &devpar);
  296. #elif defined(TCSETA)
  297.       return this->ACE_IO_SAP::control (TCSETA,
  298.                                         (void *) &devpar);
  299. #else
  300.       errno = ENOSYS;
  301.       return -1;
  302. #endif
  303.     case GETPARAMS:
  304.       return -1; // Not yet implemented.
  305.     default:
  306.       return -1; // Wrong cmd.
  307.     }
  308. #elif defined (ACE_WIN32)
  309.   switch (cmd)
  310.     {
  311.     case SETPARAMS:
  312.       DCB dcb;
  313.       dcb.DCBlength = sizeof dcb;
  314.       if (!::GetCommState (this->get_handle (), &dcb))
  315.         {
  316.           ACE_OS::set_errno_to_last_error ();
  317.           return -1;
  318.         }
  319. /*SadreevAA
  320.       switch (arg->baudrate)
  321.         {
  322.         case   300: dcb.BaudRate = CBR_300; break;
  323.         case   600: dcb.BaudRate = CBR_600; break;
  324.         case  1200: dcb.BaudRate = CBR_1200; break;
  325.         case  2400: dcb.BaudRate = CBR_2400; break;
  326.         case  4800: dcb.BaudRate = CBR_4800; break;
  327.         case  9600: dcb.BaudRate = CBR_9600; break;
  328.         case  19200: dcb.BaudRate = CBR_19200; break;
  329.         case  38400: dcb.BaudRate = CBR_38400; break;
  330. //          case  56000: dcb.BaudRate = CBR_56000; break;
  331.         case  57600: dcb.BaudRate = CBR_57600; break;
  332.         case  115200: dcb.BaudRate = CBR_115200; break;
  333. //          case  128000: dcb.BaudRate = CBR_128000; break;
  334. //          case  256000: dcb.BaudRate = CBR_256000; break;
  335.         default:  return -1;
  336.         }
  337. */
  338.       dcb.BaudRate = arg->baudrate;
  339.       switch (arg->databits)
  340.         {
  341.         case 4:
  342.         case 5:
  343.         case 6:
  344.         case 7:
  345.         case 8:
  346.           dcb.ByteSize = u_char (arg->databits);
  347.           break;
  348.         default:
  349.           return -1;
  350.         }
  352.       switch (arg->stopbits)
  353.         {
  354.         case 1:
  355.           dcb.StopBits = ONESTOPBIT;
  356.           break;
  357.         case 2:
  358.           dcb.StopBits = TWOSTOPBITS;
  359.           break;
  360.         default:
  361.           return -1;
  362.         }
  365.       // 6/22/00 MLS enabled extra paths for win32 parity checking.
  366.       if (arg->parityenb)
  367.         {
  368.           dcb.fParity = TRUE;
  369.           if (ACE_OS::strcasecmp (arg->paritymode, "odd") == 0)
  370.             dcb.Parity = ODDPARITY;
  371.           else if (ACE_OS::strcasecmp (arg->paritymode, "even") == 0)
  372.             dcb.Parity = EVENPARITY;
  373.           else if (ACE_OS::strcasecmp (arg->paritymode, "mark") == 0)
  374.             dcb.Parity = MARKPARITY;
  375.           else if (ACE_OS::strcasecmp (arg->paritymode, "space") == 0)
  376.             dcb.Parity = SPACEPARITY;
  377.           else
  378.             dcb.Parity = NOPARITY;
  379.         }
  380.       else
  381.         {
  382.           dcb.fParity = FALSE;
  383.           dcb.Parity = NOPARITY;
  384.         }
  386.       if (arg->ctsenb) // enable CTS protocol.
  387.         dcb.fOutxCtsFlow = TRUE;
  388.       else
  389.         dcb.fOutxCtsFlow = FALSE;
  391.             // SadreevAA
  392.       if (arg->dsrenb) // enable DSR protocol.
  393.         dcb.fOutxDsrFlow = TRUE;
  394.       else
  395.         dcb.fOutxDsrFlow = FALSE;
  397.       // 6/22/00 MLS add  great flexibility for win32
  398.       //                     pulled rts out of ctsenb
  399.       switch (arg->rtsenb) // enable RTS protocol.
  400.         {
  401.         case 1:
  402.           dcb.fRtsControl = RTS_CONTROL_ENABLE;
  403.           break;
  404.         case 2:
  405.           dcb.fRtsControl = RTS_CONTROL_HANDSHAKE;
  406.           break;
  407.         case 3:
  408.           dcb.fRtsControl = RTS_CONTROL_TOGGLE;
  409.           break;
  410.         default:
  411.           dcb.fRtsControl = RTS_CONTROL_DISABLE;
  412.         }
  414.       // 6/22/00 MLS add enable xon/xoff
  415.       if (arg->xinenb) // enable XON/XOFF for reception
  416.         dcb.fInX = TRUE; // Fixed by SadreevAA
  417.       else
  418.         dcb.fInX = FALSE; // Fixed by SadreevAA
  420.       if (arg->xoutenb) // enable XON/XOFF for transmission
  421.         dcb.fOutX = TRUE;
  422.       else
  423.         dcb.fOutX = FALSE;
  425.       // always set limits unless set to -1 to use default
  426.       // 6/22/00 MLS add xon/xoff limits
  427.       if (arg->xonlim != -1)
  428.         dcb.XonLim  = arg->xonlim;
  429.       if (arg->xofflim != -1)
  430.         dcb.XoffLim  = arg->xofflim;
  432.      if (arg->dtrdisable)
  433.        dcb.fDtrControl = DTR_CONTROL_DISABLE;
  434.      else
  435.        dcb.fDtrControl = DTR_CONTROL_ENABLE;
  437.       dcb.fAbortOnError = FALSE;
  438.       dcb.fErrorChar = FALSE;
  439.       dcb.fNull = FALSE;
  440.       dcb.fBinary = TRUE;
  441.       if (!::SetCommState (this->get_handle (), &dcb))
  442.         {
  443.           ACE_OS::set_errno_to_last_error ();
  444.           return -1;
  445.         }
  447.       // 2/13/97 BWF added drop out timer
  448.       // modified time out to operate correctly with when delay
  449.       // is requested or no delay is requestes
  450.       COMMTIMEOUTS timeouts;
  451.       if (!::GetCommTimeouts (this->get_handle(), &timeouts))
  452.         {
  453.           ACE_OS::set_errno_to_last_error ();
  454.           return -1;
  455.         }
  457.       if (arg->readtimeoutmsec == 0)
  458.         {
  459.           // return immediately if no data in the input buffer
  460.           timeouts.ReadIntervalTimeout = MAXDWORD;
  461.           timeouts.ReadTotalTimeoutMultiplier = 0;
  462.           timeouts.ReadTotalTimeoutConstant   = 0;
  463.         }
  464.       else
  465.         {
  466.           // Wait for specified  time-out for char to arrive
  467.           // before returning.
  468.           timeouts.ReadIntervalTimeout        = MAXDWORD;
  469.           timeouts.ReadTotalTimeoutMultiplier = MAXDWORD;
  471.           // ensure specified timeout is below MAXDWORD
  473.           // We don't test arg->readtimeoutmsec against MAXDWORD
  474.           // directly to avoid a warning in the case DWORD is
  475.           // unsigned.  Ensure specified timeout is below MAXDWORD use
  476.           // MAXDWORD as indicator for infinite timeout.
  477.           DWORD dw = arg->readtimeoutmsec;
  478.           if (dw < MAXDWORD)
  479.             {
  480.               // Wait for specified time-out for char to arrive before
  481.               // returning.
  482.               timeouts.ReadIntervalTimeout = MAXDWORD;
  483.               timeouts.ReadTotalTimeoutMultiplier = MAXDWORD;
  484.               timeouts.ReadTotalTimeoutConstant = dw;
  485.             }
  486.           else
  487.             {
  488.               // settings for infinite timeout
  489.               timeouts.ReadIntervalTimeout = 0;
  490.               timeouts.ReadTotalTimeoutMultiplier = 0;
  491.               timeouts.ReadTotalTimeoutConstant = 0;
  492.             }
  493.           }
  495.        if (!::SetCommTimeouts (this->get_handle (), &timeouts))
  496.          {
  497.            ACE_OS::set_errno_to_last_error ();
  498.            return -1;
  499.          }
  501.        return 0;
  503.     case GETPARAMS:
  504.       ACE_NOTSUP_RETURN (-1); // Not yet implemented.
  505.     default:
  506.       return -1; // Wrong cmd.
  508.     } // arg switch
  509. #else
  510.   ACE_UNUSED_ARG (cmd);
  511.   ACE_UNUSED_ARG (arg);
  512.   ACE_NOTSUP_RETURN (-1);
  513. #endif /* ACE_HAS_TERM_IOCTLS */
  514. }
  516. #if defined (ACE_NEEDS_DEV_IO_CONVERSION)
  517. ACE_TTY_IO::operator ACE_DEV_IO &()
  518. {
  519.   return (ACE_DEV_IO &) *this;
  520. }
  521. #endif /* ACE_NEEDS_DEV_IO_CONVERSION */