Changeset 2084

Show
Ignore:
Timestamp:
31/01/2008 23:55:37 (11 months ago)
Author:
chris
Message:

Use logging framework for streaming messages.

Fix double logging of protocol commands on the server side.

Log protocol errors at WARNING level.

Fix typos in comments and variable names.

Files:
1 modified

Legend:

Unmodified
Added
Removed
  • box/trunk/lib/server/makeprotocol.pl.in

    r1937 r2084  
    621621__E 
    622622 
    623 my $construtor_extra = ''; 
    624 $construtor_extra .= ', mLogToSysLog(false)' if $implement_syslog; 
    625 $construtor_extra .= ', mLogToFile(0)' if $implement_filelog; 
     623my $constructor_extra = ''; 
     624$constructor_extra .= ', mLogToSysLog(false)' if $implement_syslog; 
     625$constructor_extra .= ', mLogToFile(0)' if $implement_filelog; 
    626626 
    627627my $destructor_extra = ($type eq 'Server')?"\n\tDeleteStreamsToSend();":''; 
     
    630630print CPP <<__E; 
    631631$prefix$classname_base(IOStream &rStream) 
    632         : Protocol(rStream)$construtor_extra 
     632        : Protocol(rStream)$constructor_extra 
    633633{ 
    634634} 
     
    662662} 
    663663__E 
    664 # write receieve and send functions 
     664# write receive and send functions 
    665665print CPP <<__E; 
    666666std::auto_ptr<$derive_objects_from> ${prefix}Receive() 
     
    735735                std::auto_ptr<${derive_objects_from}> pobj(Receive()); 
    736736 
    737 __E 
    738         if($implement_syslog) 
    739         { 
    740                 print CPP <<__E; 
    741                 if(mLogToSysLog) 
    742                 { 
    743                         pobj->LogSysLog("Receive"); 
    744                 } 
    745 __E 
    746         } 
    747         if($implement_filelog) 
    748         { 
    749                 print CPP <<__E; 
    750                 if(mLogToFile != 0) 
    751                 { 
    752                         pobj->LogFile("Receive", mLogToFile); 
    753                 } 
    754 __E 
    755         } 
    756         print CPP <<__E; 
    757  
    758737                // Run the command 
    759738                std::auto_ptr<${derive_objects_from}> preply((${derive_objects_from}*)(pobj->DoCommand(*this, rContext).release())); 
    760739                 
    761 __E 
    762         if($implement_syslog) 
    763         { 
    764                 print CPP <<__E; 
    765                 if(mLogToSysLog) 
    766                 { 
    767                         preply->LogSysLog("Send"); 
    768                 } 
    769 __E 
    770         } 
    771         if($implement_filelog) 
    772         { 
    773                 print CPP <<__E; 
    774                 if(mLogToFile != 0) 
    775                 { 
    776                         preply->LogFile("Send", mLogToFile); 
    777                 } 
    778 __E 
    779         } 
    780         print CPP <<__E; 
    781  
    782740                // Send the reply 
    783741                Send(*(preply.get())); 
     
    825783        if($implement_syslog) 
    826784        { 
    827                 $fR .= qq~\tif(mLogToSysLog) { ::syslog(LOG_INFO, (Size==Protocol::ProtocolStream_SizeUncertain)?"Receiving stream, size uncertain":"Receiving stream, size %d", Size); }\n~; 
    828                 $fS .= qq~\tif(mLogToSysLog) { ::syslog(LOG_INFO, (Size==Protocol::ProtocolStream_SizeUncertain)?"Sending stream, size uncertain":"Sending stream, size %d", Size); }\n~; 
    829         } 
     785                $fR .= <<__E; 
     786        if(mLogToSysLog) 
     787        { 
     788                if(Size==Protocol::ProtocolStream_SizeUncertain) 
     789                { 
     790                        BOX_TRACE("Receiving stream, size uncertain"); 
     791                } 
     792                else 
     793                { 
     794                        BOX_TRACE("Receiving stream, size " << Size); 
     795                } 
     796        } 
     797__E 
     798                 
     799                $fS .= <<__E; 
     800        if(mLogToSysLog) 
     801        { 
     802                if(Size==Protocol::ProtocolStream_SizeUncertain) 
     803                { 
     804                        BOX_TRACE("Sending stream, size uncertain"); 
     805                } 
     806                else 
     807                { 
     808                        BOX_TRACE("Sending stream, size " << Size); 
     809                } 
     810        } 
     811__E 
     812        } 
     813 
    830814        if($implement_filelog) 
    831815        { 
    832                 $fR .= qq~\tif(mLogToFile) { ::fprintf(mLogToFile, (Size==Protocol::ProtocolStream_SizeUncertain)?"Receiving stream, size uncertain\\n":"Receiving stream, size %d\\n", Size); ::fflush(mLogToFile); }\n~; 
    833                 $fS .= qq~\tif(mLogToFile) { ::fprintf(mLogToFile, (Size==Protocol::ProtocolStream_SizeUncertain)?"Sending stream, size uncertain\\n":"Sending stream, size %d\\n", Size); ::fflush(mLogToFile); }\n~; 
     816                $fR .= <<__E; 
     817        if(mLogToFile) 
     818        { 
     819                ::fprintf(mLogToFile, 
     820                        (Size==Protocol::ProtocolStream_SizeUncertain) 
     821                        ?"Receiving stream, size uncertain\\n" 
     822                        :"Receiving stream, size %d\\n", Size); 
     823                ::fflush(mLogToFile); 
     824        } 
     825__E 
     826                $fS .= <<__E; 
     827        if(mLogToFile) 
     828        { 
     829                ::fprintf(mLogToFile, 
     830                        (Size==Protocol::ProtocolStream_SizeUncertain) 
     831                        ?"Sending stream, size uncertain\\n" 
     832                        :"Sending stream, size %d\\n", Size); 
     833                ::fflush(mLogToFile); 
     834        } 
     835__E 
    834836        } 
    835837 
     
    889891                { 
    890892                        SetError(type, subType); 
    891                         TRACE2("Protocol: Error received %d/%d\\n", type, subType); 
     893                        BOX_WARNING("Protocol: Received error " << type << 
     894                                "/" << subType); 
    892895                } 
    893896                else 
    894897                { 
    895898                        SetError(Protocol::UnknownError, Protocol::UnknownError); 
     899                        BOX_WARNING("Protocol: Received unknown error"); 
    896900                } 
    897901