Module: /home/henthorn/AUV/auv-qnx/auv/altex/onboard/camera/xportTest.cc Group: 'DGROUP' CONST,CONST2,_DATA,_BSS Segment: _TEXT DWORD USE32 00000c5a bytes /****************************************************************************/ /* Copyright (c) 2008 MBARI */ /* MBARI Proprietary Information. All rights reserved. */ /****************************************************************************/ /* Summary : */ /* Filename : xportTest.cc */ /* Author : K Headley */ /* Project : Benthic Imaging AUV */ /* Created : 04/01/2008 */ /****************************************************************************/ /* Modification History: */ /* $Id: xportTest.cc,v 1.3 2012/04/05 22:43:38 headley Exp $ */ /* $Name: $ */ /****************************************************************************/ #include "XPort.h" #include "BicamConsts.h" #include "qnx_port.h" #include #ifdef QNX using namespace std; #endif /* local function defs */ int testConnectXPort(XPort xport); int testWriteMessage(XPort xport); int testWriteCommand(XPort xport); int testReadResponse(XPort xport); void startMockXPort(char *host); pid_t mockXPortPID; pid_t gpioPID; pid_t serialPID; #define NUM_THREADS 2 int testConnectXPort(XPort *xport){ int test; 0000 int near testConnectXPort( XPort near * ): 0000 68 1c 00 00 00 push 0000001cH 0005 e8 00 00 00 00 call __CHK 000a 53 push ebx 000b 52 push edx 000c 89 c3 mov ebx,eax test=xport->connectxp(XPCON_ALL); 000e ba 02 00 00 00 mov edx,00000002H 0013 e8 00 00 00 00 call int near XPort::connectxp( ConnectionID ) if(test==OK){ 0018 85 c0 test eax,eax 001a 75 39 jne L1 printdbg("testConnectXPort: host:%s gpioPort:%d serialPort:%d \n", xport->getConnection()->getHost(), xport->getConnection()->getpGPIO(), xport->getConnection()->getpSerial()); 001c 89 d8 mov eax,ebx 001e e8 00 00 00 00 call XPortConnection near * near XPort::getConnection() 0023 e8 00 00 00 00 call int unsigned near XPortConnection::getpSerial() 0028 50 push eax 0029 89 d8 mov eax,ebx 002b e8 00 00 00 00 call XPortConnection near * near XPort::getConnection() 0030 e8 00 00 00 00 call int unsigned near XPortConnection::getpGPIO() 0035 50 push eax 0036 89 d8 mov eax,ebx 0038 e8 00 00 00 00 call XPortConnection near * near XPort::getConnection() 003d e8 00 00 00 00 call char near * near XPortConnection::getHost() 0042 50 push eax 0043 68 00 00 00 00 push offset L63 0048 e8 00 00 00 00 call void near printdbg( char near *, ... ) 004d 83 c4 10 add esp,00000010H return TEST_OK; } 0050 31 c0 xor eax,eax 0052 5a pop edx 0053 5b pop ebx 0054 c3 ret return TEST_FAILED; 0055 b8 fb ff ff ff L1 mov eax,0fffffffbH } 005a 5a pop edx 005b 5b pop ebx 005c c3 ret int testDisconnectXPort(XPort xport){ int test; 005d int near testDisconnectXPort( XPort ): 005d 68 0c 00 00 00 push 0000000cH 0062 e8 00 00 00 00 call __CHK 0067 52 push edx 0068 50 push eax test=xport.disconnectxp(XPCON_ALL); 0069 ba 02 00 00 00 mov edx,00000002H 006e e8 00 00 00 00 call int near XPort::disconnectxp( ConnectionID ) if(test==OK){ return TEST_OK; } 0073 85 c0 test eax,eax 0075 74 05 je L2 return TEST_FAILED; 0077 b8 fb ff ff ff mov eax,0fffffffbH } 007c 83 c4 04 L2 add esp,00000004H 007f 5a pop edx 0080 c3 ret int testWriteSerial(XPort xport){ int test=0; char *msg="this is a test message\n"; 0081 int near testWriteSerial( XPort ): 0081 68 18 00 00 00 push 00000018H 0086 e8 00 00 00 00 call __CHK 008b 53 push ebx 008c 51 push ecx 008d 52 push edx 008e 56 push esi 008f 50 push eax int len=(strlen(msg)+1); 0090 b8 36 00 00 00 mov eax,offset L64 0095 e8 00 00 00 00 call strlen_ 009a 8d 70 01 lea esi,+1H[eax] test=xport.writeSerial(msg,len,0); 009d 31 c9 xor ecx,ecx 009f 89 f3 mov ebx,esi 00a1 ba 36 00 00 00 mov edx,offset L64 00a6 8b 04 24 mov eax,[esp] 00a9 e8 00 00 00 00 call int near XPort::writeSerial( char const near *, int unsigned, int unsigned ) 00ae 89 c3 mov ebx,eax if(test!=len){ 00b0 39 f0 cmp eax,esi 00b2 74 27 je L3 cout << "testWriteSerial: failed; returned "<0) 0139 85 f6 test esi,esi 013b 7e 07 jle L6 return TEST_FAILED; else 013d b8 fb ff ff ff mov eax,0fffffffbH 0142 eb 02 jmp L7 return TEST_OK; 0144 31 c0 L6 xor eax,eax } 0146 83 c4 18 L7 add esp,00000018H 0149 5e pop esi 014a 5a pop edx 014b 59 pop ecx 014c 5b pop ebx 014d c3 ret int testReadResponse(XPort xport){ int test=0; 014e int near testReadResponse( XPort ): 014e 68 30 00 00 00 push 00000030H 0153 e8 00 00 00 00 call __CHK 0158 53 push ebx 0159 51 push ecx 015a 52 push edx 015b 56 push esi 015c 83 ec 18 sub esp,00000018H 015f 50 push eax int result=0; 0160 31 f6 xor esi,esi unsigned char testCmd=XP_CMD_GET_FUNCTIONS; 0162 c6 44 24 18 10 mov byte ptr +18H[esp],10H XPortResponse xpResponse; 0167 8d 44 24 10 lea eax,+10H[esp] 016b e8 00 00 00 00 call near XPortResponse::XPortResponse() XPortCommand xpCommand; 0170 8d 44 24 04 lea eax,+4H[esp] 0174 e8 00 00 00 00 call near XPortCommand::XPortCommand() xpCommand.set(testCmd,0xFF,0xFF); //printdbg("testReadResponse sending:\n"); //showCommand(xpCommand); 0179 b9 ff 00 00 00 mov ecx,000000ffH 017e 89 cb mov ebx,ecx 0180 ba 10 00 00 00 mov edx,00000010H 0185 8d 44 24 04 lea eax,+4H[esp] 0189 e8 00 00 00 00 call void near XPortCommand::set( char unsigned, int unsigned, int unsigned ) test=xport.writeCommand(&xpCommand); 018e 8d 54 24 04 lea edx,+4H[esp] 0192 8b 04 24 mov eax,[esp] 0195 e8 00 00 00 00 call int near XPort::writeCommand( XPortCommand near * ) if(test!=XPORT_COMMAND_LEN){ 019a 83 f8 09 cmp eax,00000009H 019d 74 05 je L8 result++; } //printdbg("testReadResponse: sendCommand returned %d\n",test); 019f be 01 00 00 00 mov esi,00000001H test=xport.readResponse(&xpResponse); 01a4 8d 54 24 10 L8 lea edx,+10H[esp] 01a8 8b 04 24 mov eax,[esp] 01ab e8 00 00 00 00 call int near XPort::readResponse( XPortResponse near * ) if(xpResponse.getCommand() != testCmd || xpResponse.getP1() != 0xff){ 01b0 8d 44 24 10 lea eax,+10H[esp] 01b4 e8 00 00 00 00 call char unsigned near XPortResponse::getCommand() 01b9 3a 44 24 18 cmp al,+18H[esp] 01bd 75 10 jne L9 01bf 8d 44 24 10 lea eax,+10H[esp] 01c3 e8 00 00 00 00 call int unsigned near XPortResponse::getP1() 01c8 3d ff 00 00 00 cmp eax,000000ffH 01cd 74 01 je L10 result++; } 01cf 46 L9 inc esi if(result>0) 01d0 85 f6 L10 test esi,esi 01d2 7e 07 jle L11 return TEST_FAILED; else 01d4 b8 fb ff ff ff mov eax,0fffffffbH 01d9 eb 02 jmp L12 return TEST_OK; 01db 31 c0 L11 xor eax,eax } 01dd 83 c4 1c L12 add esp,0000001cH 01e0 5e pop esi 01e1 5a pop edx 01e2 59 pop ecx 01e3 5b pop ebx 01e4 c3 ret int getListenerSocket(int *sd, char *hostname, unsigned short port, struct sockaddr_in *servAddr){ struct hostent *h; 01e5 int near getListenerSocket( int near *, char near *, short unsigned, sockaddr_in near * ): 01e5 68 20 00 00 00 push 00000020H 01ea e8 00 00 00 00 call __CHK 01ef 56 push esi 01f0 57 push edi 01f1 55 push ebp 01f2 89 c6 mov esi,eax 01f4 89 d7 mov edi,edx printdbg("getListenerSocket: setting up listener on %s port %d (%hu)\n",hostname,port,port); /* create socket */ 01f6 0f b7 eb movzx ebp,bx 01f9 55 push ebp 01fa 55 push ebp 01fb 52 push edx 01fc 68 71 00 00 00 push offset L66 0201 e8 00 00 00 00 call void near printdbg( char near *, ... ) 0206 83 c4 10 add esp,00000010H *sd = socket(AF_INET, SOCK_STREAM, 0); 0209 31 db xor ebx,ebx 020b ba 01 00 00 00 mov edx,00000001H 0210 b8 02 00 00 00 mov eax,00000002H 0215 e8 00 00 00 00 call socket_ 021a 89 06 mov [esi],eax if(*sd<0) { 021c 85 c0 test eax,eax 021e 7d 13 jge L14 perror("getListenerSocket: cannot open socket "); 0220 b8 ad 00 00 00 mov eax,offset L67 0225 e8 00 00 00 00 call perror_ return ERROR; } 022a b8 ff ff ff ff L13 mov eax,0ffffffffH 022f 5d pop ebp 0230 5f pop edi 0231 5e pop esi 0232 c3 ret printdbg("getListenerSocket: got socket (%d)\n",*sd); /* bind server port */ 0233 50 L14 push eax 0234 68 d4 00 00 00 push offset L68 0239 e8 00 00 00 00 call void near printdbg( char near *, ... ) 023e 83 c4 08 add esp,00000008H printdbg("getListenerSocket: calling gethostbyname %s\n",hostname); 0241 57 push edi 0242 68 f8 00 00 00 push offset L69 0247 e8 00 00 00 00 call void near printdbg( char near *, ... ) 024c 83 c4 08 add esp,00000008H h = gethostbyname(hostname); 024f 89 f8 mov eax,edi 0251 e8 00 00 00 00 call gethostbyname_ if(h==NULL) { 0256 85 c0 test eax,eax 0258 75 17 jne L15 printdbg("getListenerSocket: unknown host '%s' (%d)\n",hostname,h_errno); return ERROR; } 025a 8b 35 00 00 00 00 mov esi,_h_errno 0260 56 push esi 0261 57 push edi 0262 68 25 01 00 00 push offset L70 0267 e8 00 00 00 00 call void near printdbg( char near *, ... ) 026c 83 c4 0c add esp,0000000cH 026f eb b9 jmp L13 printdbg("getListenerSocket: gethostbyname complete\n"); 0271 68 50 01 00 00 L15 push offset L71 0276 e8 00 00 00 00 call void near printdbg( char near *, ... ) 027b 83 c4 04 add esp,00000004H servAddr->sin_family = AF_INET; //memcpy((char *) &servAddr->sin_addr.s_addr, h->h_addr_list[0], h->h_length); /* not sure why, but it won't bind using the hostname: memcpy((char *) &servAddr->sin_addr.s_addr, h->h_addr_list[0], h->h_length); must use INADDR_ANY */ 027e c6 41 01 02 mov byte ptr +1H[ecx],02H servAddr->sin_addr.s_addr = htonl(INADDR_ANY); 0282 31 c0 xor eax,eax 0284 e8 00 00 00 00 call htonl_ 0289 89 41 04 mov +4H[ecx],eax servAddr->sin_port = htons(port); 028c 89 e8 mov eax,ebp 028e e8 00 00 00 00 call htons_ 0293 66 89 41 02 mov +2H[ecx],ax errno=0; 0297 e8 00 00 00 00 call __get_errno_ptr_ 029c c7 00 00 00 00 00 mov dword ptr [eax],00000000H if(bind(*sd, (struct sockaddr *) servAddr, sizeof(*servAddr))<0) { 02a2 8b 06 mov eax,[esi] 02a4 bb 10 00 00 00 mov ebx,00000010H 02a9 89 ca mov edx,ecx 02ab e8 00 00 00 00 call bind_ 02b0 85 c0 test eax,eax 02b2 7d 1a jge L16 printdbg("getListenerSocket: cannot bind port (%d)\n",errno); return ERROR; } 02b4 e8 00 00 00 00 call __get_errno_ptr_ 02b9 8b 08 mov ecx,[eax] 02bb 51 push ecx 02bc 68 7b 01 00 00 push offset L72 02c1 e8 00 00 00 00 call void near printdbg( char near *, ... ) 02c6 83 c4 08 add esp,00000008H 02c9 e9 5c ff ff ff jmp L13 listen(*sd,2); 02ce 8b 06 L16 mov eax,[esi] 02d0 ba 02 00 00 00 mov edx,00000002H 02d5 e8 00 00 00 00 call listen_ return *sd; 02da 8b 06 mov eax,[esi] } 02dc 5d pop ebp 02dd 5f pop edi 02de 5e pop esi 02df c3 ret void *gpioListener(void *threadid){ int tid; int sd, newSd; SOCKLEN svrLen; struct sockaddr_in svrAddr; 02e0 void near * near gpioListener( void near * ): 02e0 68 b4 00 00 00 push 000000b4H 02e5 e8 00 00 00 00 call __CHK 02ea 53 push ebx 02eb 51 push ecx 02ec 52 push edx 02ed 56 push esi 02ee 57 push edi 02ef 55 push ebp 02f0 81 ec 8c 00 00 00 sub esp,0000008cH 02f6 89 c2 mov edx,eax int MSG_BUFFER_SIZE=32; char msgBuffer[32]; int readLen=0; 02f8 bf 20 00 00 00 mov edi,00000020H XPortCommand xpCommand; 02fd 8d 44 24 70 lea eax,+70H[esp] 0301 e8 00 00 00 00 call near XPortCommand::XPortCommand() XPortResponse xpResponse; int test=0,disconnect=0; char hostName[MAXHOSTNAMELEN]; //tid=(int)threadid; tid=(long)threadid; 0306 8d 44 24 7c lea eax,+7cH[esp] 030a e8 00 00 00 00 call near XPortResponse::XPortResponse() printdbg("GPIO listener: starting on port %ld thread tid=%d\n",GPIO_IP_PORT,tid); 030f 52 push edx 0310 68 f0 77 00 00 push 000077f0H 0315 68 a5 01 00 00 push offset L73 031a e8 00 00 00 00 call void near printdbg( char near *, ... ) 031f 83 c4 0c add esp,0000000cH test=gethostname(hostName,MAXHOSTNAMELEN); /* create socket */ 0322 ba 40 00 00 00 mov edx,00000040H 0327 89 e0 mov eax,esp 0329 e8 00 00 00 00 call gethostname_ sd = getListenerSocket(&sd,hostName,GPIO_IP_PORT,&svrAddr); 032e 8d 4c 24 60 lea ecx,+60H[esp] 0332 bb f0 77 00 00 mov ebx,000077f0H 0337 89 e2 mov edx,esp 0339 8d 84 24 84 00 00 00 lea eax,+84H[esp] 0340 e8 00 00 00 00 call int near getListenerSocket( int near *, char near *, short unsigned, sockaddr_in near * ) 0345 89 84 24 84 00 00 00 mov +84H[esp],eax if(sd==ERROR){ 034c 83 f8 ff cmp eax,0ffffffffH 034f 75 11 jne L18 perror("gpioListener: GPIO listener: cannot open socket\n"); 0351 b8 d8 01 00 00 mov eax,offset L74 0356 e8 00 00 00 00 L17 call perror_ return NULL;//pthread_exit((void *)err); } while(1) { 035b 31 c0 xor eax,eax 035d e9 56 01 00 00 jmp L26 printdbg("GPIO listener: waiting on port %d sd=%d\n",GPIO_IP_PORT,sd); 0362 8b 94 24 84 00 00 00 L18 mov edx,+84H[esp] 0369 52 push edx 036a 68 f0 77 00 00 push 000077f0H 036f 68 09 02 00 00 push offset L75 0374 e8 00 00 00 00 call void near printdbg( char near *, ... ) 0379 83 c4 0c add esp,0000000cH listen(sd,2); 037c ba 02 00 00 00 mov edx,00000002H 0381 8b 84 24 84 00 00 00 mov eax,+84H[esp] 0388 e8 00 00 00 00 call listen_ svrLen = sizeof(svrAddr); 038d c7 84 24 88 00 00 00 10 00 00 00 mov dword ptr +88H[esp],00000010H newSd = accept(sd, (struct sockaddr *) &svrAddr, &svrLen); 0398 8d 9c 24 88 00 00 00 lea ebx,+88H[esp] 039f 8d 54 24 60 lea edx,+60H[esp] 03a3 8b 84 24 84 00 00 00 mov eax,+84H[esp] 03aa e8 00 00 00 00 call accept_ 03af 89 c6 mov esi,eax if(newSd<0) { 03b1 85 c0 test eax,eax 03b3 7d 07 jge L19 perror("GPIO listener: cannot accept connection "); //pthread_exit((void *)&err); return NULL; } 03b5 b8 32 02 00 00 mov eax,offset L76 03ba eb 9a jmp L17 printdbg("GPIO listener: got GPIO connection from %s\n",inet_ntoa(svrAddr.sin_addr)); /* wait for data */ 03bc 8b 44 24 64 L19 mov eax,+64H[esp] 03c0 e8 00 00 00 00 call inet_ntoa_ 03c5 50 push eax 03c6 68 5b 02 00 00 push offset L77 03cb e8 00 00 00 00 call void near printdbg( char near *, ... ) 03d0 83 c4 08 add esp,00000008H disconnect=0; 03d3 31 ed xor ebp,ebp while(!disconnect){ errno=0; readLen=recv(newSd, msgBuffer,MSG_BUFFER_SIZE,0); if(readLen<0){ printdbg("GPIO listener: recv returned %d (errno=%d)\n",readLen,errno); switch(errno){ case ENOTCONN: disconnect=1; break; default: break; } 03d5 e9 90 00 00 00 jmp L25 }else if(readLen==0){ 03da 75 12 L20 jne L21 printdbg("GPIO listener: connection closed by client\n"); disconnect=1; 03dc 68 b3 02 00 00 push offset L79 03e1 e8 00 00 00 00 call void near printdbg( char near *, ... ) 03e6 83 c4 04 add esp,00000004H }else{ 03e9 e9 74 ff ff ff jmp L18 if(readLen!=XPORT_COMMAND_LEN){ 03ee 83 f8 09 L21 cmp eax,00000009H 03f1 74 10 je L22 printdbg("GPIO listener: warning - invalid message length (%d!=%d)\n",readLen,XPORT_COMMAND_LEN); } 03f3 6a 09 push 00000009H 03f5 50 push eax 03f6 68 df 02 00 00 push offset L80 03fb e8 00 00 00 00 call void near printdbg( char near *, ... ) 0400 83 c4 0c add esp,0000000cH test=xpCommand.parse(msgBuffer); 0403 8d 54 24 40 L22 lea edx,+40H[esp] 0407 8d 44 24 70 lea eax,+70H[esp] 040b e8 00 00 00 00 call int near XPortCommand::parse( char const near * ) if(test!=IS_VALID){ 0410 85 c0 test eax,eax 0412 74 10 je L23 printdbg("GPIO listener: invalid command returned (%d)\n",test); 0414 50 push eax 0415 68 19 03 00 00 push offset L81 041a e8 00 00 00 00 call void near printdbg( char near *, ... ) 041f 83 c4 08 add esp,00000008H }else{ 0422 eb 3e jmp L24 xpResponse.set(xpCommand.getCommand(),xpCommand.getP1()); //printdbg("GPIO listener: sending response:\n"); //showResponse(&xpResponse); 0424 8d 44 24 70 L23 lea eax,+70H[esp] 0428 e8 00 00 00 00 call int unsigned near XPortCommand::getP1() 042d 89 c3 mov ebx,eax 042f 8d 44 24 70 lea eax,+70H[esp] 0433 e8 00 00 00 00 call char unsigned near XPortCommand::getCommand() 0438 31 d2 xor edx,edx 043a 88 c2 mov dl,al 043c 8d 44 24 7c lea eax,+7cH[esp] 0440 e8 00 00 00 00 call void near XPortResponse::set( char unsigned, int unsigned ) send(newSd,xpResponse.toBytes(msgBuffer),XPORT_RESPONSE_LEN,0); 0445 8d 54 24 40 lea edx,+40H[esp] 0449 8d 44 24 7c lea eax,+7cH[esp] 044d e8 00 00 00 00 call char near * near XPortResponse::toBytes( char near * ) 0452 89 c2 mov edx,eax 0454 31 c9 xor ecx,ecx 0456 bb 05 00 00 00 mov ebx,00000005H 045b 89 f0 mov eax,esi 045d e8 00 00 00 00 call send_ } } } } return NULL;//pthread_exit( (void *) err); 0462 85 ed L24 test ebp,ebp 0464 0f 85 f8 fe ff ff jne L18 046a e8 00 00 00 00 L25 call __get_errno_ptr_ 046f c7 00 00 00 00 00 mov dword ptr [eax],00000000H 0475 31 c9 xor ecx,ecx 0477 89 fb mov ebx,edi 0479 8d 54 24 40 lea edx,+40H[esp] 047d 89 f0 mov eax,esi 047f e8 00 00 00 00 call recv_ 0484 89 c2 mov edx,eax 0486 85 c0 test eax,eax 0488 0f 8d 4c ff ff ff jge L20 048e e8 00 00 00 00 call __get_errno_ptr_ 0493 8b 08 mov ecx,[eax] 0495 51 push ecx 0496 52 push edx 0497 68 87 02 00 00 push offset L78 049c e8 00 00 00 00 call void near printdbg( char near *, ... ) 04a1 83 c4 0c add esp,0000000cH 04a4 e8 00 00 00 00 call __get_errno_ptr_ 04a9 8b 00 mov eax,[eax] 04ab 3d 01 01 00 00 cmp eax,00000101H 04b0 0f 84 ac fe ff ff je L18 04b6 eb aa jmp L24 } 04b8 81 c4 8c 00 00 00 L26 add esp,0000008cH 04be 5d L27 pop ebp 04bf 5f pop edi 04c0 5e pop esi 04c1 5a pop edx 04c2 59 pop ecx 04c3 5b pop ebx 04c4 c3 ret void *serialListener(void *threadid){ int tid; int sd, newSd; SOCKLEN svrLen; struct sockaddr_in svrAddr; 04c5 void near * near serialListener( void near * ): 04c5 68 80 01 00 00 push 00000180H 04ca e8 00 00 00 00 call __CHK 04cf 53 push ebx 04d0 51 push ecx 04d1 52 push edx 04d2 56 push esi 04d3 57 push edi 04d4 55 push ebp 04d5 81 ec 58 01 00 00 sub esp,00000158H int MSG_BUFFER_SIZE=256; char msgBuffer[256]; int readLen=0; int disconnect=0; char hostName[MAXHOSTNAMELEN]; //tid=(int)threadid; tid=(long)threadid; 04db be 00 01 00 00 mov esi,00000100H printdbg("SERIAL listener: starting on port %d thread tid=%ld\n",SERIAL_IP_PORT,tid); 04e0 50 push eax 04e1 68 11 27 00 00 push 00002711H 04e6 68 47 03 00 00 push offset L82 04eb e8 00 00 00 00 call void near printdbg( char near *, ... ) 04f0 83 c4 0c add esp,0000000cH gethostname(hostName,MAXHOSTNAMELEN); /* create socket */ 04f3 ba 40 00 00 00 mov edx,00000040H 04f8 8d 84 24 00 01 00 00 lea eax,+100H[esp] 04ff e8 00 00 00 00 call gethostname_ sd = getListenerSocket(&sd,hostName,SERIAL_IP_PORT,&svrAddr); 0504 8d 8c 24 40 01 00 00 lea ecx,+140H[esp] 050b bb 11 27 00 00 mov ebx,00002711H 0510 8d 94 24 00 01 00 00 lea edx,+100H[esp] 0517 8d 84 24 50 01 00 00 lea eax,+150H[esp] 051e e8 00 00 00 00 call int near getListenerSocket( int near *, char near *, short unsigned, sockaddr_in near * ) 0523 89 84 24 50 01 00 00 mov +150H[esp],eax if(sd==ERROR){ 052a 83 f8 ff cmp eax,0ffffffffH 052d 75 11 jne L29 perror("SERIAL listener: cannot open socket"); 052f b8 7c 03 00 00 mov eax,offset L83 0534 e8 00 00 00 00 L28 call perror_ return NULL;//pthread_exit((void *)err); } while(1) { 0539 31 c0 xor eax,eax 053b e9 ff 00 00 00 jmp L37 printdbg("SERIAL listener: waiting on port %d sd=%d\n",SERIAL_IP_PORT,sd); 0540 8b 94 24 50 01 00 00 L29 mov edx,+150H[esp] 0547 52 push edx 0548 68 11 27 00 00 push 00002711H 054d 68 a0 03 00 00 push offset L84 0552 e8 00 00 00 00 call void near printdbg( char near *, ... ) 0557 83 c4 0c add esp,0000000cH listen(sd,2); 055a ba 02 00 00 00 mov edx,00000002H 055f 8b 84 24 50 01 00 00 mov eax,+150H[esp] 0566 e8 00 00 00 00 call listen_ svrLen = sizeof(svrAddr); 056b c7 84 24 54 01 00 00 10 00 00 00 mov dword ptr +154H[esp],00000010H newSd = accept(sd, (struct sockaddr *) &svrAddr, &svrLen); 0576 8d 9c 24 54 01 00 00 lea ebx,+154H[esp] 057d 8d 94 24 40 01 00 00 lea edx,+140H[esp] 0584 8b 84 24 50 01 00 00 mov eax,+150H[esp] 058b e8 00 00 00 00 call accept_ 0590 89 c5 mov ebp,eax if(newSd<0) { 0592 85 c0 test eax,eax 0594 7d 07 jge L30 perror("SERIAL listener: cannot accept connection "); return NULL;//pthread_exit((void *)err); } 0596 b8 cb 03 00 00 mov eax,offset L85 059b eb 97 jmp L28 printdbg("SERIAL listener: got SERIAL connection from %s\n",inet_ntoa(svrAddr.sin_addr)); /* wait for data */ 059d 8b 84 24 44 01 00 00 L30 mov eax,+144H[esp] 05a4 e8 00 00 00 00 call inet_ntoa_ 05a9 50 push eax 05aa 68 f6 03 00 00 push offset L86 05af e8 00 00 00 00 call void near printdbg( char near *, ... ) 05b4 83 c4 08 add esp,00000008H disconnect=0; 05b7 31 ff xor edi,edi while(!disconnect){ errno=0; readLen=recv(newSd, msgBuffer,MSG_BUFFER_SIZE,0); if(readLen<0){ 05b9 eb 4d jmp L35 printdbg("SERIAL listener: recv returned %d (errno=%d)\n",readLen,errno); 05bb e8 00 00 00 00 L31 call __get_errno_ptr_ 05c0 8b 08 mov ecx,[eax] 05c2 51 push ecx 05c3 52 push edx 05c4 68 26 04 00 00 push offset L87 05c9 e8 00 00 00 00 call void near printdbg( char near *, ... ) 05ce 83 c4 0c add esp,0000000cH switch(errno){ case ENOTCONN: disconnect=1; break; default: break; } 05d1 e8 00 00 00 00 call __get_errno_ptr_ 05d6 8b 00 mov eax,[eax] 05d8 3d 01 01 00 00 cmp eax,00000101H 05dd 74 11 je L33 05df eb 14 jmp L34 }else if(readLen==0){ 05e1 75 45 L32 jne L36 printdbg("SERIAL listener: connection closed by client\n"); disconnect=1; }else{ 05e3 68 54 04 00 00 push offset L88 05e8 e8 00 00 00 00 call void near printdbg( char near *, ... ) 05ed 83 c4 04 add esp,00000004H 05f0 bf 01 00 00 00 L33 mov edi,00000001H 05f5 89 f3 L34 mov ebx,esi 05f7 31 d2 xor edx,edx 05f9 89 e0 mov eax,esp 05fb e8 00 00 00 00 call memset_ 0600 85 ff test edi,edi 0602 0f 85 38 ff ff ff jne L29 0608 e8 00 00 00 00 L35 call __get_errno_ptr_ 060d c7 00 00 00 00 00 mov dword ptr [eax],00000000H 0613 31 c9 xor ecx,ecx 0615 89 f3 mov ebx,esi 0617 89 e2 mov edx,esp 0619 89 e8 mov eax,ebp 061b e8 00 00 00 00 call recv_ 0620 89 c2 mov edx,eax 0622 85 c0 test eax,eax 0624 7c 95 jl L31 0626 eb b9 jmp L32 msgBuffer[MSG_BUFFER_SIZE]='\0'; 0628 30 e4 L36 xor ah,ah 062a 88 24 34 mov [esp+esi],ah printdbg("Serial listener received message:[%s]\n",msgBuffer); 062d 89 e0 mov eax,esp 062f 50 push eax 0630 68 82 04 00 00 push offset L89 0635 e8 00 00 00 00 call void near printdbg( char near *, ... ) 063a 83 c4 08 add esp,00000008H } memset(&msgBuffer[0],0x00,MSG_BUFFER_SIZE); } } return NULL;//pthread_exit( (void *) err); 063d eb b6 jmp L34 } /* void startMockXPortThreads(char *host){ pthread_t threads[NUM_THREADS]; pthread_attr_t pthread_custom_attr; int rc,i=0,j=1; /// fork a process to act as an XPort stand-in mockXPortPID=fork(); if( mockXPortPID == -1){ perror("fork"); exit(EXIT_FAILURE); } if( mockXPortPID == 0){ printdbg("mock xport PID %ld on host %s\n",(long)getpid(),host); // spin threads to listen on different ports pthread_attr_init(&pthread_custom_attr); rc=pthread_create(&threads[0],&pthread_custom_attr,gpioListener,(void *)i); if(rc!=0) printdbg("error creating gpio listener: %d\n",rc); rc=pthread_create(&threads[1],&pthread_custom_attr,serialListener,(void *)j); if(rc!=0) printdbg("error creating serial listener: %d\n",rc); printdbg("mock XPort listening...\n"); pthread_join(threads[0],NULL); pthread_join(threads[1],NULL); printdbg("mock XPort exiting\n"); return;//_exit(-1); } printdbg("sleeping 2 sec\n"); sleep(2); return; } */ 063f 81 c4 58 01 00 00 L37 add esp,00000158H 0645 e9 74 fe ff ff jmp L27 void startMockXPort(char *host){ unsigned foo; /* fork processes to act as an XPort stand-in One listens for GPIO and the other for serial connections. */ 064a void near startMockXPort( char near * ): 064a 68 14 00 00 00 push 00000014H 064f e8 00 00 00 00 call __CHK 0654 52 push edx 0655 89 c2 mov edx,eax gpioPID=fork(); 0657 e8 00 00 00 00 call fork_ 065c a3 00 00 00 00 mov int near gpioPID,eax if( gpioPID == -1){ 0661 83 f8 ff cmp eax,0ffffffffH 0664 75 14 jne L38 perror("startMockXPort: gpio fork"); 0666 b8 a9 04 00 00 mov eax,offset L90 066b e8 00 00 00 00 call perror_ exit(EXIT_FAILURE); } 0670 b8 01 00 00 00 mov eax,00000001H 0675 e8 00 00 00 00 call exit_ if( gpioPID == 0){ 067a 83 3d 00 00 00 00 00 L38 cmp dword ptr int near gpioPID,00000000H 0681 75 25 jne L39 printdbg("startMockXPort: gpio PID %ld on host %s\n",(long)getpid(),host); 0683 52 push edx 0684 e8 00 00 00 00 call getpid_ 0689 50 push eax 068a 68 c3 04 00 00 push offset L91 068f e8 00 00 00 00 call void near printdbg( char near *, ... ) 0694 83 c4 0c add esp,0000000cH gpioListener(NULL); 0697 31 c0 xor eax,eax 0699 e8 00 00 00 00 call void near * near gpioListener( void near * ) _exit(-1); } 069e b8 ff ff ff ff mov eax,0ffffffffH 06a3 e8 00 00 00 00 call _exit_ errno=0; 06a8 e8 00 00 00 00 L39 call __get_errno_ptr_ 06ad c7 00 00 00 00 00 mov dword ptr [eax],00000000H foo=sleep(2); 06b3 b8 02 00 00 00 mov eax,00000002H 06b8 e8 00 00 00 00 call sleep_ serialPID=fork(); 06bd e8 00 00 00 00 call fork_ 06c2 a3 00 00 00 00 mov int near serialPID,eax if( serialPID == -1){ 06c7 83 f8 ff cmp eax,0ffffffffH 06ca 75 14 jne L40 perror("startMockXPort: serial fork"); 06cc b8 ec 04 00 00 mov eax,offset L92 06d1 e8 00 00 00 00 call perror_ exit(EXIT_FAILURE); } 06d6 b8 01 00 00 00 mov eax,00000001H 06db e8 00 00 00 00 call exit_ if( serialPID == 0){ 06e0 83 3d 00 00 00 00 00 L40 cmp dword ptr int near serialPID,00000000H 06e7 75 25 jne L41 printdbg("startMockXPort: serial PID %ld on host %s\n",(long)getpid(),host); 06e9 52 push edx 06ea e8 00 00 00 00 call getpid_ 06ef 50 push eax 06f0 68 08 05 00 00 push offset L93 06f5 e8 00 00 00 00 call void near printdbg( char near *, ... ) 06fa 83 c4 0c add esp,0000000cH serialListener(NULL); 06fd 31 c0 xor eax,eax 06ff e8 00 00 00 00 call void near * near serialListener( void near * ) _exit(-1); } return; 0704 b8 ff ff ff ff mov eax,0ffffffffH 0709 e8 00 00 00 00 call _exit_ } /* Main Entry Point */ 070e 5a L41 pop edx 070f c3 ret int main (int argc, char *argv[]){ char xportHost[MAXHOSTNAMELEN+1]; 0710 68 1c 01 00 00 main_ push 0000011cH 0715 e8 00 00 00 00 call __CHK 071a 53 push ebx 071b 51 push ecx 071c 56 push esi 071d 57 push edi 071e 81 ec f8 00 00 00 sub esp,000000f8H int test,passed=0,failed=0; 0724 31 f6 xor esi,esi 0726 31 ff xor edi,edi XPort xport(xportHost, GPIO_IP_PORT,SERIAL_IP_PORT, CFG_GPIO_ALL,CFG_GPIO_OUT, CFG_GPIO_ALL,CFG_GPIO_HI); 0728 68 ff 00 00 00 push 000000ffH 072d 68 ff 00 00 00 push 000000ffH 0732 68 ff 00 00 00 push 000000ffH 0737 68 ff 00 00 00 push 000000ffH 073c b9 11 27 00 00 mov ecx,00002711H 0741 bb f0 77 00 00 mov ebx,000077f0H 0746 8d 54 24 10 lea edx,+10H[esp] 074a 8d 84 24 c0 00 00 00 lea eax,+0c0H[esp] 0751 e8 00 00 00 00 call near XPort::XPort( char near *, int unsigned, int unsigned, int unsigned, int unsigned, int unsigned, int unsigned ) errno=0; 0756 e8 00 00 00 00 call __get_errno_ptr_ 075b 89 30 mov [eax],esi test=gethostname(xportHost,MAXHOSTNAMELEN); 075d ba 40 00 00 00 mov edx,00000040H 0762 89 e0 mov eax,esp 0764 e8 00 00 00 00 call gethostname_ if(test<0) 0769 85 c0 test eax,eax 076b 7d 27 jge L42 cout<<"gethostname failed errno "<configAll(xportHost, GPIO_IP_PORT,SERIAL_IP_PORT, CFG_GPIO_ALL,CFG_GPIO_OUT, CFG_GPIO_ALL,CFG_GPIO_HI); 07e8 68 ff 00 00 00 push 000000ffH 07ed 68 ff 00 00 00 push 000000ffH 07f2 68 ff 00 00 00 push 000000ffH 07f7 68 ff 00 00 00 push 000000ffH 07fc 8d 84 24 c0 00 00 00 lea eax,+0c0H[esp] 0803 e8 00 00 00 00 call XPortConnection near * near XPort::getConnection() 0808 b9 11 27 00 00 mov ecx,00002711H 080d bb f0 77 00 00 mov ebx,000077f0H 0812 8d 54 24 10 lea edx,+10H[esp] 0816 e8 00 00 00 00 call int near XPortConnection::configAll( char near *, int unsigned, int unsigned, int unsigned, int unsigned, int unsigned, int unsigned ) test=testConnectXPort(&xport); 081b 8d 84 24 b0 00 00 00 lea eax,+0b0H[esp] 0822 e8 00 00 00 00 call int near testConnectXPort( XPort near * ) (test==TEST_OK?passed++:failed++); 0827 85 c0 test eax,eax 0829 75 03 jne L43 082b 46 inc esi 082c eb 01 jmp L44 082e 47 L43 inc edi cout << "main: test connectXport: "<<(test==TEST_OK?"OK":"ERR"); 082f 85 c0 L44 test eax,eax 0831 75 07 jne L45 0833 bb 8d 05 00 00 mov ebx,offset L98 0838 eb 05 jmp L46 083a bb 90 05 00 00 L45 mov ebx,offset L99 083f ba 94 05 00 00 L46 mov edx,offset L100 0844 b8 00 00 00 00 mov eax,offset ostream near cout 0849 e8 00 00 00 00 call ostream near & near ostream::operator <<( char const near * ) 084e 89 da mov edx,ebx 0850 e8 00 00 00 00 call ostream near & near ostream::operator <<( char const near * ) cout << "(sdGPIO="<getsdGPIO()<<") "; 0855 8d 84 24 b0 00 00 00 lea eax,+0b0H[esp] 085c e8 00 00 00 00 call XPortConnection near * near XPort::getConnection() 0861 e8 00 00 00 00 call int near XPortConnection::getsdGPIO() 0866 89 c3 mov ebx,eax 0868 ba b1 05 00 00 mov edx,offset L102 086d b8 00 00 00 00 mov eax,offset ostream near cout 0872 e8 00 00 00 00 call ostream near & near ostream::operator <<( char const near * ) 0877 89 da mov edx,ebx 0879 e8 00 00 00 00 call ostream near & near ostream::operator <<( long ) 087e ba ae 05 00 00 mov edx,offset L101 0883 e8 00 00 00 00 call ostream near & near ostream::operator <<( char const near * ) cout << "(sdSerial="<getsdSerial()<<")"<>( istream near &, ::smanip const near & ) SEGMENT ANY '_TEXT' 00000021 bytes 0000 68 0c 00 00 00 push 0000000cH 0005 e8 00 00 00 00 call __CHK 000a 53 push ebx 000b 51 push ecx 000c 89 c3 mov ebx,eax 000e 89 d1 mov ecx,edx 0010 8b 52 04 mov edx,+4H[edx] 0013 8b 00 mov eax,[eax] 0015 8b 40 04 mov eax,+4H[eax] 0018 01 d8 add eax,ebx 001a ff 11 call dword ptr [ecx] 001c 89 d8 mov eax,ebx 001e 59 pop ecx 001f 5b pop ebx 0020 c3 ret No disassembly errors ------------------------------------------------------------ Comdat: istream near & near operator >>( istream near &, ::smanip const near & ) SEGMENT ANY '_TEXT' 00000021 bytes 0000 68 0c 00 00 00 push 0000000cH 0005 e8 00 00 00 00 call __CHK 000a 53 push ebx 000b 51 push ecx 000c 89 c3 mov ebx,eax 000e 89 d1 mov ecx,edx 0010 8b 52 04 mov edx,+4H[edx] 0013 8b 00 mov eax,[eax] 0015 8b 40 04 mov eax,+4H[eax] 0018 01 d8 add eax,ebx 001a ff 11 call dword ptr [ecx] 001c 89 d8 mov eax,ebx 001e 59 pop ecx 001f 5b pop ebx 0020 c3 ret No disassembly errors ------------------------------------------------------------ Comdat: ostream near & near operator <<( ostream near &, ::smanip const near & ) SEGMENT ANY '_TEXT' 00000021 bytes 0000 68 0c 00 00 00 push 0000000cH 0005 e8 00 00 00 00 call __CHK 000a 53 push ebx 000b 51 push ecx 000c 89 c3 mov ebx,eax 000e 89 d1 mov ecx,edx 0010 8b 52 04 mov edx,+4H[edx] 0013 8b 00 mov eax,[eax] 0015 8b 40 04 mov eax,+4H[eax] 0018 01 d8 add eax,ebx 001a ff 11 call dword ptr [ecx] 001c 89 d8 mov eax,ebx 001e 59 pop ecx 001f 5b pop ebx 0020 c3 ret No disassembly errors ------------------------------------------------------------ Comdat: ostream near & near operator <<( ostream near &, ::smanip const near & ) SEGMENT ANY '_TEXT' 00000021 bytes 0000 68 0c 00 00 00 push 0000000cH 0005 e8 00 00 00 00 call __CHK 000a 53 push ebx 000b 51 push ecx 000c 89 c3 mov ebx,eax 000e 89 d1 mov ecx,edx 0010 8b 52 04 mov edx,+4H[edx] 0013 8b 00 mov eax,[eax] 0015 8b 40 04 mov eax,+4H[eax] 0018 01 d8 add eax,ebx 001a ff 11 call dword ptr [ecx] 001c 89 d8 mov eax,ebx 001e 59 pop ecx 001f 5b pop ebx 0020 c3 ret No disassembly errors ------------------------------------------------------------