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.SocketConduit;
00053         }
00054 
00055 /*******************************************************************************
00056 
00057         Appender for sending formatted output to a Socket.
00058 
00059 *******************************************************************************/
00060 
00061 public class SocketAppender : Appender
00062 {
00063         private static uint mask;
00064 
00065         version (Isolated)
00066                  private SocketStream stream;
00067               else
00068                  private IBuffer buffer;
00069 
00070         /***********************************************************************
00071                 
00072                 Get a unique fingerprint for this class
00073 
00074         ***********************************************************************/
00075 
00076         static this()
00077         {
00078                 mask = nextMask();
00079         }
00080 
00081         /***********************************************************************
00082                 
00083                 Create with the given Layout and address
00084 
00085         ***********************************************************************/
00086 
00087         this (Layout layout, InternetAddress address)
00088         {
00089                 setLayout (layout);
00090                 setAddress (address);
00091         }
00092 
00093         /***********************************************************************
00094              
00095              Ensure the socket is closed when we're GC'd
00096                 
00097         ***********************************************************************/
00098 
00099         ~this ()
00100         {
00101                 close();
00102         }
00103 
00104         /***********************************************************************
00105                
00106                Set the destination address and port for this socket
00107 
00108         ***********************************************************************/
00109 
00110         void setAddress (InternetAddress address)
00111         {
00112                 close ();
00113                 
00114                 version (Isolated)
00115                         {
00116                         try {
00117                             throw new Exception ("SocketAppender fails with dmd v0.115");
00118                             Socket s = null; //new Socket (AddressFamily.INET, SocketType.STREAM, ProtocolType.IP);
00119                             s.connect (address);
00120                             stream = new SocketStream (s, FileMode.Out);
00121                             } catch (Object x)
00122                                      printf ("SocketAppender: failed to connect\n");
00123                         }
00124                      else
00125                         {
00126                         try {
00127                             SocketConduit socket = new SocketConduit ();
00128                             socket.connect (address);
00129                             buffer = socket.createBuffer ();
00130                             } catch (Object x)
00131                                      printf ("SocketAppender: failed to connect\n");
00132                         }
00133         }
00134 
00135         /***********************************************************************
00136                 
00137                 Return the fingerprint for this class
00138 
00139         ***********************************************************************/
00140 
00141         uint getMask ()
00142         {
00143                 return mask;
00144         }
00145 
00146         /***********************************************************************
00147                 
00148                 Return the name of this class
00149 
00150         ***********************************************************************/
00151 
00152         char[] getName ()
00153         {
00154                 return this.classinfo.name;
00155         }
00156                 
00157         /***********************************************************************
00158                 
00159                 Append an event to the output.
00160                  
00161         ***********************************************************************/
00162 
00163         void append (Event event)
00164         {
00165                 version (Isolated)
00166                         {
00167                         if (stream)
00168                            {
00169                            Layout layout = getLayout;
00170                            stream.writeString (layout.header  (event));
00171                            stream.writeString (layout.content (event));
00172                            stream.writeString (layout.footer  (event));
00173                            stream.flush ();
00174                            }    
00175                         }
00176                      else
00177                         {
00178                         if (buffer)
00179                            {
00180                            Layout layout = getLayout;
00181                            buffer.append (layout.header  (event));
00182                            buffer.append (layout.content (event));
00183                            buffer.append (layout.footer  (event)).flush();
00184                            }    
00185                         }
00186         }
00187 
00188         /***********************************************************************
00189             
00190                 Close the socket associated with this Appender
00191                     
00192         ***********************************************************************/
00193 
00194         void close ()
00195         {
00196                 version (Isolated)
00197                         {
00198                         if (stream)
00199                             stream.close ();
00200                         stream = null;
00201                         }
00202                      else
00203                         {
00204                         if (buffer)
00205                             buffer.getConduit.close();
00206                         buffer = null;
00207                         }
00208         }
00209 }

Generated on Fri May 27 18:11:56 2005 for Mango by  doxygen 1.4.0