Mercurial > projects > ldc

comparison tango/tango/io/protocol/EndianProtocol.d @ 132:1700239cab2e trunk

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
[svn r136] MAJOR UNSTABLE UPDATE!!! Initial commit after moving to Tango instead of Phobos. Lots of bugfixes... This build is not suitable for most things.
author lindquist
date Fri, 11 Jan 2008 17:57:40 +0100
parents
children
comparison
equal deleted inserted replaced
131:5825d48b27d1 132:1700239cab2e
1 /*******************************************************************************
2
3 copyright: Copyright (c) 2007 Kris Bell. All rights reserved
4
5 license: BSD style: $(LICENSE)
6
7 version: Jan 2007 : initial release
8
9 author: Kris
10
11 *******************************************************************************/
12
13 module tango.io.protocol.EndianProtocol;
14
15 private import tango.core.ByteSwap;
16
17 private import tango.io.model.IBuffer,
18 tango.io.model.IConduit;
19
20 private import tango.io.protocol.NativeProtocol;
21
22 /*******************************************************************************
23
24 *******************************************************************************/
25
26 class EndianProtocol : NativeProtocol
27 {
28 /***********************************************************************
29
30 ***********************************************************************/
31
32 this (IConduit conduit, bool prefix=true)
33 {
34 super (conduit, prefix);
35 }
36
37 /***********************************************************************
38
39 ***********************************************************************/
40
41 override void[] read (void* dst, uint bytes, Type type)
42 {
43 auto ret = super.read (dst, bytes, type);
44
45 switch (type)
46 {
47 case Type.Short:
48 case Type.UShort:
49 case Type.Utf16:
50 ByteSwap.swap16 (dst, bytes);
51 break;
52
53 case Type.Int:
54 case Type.UInt:
55 case Type.Float:
56 case Type.Utf32:
57 ByteSwap.swap32 (dst, bytes);
58 break;
59
60 case Type.Long:
61 case Type.ULong:
62 case Type.Double:
63 ByteSwap.swap64 (dst, bytes);
64 break;
65
66 case Type.Real:
67 ByteSwap.swap80 (dst, bytes);
68 break;
69
70 default:
71 break;
72 }
73
74 return ret;
75 }
76
77 /***********************************************************************
78
79 ***********************************************************************/
80
81 override void write (void* src, uint bytes, Type type)
82 {
83 alias void function (void* dst, uint bytes) Swapper;
84
85 void write (int mask, Swapper mutate)
86 {
87 uint writer (void[] dst)
88 {
89 // cap bytes written
90 uint len = dst.length & mask;
91 if (len > bytes)
92 len = bytes;
93
94 dst [0..len] = src [0..len];
95 mutate (dst.ptr, len);
96 return len;
97 }
98
99 while (bytes)
100 if (bytes -= buffer_.write (&writer))
101 // flush if we used all buffer space
102 buffer_.drain (buffer.output);
103 }
104
105
106 switch (type)
107 {
108 case Type.Short:
109 case Type.UShort:
110 case Type.Utf16:
111 write (~1, &ByteSwap.swap16);
112 break;
113
114 case Type.Int:
115 case Type.UInt:
116 case Type.Float:
117 case Type.Utf32:
118 write (~3, &ByteSwap.swap32);
119 break;
120
121 case Type.Long:
122 case Type.ULong:
123 case Type.Double:
124 write (~7, &ByteSwap.swap64);
125 break;
126
127 case Type.Real:
128 write (~15, &ByteSwap.swap80);
129 break;
130
131 default:
132 super.write (src, bytes, type);
133 break;
134 }
135 }
136 }
137
138
139 /*******************************************************************************
140
141 *******************************************************************************/
142
143 debug (UnitTest)
144 {
145 import tango.io.Buffer;
146
147 unittest
148 {
149 void[] alloc (EndianProtocol.Reader reader, uint bytes, EndianProtocol.Type type)
150 {
151 return reader ((new void[bytes]).ptr, bytes, type);
152 }
153
154 char[] mule;
155 char[] test = "testing testing 123";
156
157 auto protocol = new EndianProtocol (new Buffer(32));
158 protocol.writeArray (test.ptr, test.length, protocol.Type.Utf8);
159
160 mule = cast(char[]) protocol.readArray (mule.ptr, mule.length, protocol.Type.Utf8, &alloc);
161 assert (mule == test);
162
163 }
164 }
165
166
167
168
169