Main Page | Class Hierarchy | Alphabetical List | Class List | Directories | File List | Class Members | File Members | Related Pages

SocketAppender.d

Go to the documentation of this file.
00001 /*******************************************************************************
00002 
00003         @file SocketAppender.d
00004 
00005         Copyright (c) 2004 Kris Bell
00006         
00007         This software is provided 'as-is', without any express or implied
00008         warranty. In no event will the authors be held liable for damages
00009         of any kind arising from the use of this software.
00010         
00011         Permission is hereby granted to anyone to use this software for any 
00012         purpose, including commercial applications, and to alter it and/or 
00013         redistribute it freely, subject to the following restrictions:
00014         
00015         1. The origin of this software must not be misrepresented; you must 
00016            not claim that you wrote the original software. If you use this 
00017            software in a product, an acknowledgment within documentation of 
00018            said product would be appreciated but is not required.
00019 
00020         2. Altered source versions must be plainly marked as such, and must 
00021            not be misrepresented as being the original software.
00022 
00023         3. This notice may not be removed or altered from any distribution
00024            of the source.
00025 
00026         4. Derivative works are permitted, but they must carry this notice
00027            in full and credit the original source.
00028 
00029 
00030                         ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
00031 
00032       
00033         @version        Initial version, May 2004
00034         @author         Kris
00035 
00036 
00037 *******************************************************************************/
00038 
00039 module mango.log.SocketAppender;
00040 
00041 private import  mango.log.Appender;
00042 
00043 version (Isolated)
00044         {
00045         private import  std.stream,
00046                         std.Socket,
00047                         std.SocketStream;
00048         }
00049      else
00050         {
00051         private import  mango.io.Buffer,
00052                         mango.io.Console,
00053                         mango.io.SocketConduit;
00054         }
00055 
00056 /*******************************************************************************
00057 
00058         Appender for sending formatted output to a Socket.
00059 
00060 *******************************************************************************/
00061 
00062 public class SocketAppender : Appender
00063 {
00064         private static uint mask;
00065 
00066         version (Isolated)
00067                  private SocketStream stream;
00068               else
00069                  private IBuffer buffer;
00070 
00071         /***********************************************************************
00072                 
00073                 Get a unique fingerprint for this class
00074 
00075         ***********************************************************************/
00076 
00077         static this()
00078         {
00079                 mask = nextMask();
00080         }
00081 
00082         /***********************************************************************
00083                 
00084                 Create with the given Layout and address
00085 
00086         ***********************************************************************/
00087 
00088         this (Layout layout, InternetAddress address)
00089         {
00090                 setLayout (layout);
00091                 setAddress (address);
00092         }
00093 
00094         /***********************************************************************
00095              
00096              Ensure the socket is closed when we're GC'd
00097                 
00098         ***********************************************************************/
00099 
00100         ~this ()
00101         {
00102                 close();
00103         }
00104 
00105         /***********************************************************************
00106                
00107                Set the destination address and port for this socket
00108 
00109         ***********************************************************************/
00110 
00111         void setAddress (InternetAddress address)
00112         {
00113                 close ();
00114                 
00115                 version (Isolated)
00116                         {
00117                         try {
00118                             throw new Exception ("SocketAppender fails with dmd v0.115");
00119                             Socket s = null; //new Socket (AddressFamily.INET, SocketType.STREAM, ProtocolType.IP);
00120                             s.connect (address);
00121                             stream = new SocketStream (s, FileMode.Out);
00122                             } catch (Object x)
00123                                      printf ("SocketAppender: failed to connect\n");
00124                         }
00125                      else
00126                         {
00127                         try {
00128                             SocketConduit socket = new SocketConduit ();
00129                             socket.connect (address);
00130                             buffer = socket.createBuffer ();
00131                             } catch (Object x)
00132                                      Cerr ("SocketAppender: failed to connect\n");
00133                         }
00134         }
00135 
00136         /***********************************************************************
00137                 
00138                 Return the fingerprint for this class
00139 
00140         ***********************************************************************/
00141 
00142         uint getMask ()
00143         {
00144                 return mask;
00145         }
00146 
00147         /***********************************************************************
00148                 
00149                 Return the name of this class
00150 
00151         ***********************************************************************/
00152 
00153         char[] getName ()
00154         {
00155                 return this.classinfo.name;
00156         }
00157                 
00158         /***********************************************************************
00159                 
00160                 Append an event to the output.
00161                  
00162         ***********************************************************************/
00163 
00164         void append (Event event)
00165         {
00166                 version (Isolated)
00167                         {
00168                         if (stream)
00169                            {
00170                            Layout layout = getLayout;
00171                            stream.writeString (layout.header  (event));
00172                            stream.writeString (layout.content (event));
00173                            stream.writeString (layout.footer  (event));
00174                            stream.flush ();
00175                            }    
00176                         }
00177                      else
00178                         {
00179                         if (buffer)
00180                            {
00181                            Layout layout = getLayout;
00182                            buffer.append (layout.header  (event));
00183                            buffer.append (layout.content (event));
00184                            buffer.append (layout.footer  (event)).flush();
00185                            }    
00186                         }
00187         }
00188 
00189         /***********************************************************************
00190             
00191                 Close the socket associated with this Appender
00192                     
00193         ***********************************************************************/
00194 
00195         void close ()
00196         {
00197                 version (Isolated)
00198                         {
00199                         if (stream)
00200                             stream.close ();
00201                         stream = null;
00202                         }
00203                      else
00204                         {
00205                         if (buffer)
00206                             buffer.getConduit.close();
00207                         buffer = null;
00208                         }
00209         }
00210 }

Generated on Mon Nov 14 10:59:40 2005 for Mango by  doxygen 1.4.0