wvdbus-sharp/msgwriter.cs

   1 // Copyright 2006 Alp Toker <alp@atoker.com>
   2 // This software is made available under the MIT License
   3 // See COPYING for details
   4 //
   5 using System;
   6 using System.Collections;
   7 using System.Collections.Generic;
   8 using System.Text;
   9 using System.IO;
  10 using System.Reflection;
  11 using Mono;
  12 using Wv.Extensions;
  13
  14 namespace Wv
  15 {
  16     public class WvDbusWriter
  17     {
  18         readonly DataConverter conv;
  19         readonly Dbus.Endian endianness;
  20         WvBuf buf = new WvBuf(1024);
  21
  22         public WvDbusWriter()
  23         {
  24             endianness = WvDbusMsg.NativeEndianness;
  25             if (endianness == Dbus.Endian.Little)
  26                 conv = DataConverter.LittleEndian;
  27             else
  28                 conv = DataConverter.BigEndian;
  29         }
  30
  31         public byte[] ToArray()
  32         {
  33             return (byte[])buf.peekall();
  34         }
  35
  36         void p(int align, WvBytes b)
  37         {
  38             WritePad(align);
  39             buf.put(b);
  40         }
  41
  42         public void Write(byte val)
  43         {
  44             buf.put(val);
  45         }
  46
  47         public void Write(bool val)
  48         {
  49             Write((uint)(val ? 1 : 0));
  50         }
  51
  52         public void Write(short val)
  53         {
  54             p(2, conv.GetBytes(val));
  55         }
  56
  57         public void Write(ushort val)
  58         {
  59             p(2, conv.GetBytes(val));
  60         }
  61
  62         public void Write(int val)
  63         {
  64             p(4, conv.GetBytes(val));
  65         }
  66
  67         public void Write(uint val)
  68         {
  69             p(4, conv.GetBytes(val));
  70         }
  71
  72         public void Write(long val)
  73         {
  74             p(8, conv.GetBytes(val));
  75         }
  76
  77         public void Write(ulong val)
  78         {
  79             p(8, conv.GetBytes(val));
  80         }
  81
  82         public void Write(float val)
  83         {
  84             p(4, conv.GetBytes(val));
  85         }
  86
  87         public void Write(double val)
  88         {
  89             p(8, conv.GetBytes(val));
  90         }
  91
  92         public void Write(string val)
  93         {
  94             byte[] b = Encoding.UTF8.GetBytes(val);
  95             Write((uint)b.Length);
  96             buf.put(b);
  97             WriteNull();
  98         }
  99
 100         public void WriteSig(string val)
 101         {
 102             byte[] b = val.ToUTF8();
 103
 104             if (b.Length > Dbus.Protocol.MaxSignatureLength)
 105                 throw new Exception
 106                     ("Signature length "
 107                      + b.Length + " exceeds maximum allowed "
 108                      + Dbus.Protocol.MaxSignatureLength + " bytes");
 109
 110             Write((byte)b.Length);
 111             buf.put(b);
 112             WriteNull();
 113         }
 114
 115         static byte[] zeroes = new byte[8] { 0,0,0,0,0,0,0,0 };
 116         public void WriteArray<T>(int align,
 117                                   IEnumerable<T> list,
 118                                   Action<WvDbusWriter,T> doelement)
 119         {
 120             // after the arraylength, we'll be aligned to size 4, but that
 121             // might not be enough, so maybe we need to fix it up.
 122             WritePad(4);
 123
 124             var tmp = new WvDbusWriter();
 125
 126             int startpad = (int)(buf.used+4) % 8;
 127             tmp.buf.put(zeroes.sub(0, startpad));
 128             tmp.WritePad(align);
 129             int first = tmp.buf.used;
 130
 131             foreach (T i in list)
 132             {
 133                 tmp.WritePad(align);
 134                 doelement(tmp, i);
 135             }
 136
 137             byte[] a = tmp.ToArray();
 138
 139             // the length word excludes all padding...
 140             Write((uint)(a.Length - first));
 141
 142             // ...but we have to copy all the bytes *including* padding
 143             buf.put(a.sub(startpad, a.Length - startpad));
 144         }
 145
 146         public void Write(WvBytes b)
 147         {
 148             Write((int)b.len);
 149             buf.put(b);
 150         }
 151
 152         public void Write(byte[] b)
 153         {
 154             Write((WvBytes)b);
 155         }
 156
 157         public void WriteNull()
 158         {
 159             buf.put((byte)0);
 160         }
 161
 162         public void WritePad(int alignment)
 163         {
 164             int needed = Dbus.Protocol.PadNeeded(buf.used, alignment);
 165             buf.put(zeroes.sub(0, needed));
 166         }
 167     }
 168 }