~ubuntu-branches/ubuntu/edgy/rxtx/edgy-201105201527

/*-------------------------------------------------------------------------

|   rxtx is a native interface to serial ports in java.

|

|   This library is free software; you can redistribute it and/or

|   modify it under the terms of the GNU Library General Public

   perform:     Initialize the native library

   return:      none

   exceptions:  none

 * Class:     gnu_io_RXTXPort

 * Method:    Initialize

 * Signature: ()V

  EventInfoStruct *EventInfo;

  DWORD dwErr;

 

  HANDLE hPort = CreateFileW(wszName,      // Pointer to the name of the port

                             GENERIC_READ | GENERIC_WRITE,// Access (read-write) mode

                             0,            // Share mode

                             0,            // Port attributes

                             NULL);        // Handle to port with attribute to copy

  // If it fails to open the port, return FALSE.

  { // Could not open the port.

    CreateErrorMsg(GetLastError(), lpMsgBuf);

    throw_java_exceptionW(env, PORT_IN_USE_EXCEPTION, L"open - CreateFile", lpMsgBuf );

    env->ReleaseStringChars(name, wszName);

    return (jint)INVALID_HANDLE_VALUE;

  }

 

  // Get the default port setting information.

  GetCommState(hPort, &PortDCB);

 

  // Change the DCB structure settings.

  PortDCB.fRtsControl = RTS_CONTROL_ENABLE;// RTS flow control

  PortDCB.fAbortOnError = FALSE;        // Do not abort reads/writes on error

 

  }

 

  // Retrieve the time-out parameters for all read and write operations

  GetCommTimeouts(hPort, &CommTimeouts);

 

  // Change the COMMTIMEOUTS structure settings.

 

  // Set the time-out parameters for all read and write operations

  if (!SetCommTimeouts(hPort, &CommTimeouts))

  { // Unable to set the time-out parameters

    CreateErrorMsg(GetLastError(), lpMsgBuf);

    return (jint)INVALID_HANDLE_VALUE;

  }

 

  EscapeCommFunction(hPort, SETRTS);

 

  if(dwErr = InitialiseEventInfoStruct(hPort, &EventInfo))

  { // Unable to set up EventInfo structure for event processing

                return (jint)INVALID_HANDLE_VALUE;

        }

        env->SetIntField(jobj, jfEis, (jint)EventInfo);

  env->ReleaseStringChars(name, wszName);

  // Returning HANDLE (which is a pointer) as file descriptor... Anyway, 32 bits are 32 bits

}

 

 

 * Signature: (IIII)V

 */

JNIEXPORT void JNICALL Java_gnu_io_RXTXPort_nativeSetSerialPortParams(JNIEnv *env, jobject jobj, jint speed, jint dataBits, jint stopBits, jint parity)

  DCB PortDCB;

  LPCWSTR lpMsgBuf;

 

  }

 

  // Change the DCB structure settings.

  {

    case gnu_io_RXTXPort_STOPBITS_1:

      PortDCB.StopBits = ONESTOPBIT;

 

    default:

      throw_java_exceptionW(env, UNSUPPORTED_COMM_OPERATION, L"nativeSetSerialPortParams", L"Incorrect stopBits");

  }

 

  // Configure the port according to the specifications of the DCB structure.

 * Signature: (I)V

 */

JNIEXPORT void JNICALL Java_gnu_io_RXTXPort_setflowcontrol(JNIEnv *env, jobject jobj, jint flowcontrol)

  DCB PortDCB;

  LPCWSTR lpMsgBuf;

 

    PortDCB.fInX = TRUE;

  else

    PortDCB.fInX = FALSE;

  if(flowcontrol & gnu_io_RXTXPort_FLOWCONTROL_XONXOFF_OUT)

    PortDCB.fOutX = TRUE;

  else

 

  // Configure the port according to the specifications of the DCB structure.

  if (!SetCommState (hPort, &PortDCB))

    printj(env, L"--- RXTXPort.NativegetReceiveTimeout() called\n");

  )

 

  if (!GetCommTimeouts(hPort, &CommTimeouts))

  { // Unable to get the time-out parameters

    CreateErrorMsg(GetLastError(), lpMsgBuf);

  )

 

  // Retrieve the time-out parameters for all read and write operations

  if (!GetCommTimeouts(hPort, &CommTimeouts))

  { // Unable to get the time-out parameters

    CreateErrorMsg(GetLastError(), lpMsgBuf);

  )

 

  // Retrieve the time-out parameters for all read and write operations

  if (!GetCommTimeouts(hPort, &CommTimeouts))

  { // Unable to get the time-out parameters

    CreateErrorMsg(GetLastError(), lpMsgBuf);

  /* ------ from javax.comm.CommPort javadoc -------------------------------------------------------------

  |    Threshold   |    Timeout   |Read Buffer Size | Read Behaviour

  |State   |Value  |State   |Value|                 |

  --------------------------------------------------------------------------------------------------------

  Otherwise, the behaviour is identical to having both the Timeout and Threshold disabled.

  */

 

 

  if(time == 0)

  { // polling mode - return if no data

  else if(time == -1)

  { // disable timeout

  }

  else

  { // set timeout

  }

 

  // Set the time-out parameters for all read and write operations

  if (!SetCommTimeouts (hPort, &CommTimeouts))

  { // Unable to set the time-out parameters

    CreateErrorMsg(GetLastError(), lpMsgBuf);

  DCB PortDCB;

  HANDLE hPort = get_fd(env, jobj);

 

 

  // Get the default port setting information.

  if(!GetCommState(hPort, &PortDCB))

    return JNI_FALSE;

  }

 

  // port closed) or disable mode (OFF).

  // So, don't use EscapeCommFunction(SETDTR/CLRDTR) in this library!

  return PortDCB.fDtrControl != DTR_CONTROL_DISABLE ? JNI_TRUE : JNI_FALSE;

 * Signature: (Z)V

 */

JNIEXPORT void JNICALL Java_gnu_io_RXTXPort_setDTR(JNIEnv *env, jobject jobj, jboolean state)

  DCB PortDCB;

 

  HANDLE hPort = get_fd(env, jobj);

 * Signature: (Z)V

 */

JNIEXPORT void JNICALL Java_gnu_io_RXTXPort_setRTS(JNIEnv *env, jobject jobj, jboolean state)

  HANDLE hPort = get_fd(env, jobj);

  // EscapeCommFunction will fail if there's RTS/CTS flowcontrol. If it is incorrect,

  // we could turn flowcontrol off when getting to this function

  if(state == JNI_TRUE)

 * Signature: (Z)V

 */

JNIEXPORT void JNICALL Java_gnu_io_RXTXPort_setDSR(JNIEnv *env, jobject jobj, jboolean state)

  DCB PortDCB;

 

  HANDLE hPort = get_fd(env, jobj);

  else

    PortDCB.fOutxDsrFlow = FALSE;

 

  // structure.

  if (!SetCommState (hPort, &PortDCB))

  { //Unable to configure the serial port

 

  if(!GetCommModemStatus(hPort, &ModemStat))

    return JNI_FALSE;

  return ModemStat|MS_CTS_ON ? JNI_TRUE : JNI_FALSE;

}

 

 

  if(!GetCommModemStatus(hPort, &ModemStat))

    return JNI_FALSE;

  return ModemStat|MS_DSR_ON ? JNI_TRUE : JNI_FALSE;

}

 

 

  if(!GetCommModemStatus(hPort, &ModemStat))

    return JNI_FALSE;

  return ModemStat|MS_RLSD_ON ? JNI_TRUE : JNI_FALSE;

}

 

 

  if(!GetCommModemStatus(hPort, &ModemStat))

    return JNI_FALSE;

  return ModemStat|MS_RING_ON ? JNI_TRUE : JNI_FALSE;

}

 

    printj(env, L"Undefined condition: isRTS() but control is RTS_CONTROL_HANDSHAKE. Returning FALSE\n");

    return JNI_FALSE;

  }

  return JNI_FALSE;

}

 

 * Signature: (I)V

 */

JNIEXPORT void JNICALL Java_gnu_io_RXTXPort_sendBreak(JNIEnv *env, jobject jobj, jint duration)

  HANDLE hPort = get_fd(env, jobj);

  SetCommBreak(hPort);

  Sleep(duration);

  ClearCommBreak(hPort);

   exceptions:  IOException

 * Class:     gnu_io_RXTXPort

 * Method:    writeByte

 */

  DWORD dwNumBytesWritten;

  LPCWSTR lpMsgBuf;

  HANDLE hPort = get_fd(env, jobj);

 

  do {

    if (!WriteFile(hPort,              // Port handle

                   1,                  // Number of bytes to write

                   &dwNumBytesWritten, // Pointer to the number of bytes written

                   NULL))              // Must be NULL for Windows CE

 * Signature: ([BIIZ)V

 */

JNIEXPORT void JNICALL Java_gnu_io_RXTXPort_writeArray(JNIEnv *env, jobject jobj, jbyteArray b, jint off, jint len, jboolean i)

  LPCWSTR lpMsgBuf;

        DWORD dwNumBytesWritten;

  jint total=0;

      printj(env, L"--- writeArray - %d bytes to write\n", len-total);

    )

    if (!WriteFile(hPort,              // Port handle

                   len-total,          // Number of bytes to write

                   &dwNumBytesWritten, // Pointer to the number of bytes written

                   NULL))              // Must be NULL for Windows CE

    }

    total += dwNumBytesWritten;

        } while( total < len );

  env->ReleaseByteArrayElements(b, body, JNI_ABORT);

}

 

 * Method:    nativeDrain

 * Signature: ()V

 */

  //COMSTAT Stat;

  //DWORD dwErrors;

  HANDLE hPort = get_fd(env, jobj);

  (

    printj(env, L"--- RXTXPort.nativeDrain() called\n");

  )

  if(!FlushFileBuffers(hPort))

  {

    IF_DEBUG

    )

    return JNI_FALSE;

  }

  do

  {

    if(!ClearCommError(hPort, &dwErrors, &Stat))

    throw_java_exceptionW(env, ARRAY_INDEX_OUT_OF_BOUNDS, L"readArray", L"Negative number of character to read");

    return -1;

  }

  jbyte *body = env->GetByteArrayElements(b, NULL);

  threshold = get_java_int_var(env, jobj, "threshold");

 

 

    dwTotalRead += dwNumBytesRead;

  } while(dwNumBytesRead > 0 && threshold != 0 && dwTotalRead <= (DWORD)len && dwTotalRead < (DWORD)threshold);

  env->ReleaseByteArrayElements(b, body, 0);

  return dwTotalRead;

}

 * Signature: ()V

 */

JNIEXPORT void JNICALL Java_gnu_io_RXTXPort_eventLoop(JNIEnv *env, jobject jobj)

  jfieldID jfMonitorThreadCloseLock, jfMonitorThreadLock, jfMonThreadisInterrupted;

  jmethodID jmSendEvent;

  HANDLE hCommEventThread;

  (

    printj(env, L"--- RXTXPort.eventLoop() start\n");

  )

  jclass cls = env->GetObjectClass(jobj);

 

  // Get pointers to some Java variables and methods:

      (

        printj(env, L"--- RXTXPort.eventLoop() interrupted - exiting\n");

      )

      CloseHandle(EventInfo->eventHandle);

            env->SetBooleanField(jobj, jfMonitorThreadCloseLock, JNI_FALSE);

      return;

    }

        ReleaseErrorMsg(lpMsgBuf);

      )

      CloseHandle(EventInfo->eventHandle);

      return;

    }

 

          printj(env, L"!!! eventLoop - SendEvents() result: %d\n", RetVal);

        )

        CloseHandle(EventInfo->eventHandle);

        return;

      }

    }

 * Signature: ()V

 */

JNIEXPORT void JNICALL Java_gnu_io_RXTXPort_interruptEventLoop(JNIEnv *env, jobject jobj)

  jfieldID jfid;

  HANDLE hPort = get_fd(env, jobj);

 

 * Signature: (IIZ)V

 */

JNIEXPORT void JNICALL Java_gnu_io_RXTXPort_nativeSetEventFlag(JNIEnv *env, jobject jobj, jint fd, jint event, jboolean flag)

  DWORD dwErr, NewFlag;

  EventInfoStruct *EventInfo = get_eis(env, jobj);

  HANDLE hPort = (HANDLE)fd;

    break;

 

  }

  if(flag == JNI_TRUE)

    EventInfo->ef = EventInfo->ef | NewFlag;

  else

    )

    return;

  }

}

 

/*

 * Signature: (Ljava/lang/String{ })V

 */

JNIEXPORT void JNICALL Java_gnu_io_RXTXPort_nativeClose(JNIEnv *env, jobject jobj, jstring name)

  HANDLE hPort = get_fd(env, jobj);

 

  IF_DEBUG

  (

    printj(env, L"--- RXTXPort.nativeClose(%s) called\n", wszName);

    env->ReleaseStringChars(name, wszName);

  )

   perform:     check the EndOf InputChar

   return:      the EndOfInputChar as an jbyte.  -1 on error

   exceptions:  UnsupportedCommOperationException if not implemented

 * Class:     gnu_io_RXTXPort

 * Method:    nativeGetEndOfInputChar

 * Signature: ()I