Tmax Getting Started Guide Tmax 3.8 Tmax Getting Started Guide

Transcription

1 Tmax Getting Started Guide : TMGS : Tmax 3.8 : July 31, 2003 : Sep 20, 2003

2 Tmax Getting Started Guide Tmax 3.8 Tmax Getting Started Guide

3 Copyright (c) 2001 Tmax Soft Co., Ltd. All Rights Reserved.,,, Tmax Soft.,,,..... Tmax, WebT, WebtoB, JEUS, Host-Link, WebInOneTmax Soft Co., Ltd.. Tel: , 2006 Fax: Tmax Getting Started Guide Document Edition Date Version TMGS July 27, 2002 Tmax 3.8 Tmax Tmax Base, Tmax Standard, Options. Tmax Standard. Tmax Base TP Function (Excluding 2 Phase Commit) Tmax Standard TP Function + 2 Phase Commit Web Admin Console, X.25 Gateway, TCP/IP Gateway, Host-Link, Power Tmax Options Builder Interface Module, SERIAL Gateway, TCP/IP Service Gateway Tmax Getting StartedGuide

4 Tmax Getting Started Guide

5 Tmax Getting Started Guide? Tmax Tmax.? 1. : Tmax Tmax. 5. Tmax Tmax Tmax Tmax. 8. TP Monitor TP Monitor. 9. WebT WebT Tmax. 2. : Tmax. Tmax Programming Guide Tmax Programming Guide(HostLink) Tmax Programming Guide(RCA) Tmax Programming Guide(RQ) Tmax Programming Guide(UCS) Tmax Programming Guide(WebT) Tmax Reference Manual Tmax FDL Reference Manual Tmax Administration Guide Tmax Error Message Manual Tmax Getting StartedGuide

6 TP Monitor 1.2. Tmax Tmax? Domain 5.2. Domain 5.3. Tmax Client/Server Tmax TP Monitor WebT WebT? WebTTmax : X/Open DTP Model X/Open DTP? 1.2. X/Open DTP Tmax Getting Started Guide

7 (Interfaces) Tmax API Error X/Open XATMI 2.2. X/Open TX API Tmax Tmax 3.2. Client/Server FDL (Field Definition Language) 4. Tmax API Tmax / 4.2. Buffer Error Log 4.7. Block Timeout Tmax 5.2. Tmax 6. Tmax Tmax system Tmax Oracle 8.3. Informix 9. WebT Applet Tmax Getting StartedGuide

8 Tmax Getting Started Guide

9 Tmax Getting Started Guide Tmax Getting StartedGuide

10 Tmax 43 TP Monitor 44 WebT 46 Tmax Getting Started Guide

11 TP Monitor DBMS Global Transaction - - O/S, Network,DBMS Tmax Getting StartedGuide

12 1.2. Tmax TP-Monitor - ( ) - ( ) ( ) Tmax Getting Started Guide

13 Tmax? * Transaction Maximization * X/Open, ISO, OSI - X/Open - DTP (AP), (TM), (RM), (CRM) API - ISO - DTP - OSI - TP (ISO0026) * TP-Monitor * * / (C/S) * TP-Monitors ( TP-Monitor) Tmax Getting StartedGuide

14 2.2. Large-scale OLTP Applications - - On-line - OCS (Order Communication System) ATM (Automatic Teller Machines) POS (Point-Of-Sale) - - Billing - / OLTP Tmax Getting Started Guide

15 2.3. * Application * Application * * Throughput Response Time, * Performance Reliability DBMSOverhead * ( ) Tmax Getting StartedGuide

16 2.4. : Tmax Getting Started Guide

17 Tmax - File Open & 0.5 M Memory Tmax - File Open & 0.5 M Memory Tmax Getting StartedGuide

18 3. - Tmax client/server process model (3-tier) - 2 Phase Commit Global transaction - Recovery/Rollback - - Transaction Scheduling - SLM (System Load Management) - DDR (Data Dependent Routing) - DLM (Dynamic Load Management) - Load balancing Service backup - - TCS (Tmax Control Server) - UCS (User Control Server) - POD (Processing On Demand) Reliable Queue (RQ) - - Domain Gateway Service - RCA (Raw Client Agent) - 2-tier 3-tier - Multi Thread - SCA (Simple Client Agent) - 2-tier 3-tier - non-tmax /Tmax - Tmax Getting Started Guide

19 RDP (Real Data Processor) - UDP - Tmax WinTmax Library Application - Database Tmax Getting StartedGuide

20 3.1. (1) Client/Server (2-tier ) - client/server application - - (, File DB Open/Close ) - (2) Tmax Client/Server (3-tier ) - - idle - Tuning Tmax Getting Started Guide

21 (3) 2-tier 3-tier 2-tier 3-tier ( 50 ) (50 ) Batch OLTP Application H/WDB (test ),, platform DB (Client/server test),, C/S 3-tier2-tier,,,. Tmax Getting StartedGuide

22 3.2.,.. X/Open (DTP) application program (AP), transaction manager(tm),resource manager (RM), communication resource manager (CRM) 4. X/Open DTP. RM Application Program(AP) TX TM CRM XA XA+ XATMI TxRPC CPI-C OSI - TP Tmax Getting Started Guide

23 . Two-phase commit (2PC) protocol Global Transaction ( ) Recovery / Rollback Transaction Scheduling Tmax Getting StartedGuide

24 3.3. (1) SLM (System Load Management) H/W ) Node :5:2 Node 1 1 Node 2, Node3. 3 Node 2. Tmax Getting Started Guide

25 2) DDR (Data Dependent Routing) (routing) ) Node , , 3. Tmax Getting StartedGuide

26 (3) DLM (Dynamic Load Management). Node Tmax ) Node1,2 Node1 Tmax. Tmax Getting Started Guide

27 3.4. Tmax,,,,.. (1) (Machine or Network) Tmax Peer-to-Peer.,. 2. *. ( ) Tmax Getting StartedGuide

28 *Service Back-up Node Node. (2) ( ),. tms, cas, clh restart. Tmax Getting Started Guide

29 3.5. Tmax AP process : TCS (Tmax Control Server) Tmax Handler Tmax. UCS (User Control Server) UCS. TCS., UCSTCS. POD (Processing On Demand) POD. Tmax Getting StartedGuide

30 3.6. Reliable Queue (RQ) TmaxRQ.,. - tpenq(). - queue manager(qmgr). - tpdeq() Queue Manager. Tmax Getting Started Guide

31 3.7. Domain Gateway Service - (, ) ( ) - Tmax,.,. Tmax Getting StartedGuide

32 3.8. RCA (Raw Client Agent) Thread Thread Pool RCA RCAH TCP/IP RCAL RCAH Tmax Domain THREAD POOL <RCA Tmax Getting Started Guide

33 3.9. SCA (Simple Client Agent) - customizing routine non-tmax /Tmax - - ATTACK TCP/IP CLH Cagent Library WITH- DRAWL MARCH <Cagent Tmax Getting StartedGuide

34 3.10. RDP (Real Data Processor) - UCS - UDP - CLH(Client Handler). CLH RDP Initial Connection/ Request CLH RDP Real Data Processing Line Tmax Getting Started Guide

35 WinTmax Library Tmax Domain tmaxmt Library Tmax Getting StartedGuide

36 3.12. (Resource Management) Application global monitoring Database - - Tmax (Naming Service) - - Tmax Getting Started Guide

37 3.14. (System Management) Tmax Service, Server, Server Group, Node, Domain. Tmax. - Domain : timeout, timeout, (machine) live check. - Node : message queue timeout value - Server group : load,. - Server : max queue count, queuing Start Count, restart count,,. - Service :, timeout. Monitoring Administration (,, ) Tmax Getting StartedGuide

38 3.15. (Security) Tmax UNIX 5. 1 : OS,, Permission.( ) 2 : Tmax (Domain) Tmax 3 : Tmax id Tmax 4 :,.(Tmax 4.0 ) 5 : Kerberos. Tmax Getting Started Guide

39 4. * X/Open, ISO-TP DTP 100% * IPC : Stream I/O(Pipe) Protection, Multiplexing * Integer, Long, Character Synchronous ( ), Asynchronous ( ), Conversational ( ), FDL(Field Definition Language) Structure Array * (Fault Tolerance) Peer-to-Peer H/W S/W * (Scalability) CA(Client Agent) 2-tier 3-tier WebT * (Flexibility) *, API (System Monitoring) * H/W IBM OS 390, UNIX, Linux, Windows NT * PowerBuilder, Delphi, Visual C/C++, Visual Basic,.NET(C#, VB) 4GL Tmax Getting StartedGuide

40 Domain TMM (Tmax Manager) CLL (Client Listener) CLH (Client Handler) TMS (Transaction Management Server) RQS (Reliable Queue Server) GW (Gateway Process) Tmadmin (Tmax Administrator) RACD (Remote Access Control Daemon) TCS (Tmax Control Server) UCS (User Control Server) Tmax system. CLL, CLH, TMSAP. Tmax.,.... Tmax system.. Tmax. Tmax. CLH business logic. CLH business logic control. Tmax Getting Started Guide

41 5.2. Domain Tmax Getting StartedGuide

42 5.3. Tmax Client/Server MVS(OS390) Server Application IMS or CICS AP Socket Region API T C P / I P V T A M X.25 SNA HOST Link OS (Unix, NT) TCP / IP Tmax Server DB Client Application Tmax Client Unix, Windows, DOS BP(FEP) Application Tmax Cagent Unix, Windows TCP / IP Client Application Unix, Windows, DOS TCP / IP TCP / IP Client Application Unix, Windows, DOS ` TCP / IP Tmax Getting Started Guide

43 6. O/S Platform Application API XATMI, TX Integrating API XA Network TCP/IP, X.25, SNA(LU 0/6.2) Server All Unix, NT, Linux Client All Unix, Windows, MS-DOS, etc. IBM OS 390, Unix, Linux NT H/W C, C++, COBOL C, C++ 4GL(Power Builder, Delphi, Visual C/C++, Visual Basic,.NET(C#, VB) etc.) DBMS Oracle, Informix, Sybase and DB2 (UDB) Tmax Getting StartedGuide

44 7. Tmax. (1) Server (SUN ) H / W - Memory: Mbytes ~ 0.5 Mbytes / application - Disk -Tmax Server : 6.8 Mbytes(Bin K, Lib K, Inc - 83K) S / W - IBM OS 390, UNIX, Linux, NT - C C++, COBOL Compiler Network Protocol - TCP/IP (2) Client (Windows 95 ) H / W - Memory: 0.50 Mbytes - Disk -Tmax Client : Mbytes (Include - 83K, DLL - 86K, Type Compiler - 108k), Power Builder 203K(DLL, PBD). S / W - Unix, Linux, NT, Windows (95, 98, 2000), DOS - Power Builder, Delphi, Visual Basic, Visual C++, C,.NET(C#, VB) Network Protocol -TCP/IP Tmax Getting Started Guide

45 8. TP Monitor TP Monitor C/S - : - DBMS Naming service - BP clientmultiplexing - - Structure array - HOST Resource -Site - consulting & - Consulting - (O/S, Network, TP-Monitor) Risk C/S monitoring TP-Monitor Report / Tmax Getting StartedGuide

46 (X/Open DTP, OSI-TP) H/W DBMS Version up (source programs ) Tmax Getting Started Guide

47 9. WebT 9.1. WebT? * WebTP Monitor * Web Transaction Class Library 9.2. *. * (DB Connection Overhead) * DB Web Network OverHead * Data 9.3. * Internet Mission-Critical * Java-Based Access (Applet, Servlet, JSP) Tmax Getting StartedGuide

48 9.4. HTTP over TCP/IP Server 1 Server 2 Web Server CGI, PHP, Heavy load AP Connection is established whenever clients issue requests DB server DBM Heavy traffic 2 1. * * * DB Connection OverHead *DB DB Network Traffic Tmax Getting Started Guide

49 9.5. WebTTmax HTTP over TCP/IP Server 1 Server 2 Web Server Light load AP process DBM Tmax Servlet with WebT Light traffic 2 1. * *DB Connection Overhead *DB Web Network Traffic Tmax Getting StartedGuide

50 Global transaction - DBMS access, process explosion, network traffic. -. Backup System - DB Servlet -Multi-threading, Java API, SSI (Server-Side Include). Tmax Getting Started Guide

51 Tmax Getting StartedGuide

52 Tmax Getting Started Guide Tmax Getting Started Guide

53 : X/Open DTP Model 52 Tmax API Error 55 Tmax 63 Tmax API Tmax 104 Tmax system 105 Tmax 106 WebT Sample Program 147 Tmax Getting StartedGuide

54 1. : X/Open DTP Model 1.1. X/Open DTP? (Distributed Transaction Processing) * X/Open * OSI DTP * OSI DTP (decomposition ) * API 1.2. X/Open DTP Tmax Getting Started Guide

55 1.3. Application Program (AP) - - Resource Manager (RM) DBMS, ISAM-file access system Transaction Manager(TM) - - id,, commit/rollback - Communication Resource Manager (CRM) - TM TM - Open System Interconnection -Transaction Processing (OSI -TP) - TM 1.4. (Interfaces) TM <-> RM Interface (XA) -TM RM global transaction recovery. ) xa_start(), xa_end(), xa_open(), xa_close() AP -> TM Interface (TX) - global transaction ) tx_begin(), tx_commit(), tx_rollback() AP <->CRM Interface (XATMI, TxRPC, CPI - C) - DTP API XATMI : / ) tpcall(), tpacall(), tpconnect() etc. TxRPC : CPI - C : IBMCPI C peer-to-peer TM <-> CRM Interface (XA+) - TM domain global transaction Tmax Getting StartedGuide

56 1.5. (Transaction) All or Nothing - Atomicity.. - Consistency.. - Isolation commit. - Durability commit. DTP (Distributed Transaction Processing) - RM(Resource Manager). Global Transactions - RM. commit. Commit -. Rollback -. X/Open TX Interface - tx_begin():. - tx_commit(): commit. - tx_rollback():. Tmax Getting Started Guide

57 2. Tmax API Error 2.1. X/Open XATMI X/Open DTP XATMI. XAMTI TP Monitor. Tmax Tmax. tpalloc () tprealloc () Buffer tpfree () tptypes () tpcall () tpacall () tpcancel () tpgetrply () tpconnect () tpdiscon () tprecv () tpsend () tpreturn () tpgetrply() tpacall() / Tmax Getting StartedGuide

58 2.2. X/Open TX API tx_begin () tx_commit () tx_rollback () tx_open () tx_close () tx_set_transaction_timeout () tx_info () tx_set_commit_return () tx_set_transaction_control () commit ( ) (Rolls back ) open ( ) closes ( ) (global transaction) Tmax Getting Started Guide

59 2.3. Tmax API Tmax ATMI TP Monitor. Tmax Tmax. tpbroadcast () tpsetunsol () tpgetunsol () tpsetunsol_flag () tpchkunsol () tpstrerror () Userlog () ulogsync () UserLog () gettperrno () gettpurcode () tperrordetail () tpgetpeer_ipaddr Socket () tpgetpeername () tpgetsockname () tpset_timeout () tptobackup () tpstart () tpend () (Log) ulog userlog() + ulogsync() Tmax error number urcode Tmax IP Tmax Tmax RQ tpenq () tpdeq () RQclient request RQ Tmax Getting StartedGuide

60 tpqstat () tpextsvcname () tmaxreadenv () tpputenv () tpgetenv () WinTmaxStart () WinTmaxEnd () WinTmaxSetCont ext () WinTmaxSend () WinTmaxAcall () WinTmaxAcall2 () tpscmt () tpgetlev () tpchkauth () tpgprio () tpsprio () tpsleep () tp_sleep () tp_usleep () tpschedule () tpuschedule () RQ RQ Tmax Tmax microsecond UCS UCS Tmax Getting Started Guide

61 FDL API FDLField Definition Language. FDL associative-typed data. Tmax. Tmax Tmax FDL. fbget_fldkey (). fbget_fldname (). fbget_fldno (). fbget_fldtype () (type).( ) fbget_strfldtype (). fbisfbuf (). fbinit (). fbcalcsize (). fballoc (). fbfree (). fbget_fbsize (). fbget_unused (). fbget_used (). fbrealloc (). fbput (). fbinsert () fbchg_tu () fbdelete () fbdelall () fbdelall_tu () fbget () fbgetf () fbget_tu () fbnext_tu () fbgetalloc_tu () fbgetval_last_tu () fbgetlast_tu () fbgetnth () fbfldcount () fbkeyoccur () fbispres ().... (fieldkey[]) occurrence. entry..... Tmax Getting StartedGuide

62 fbgetval () fbgetvall_tu () fbupdate () fbgetlen () fbtypecvt () fbputt () fbget_tut () fbgetalloc_tut () fbgetvalt () fbgetvali () fbgetvals () fbgetvals_tu () fbgetntht () fbchg_tut () fbbufop () fbbufop_proj () fbread () I/O fbwrite () fbprint () fbfprint () fbstrerror () Errors getfberrno () fbmake_fldkey () fbftos () fbstof () fbsnull () fbstelinit () fbstinit (). long (type).. occurrence integer. String. string...,,, FDLFILE. C (stname). C mapping FIELD. C occurrence mapping NULL. mapping C NULL. mappingc NULL. Tmax Getting Started Guide

63 Tmax Getting StartedGuide 2.4. X/Open DTP Tmax tperrno. tperrno.. Tmax Tmax. tperrno : (ATMI 1.) Error Message (tperrno) Description TPEBADDESC(2) TPEBLOCK(3) TPEINVAL(4) TPELIMIT(5) TPENOENT(6) TPEOS(7) TPEPROTO(9) TPESVCERR(10) Tmax TPESVCFAIL(11) TPESYSTEM(12) Tmax ( ) TPETIME(13) (BLOCKTIME) TPETRAN(14) TPGOTSIG(15) TPEITYPE(17) TPEOTYPE(18) TPEEVENT(22) TPEMATCH(23) RQtpdeq() TPENOREADY(24) TPESECURITY(25) TPEQFULL(26) TPEQPURGE(27) TPECLOSE(28) Tmax TPESVRDOWN(29) TPEPRESVC(30) TPEMAXNO(31) FDL fberrno.

64 fberrno.. Tmax Tmax FDL. fberror : (FDL 1.) Error Message Description (tperrno) ( ) Tmax Getting Started Guide

65 3. Tmax 3.1. Tmax ( : Presentation logic) ( DB access logic) - (input) (output) Tmax main() (Application) (Service Routine) - main() (Service registration, resource open, etc.) buffer. - Service routines * :. -.,. ->. ->,. (, ) Tmax Getting StartedGuide

66 3.2. Client/Server (1) -, blocking. - client/server. Client Server main() { /* Tmax */ tpstart(); /* */ tpalloc(); while(true) { /*..*/ tpcall(servicename,...); servicename(msg) TPSVCINFO *msg; { /* client. */ rcvbuf = msg->data; tpfree(); /*Frees message buffer */ tpend(); /* Tmax */. /* */ tpreturn(); Tmax Getting Started Guide

67 (2) -. - client/server. Client Server main() { /* Tmax */ tpstart(); /* */ tpalloc(); servicename(msg) TPSVCINFO *msg; while( true){ /*. */ tpacall(servicename,...); /*... */ { /* client. */ rcvbuf = msg->data; /* * / tpgetrply(). tpfree(); /* */ /*client */ tpreturn(); tpend() ; /* Tmax */ Tmax Getting StartedGuide

68 (3) - / logical connection control,. - control. - connection connection descriptor Client/Server. Client Server main() { tpstart(); tpalloc(); cd= tpconnect(); /* service */ tpsend(cd,...); /* */ tprecv(cd,...); /* */ tprecv(cd,...);... servicename(msg) TPSVCINFO *msg; { cd = msg->cd ; tprecv(cd,...); tpsend(cd,...); tpreturn(); /* */ tpfree();... tpend(); Tmax Getting Started Guide

69 (4) SERVICE A tpforward(b) SERVICE B tpforward(c) SERVICE C tpreturn < (5) SERVICE B tpsavectx() SERVIE C tpreturn usermain() tprelay(c) UCS Legacy System < Tmax Getting StartedGuide

70 3.3. -Transaction. -Client. Client Server main() { tpstart(); /* Tmax */ tpalloc(); /* */ while(true){ /*.*/ tx_begin(); /* transaction */ tpcall( servicename,...); if(error) /*Fail: transaction */ tx_rollback(); else /*Succeed : transaction */ tx_commit(); tpfree(); tpend(); /*. */ /* Tmax */ servicename(msg) TPSVCINFO *msg; { /* */ rcvbuf = msg->data;. /* */ tpreturn(); Tmax Getting Started Guide

71 -. main() { Client Server servicename(msg) TPSVCINFO *msg; tpstart(); /* Tmax */ tpalloc(); /* */ while(true){ /* */ tpcall( servicename,...); tpfree(); tpend();... /* */ /* Tmax */ { rcvbuf = msg -> data; tx_begin(); /* transaction */ If(error) tx_rollback(); /*fail :transaction */ else tx_commit(); /*Succeed : transaction */ /* */ tpreturn(); Tmax Getting StartedGuide

72 3.4. FDL (Field Definition Language) - Field Key Buffer. - Field Key (NAME, ADDR, TEL ),, (XXX.f). - FDLC XXX.f XXX_fdl.h Mapping. - include XXX_fdl.h. Tmax Getting Started Guide

73 4. Tmax API 4.1. Tmax / int tpstart(tpstart_t *tpinfo): Tmax. - TPSTART_T char cltname[maxtident+2]; -> ->MAXTIDENT = 16 (must be more than 15) char dompwd[max_passwd_length+2]; -> ->MAX_PASSWD_LENGTH = 16 char usrname[maxtident+2]; -> char usrpwd[max_passwd_length+2]; -> long flags; -> TPUNSOLIGN: TPUNSOLPOLL: TPUNSOL_HND: -. Tmax Getting StartedGuide

74 int tpend():. main() { if (tpstart ((TPSTART_T *) NULL ) == -1 ) { error routine;, {... if (tpend() == -1 ) { error routine; Tmax Getting Started Guide

75 4.2. Buffer char *tpalloc(char *type, char *subtype, long size): - - type : * STRING CARRAY X_OCTET STRUCT X_C_TYPE X_COMMON FIELD NULL(\0) (character array) (ex: ) NULL (\0) CARRAY C STRUCT STRUCT confined to char, int, and long. field transmission. - subtype: * : X_C_TYPE, STRUCT X_COMMON NULL. - size : 1) struct account *accp;... accp = (struct account *)tpalloc ( STRUCT, account, sizeof(struct account)); 2) char *str_ptr; char *ptr1, *ptr2; str_ptr = tpalloc ( STRING, NULL, 25); ptr1 = str_ptr; ptr2 = str_ptr + 10; strcpy(ptr1, hello ); strcpy(ptr2, goodbye ); Tmax Getting StartedGuide

76 char *tprealloc(char *bufptr, long size):. - - bufptr: - size: 1) struct account *accp;... accp = (struct account *) tpalloc( STRUCT, account, sizeof(struct account));... accp = tprealloc (accp, sizeof(struct account) * len); 2) char *octet_ptr; char *ptr1, *ptr2;... octet_ptr = tpalloc( X_OCTET, NULL, 25);... octet_ptr = tprealloc (octet_ptr, 40); void tpfree(char *bufptr): bufptr: 1) struct account *accp; accp = (struct account *) tpalloc( STRUCT, account, sizeof(struct account));... accp = tprealloc(accp, sizeof(struct account) * len); tpfree ((char *)accp); 2) char *str_ptr; char *ptr1, *ptr2; str_ptr = tpalloc( STRING, NULL, 25);... str_ptr = tprealloc(str_ptr, 40); tpfree (str_ptr) ; Tmax Getting Started Guide

77 long tptypes(char *ptr, char *type, char *subtype) : char *ptr : buffer type char *type : char *subtype : RETURN : 1 ) char type[9], subtype[17]; struct account *accp;... accp = (struct account *)tpalloc( STRUCT, account, sizeof(struct account));... len = tptypes ((char *)accp, type, subtype); Tmax Getting StartedGuide

78 4.3. int tpcall(char *service, char *sbufp, long slength, char **rbufpp, long *rlength, long flags) : ( ) service : sbufp : slength : (CARRAY, X_OCTET ) rbufpp : rlength : flags : TPNOTRAN : TPNOCHANGE:. TPNOBLOCK :. TPNOTIME : TPSIGRSTRT : signal catch. tpcall();... blocking tpreturn() ) transfp = (struct transf *) tpalloc( STRUCT, transf, sizeof(struct transf)); transfp->b_id = q_branchid; transfp->balance = 0.0; strcpy(transfp->errmsg, ); if (tpcall (svc_name, (char *)transfp, 0, (char **)&transf, &nrecv, TPNOFLAGS) == -1) { fprintf(stderr, Tpcall(%s) error->%s!, svc_name, tpstrerror(tperrno)); tpfree((char *)transf); retc = -1; else printf( Branch %ld balance is $.2f\n,transfp->b_id, transfp->balance); Tmax Getting Started Guide

79 int tpacall(char *service, char *bufptr, long length, long flags) :, ( -1 ) service : bufptr : length : (CARRAY, X_OCTET ) flags :..TPNOTRAN :.TPNOREPLY :.TPNOTIME : (time-out).tpsigrstrt : catch.tpblock :.TPNOBLOCK : ) for (i = 0; i < NSIZE; i++) { audv->b_id = sitelist[i]; if ((cd[i] = tpacall( servicename, (char *)audv, sizeof(struct accnt), TPNOFLAGS)) == -1 ) { fprintf(stderr, %s: %s service request failed for site rep %ld\n, pgmname, sname, sitelist[i]); tpfree ((char *)audv); return (-1); Tmax Getting StartedGuide

80 int tpgetrply(int *handle, char **bufpp, long *length, long flags) handle : tpacall() bufpp : length : flags :.TPNOTIME, TPSIGRSTRT, TPNOBLOCK.TPGETANY :.TPNOCHANGE :. ) if ((cd1 = tpacall( service1, buf1, 0, TPNOFLAGS)) == -1) error if ((cd2 = tpacall( server2, buf2, 0, TPNOFLAGS)) == -1) error if (tpgetrply(&cd1, &buf1, &buf1len, TPNOFLAGS) == -1) error if (tpgetrply (&cd2, &buf2, &buf2len, TPNOFLAGS) == -1) error. cd = tpacall(); tpgetrply(cd,..); tpreturn() int tpcancel(int handle) : tpacall() - handle : tpacall() * Client ( ). 1. Tmax Getting Started Guide

81 Tmax Getting StartedGuide

82 int tpconnect(char *name, char *data, long length, long flags) : ->. -> 1. name : data : (NULL ) length : flags :.TPNOTRAN, TPNOTIME, TPSIGSTRT.TPSENDONLY :.TPRECVONLY : ) if ((cd = tpconnect ( ACCOUNT, NULL, 0, TPSENDONLY)) == -1) { error routine; int tpsend(int cd, char *data, long length, long flags, long *revent) : - cd : tpconnect() - data : - length : - flags.tpnotime, TPSIGSTRT, TPNOBLOCK :.TPRECVONLY :. - revent :. ( ) ) if (tpsend(cd, line, 0, TPRECVONLY, &revent) == -1) { tpend(); exit(1); Tmax Getting Started Guide

83 cd = tpconnect()... tpsend(cd,... )... tprecv(cd,... )... tprecv(cd,... )... cd = msg->cd... tprecv(cd,... )... tpsend(cd,... )... tpsend(cd,... )... tpreturn() int tprecv(int cd, char **data, long *length, long flags, long *revent) : - -1 ( ) cd : data : length : flags : TPNOCHANGE, TPNOTIME, TPSIGSTRT revent : ( ) ) if (tprecv(cd, &line, &len, TPNOCHANGE, &revent) { tx_rollback(); tpend(); exit(1); Tmax Getting StartedGuide

84 int tpdiscon(int cd) :. - cd : * * - tpdiscon(). - tpreturn(). ) if ((cd = tpconnect( ACCOUNT, NULL, 0, TPSENDONLY)) == -1) { error... if (error occurs) tpdiscon (cd); /*. */ Tmax Getting Started Guide

85 4.4. void tpreturn(int rval, int rcode, char *data, long len, long flags) : - rval : TPSUCCESS : TPFAIL : (tperrno ) TPEXIT : TPFAIL rcode : data : len : flags : ) tpreturn (TPSUCCESS, 0, sdata, len, TPNOFLAGS); Tmax Getting StartedGuide

86 4.5. int tpbroadcast (char *lnid, char *usrname, char *cltname, char *data, long len,long flags) - lnid, usrname, cltname : - data : - len : - flags : TPNOBLOCK, TPNOTIME, TPSIGRSTRT : ) if (tpbroadcast(null, NULL, NULL, (char *)msgdata, sizeof(struct kstrdata), 0) == -1) { printf( tpbroadcast failed tpstrerror = %s\n, tpstrerror(tperrno)); int tpsendtocli(clientid *id, char *data, long len, long flags) :. - id : - data : - len : - flags : TPUDP, TPFLOWCONTROL : refer to Tmax Reference manual ) if (tpsendtocli(cliid, data, (long *)len, TPUDP) == -1){ printf( tpsendtocli failed, tperrno=%d\n, tperrno); return(-1) ; Unsolfunc * tpsetunsol(unsolfunc *func) :. (.) - func : function to perform messages ) if (tpsetunsol(get_post) == -1){ printf( tpsetunsol failed, tpstrerror=%s\n, tpstrerror(tperrno)) ; tpfree((char *)sndbuf); tpend(); exit(1); Tmax Getting Started Guide

87 int tpgetunsol(int type, char **data, long *len, long flags) :. - type : (UNSOL_TPBROADCAST, NSOL_TPSENDTOCLI) - data : - len : - flag TPBLOCK : tpgetunsol. TPNOBLOCK :. ) if (tpgetunsol(unsol_tpbroadcast, &data, &len, TPGETANY TPBLOCK) == -1){ printf( tpgetunsol failed, tperrno=%d\n, tperrno); tpfree(data); exit(1); tpsetunsol(get_broad); get_broad(); tpbroadcast() Tmax Getting StartedGuide

88 4.6. Error Log int userlog(const char *fmt,...) : ULOG. - printf() int UserLog(const char *fmt,...) : ULOG - printf() ) exec sql insert into ktran(no, name) values(:no, :name); if (sqlca.sqlcode!= 0){ userlog( oracle sqlerror=%s,sqlca.sqlerrm.sqlerrmc); tpreturn(tpfail, sqlca.sqlcode, NULL, 0, TPNOFLAGS); char * tpstrerror(int err) :. - err : tperrno ) if (tpcall( ASYNC, (char *)sndbuf, 0, (char **)&rcvbuf, &rcvlen, TPNOFLAGS)== -1){ printf( ASYNC service call failed=%s\n, tpstrerror(tperrno)); tpfree((char *)sndbuf); tpfree((char *)rcvbuf); tpend(); exit(1); Tmax Getting Started Guide

89 4.7. Block Timeout int tpset_timeout(int timeout) : block timeout. - timeout : ) tpset_timeout (30); 4.8. int tpgetpeer_ipaddr(struct sockaddr *name, int *namelen) : IP. - name : - namelen : name ) if (tpgetpeer_ipaddr((struct sockaddr *)&name, &namelen)== -1){ printf( tpgetpeer_ipaddr is failed\n ); tpreturn(tpfail, 0, NULL, 0, TPNOFLAGS); printf("address of client is %s\n", inet_ntoa(name.sin_addr)); int tpgetpeername(struct sockaddr *name, int *namelen) :. - name : - namelen : ) if (tpgetpeername((struct sockaddr *)&name, &namelen) == -1){ printf( tpgetpeername is failed\n ); tpreturn(tpfail, 0, NULL, 0, TPNOFLAGS); ptr_cli = gethostbyaddr((char *)&(name.sin_addr.s_addr), sizeof(name.sin_addr.s_addr), AF_INET); printf("name of client is %s\n", ptr_cli->h_name); Tmax Getting StartedGuide

90 int tpgetsockname(struct sockaddr *name, int *namelen) : - name : - namelen : ) if (tpgetsockname(name, &namelen) == -1){ printf( tpgetsockname is failed\n ); tpreturn(tpfail, 0, NULL, 0, TPNOFLAGS); 4.9. int tptobackup() : * * :. TMAX_BACKUP_ADDR : IP TMAX_BACKUP_PORT : ) if (tpcall( SYNC, (char *)sndbuf, 0, (char **)&rcvbuf, &rcvlen, TPNOFLAGS) == -1){ printf( tpcall failed:sync service, tperrno=%d\n, tperrno); tpend(); if (tptobackup() == -1){ printf( tptobackup is failed\n ); tpfree((char *)sndbuf); tpfree((char *)rcvbuf); tpend(); exit(1) Tmax Getting Started Guide

91 All or Nothing -, int tx_begin() : int tx_commit() : (commit) int tx_rollback() : (rollback) tx_set_transaction_timeout(int timeout) timeout : timeout () ) tx_set_transaction_timeout(30) ; tx_begin( ); if ((cd = tpacall( TOUPPER,(char *)sendbuf, 0, TPNOFLAGS)) == -1) { fprintf(stderr tpacall( TOUPPER,..): %s, tpstrerr(tperrno)); tx_rollback(); tpfree(sendbuf); tpend(); if ((tpcall( TOLOWER,(char *)sendbuf, 0, (char **)&sendbuf, &dlen,tpsigrstrt)) == -1 ) { fprintf(stderr tpcall( TOLOWER,..): %s, tpstrerr(tperrno)); tx_rollback(); tpfree(sendbuf); tpend(); if ((tpgetrply(&cd, (char **)&sendbuf, &clen, TPSIGRSTRT)) == -1) { fprintf(stderr tpgetrply: %s, tpstrerr(tperrno)); tx_rollback(); tpfree(sendbuf); tpend(); tx_commit(); tpfree(sendbuf); tpend(); Tmax Getting StartedGuide

92 4.11. tmadmin boot/down - suspend/resume - int tmadmin(int cmd, void *arg, int opt_flag, long flags): ADMIN(TPSVCINFO *rqst) { char cmd, *buf, *sndbuf; int len; long sndlen; if (rqst->len < 1) tpreturn(tpfail, 0, NULL, 0, 0); cmd = rqst->data[0]; switch (cmd) { case TMADM_TMAX_INFO: len = tmaxinfo(&buf); break; case TMADM_SVC_STAT: len = svcstat(&buf); break; case TMADM_SPR_STAT: len = sprstat(&buf); break; default: len = -1; break; if (len < 0) tpreturn(tpfail, 0, NULL, 0, 0); Tmax Getting Started Guide

93 if ((sndbuf = (char *)tpalloc("string", NULL, len + 1)) == NULL) tpreturn(tpfail, 0, NULL, 0, 0); memcpy(sndbuf, buf, len); sndlen = len; /* do not free it's static area free(buf); */ tpreturn(tpsuccess, 0, sndbuf, sndlen, 0); int tmaxinfo(char **buf) { int i, n, tmp, size, num_node; int major, minor, patch; int year, month, day; struct tmadm_tmax_info *info; size = sizeof(struct tmadm_tmax_info) + (MAX_NODE - 1) * sizeof (struct tmadm_node_summary); info = (struct tmadm_tmax_info *) malloc(size); if (info == NULL) return -1; memset(info, 0x00, size); info->header.version = _TMADMIN_VERSION; info->header.size = size; n = tmadmin(tmadm_tmax_info, info, 0, 0); if (n < 0) return -1; WinTmaxtmaxmt.. WinTmax. WinTmaxStart(TPSTART_T *tpinfo) :Tmax tpstart(). Tmax Getting StartedGuide

94 WinTmaxEnd(() :Tmax tpend(). WinTmaxSetContext(void *winhandle, unsigned int msgtype, int slot) :. WinTmaxSend(int recvcontext, char *svc, char *data, long len, long flags) : Tmax recvcontext WinTmaxSetContext(). SendMessage. tmaxmt. WinTmaxAcall(TPSTART_T *sinfo, HANDLE whandle, unsigned int msgtype, char *svc, char *sndbuf, int len, int flags); :Tmax / / Tmax recvcontext WinTmaxSetContext(). SendMessage. WinTmaxAcall2(TPSTART_T *sinfo, WinTmaxCallback fn, char *svc, char *sndbuf, int len, int flags); :Tmax / / WinTmaxAcall. WinTmax.. tmaxmt. tmaxmt Tmax /. Tmax Getting Started Guide

95 4.13. int tpsleep(int timeout) :. - timeout : () ) if (tpsleep(10) > 0){ if (tpgetrply( &cd, &rc_buf, &len, TPNOBLOCK) == -1) { printf( tpgetrply failed tperrno=%d, cd=%d \n, tperrno, cd); tpfree(sn_buf); tpfree(rc_buf); tpend(); exit(-1); Tmax Getting StartedGuide

96 Tmax - UNIX Tmax.profile,.login,.cshrc TMAX_HOST_ADDR = Tmax (=IP Address) TMAX_HOST_PORT = (default : 8888). SDLFILE = sdlc * * :, TMAX_BACKUP_ADDR,TMAX_BACKUP_PORT tpstart() : -, - Tmax client library (libcli.a / libcli.so) - (STRUCT ) STRUCT, X_C_TYPE, X_COMMON. dummy struct. sdlc. ) sdlc -c -i mystruct.s -> mystruct.sdl, mystruct_sdl.h Tmax Getting Started Guide

97 -. Tmax Getting StartedGuide

98 - Client Makefile : Makefile : ) Makefile (solaris) -, : UNIX TMAXDIR, TMAX_HOST_ADDR, FDLFILE, TMAX_HOST_PORT, SDLFILE CFLAGS-xarch = V9 Tmax Getting Started Guide

99 . - UNIX Tmax system.profile(bourne shell),.login(c shell),.cshrc(c shell),.bashrc(linux) TMAXDIR = Tmax - Tmax Tmax DOMAIN : NODE : SVRGROUP : SERVER : SERVICE :. cfl. cfl [ -i system configuration file] ) cfl -i tmconfig.m, default tmconfig.gst :.tmboot :. - Tmax main() - (STRUCT ) STRUCT. sdlc _sdl.c. ) sdlc c -i mystruct.s -> mystruct_sdl.c mystruct_sdl.h _sdl.c. -Tmax server library (libsvr.a libsvr.so) Tmax Getting StartedGuide

100 - : Tmax Getting Started Guide

101 Tmax Getting StartedGuide - Makefile : Makefile. ) Makefile(Solaris)

102 -, Tmax UNIX TMAXDIR Tmax Tmax Tmax (tmm, tms, cll, clh, racd) tmboot tmboot [-f Tmax ] : Tmax tmboot -s : tmdown tmdown [ -f Tmax ] : Tmax tmdown -s : Tmax Getting Started Guide

103 5.2. Tmax : Tmax DOMAIN NODE SVRGROUP SERVER SERVICE GATEWAY ROUTING RQ Tmax DOMAIN DOMAIN <resrc_name> * NODE <uname> * SVRGROUP <svg_name> - (*) (: *DOMAIN, *NODE ) -. (,) - cfl ) cfl -i - Tmax (< > ) SHMKEY = <UNIQUE IPCKEY>, MAXUSER = 256, TPORTNO=8999 TMAXDIR = <TMAX installed directory>, APPDIR = <APPLICATION directory>, PATHDIR = <PATH directory > NODENAME = <uname>, DBNAME=ORACLE, OPENINFO = ORACLE_XA+Acc =P/tmaxsoft/tmaxsoft+SesTm=60 * SERVER <svr_name> SVGNAME = < svg_name >, MIN = 5, MAX = 10 * SERVIC <svc_name> SVRNAME = < svr_name > Tmax Getting StartedGuide

104 (1) Domain (DOMAIN ) : <resrc_name> - Tmax (domain) 16. SHMKEY -. - : 32, , MAXUSER - Domain TPORTNO -. (2) Node (NODE ) :. <uname> uname -n. * * : hostnameuname -n. TMAXDIR, APPDIR, PATHDIR - TMAXDIR : Tmax - APPDIR : - PATHDIR : Tmax (3) Server group (SVRGROUP ) : 1. <svg_name> -. - SVRGROUP NODENAME -. Tmax Getting Started Guide

105 : 4 DBNAME - OPENINFO Oracle OPENINFO = ORACLE_XA+Acc = P/ / + SesTm = 60 Informix OPENINFO = CLOSEINFO Informix CLOSEINFO = TMSNAME - TMS - 16 (4) Server (SERVER ) <svr_name> SVGNAME - - SVRGROUP. CLOPT - (dommand line option) - --,. - main() tpsvrinit(). - -o : -o output. -e : -e error. ) CLOPT = -e err1 -- abc MIN, MAX - MIN : - MAX : Tmax Getting StartedGuide

106 CONV - Y. ( N.) (5) Service (SERVICE ) <svc_name> SERVICE. - SERVICE. SVRNAME -. (6) (GATEWAY, ROUTING, RQ) : Tmax Administration Guide. Tmax Getting Started Guide

107 6. Tmax <tmboot : Tmax > Option -A SERVER -b -c Client Handler (CLH) (Tmax 4.0 ) -f -g -h Online Help -k -s, -t flag -n -o clopt_string CLOPT string -q RQ svg_name RQS -s [-k ] -k (-k ) -S -t TMS TMS. -T Tmax -w, RQ,Gateway -V <tmdown : Tmax > Option -A -f -g -h Online Help -i tmdown -k -s, -t flag -n -p id -q RQ svg_name RQS -s [-k ] st p spr_no (-k, ) -S -t TMS tms (RM) -w Wait_sec Wait_sec -V Tmax Getting StartedGuide

108 Tmax Getting Started Guide

109 Tmax system : Tmax (monitor) Tmax Tmax :tmadmin. : tmadmin tool - Config(cfg) : -stat(st) : <config : (cfg)> Option -d -n [ ]. -g [ ]. -v [ ] -s [ ]. <stat : (st) > Option -p [ ]. -s [ ]. ti (Tmax Information) Tmax. (version), (maxuser),. ci (Client Information). (status), IP Address, (count) -s si (Server Information).,, (status), (count), (qcount), (qpcount), (maxqcount) (emaxcount) Tmax Getting StartedGuide

110 8. Tmax 8.1. (1) ( ) - Unix machine - (TOUPPER() STRING ) - Client program : client.c - Server program : touppersvc.c - Makefile (Tmax Makefile ) - tmconfig.m : Tmax -Client Tmax : NULL ( ) : STRING : tpcall() : N/A - Server : TOUPPER 1 Database : Tmax Getting Started Guide

111 (client.c) #include <stdio.h> #include <string.h> #include <usrinc/atmi.h> main(int argc, char *argv[]) { char *sendbuf; long rlen; if (argc!= 2) { fprintf(stderr, Usage: $ %s string\n, argv[0]); exit(1); if (tpstart((tpstart_t *)NULL) == -1) { fprintf(stderr, tpstart failed\n ); exit(1); if ((sendbuf = tpalloc( STRING, NULL, 128)) == NULL) { fprintf(stderr, Error allocation send buffer\n ); tpend(); exit(1); strcpy(sendbuf,argv[1]); if (tpcall( TOUPPER, sendbuf, 0, &sendbuf, &rlen, TPNOFLAGS) == -1) { fprintf(stderr, Can t send request to service TOUPPER->%s!\n, tpstrerror(tperrno)); tpfree(sendbuf); tpend(); exit(1); printf( Return value:%s\n, sendbuf); tpfree(sendbuf); tpend(); Tmax Getting StartedGuide

112 ( touppersvc.c ) #include <stdio.h> #include <usrinc/atmi.h> TOUPPER(TPSVCINFO *msg) { int i; for (i = 0; i < msg->len; i++) msg->data[i] = toupper(msg->data[i]); msg->data[i] = \0 ; tpreturn(tpsuccess, 0, msg->data, 0, TPNOFLAGS); *DOMAIN dom1 *NODE tmax1 SHMKEY=77900, MAXUSER=100, MINCLH=1, TPORTNO=8888, BLOCKTIME=60, TXTIME=60 TMAXDIR = /home/tmax, APPDIR = /home/tmax/appbin, PATHDIR = /home/tmax/path, TLOGDIR = /home/tmax/log/tlog, ULOGDIR = /home/tmax/log/slog, SLOGDIR = /home/tmax/log/ulog *SVRGROUP svg1 *SERVER touppersvc *SERVICE TOUPPER NODENAME=tmax1 SVGNAME=svg1, MIN=1, MAX=5, CLOPT = e $(SVR).err o $(SVR).out SVRNAME=touppersvc Tmax Getting Started Guide

113 (2) ( / ) - string. (TOUPPER(), TOLOWER().) - (native client). - Client program : client.c - Server program : tosvc.c - Makefile (Tmax Makefile.) - tmconfig.m : Tmax - strdata.s : SDLFILE - Client Tmax : default : STRUCT (C ) : tpcall(), tpacall() - Server : (TOUPPER, TOLOWER). Database :. (strdata.s) struct strdata { int len; char sdata[20]; ; Tmax Getting StartedGuide

114 ( client.c ) #include <stdio.h> #include <string.h> #include <usrinc/atmi.h> #include strdata.s main(int argc, char *argv[]) { struct strdata *sendbuf, *sendbuf1; long dlen, clen; int cd; if(argc!= 3) { fprintf(stderr, Usage: $ %s string STRING\n, argv[0]); exit(1); if (tpstart((tpstart_t *)NULL) == -1) { fprintf(stderr, tpstart failed\n ); exit(1); sendbuf = (struct strdata *) tpalloc( STRUCT, strdata, 0); if (sendbuf == NULL) { fprintf(stderr, Error allocatio send buffer\n ); tpend(); exit(1); sendbuf1 = (struct strdata *)tpalloc( STRUCT, strdata, 0); if (sendbuf1 == NULL) { fprintf(stderr, Error allocatio send buffer\n ); tpfree((char *)sendbuf); tpend(); exit(1); strcpy(sendbuf->sdata, argv[1]); strcpy(sendbuf1->sdata, argv[2]); if ((cd = tpacall( TOUPPER, (char *)sendbuf, 0, TPNOFLAGS)) == -1) { fprintf(stderr, Toupper error -> %s, tpstrerror(tperrno)); tpfree ((char *) sendbuf); tpfree((char *) sendbuf1); tpend(); Tmax Getting Started Guide

115 exit(1); if (tpcall( TOLOWER, (char *)sendbuf1, 0, (char**)&sendbuf1, &dlen, TPSIGRSTRT) == -1) { fprintf(stderr, Tolower error -> %s, tpstrerror(tperrno)); tpfree((char *) sendbuf); tpfree((char *) sendbuf1); tpend(); exit(1); if (tpgetrply(&cd, (char **)&sendbuf, &clen, TPSIGRSTRT) == -1) { fprintf(stderr, Touuer getrply error -> %s, tpstrerror(tperrno)); tpfree((char *) sendbuf); tpfree((char *) sendbuf1); tpend(); exit(1); printf( return value %s %s\n, sendbuf->sdata, sendbuf1->sdata); tpfree((char *) sendbuf); tpfree((char *) sendbuf1); tpend(); exit(0); ( tosvc.c ) #include <stdio.h> #include <usrinc/atmi.h> #include strdata.s TOUPPER(TPSVCINFO *msg) { int i = 0; struct strdata *stdata; stdata = (struct strdata *)msg->data; while(stdata->sdata[i]!= \0 ) { stdata->sdata[i] = toupper(stdata->sdata[i]); i++; ; tpreturn(tpsuccess, 0, (char *)stdata, 0, TPNOFLAGS); Tmax Getting StartedGuide

116 TOLOWER(TPSVCINFO *msg) { int i = 0; struct strdata *stdata; stdata = (struct strdata *)msg->data; while(stdata->sdata[i]!= \0 ) { stdata->sdata[i] = tolower(stdata->sdata[i]); i++ ; ; tpreturn(tpsuccess, 0, (char *)stdata, 0, TPNOFLAGS); *DOMAIN dom1 *NODE tmax1 *SVRGROUP svg1 *SERVER tosvc *SERVICE TOUPPER TOLOWER SHMKEY=77900, MAXUSER=100, MINCLH=1, TPORTNO=8888, BLOCKTIME=60, TXTIME=60 TMAXDIR= /home/tmax, APPDIR= /home/tmax/app, PATHDIR= /home/tmax/path NODENAME=tmax1 SVGNAME=svg1, MIN=1, MAX=5 SVRNAME=tosvc SVRNAME=tosvc Tmax Getting Started Guide

117 (3) ( ) -,. - ORACLE programing 7.2 r - Client program: client.c - Server program: multi_sel.pc - Makefile (Tmax Makefile.) - tmconfig.m : Tmax - sel_o.s : SDLFILE - Client Tmax : default : STRING type, STRUCT type. : - Server tmconfig.m. Database : Oracle DB (sel_o.s) struct sel_o { char seqno[10]; char corpno[10]; char compdate[8]; Int totmon; Float guarat; Float guamon; ; Tmax Getting StartedGuide

118 (client.c) #include <stdio.h> #include <usrinc/atmi.h> #include sel_o.s main(int argc, char *argv[]) { struct sel_o *rcvbuf; char *sndbuf; long sndlen, rcvlen, revent; int cd; if (argc!= 2) { printf( Usage: client string\n ); exit(1); if (tpstart ((TPSTART_T *) NULL) == -1) { printf( tpstart failed\n ); exit(1); if ((sndbuf = tpalloc ( STRING, NULL, 12)) == NULL) { printf( tpalloc failed:sndbuf\n ); tpend ( ) ; exit(1); if((rcvbuf = (struct sel_o *) tpalloc( STRUCT, sel_o, 0)) == NULL) { printf( tpalloc failed:sndbuf\n ); tpfree(sndbuf); tpend(); exit(1); strcpy(sndbuf, argv[1]); if ((cd = tpconnect ( MULTI, sndbuf, 0, TPRECVONLY)) == -1){ printf( tpconnect failed:conver service, tperrno=%d\n, tperrno); tpfree(sndbuf); tpfree ((char *)rcvbuf); tpend(); exit(1); /*. */ Tmax Getting Started Guide

119 while(1){ /* */ if (tprecv(cd, (char **)&rcvbuf, &rcvlen, TPNOTIME, &revent) == -1){ printf( tprecv failed, tperrno=%d, revent=%x\n, tperrno, revent); tpfree ( sndbuf ) ; tpfree ((char *)rcvbuf); tpend(); exit(1); /* tpreturn() */ if (revent == TPEV_SVCSUCC){ printf( all is completed\n ); break; printf( seqno = %s\t\t corpno =%s\n, rcvbuf->seqno, rcvbuf->corpno); printf( compdate = %s\t\t totmon =%d\n, rcvbuf->compdate, rcvbuf->totmon); printf( guarat = %f\t\t guamon =%f\n\n\n, rcvbuf->guarat, rcvbuf->guamon); tpfree(sndbuf); tpfree((char *)rcvbuf); tpend(); (multi_sel.pc) #include <stdio.h> #include <string.h> #include <usrinc/atmi.h> #include sel_o.s /* Oracle. */ exec sql begin declare section; char seq[10]; int seqi; struct sel_o *sndbuf; exec sql end declare section; exec sql include sqlca; MULTI(TPSVCINFO *msg) { int i, cd; long sndlen, revent; memset(seq, 0, 10); strcpy(seq, msg->data); Tmax Getting StartedGuide

120 seqi = atoi(seq); if ((sndbuf = (struct sel_o *) tpalloc ( STRUCT, sel_o, 0)) == NULL) { printf( tpalloc failed:\n ); tpreturn(tpfail, -1, NULL, 0, TPNOFLAGS); /*. */ exec sql declare democursor cursor for select * from corp where seqno > :seqi; exec sql open democursor; exec sql whenever not found goto end_of_fetch; if (sqlca.sqlcode!= 0){ printf( oracle sqlerror=%s, sqlca.sqlerrm.sqlerrmc); tpreturn(tpfail, sqlca.sqlcode, NULL, 0, TPNOFLAGS); /* Oracle. */ while (sqlca.sqlcode == 0 ){ exec sql fetch democursor into :sndbuf; if (tpsend(msg->cd, (char *)sndbuf, 0, TPNOTIME, &revent) == -1){ printf( tpsend failed, tperrno=%d, revent=%x\n, tperrno, revent); tpfree ((char *)sndbuf); tpreturn(tpfail, -1, NULL, 0, TPNOFLAGS); tpreturn(tpfail, sqlca.sqlcode, NULL, 0, 0); end_of_fetch: exec sql close democursor; tpreturn(tpsuccess, 0, NULL, 0, TPNOFLAGS); mktable.sql Oracle table creation script sqlplus scott/tiger <<! create table multi_sel ( seqno VARCHAR(10), corpno VARCHAR(10), compdate VARCHAR(8), totmon NUMERIC(38), guarat FLOAT, guamon FLOAT ) ; Tmax Getting Started Guide

121 create unique index idx_tdb multi_sel(seqno);! sel.sql Oracle sqlplus scott/tiger <<! Desc multi_sel; select * from multi_sel;! *DOMAIN dom1 *NODE tmax1 *SVRGROUP svg1 *SERVER multi_sel *SERVICE MULTI SHMKEY=77900, MAXUSER=100, MINCLH=1, TPORTNO=8880, BLOCKTIME=60, TXTIME=60 TMAXDIR= /home/tmax, APPDIR= /home/tmax/app, PATHDIR= /home/tmax/path NODENAME=tmax1, DBNAME=ORACLE, OPENINFO="ORACLE_XA+Acc=P/scott/tiger+SesTm=60, TMSNAME=svg1_tms SVGNAME=svg1, CONV=Y SVRNAME=multi_sel - DBNAME. OPENINFO Oracle. TMSNAME. CONV = Y. Tmax Getting StartedGuide

122 8.2. Oracle * Oracle Unix (.profile.login.cshrc ) - ORACLE_HOME /user/oracle ORACLE_SID ORA805 ORACLE_TERM vt100 ORA_NLS32 $ORACLE_HOME/ocommon/nls/admin/data TNS_ADMIN $ORACLE_HOME/network/admin NLS_LANG American_America.US7ASCII path ($path $ORACLE_HOME/bin $TMAXDIR/bin) LD_LIBRARY_PATH ${LD_LIBRARY_PATH:/user/oracle/lib Makefile -. # Server Pro*C makefile include $(ORACLE_HOME)/precomp/lib/env_precomp.mk ORALIBDIR = $(LIBHOME) ORALIB = $(PROLDLIBS) -lclntsh TARGET = <svrname> APOBJS = $(TARGET).o SDLFILE = <sdlfilename> LIBS = -lsvr -lsocket -lnsl -loras OBJS = $(APOBJS) $(SDLOBJ) $(SVCTOBJ) SDLOBJ = ${SDLFILE:.s=_sdl.o SDLC = ${SDLFILE:.s=_sdl.c SVCTOBJ = $(TARGET)_svctab.o CFLAGS = -O -I$(TMAXDIR) APPDIR = $(TMAXDIR)/appbin SVCTDIR = $(TMAXDIR)/svct TMAXLIBDIR = $(TMAXDIR)/lib #.SUFFIXES :.c.c.o: $(CC) $(CFLAGS) -c $< Tmax Getting Started Guide

123 # # server compile # all: $(TARGET) $(TARGET): $(OBJS) $(CC) $(CFLAGS) -L$(TMAXLIBDIR) -o $(TARGET) -L$(ORALIBDIR) $(ORALIB) $(OBJS) $(LIBS) $(NSDLOBJ) mv $(TARGET) $(APPDIR) rm -f $(OBJS) $(APOBJS): $(TARGET).pc proc iname=$(target) include=$(tmaxdir) $(CC) $(CFLAGS) -c $(TARGET).c $(SVCTOBJ): touch $(SVCTDIR)/$(TARGET)_svctab.c $(CC) $(CFLAGS) -c $(SVCTDIR)/$(TARGET)_svctab.c $(SDLOBJ): $(TMAXDIR)/bin/sdlc -i../sdl/$(sdlfile) $(CC) $(CFLAGS) -c../sdl/$(sdlc) # clean: -rm -f *.o core $(TARGET) $(TARGET).lis TMS Makefile Tmax Getting StartedGuide

124 (1) Insert Client program : client.c - Server program : tdbsvr.pc - Makefile (Tmax Makefile.) - tmconfig.m: Tmax - mktables.sql : SQL script - sel.sql : SQL script - demo.s : SDLFILE - Tmax : NULL : STRUCT ( sdlc ). : tpcall(). :. - : Oracle insert 1 : STRUCT ( ) DB : Oracle database Tmax SVRGROUP. Tmax Getting Started Guide

125 ( demo.s ) struct ktran{ int no; ichar name[20]; ; ( client.c ) #include <stdio.h> #include <usrinc/atmi.h> #include demo.s main(int argc, char *argv[]) { struct ktran *sndbuf, *rcvbuf; long sndlen, rcvlen; int cd; if(argc!= 3) { printf( Usage: client no name\n ); exit(1); printf( tpstart-start \n ); if (tpstart((tpstart_t *) NULL) == -1) { printf( Tpinit failed\n ); exit(1); printf( tpstart-ok \n ); if ((sndbuf = (struct ktran *) tpalloc ( STRUCT, ktran, 0)) == NULL) { printf( tpalloc failed:sndbuf, tperrno=%d\n, tperrno); tpend(); exit(1); if((rcvbuf = (struct ktran *) tpalloc ( STRUCT, ktran, 0)) == NULL) { printf( tpalloc failed:rcvbuf, tperrno=%d\n, tperrno); tpfree((char *)sndbuf); tpend(); exit(1); sndbuf->no = atoi(argv[1]); strcpy(sndbuf->name, argv[2]); printf( tpcall-start \n ); if (tpcall ( INSERT, (char *)sndbuf, 0, (char **)&rcvbuf, &rcvlen, Tmax Getting StartedGuide

126 TPNOFLAGS) == -1){ printf( tpcall failed:ora service, tperrno=%d, tperrno); printf( tpurcode=%d\n, tpurcode); tpfree ((char *)sndbuf); tpfree ((char *)rcvbuf); tpend( ) ; exit(1); tpfree ((char *)sndbuf); tpfree ((char *)rcvbuf); tpend ( ) ; ( tdbsvr.pc ) #include <stdio.h> #include <usrinc/atmi.h> #include demo.s exec sql begin declare section; char name[20]; int no; exec sql end declare section; exec sql include sqlca; INSERT(TPSVCINFO *msg) { struct ktran *stdata; stdata = (struct ktran *)msg->data; strcpy(name, stdata->name); no = stdata->no; printf( Ora service started\n ); /* databaseinsert. */ exec sql insert into testdbl(no, name) values(:no, :name); if(sqlca.sqlcode!= 0){ printf( oracle sqlerror=%s, sqlca.sqlerrm.sqlerrmc); tpreturn(tpfail, sqlca.sqlcode, NULL, 0, TPNOFLAGS); Tmax Getting Started Guide

127 tpreturn(tpsuccess, sqlca.sqlcode, (char *)stdata, 0, TPNOFLAGS); mktable.sql sqlplus tmax/tmax <<! create table testdb1 ( no number(7), name char(30) ); sel.sql sqlpus tmax/tmax <<! desc testdb1; select * from testdb1; select count (*) from testdb1; Tmax Getting StartedGuide

128 *DOMAIN dom1 *NODE tmax1 *SVRGROUP svg1 *SERVER tdbsvr *SERVICE INSERT SHMKEY=77900, MAXUSER=100, MINCLH=1, TPORTNO=8888, BLOCKTIME=60, TXTIME=60 TMAXDIR= /home/tmax, APPDIR= /home/tmax/app, PATHDIR= /home/tmax/path NODENAME=tmax1, DBNAME=ORACLE, OPENINFO= Oracle_XA+Acc=P/scott/tiger+SesTm=60, TMSNAME=svg1_tms SVGNAME=svg1, MIN=1, MAX=5 SVRNAME=tdbsvr - DBNAME. OPENINFO Oracle database. tpsvrinfo(). Oracle database, CLOSEINFO. TMSNAME OPENINFO svg1 Tmax Getting Started Guide

129 (2) Select - Oracle select. - client.c : client - cdate.c : client.c - sel_his.pc : Oracle source - Makefile (Tmax Makefile.) - tmconfig.m : Tmax - mktables.sql : table SQL - sel.sql : table SQL - his.s : SDLFILE - Client Tmax : NULL. : STRUCT : stru_his. : tpcall(). :. - Server : SEL_HIS, Oracle DBselect Database : Oracle database Tmax SVRGROUP. : main( ). ( his.s ) struct stru_his { long ACCOUNT_ID; long TELLER_ID; long BRANCH_ID; long AMOUNT; ; Tmax Getting StartedGuide

130 (sel_his.pc) #include <stdio.h> #include <usrinc/atmi.h> #include his.s #define NARRAY 5 #define TOOMANY #define NOTFOUND 1403 EXEC SQL include sqlca.h; EXEC SQL begin declare section; long key, rowno; long account_id[narray],teller_id[narray], branch_id[narray], amount [NARRAY]; EXEC SQL end declare section; /* global.*/ SEL_HIS(TPSVCINFO *msg) /* */ { struct stru_his *transf; int i, lastno; int return_code; /*msg. */ transf = (struct stru_his *) msg->data; key = transf->account_id; if ((transf = (struct stru_his *) tprealloc((char*)transf, sizeof(struct stru_his) * NARRAY )) == (struct stru_his *)NULL) { fprintf(stderr, tprealloc error ->%s\n, tpstrerror(tperrno)); tpreturn(tpfail, tperrno, NULL, 0, TPNOFLAGS); /* transf. */ /* account_ids global. */ EXEC SQL select account_id, teller_id, branch_id, amount into :account_id, :teller_id, :branch_id, :amount from sel_his where account_id> :key order by account_id; if (sqlca.sqlcode!= 0 && sqlca.sqlcode!= NOTFOUND && sqlca.sqlcode!= TOOMANY) { fprintf(stderr, SQL ERROR ->NO(%d):%s\n, sqlca.sqlcode, sqlca.sqlerrm.sqlerrmc); tpreturn(tpfail, sqlca.sqlcode, NULL, 0, TPNOFLAGS); /* sql error (select.) */ Tmax Getting Started Guide

131 /* lastno. */ lastno = sqlca.sqlerrd[2]; rowno = lastno; if(lastno!=0) return_code = lastno; else return_code = NOTFOUND; /* selectdata. */ if(sqlca.sqlcode == TOOMANY) lastno = NARRAY; /* Oracle select. */ for (i = 0 ; i < rowno; i++) { transf[i].account_id = account_id[i]; transf[i].teller_id = teller_id[i]; transf[i].branch_id = branch_id[i]; transf[i].amount = amount[i]; tpreturn(tpsuccess, return_code,(char *)transf, sizeof(struct stru_his) * i, TPNOFLAGS); ( client.c ) #include <stdio.h> #include <usrinc/atmi.h> #include his.s #define NARRAY 5 #define NOTFOUND 1403 main(int argc,char *argv[]) { struct stru_his *transf; float tps; int i, j, loop, cnt_data = 0, sec1, sec2; long urcode, nrecv, narray; long account_id, teller_id, branch_id, amount, key; char ts[30], te[30]; if (argc!= 2) { printf( Usage:$%sLOOP (NARRAY = 10)!\n, argv[0]); exit(0); Tmax Getting StartedGuide

132 loop = atoi(argv[1] ); if (tpstart ((TPSTART_T *) NULL) == -1) { /* Tmax. */ fprintf(stderr, tpstart(tpinfo) failed -> %s!\n, tpstrerror(tperrno)); exit(1); htime(ts,&sec1); key = 0; /*. */ for (i = 0; i <loop ; i++) { if ((transf = (struct stru_his *) tpalloc( STRUCT, stru_his, 0)) == (struct stru_his *)NULL) { fprintf(stderr, tpalloc(struct..)failed->%s!\n, tpstrerror(tperrno)); tpend(); exit(1); /* Creates c structure type buffer. */ transf->account_id = key; tx_set_transaction_timeout(30); /*. */ if (tx_begin()< 0) { /* global transaction. */ fprintf(stderr, tx_begin () failed ->%s!\n, tpstrerror(tperrno)); tpfree ((char *)transf); tpend (); exit(0); /* SEL_HIS */ if (tpcall( SEL_HIS,(char *)transf, 0,(char **)&transf, &nrecv, TPNOFLAGS) == -1){ fprintf(stderr, Tpcall(SELECT...)error->%s!, tpstrerror (tperrno)); tpfree((char *)transf); tx_rollback(); /*, rollback. */ tpend(); exit(); urcode = tpurcode; /*,commit.*/ if (tx_commit() == -1) { fprintf(stderr, tx_commit() failed ->%s!\n, tpstrerror(tperrno)); tpfree((char *)transf); tpend(); exit(0); if (urcode!=notfound){ Tmax Getting Started Guide

133 narray = urcode; key = transf[narray-1].account_id; for (j =0; j < NARRAY; j++) { if (j == 0) printf( %-12s%-10s%-10s%-10s\n, ACCOUNT_ID, TELLER_ID, BRANCH_ID, AMOUNT ); account_id=transf[j].account_id; teller_id=transf[j].teller_id; branch_id=(*(transf+j)).branch_id; amount=transf[j].amount; printf( %-12d %-10d %-10d %-10d\n, account_id, teller_id, branch_id, amount); /* Oracle select. */ cnt_data += j; else if (urcode == NOTFOUND){ /* select, EOF, */ printf( No records selected!\n ); break; tpfree ((char *)transf); tpfree ( (char *)transf); tpend(); htime(te, &sec2); printf( TOT.COUNT = %d\n, cnt_data); printf( Start time = %s\n, ts); printf( End time = %s\n, te); if ((sec2 - sec1)! = 0) tps =(float) cnt_data / (sec2-sec1); else tps = cnt_data; printf( Interval = %d secs ==> %10.2fT/S\n, sec2 - sec1, tps); Tmax Getting StartedGuide

134 ( cdate.c) #include <stdio.h> #include <time.h> htime(char *cdate,int *sec) { long time(),timef,pt; char ct[20], *ap; struct tm *localtime(),*tmp; pt = time(&timef); *sec = pt; tmp = localtime(&timef); ap = asctime(tmp); sscanf(ap, %*s%*s%*s%s,ct);/* HH.MM.SS YY.MM.DD */ sprintf(cdate, %02d. %02d. %02d %s,tmp->tm_year, ++tmp->tm_mon, tmp- >tm_mday,ct); mktable.sql sel.sql sqlplus tmax/tmax <<! create table sel_his( account_id LONG, teller_id LONG, branch_id LONG, amount LONG ) ; create unique index idx_tdb1 on sel_his(account_id); sqlplus tmax/tmax<<! desc sel_his; select * from sel_his; *DOMAIN dom1 *NODE tmax1 SHMKEY=77900, MAXUSER=100, MINCLH=1, TPORTNO=8880, BLOCKTIME=60, TXTIME=60 TMAXDIR= /home/tmax, APPDIR= /home/tmax/app, PATHDIR= /home/tmax/path Tmax Getting Started Guide