2007-10-22 Atsushi Enomoto <atsushi@ximian.com>

[mono.git] / mcs / class / System / System.IO.Ports / WinSerialStream.cs

diff --git a/mcs/class/System/System.IO.Ports/WinSerialStream.cs b/mcs/class/System/System.IO.Ports/WinSerialStream.cs
index b2c097712b789b5a8315a0d41c905d4601b31931..916d45e37e4cda0c79e004d45f20acf545ae2f89 100644 (file)
--- a/mcs/class/System/System.IO.Ports/WinSerialStream.cs
+++ b/mcs/class/System/System.IO.Ports/WinSerialStream.cs
@@ -74,8 +74,8 @@ namespace System.IO.Ports
                [DllImport("kernel32", SetLastError = true)]
                static extern bool SetCommTimeouts(int handle, Timeouts timeouts);
 
-               public WinSerialStream (string port_name, int baud_rate, int data_bits, Parity parity,
-                               StopBits sb, Handshake hs, int read_timeout, int write_timeout,
+               public WinSerialStream (string port_name, int baud_rate, int data_bits, Parity parity, StopBits sb,
+                               bool dtr_enable, bool rts_enable, Handshake hs, int read_timeout, int write_timeout,
                                int read_buffer_size, int write_buffer_size)
                {
                        handle = CreateFile (port_name, GenericRead | GenericWrite, 0, 0, OpenExisting,
@@ -99,16 +99,31 @@ namespace System.IO.Ports
                        if (!SetCommTimeouts(handle, timeouts))
                                ReportIOError (null);
 
+                       /// Set DTR and RTS
+                       SetSignal(SerialSignal.Dtr, dtr_enable);
+
+                       if (hs != Handshake.RequestToSend &&
+                                       hs != Handshake.RequestToSendXOnXOff)
+                               SetSignal(SerialSignal.Rts, rts_enable);
+
                        // Init overlapped structures
                        NativeOverlapped wo = new NativeOverlapped ();
                        write_event = new ManualResetEvent (false);
+#if NET_2_0
+                       wo.EventHandle = write_event.Handle;
+#else
                        wo.EventHandle = (int) write_event.Handle;
+#endif
                        write_overlapped = Marshal.AllocHGlobal (Marshal.SizeOf (typeof (NativeOverlapped)));
                        Marshal.StructureToPtr (wo, write_overlapped, true);
 
                        NativeOverlapped ro = new NativeOverlapped ();
                        read_event = new ManualResetEvent (false);
+#if NET_2_0
+                       ro.EventHandle = read_event.Handle;
+#else
                        ro.EventHandle = (int) read_event.Handle;
+#endif
                        read_overlapped = Marshal.AllocHGlobal (Marshal.SizeOf (typeof (NativeOverlapped)));
                        Marshal.StructureToPtr (ro, read_overlapped, true);
                }
@@ -231,6 +246,7 @@ namespace System.IO.Ports
                        throw new NotSupportedException();
                }
 
+#if !TARGET_JVM
                [DllImport("kernel32", SetLastError = true)]
                        static extern unsafe bool ReadFile (int handle, byte* buffer, int bytes_to_read,
                                        out int bytes_read, IntPtr overlapped);
@@ -238,18 +254,19 @@ namespace System.IO.Ports
                [DllImport("kernel32", SetLastError = true)]
                        static extern unsafe bool GetOverlappedResult (int handle, IntPtr overlapped,
                                        ref int bytes_transfered, bool wait);
+#endif
 
                public override int Read ([In, Out] byte [] buffer, int offset, int count)
                {
                        CheckDisposed ();
                        if (buffer == null)
                                throw new ArgumentNullException ("buffer");
-                       if (offset < 0 || offset >= buffer.Length)
-                               throw new ArgumentOutOfRangeException ("offset");
-                       if (count < 0 || count > buffer.Length)
-                               throw new ArgumentOutOfRangeException ("count");
-                       if (count > buffer.Length - offset)
-                               throw new ArgumentException ();
+                       if (offset < 0 || count < 0)
+                               throw new ArgumentOutOfRangeException ("offset or count less than zero.");
+
+                       if (buffer.Length - offset < count )
+                               throw new ArgumentException ("offset+count",
+                                                             "The size of the buffer is less than offset + count.");
 
                        int bytes_read;
 
@@ -274,21 +291,24 @@ namespace System.IO.Ports
                        return bytes_read;
                }
 
+#if !TARGET_JVM
                [DllImport("kernel32", SetLastError = true)]
                static extern unsafe bool WriteFile (int handle, byte* buffer, int bytes_to_write,
                                out int bytes_written, IntPtr overlapped);
+#endif
 
                public override void Write (byte [] buffer, int offset, int count)
                {
                        CheckDisposed ();
                        if (buffer == null)
                                throw new ArgumentNullException ("buffer");
-                       if (offset < 0 || offset >= buffer.Length)
-                               throw new ArgumentOutOfRangeException ("offset");
-                       if (count < 0 || count > buffer.Length)
-                               throw new ArgumentOutOfRangeException ("count");
-                       if (count > buffer.Length - offset)
-                               throw new ArgumentException ("count > buffer.Length - offset");
+
+                       if (offset < 0 || count < 0)
+                               throw new ArgumentOutOfRangeException ();
+
+                       if (buffer.Length - offset < count)
+                               throw new ArgumentException ("offset+count",
+                                                            "The size of the buffer is less than offset + count.");
 
                        int bytes_written = 0;
 
@@ -415,7 +435,7 @@ namespace System.IO.Ports
 
                public void SetSignal (SerialSignal signal, bool value)
                {
-                       if (signal != SerialSignal.Rts || signal != SerialSignal.Dtr)
+                       if (signal != SerialSignal.Rts && signal != SerialSignal.Dtr)
                                throw new Exception ("Wrong internal value");
 
                        uint flag;
@@ -424,7 +444,7 @@ namespace System.IO.Ports
                                        flag = SetRts;
                                else
                                        flag = ClearRts;
-                       else 
+                       else
                                if (value)
                                        flag = SetDtr;
                                else
@@ -461,6 +481,23 @@ namespace System.IO.Ports
                public byte evt_char;
                public short w_reserved1;
 
+               // flags:
+               //const int fBinary = 0x0001;
+               //const int fParity = 0x0002;
+               const int fOutxCtsFlow = 0x0004;
+               //const int fOutxDsrFlow1 = 0x0008;
+               //const int fOutxDsrFlow2 = 0x0010;
+               //const int fDtrControl = 0x00020;
+               //const int fDsrSensitivity = 0x0040;
+               //const int fTXContinueOnXoff = 0x0080;
+               const int fOutX = 0x0100;
+               const int fInX = 0x0200;
+               //const int fErrorChar = 0x0400;
+               //const int fNull = 0x0800;
+               //const int fRtsControl1 = 0x1000;
+               const int fRtsControl2 = 0x2000;
+               //const int fAbortOnError = 0x4000;
+
                public void SetValues (int baud_rate, Parity parity, int byte_size, StopBits sb, Handshake hs)
                {
                        switch (sb) {
@@ -478,10 +515,30 @@ namespace System.IO.Ports
                        }
 
                        this.baud_rate = baud_rate;
-                       this.parity = (byte) parity;
-                       this.byte_size = (byte) byte_size;
-               }
+                       this.parity = (byte)parity;
+                       this.byte_size = (byte)byte_size;
+
+                       // Clear Handshake flags
+                       flags &= ~(fOutxCtsFlow | fOutX | fInX | fRtsControl2);
 
+                       // Set Handshake flags
+                       switch (hs)
+                       {
+                               case Handshake.None:
+                                       break;
+                               case Handshake.XOnXOff:
+                                       flags |= fOutX | fInX;
+                                       break;
+                               case Handshake.RequestToSend:
+                                       flags |= fOutxCtsFlow | fRtsControl2;
+                                       break;
+                               case Handshake.RequestToSendXOnXOff:
+                                       flags |= fOutxCtsFlow | fOutX | fInX | fRtsControl2;
+                                       break;
+                               default: // Shouldn't happen
+                                       break;
+                       }
+               }
        }
        
        [StructLayout (LayoutKind.Sequential)]