Changeset 4186


Ignore:
Timestamp:
04/01/11 15:18:12 (10 years ago)
Author:
dietz
Message:

rearranged tport_getmsg loop such that msgs with GET_OK,GET_MISS,GET_NO_TRACK returns are processed. Formerly was only processing GET_OK msgs.

File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/src/seismic_processing/eqassemble/eqassemble.c

    r3821 r4186  
    323323         *******************************************************************/ 
    324324        do { 
     325            fflush( stdout ); 
     326 
    325327            /* see if a termination has been requested 
    326328             *****************************************/ 
     
    349351                                &reclogo, &recsize, rec, MAXSTRLEN-1 ); 
    350352            switch(res) { 
    351             case GET_MISS:   /* got a message; missed some */ 
     353            case GET_OK:      /* got a message just fine    */ 
     354                break; 
     355            case GET_MISS:    /* got a message; missed some */ 
    352356                sprintf( Text, 
    353357                         "Missed msg(s)  i%u m%u t%u  region:%ld.", 
     
    355359                eqas_status( TypeError, ERR_MISSMSG, Text ); 
    356360                break; 
    357             case GET_NOTRACK:   /* got a message; can't tell is any were missed */ 
     361            case GET_NOTRACK: /* got a message; can't tell is any were missed */ 
    358362                sprintf( Text, 
    359363                         "Msg received (i%u m%u t%u); transport.h NTRACK_GET exceeded", 
    360364                         reclogo.instid, reclogo.mod, reclogo.type ); 
    361365                eqas_status( TypeError, ERR_NOTRACK, Text ); 
    362                 break; 
    363             case GET_OK:   /* got a message just fine */ 
    364                 rec[recsize] = '\0';      /*null terminate the message*/ 
    365                 if (reclogo.type == TypePickSCNL) { 
    366                     eqas_pickscnl( rec ); 
    367                 } else if ( reclogo.type == TypeCodaSCNL) { 
    368                     eqas_codascnl( rec ); 
    369                 } else if (reclogo.type == TypeQuake2K) { 
    370                     eqas_quake2k( rec ); 
    371                 } else if (reclogo.type == TypeLink) { 
    372                     eqas_link( rec ); 
    373                 } 
    374366                break; 
    375367            case GET_TOOBIG:  /* no message returned; it was too big */ 
     
    379371                        MAXSTRLEN-1 ); 
    380372                eqas_status( TypeError, ERR_TOOBIG, Text ); 
    381                 break; 
    382             case GET_NONE:  /* no messages to process */ 
    383                 break; 
    384             } 
    385             fflush( stdout ); 
     373                continue; 
     374            case GET_NONE:   /* no messages to process */ 
     375                continue; 
     376            } 
     377 
     378            /* Process the message (GET_MISS, GETNOTRACK, GET_OK returns) 
     379             ***********************************************************/ 
     380            rec[recsize] = '\0';      /*null terminate the message*/ 
     381            if (reclogo.type == TypePickSCNL) { 
     382                eqas_pickscnl( rec ); 
     383            } else if ( reclogo.type == TypeCodaSCNL) { 
     384                eqas_codascnl( rec ); 
     385            } else if (reclogo.type == TypeQuake2K) { 
     386                eqas_quake2k( rec ); 
     387            } else if (reclogo.type == TypeLink) { 
     388                eqas_link( rec ); 
     389            }    
     390 
    386391        } while( res != GET_NONE );  /*end of message-processing-loop */ 
    387392    } 
Note: See TracChangeset for help on using the changeset viewer.