#include <stdio.h>
#include <mdeapi.h>
#include <cdr.h>
#include <ftamapi.h>
#include <time.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <stdlib.h>
#include <chenpubhead.h>
extern void set_inited(int init);
int Ftam_get_again( char *line, char *dest_file , int x25_port );
void pre_write(void)
{
;
}
int
main( int argc, char *argv[] ) {
char str_minu[128];
if ( daemon_start( getenv("HOME") ) != E_OK ) {
fprintf( stderr, "5ESS_MAIN boot failed!\n" );
Errlog( __FILE__, __LINE__, "daemon_start()" );
exit( 1 );
}
while(1) {
memset( str_minu,0x00,128 );
Get_minu( str_minu );
ltrim( str_minu );
rtrim( str_minu );
if( atoi( str_minu ) == 20 )
lz_getfiles();
sleep(10);
}
}
int
lz_getfiles( ) {
int ret;
int first_line_good = 1 ;
int x25_port ;
FILE *fp;
char *p;
char ftam_local[128] ;
char ftam_responder[128] ;
char ftam_local_fna[128] ;
char ftam_responder_fna[128] ;
char line[128] ;
char dest_file[128] ;
char last_dest_file[128];
char cmd[256];
char err_msg[512];
char str_time[128];
char getted_msg[128];
docstat_type docstat;
F_docstat_Element *attrele;
memset( ftam_local,0x00,128 );
memset( ftam_responder,0x00,128 );
memset( ftam_local_fna,0x00,128 );
memset( ftam_responder_fna,0x00,128 );
memset( line,0x00,128 );
/****** X25 Link Is up or down ******/
if( x25_line_test( 1 ) == 2 ) {
x25_port = 1;
strcpy( ftam_local,"ANON1" );
strcpy( ftam_responder,"filestore1" );
strcpy( ftam_local_fna,"ANON2" );
strcpy( ftam_responder_fna,"filestore2" );
}
else if( x25_line_test( 2 ) == 2 ) {
x25_port = 2;
strcpy( ftam_local,"ANON3" );
strcpy( ftam_responder,"filestore3" );
strcpy( ftam_local_fna,"ANON" );
strcpy( ftam_responder_fna,"filestore4" );
}
else {
Errlog( __FILE__,__LINE__," No Available x25 Line " );
return E_FAIL;
}
Errlog( __FILE__,__LINE__,ftam_local);
Errlog( __FILE__,__LINE__,ftam_responder);
Errlog( __FILE__,__LINE__,ftam_local_fna);
Errlog( __FILE__,__LINE__,ftam_responder_fna);
tpi_timeout(180);
if ( ret = ftiapi_connect(ftam_local_fna,ftam_responder_fna,"","", 0,2) ) {
if ( ftiapi_getremoteerror() )
ret = ftiapi_getremoteerror();
else if ( ftiapi_getlocalerror() )
ret = ftiapi_getlocalerror();
else
ret = ret + 100;
memset( err_msg,0x00,512 );
sprintf(err_msg,"ftiapi_connect in fna failed,the ret is:[%d]\n",ret );
Errlog(__FILE__,__LINE__,err_msg );
return ret;
}
else
{
Errlog( __FILE__,__LINE__,"ftiapi_connect success");
}
ret = ftiapi_get("fna","/home/lzcdr/etc/fna","FTAM-1" );
if ( ret )
{
if ( ftiapi_getremoteerror() )
ret = ftiapi_getremoteerror();
else if ( ftiapi_getlocalerror() )
ret = ftiapi_getlocalerror();
else
ret = ret + 300;
memset(err_msg,0x00,512);
sprintf( err_msg, "ftiapi_get in get fna failed,the ret is:[%d]\n",ret);
Errlog(__FILE__,__LINE__,err_msg );
/*Release the fna filestore connection*/
if ( ret = ftiapi_release() ) {
if ( ftiapi_getremoteerror() )
ret = ftiapi_getremoteerror();
else if ( ftiapi_getlocalerror() )
ret = ftiapi_getlocalerror();
else
ret = ret + 500;
}
return ret ;
}
// return 0;success
/*Release the fna filestore connection*/
if ( ret = ftiapi_release() ) {
if ( ftiapi_getremoteerror() )
ret = ftiapi_getremoteerror();
else if ( ftiapi_getlocalerror() )
ret = ftiapi_getlocalerror();
else
ret = ret + 500;
}
/*
memset( cmd,0x00,256 );
memset( str_time,0x00,128 );
GetTime( str_time );
sprintf( cmd, "cp /home/lzcdr/etc/fna /u/bill/fna/fna.%s ", str_time );
if( system( cmd ) == E_FAIL ) {
Errlog( __FILE__,__LINE__,"cp fna error " );
}
*/
tpi_timeout(180);
if ( ret = ftiapi_connect(ftam_local,ftam_responder,"","", 0,2) ) {
if ( ftiapi_getremoteerror() )
ret = ftiapi_getremoteerror();
else if ( ftiapi_getlocalerror() )
ret = ftiapi_getlocalerror();
else
ret = ret + 100;
memset( err_msg,0x00,512 );
sprintf(err_msg,"ftiapi_connect failed,the ret is:[%d]\n",ret );
Errlog(__FILE__,__LINE__,err_msg );
return ret;
}
else
{
Errlog( __FILE__,__LINE__,"ftiapi_connect success");
}
if(( fp = fopen( "/home/lzcdr/etc/fna","r" )) == NULL ) {
Errlog( __FILE__,__LINE__,"fopen fna file " );
/*Release the connection*/
if ( ret = ftiapi_release() ) {
if ( ftiapi_getremoteerror() )
ret = ftiapi_getremoteerror();
else if ( ftiapi_getlocalerror() )
ret = ftiapi_getlocalerror();
else
ret = ret + 500;
}
return E_FAIL;
}
while(( p = fgets( line,128,fp )) != NULL ) {
ltrim( line );
line[12]='\0';
memset( dest_file,0x00,128 );
memset( cmd,0x00,256 );
memset( str_time,0x00,128 );
GetTime( str_time );
sprintf(dest_file,"/u/bill/data/%s.%s",line,str_time );
memset( last_dest_file,0x00,128 );
sprintf( last_dest_file,"%s.dat",dest_file );
if( first_line_good == 0 ) {
Ftam_get_again( line,dest_file,x25_port );
continue;
}
Errlog( __FILE__,__LINE__,line );
ret = ftiapi_get(line,dest_file,"FTAM-3" );
if ( ret )
{
if ( ftiapi_getremoteerror() )
ret = ftiapi_getremoteerror();
else if ( ftiapi_getlocalerror() )
ret = ftiapi_getlocalerror();
else
ret = ret + 300;
printf( " ftpapi_get return is [%d] \n", ret ) ;
memset(err_msg,0x00,512);
sprintf( err_msg, "ftiapi_get failed,the ret is:[%d]\n",ret);
Errlog(__FILE__,__LINE__,err_msg );
if( ret == 1011 ) {
/*Release the filestore connection*/
if ( ret = ftiapi_release() ) {
if ( ftiapi_getremoteerror() )
ret = ftiapi_getremoteerror();
else if ( ftiapi_getlocalerror() )
ret = ftiapi_getlocalerror();
else
ret = ret + 500;
}
first_line_good = 0;
Ftam_get_again( line,dest_file ,x25_port );
continue;
}
5ess_getfiles.rar_交换机_程控交换机
版权申诉
21 浏览量
2022-09-19
12:35:19
上传
评论
收藏 2KB RAR 举报
小贝德罗
- 粉丝: 68
- 资源: 1万+
最新资源
- tensorflow-gpu-2.7.4-cp37-cp37m-manylinux2010-x86-64.whl
- 多段线、 圆、弧转多段线(仅我可见)
- tensorflow-2.7.2-cp38-cp38-manylinux2010-x86-64.whl
- yeyue-p8Yi4-ve4a83792.apk
- tensorflow-gpu-2.7.3-cp38-cp38-manylinux2010-x86-64.whl
- 五相感应电机矢量控制模型MATLAB
- RGLED (1) (1).circ
- IMG_20240427_215747.jpg
- python下前端WEB学习笔记
- 田间种植行排号自动生成工具
资源上传下载、课程学习等过程中有任何疑问或建议,欢迎提出宝贵意见哦~我们会及时处理!
点击此处反馈