1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
|
// Copyright 2006 Alp Toker <alp@atoker.com>
// This software is made available under the MIT License
// See COPYING for details
using System;
using System.Collections.Generic;
using System.IO;
namespace NDesk.DBus
{
class Message
{
public Message ()
{
Header.Endianness = Connection.NativeEndianness;
Header.MessageType = MessageType.MethodCall;
Header.Flags = HeaderFlag.NoReplyExpected; //TODO: is this the right place to do this?
Header.MajorVersion = Protocol.Version;
Header.Fields = new Dictionary<FieldCode,object> ();
}
public Header Header;
public Connection Connection;
public Signature Signature
{
get {
object o;
if (Header.Fields.TryGetValue (FieldCode.Signature, out o))
return (Signature)o;
else
return Signature.Empty;
} set {
if (value == Signature.Empty)
Header.Fields.Remove (FieldCode.Signature);
else
Header.Fields[FieldCode.Signature] = value;
}
}
public bool ReplyExpected
{
get {
return (Header.Flags & HeaderFlag.NoReplyExpected) == HeaderFlag.None;
} set {
if (value)
Header.Flags &= ~HeaderFlag.NoReplyExpected; //flag off
else
Header.Flags |= HeaderFlag.NoReplyExpected; //flag on
}
}
//public HeaderField[] HeaderFields;
//public Dictionary<FieldCode,object>;
public byte[] Body;
//TODO: make use of Locked
/*
protected bool locked = false;
public bool Locked
{
get {
return locked;
}
}
*/
public void SetHeaderData (byte[] data)
{
EndianFlag endianness = (EndianFlag)data[0];
MessageReader reader = new MessageReader (endianness, data);
Header = (Header)reader.ReadStruct (typeof (Header));
}
public byte[] GetHeaderData ()
{
if (Body != null)
Header.Length = (uint)Body.Length;
MessageWriter writer = new MessageWriter (Header.Endianness);
writer.WriteValueType (Header, typeof (Header));
writer.CloseWrite ();
return writer.ToArray ();
}
}
}
|
