Message transfer using multiplexed connections in an open system interconnection transaction processing environment

• US 20050193056A1
• Filed: 12/26/2002
• Published: 09/01/2005
• Est. Priority Date: 12/26/2002
• Status: Abandoned Application

• Current Assignee: Unisys Corporation
• Original Assignee: Unisys Corporation
• Inventors: Schaefer, Diane E., Burdeau, Stephen A.
• Application Number:
  US10/329,723
• Publication Number:
  US 20050193056A1
• Time in Patent Office: Days
• US Class Current: 709/203
• CPC Class Codes: H04L 67/104 Peer-to-peer [P2P] networks
• CPC Class Codes: H04L 67/1068 Discovery involving direct consultation or announcement among potential requesting and potential source peers
• CPC Class Codes: H04L 69/16 Implementation or adaptation of Internet protocol [IP], of transmission control protocol [TCP] or of user datagram protocol [UDP]
• CPC Class Codes: H04L 69/161 Implementation details of TCP/IP or UDP/IP stack architecture; Specification of modified or new header fields
• CPC Class Codes: H04L 69/162 involving adaptations of sockets based mechanisms secure socket layer H04L63/168
• CPC Class Codes: H04L 69/22 Parsing or analysis of headers
• CPC Class Codes: H04L 69/329 in the application layer [OSI layer 7]
• CPC Class Codes: H04L 9/40 Network security protocols

Abstract

Novel message formats for use in a distributed transaction environment are disclosed. Each message includes a message type field, a message length field, and a data field, typically in the foregoing order, and each field in the message has a fixed number of bytes. The message type and data length fields may be comprised of a single header. The data field may include novel groups of OSI TP PDUs where each grouping characterizes the content of the data in the PDU. A novel apparatus for use in a distributed transaction environment also is disclosed. The apparatus may include a peer processing machine and a multiplexed TCP/IP connection for exchanging messages with other peer processing machines in the distributed transaction environment.

Claims

1. In an environment for performing distributed transaction processing via data contained in messages exchanged between heterogeneous computer systems, a message format wherein each message exchanged comprises a plurality of fields, and the fields comprise at least a message type field, a message length field, and a fixed set of fields dictated by the message type.

2. The message format of claim 1 wherein each message exchanged has a fixed number of parameters.

3. The message format of claim 1 wherein each message field has a fixed number of bytes.

4. The message format of claim 1 wherein each message comprises a stream of bytes without regard to word alignment within the message.

5. The message format of claim 1 wherein the message fields comprise a plurality of logical field types including an unsigned byte, an array of unsigned bytes, an unsigned short integer, and an unsigned long integer.

6. The message format of claim 1 wherein each message exchanged has the general format of a Header followed by OSI TP Data, XATMI Encoding following the OSI TP Data, and user data following the XATMI Encoding, the message type and data length fields being comprised of the Header, and the data field being comprised of the OSI TP Data, XATMI Encoding, and user data.

7. The message format of claim 6 wherein the Header comprises an unsigned byte for the message type field and an unsigned long integer for the data length field.

8. The message format of claim 6 wherein the XATMI Encoding comprises an unsigned long integer indicating length of XATMI data in the message and an array of unsigned bytes comprising the XATMI data.

9. The message format of claim 1 wherein there are at least nine message type fields.

10. The message format of claim 1 wherein the message type fields comprise Keep_Alive, Keep_Alive_Ok, Associate_Req, Associate_Rsp, Security_Rsp, Security_Ok, New_Dialogue, Data, and Abort_Req.

11. In an environment for performing distributed transaction processing via exchange of messages containing data in the form of OSI TP PDUs, a plurality of PDU types comprising groups of the OSI TP PDUs, each of the PDU types characterizing the data contained in each of the OSI TP PDU groups.

12. The PDU types of claim 11 wherein each type has a numeric value.

13. The PDU types of claim 12 wherein each numeric value is unique.

14. The PDU types of claim 11 wherein an XATMI API is utilized as an AP-CRM interface in the distributed transaction processing environment.

15. The PDU types of claim 14 wherein there are at least forty-one PDU types.

16. The PDU types of claim 14 wherein there are at least six PDU types associated with the establishment of OSI TP dialogues.

17. The PDU types of claim 16 wherein the at least six PDU types comprise p_tpcall_notran_ri, p_tpcall_noreply_ri, p_tpconnect_notran_sendonly_ri, p_tpcall_tran_ri, p_tpconnect_tran_sendonly_ri, and p_tpcall_prepare_ri.

18. The PDU types of claim 14 comprising p_bdrc_tpreturn_notran, p_bdrc_tpsend_rcvonly, p_bdrc_tpsend_sendonly, p_bd_rc, p_bdc_rc, p_bdc_rc_tpsend_sendonly_ri, p_bdc_rc_tpsend_rcvonly_ri, p_bdc_rc_tpsend_ready_ri, p_tpsend_rcvonly, p_tpreturn_notran, p_tpreturn_ready, p_bdrc_abort_ri, and p_bdri_channel.

19. An apparatus for participating in distributed transaction processing via exchange of messages between peer processing machines, comprising a first peer processing machine running executable code capable of establishing a multiplexed TCP/IP connection with a second peer processing machine and exchanging messages with the second peer processing machine over the multiplexed TCP/IP connection.

20. The apparatus of claim 19 wherein a plurality of concurrent OSI TP dialogues reside on the first peer processing machine, and each of the concurrent OSI TP dialogues are mapped by the first peer processing machine into the multiplexed TCP/IP connection.

21. The apparatus of claim 19 wherein the first peer processing machine utilizes a multiplexed communications instance with the multiplexed TCP/IP connection.

22. The apparatus of claim 21 wherein the multiplexed communications instance includes state information about the multiplexed TCP/IP connection.

23. The apparatus of claim 21 wherein the multiplexed communications instance includes information for establishing communications with, sending data to, and receiving data from the second peer processing machine.

24. The apparatus of claim 19 wherein the first peer processing machine utilizes a multiplexed branch data structure with the multiplexed TCP/IP connection.

25. The apparatus of claim 24 wherein the multiplexed branch data structure includes a pointer to another data structure for queuing output requests and posting network aborts generated by the first peer processing machine, decoded fields for placing flags or other information discovered by the first processing machine while decoding a message;

and a unique identification number comprised of a branch and generation id for the second peer processing machine.

26. The apparatus of claim 19 wherein a plurality of threads are utilized by the first peer processing machine to establish and manage the multiplexed TCP/IP connection.

27. The apparatus of claim 26 wherein the plurality of threads comprise a timer thread, socket listener thread, socket worker thread, socket input thread, and socket output thread.

28. The apparatus of claim 27 wherein the socket input thread controls a communications instance array and a poll array in the first peer processing machine.

29. The apparatus of claim 27 wherein the socket output thread controls data output by a protocol machine in the first peer processing machine and destined for the output socket thread.