tuxedo 会话通信 运行失败

fangang001

服务器端源程序：

1. #include<stdio.h>
   
2. #include<string.h>
   
3. #include<stdlib.h>
   
4. #include"atmi.h"
   
5. #include"viewrecord.h"
   
6. 
   
7. #define MXSTR 80
   
8. static struct viewrecord* bufptr;
   
9. 
   
10. int tpsvrinit(int argc,char* argv[]){
    
11.     bufptr=(struct viewrecord*)tpalloc("VIEW32","viewrecord",sizeof(struct viewrecord));
    
12.     return 0;
    
13. }
    
14. 
    
15. void GETRECORDS(TPSVCINFO* msg){
    
16.     long len,revent;
    
17.     int cd;
    
18.     FILE *file;
    
19.     char *error,input[MXSTR];
    
20.     cd=msg->cd;
    
21. 
    
22.     file=fopen("customerinfo.data","r");
    
23. 
    
24.     while((error=fgets(input,80,file))!=NULL){
    
25.         strcpy(bufptr->f_name,strtok(input,"    "));
    
26.         strcpy(bufptr->l_name,strtok(NULL," "));
    
27.         strcpy(bufptr->address,strtok(NULL,"    "));
    
28.         strcpy(bufptr->city,strtok(NULL,"   "));
    
29.         strcpy(bufptr->state,strtok(NULL,"  "));
    
30.         strcpy(bufptr->zipcode,strtok(NULL,"    "));
    
31. 
    
32.         if(tpsend(cd,(char*)bufptr,0,TPSIGRSTRT,&revent)==-1){
    
33.             userlog("serverconv tpsend receive an unexpected event\n");
    
34.             tpreturn(TPFAIL,0,(char*)bufptr,0,0);
    
35.         }
    
36.     }
    
37.     fclose(file);
    
38.     tpreturn(TPSUCCESS,0,NULL,0L,0);
    
39. }
    
40. 
    
41. void tpsvrdone(){
    
42.     tpfree((char*)bufptr);
    
43. }
    

复制代码

客户端程序：

1. 
   
2. #include<stdio.h>
   
3. #include<stdlib.h>
   
4. #include"atmi.h"
   
5. #include"viewrecord.h"
   
6. 
   
7. int main(int argc,char* argv[]){
   
8.     int cd,recvlen,ret/*,revent*/;
   
9.     long revent;
   
10.     struct viewrecord *bufptr;
    
11. 
    
12.     tpinit((TPINIT*)NULL);
    
13.     if((cd=tpconnect("GETRECORDS",(char*)NULL,0,TPRECVONLY))==-1){
    
14.         fprintf(stderr,"tpconnect:%s\n",tpstrerror(tperrno));
    
15.         exit(1);
    
16.     }
    
17. 
    
18.     if((bufptr=(struct viewrecord*)tpalloc("VIEW32","viewrecord",sizeof(struct viewrecord)))==NULL){
    
19.         fprintf(stderr,"tpalloc for VIEW32 failed!\n");
    
20.         tpterm();
    
21.     }
    
22. 
    
23.     while(1){
    
24.         if((ret=tprecv(cd,(char**)&bufptr,(long*)&recvlen,TPSIGRSTRT,(long*)&revent))==-1)
    
25.             if(revent==TPEV_SVCSUCC)
    
26.                 break;
    
27.         else
    
28.             tpdiscon(cd);
    
29. 
    
30.         printf("NAME:%s %s\nADDRESS:%s\nCity/State/Zip:%s,%s,%s\n\n",bufptr->f_name,bufptr->l_name,
    
31.                 bufptr->address,bufptr->city,bufptr->state,bufptr->zipcode);
    
32.     }
    
33. 
    
34.     tpfree((char*)bufptr);
    
35.     tpterm();
    
36.     fprintf(stderr,"----The End!----\n");
    
37.     return 0;
    
38. }
    
39. 
    

复制代码

客户端运行结果：
[tuxapp@localhost src]$ ./convclient
NAME:#firstname lastname
ADDRESS:address
City/State/Zip:city,state,zipcode


NAME:jon smith
ADDRESS:123 allen rode
City/State/Zip:san jose,NJ,07938


之后一直输出
NAME:jon smith
ADDRESS:123 allen rode
City/State/Zip:san jose,NJ,07938


NAME:jon smith
ADDRESS:123 allen rode
City/State/Zip:san jose,NJ,07938


NAME:jon smith
ADDRESS:123 allen rode
City/State/Zip:san jose,NJ,07938

.......

不知道哪位大侠知道是哪个地方出错了，求指导

rdcwayx

死循环了，看看 客户端程序里，while loop那个部分 if break部分是否有效。

fangang001

嗯，是这样，貌似服务器端tpreturn(TPSUCCESS,...),客户端没有收到，我尝试了去掉中间的数据发送部分，单单进行tpreturn(TPSUCCESS,...)，客户端是可以正常结束的，所以我怀疑是不是tpsend的使用方法不当，我刚接触tuxedo不久，希望版主不吝赐教回复 2# rdcwayx


   

fangang001

这个问题搞定了，是数据问题，和程序无关，特此结贴