|
||||
0001 /** 0002 * @brief Thread logging and check for stderr/stdout server logrotate - server 0003 * 0004 * @file atmisv88.c 0005 */ 0006 /* ----------------------------------------------------------------------------- 0007 * Enduro/X Middleware Platform for Distributed Transaction Processing 0008 * Copyright (C) 2009-2016, ATR Baltic, Ltd. All Rights Reserved. 0009 * Copyright (C) 2017-2023, Mavimax, Ltd. All Rights Reserved. 0010 * This software is released under one of the following licenses: 0011 * AGPL (with Java and Go exceptions) or Mavimax's license for commercial use. 0012 * See LICENSE file for full text. 0013 * ----------------------------------------------------------------------------- 0014 * AGPL license: 0015 * 0016 * This program is free software; you can redistribute it and/or modify it under 0017 * the terms of the GNU Affero General Public License, version 3 as published 0018 * by the Free Software Foundation; 0019 * 0020 * This program is distributed in the hope that it will be useful, but WITHOUT ANY 0021 * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A 0022 * PARTICULAR PURPOSE. See the GNU Affero General Public License, version 3 0023 * for more details. 0024 * 0025 * You should have received a copy of the GNU Affero General Public License along 0026 * with this program; if not, write to the Free Software Foundation, Inc., 0027 * 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA 0028 * 0029 * ----------------------------------------------------------------------------- 0030 * A commercial use license is available from Mavimax, Ltd 0031 * contact@mavimax.com 0032 * ----------------------------------------------------------------------------- 0033 */ 0034 #include <stdio.h> 0035 #include <stdlib.h> 0036 #include <ndebug.h> 0037 #include <atmi.h> 0038 #include <ndrstandard.h> 0039 #include <ubf.h> 0040 #include <test.fd.h> 0041 #include <string.h> 0042 #include <unistd.h> 0043 #include "test88.h" 0044 0045 /*---------------------------Externs------------------------------------*/ 0046 /*---------------------------Macros-------------------------------------*/ 0047 /*---------------------------Enums--------------------------------------*/ 0048 /*---------------------------Typedefs-----------------------------------*/ 0049 /*---------------------------Globals------------------------------------*/ 0050 /*---------------------------Statics------------------------------------*/ 0051 /*---------------------------Prototypes---------------------------------*/ 0052 0053 /** 0054 * Standard service entry 0055 */ 0056 void TESTSV (TPSVCINFO *p_svc) 0057 { 0058 int ret=EXSUCCEED; 0059 char testbuf[1024]; 0060 static int test_num = 0; 0061 UBFH *p_ub = (UBFH *)p_svc->data; 0062 0063 NDRX_LOG(log_debug, "%s got call", __func__); 0064 0065 /* Just print the buffer */ 0066 Bprint(p_ub); 0067 0068 if (EXFAIL==Bget(p_ub, T_STRING_FLD, 0, testbuf, 0)) 0069 { 0070 NDRX_LOG(log_error, "TESTERROR: Failed to get T_STRING_FLD: %s", 0071 Bstrerror(Berror)); 0072 ret=EXFAIL; 0073 goto out; 0074 } 0075 0076 test_num++; 0077 0078 NDRX_LOG(log_error, "HELLO WORLD SV"); 0079 fprintf(stderr, "HELLO STDERR %d\n", test_num); 0080 fprintf(stdout, "HELLO STDOUT %d\n", test_num); 0081 0082 if (0!=strcmp(testbuf, VALUE_EXPECTED)) 0083 { 0084 NDRX_LOG(log_error, "TESTERROR: Expected: [%s] got [%s]", 0085 VALUE_EXPECTED, testbuf); 0086 ret=EXFAIL; 0087 goto out; 0088 } 0089 0090 fflush(stderr); 0091 fflush(stdout); 0092 0093 out: 0094 tpreturn( ret==EXSUCCEED?TPSUCCESS:TPFAIL, 0095 0L, 0096 (char *)p_ub, 0097 0L, 0098 0L); 0099 } 0100 0101 /** 0102 * Do initialisation 0103 */ 0104 int tpsvrinit(int argc, char **argv) 0105 { 0106 int ret = EXSUCCEED; 0107 NDRX_LOG(log_debug, "tpsvrinit called"); 0108 0109 if (EXSUCCEED!=tpadvertise("TESTSV", TESTSV)) 0110 { 0111 NDRX_LOG(log_error, "Failed to initialise TESTSV!"); 0112 EXFAIL_OUT(ret); 0113 } 0114 out: 0115 return ret; 0116 } 0117 0118 /** 0119 * Do de-initialisation 0120 */ 0121 void tpsvrdone(void) 0122 { 0123 NDRX_LOG(log_debug, "tpsvrdone called"); 0124 } 0125 0126 /* Auto generated system advertise table */ 0127 expublic struct tmdsptchtbl_t ndrx_G_tmdsptchtbl[] = { 0128 { "TESTSV", "TESTSV", TESTSV, 0, 0 } 0129 , { NULL, NULL, NULL, 0, 0 } 0130 }; 0131 /*---------------------------Prototypes---------------------------------*/ 0132 0133 /** 0134 * Main entry for tmsrv 0135 */ 0136 int main( int argc, char** argv ) 0137 { 0138 _tmbuilt_with_thread_option=EXTRUE; 0139 struct tmsvrargs_t tmsvrargs = 0140 { 0141 &tmnull_switch, 0142 &ndrx_G_tmdsptchtbl[0], 0143 0, 0144 tpsvrinit, 0145 tpsvrdone, 0146 NULL, 0147 NULL, 0148 NULL, 0149 NULL, 0150 NULL, 0151 tpsvrthrinit, 0152 tpsvrthrdone 0153 }; 0154 0155 return( _tmstartserver( argc, argv, &tmsvrargs )); 0156 0157 } 0158 0159 0160 /* vim: set ts=4 sw=4 et smartindent: */
[ Source navigation ] | [ Diff markup ] | [ Identifier search ] | [ general search ] |
This page was automatically generated by the 2.1.0 LXR engine. The LXR team |