| OLD | NEW |
| (Empty) |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | |
| 2 // Use of this source code is governed by a BSD-style license that can be | |
| 3 // found in the LICENSE file. | |
| 4 | |
| 5 define("mojo/apps/js/bindings/codec", function() { | |
| 6 | |
| 7 // Memory ------------------------------------------------------------------- | |
| 8 | |
| 9 function store8(memory, pointer, val) { | |
| 10 memory[pointer] = val; | |
| 11 } | |
| 12 | |
| 13 function store16(memory, pointer, val) { | |
| 14 memory[pointer + 0] = val >> 0; | |
| 15 memory[pointer + 1] = val >> 8; | |
| 16 } | |
| 17 | |
| 18 function store32(memory, pointer, val) { | |
| 19 memory[pointer + 0] = val >> 0; | |
| 20 memory[pointer + 1] = val >> 8; | |
| 21 memory[pointer + 2] = val >> 16; | |
| 22 memory[pointer + 3] = val >> 24; | |
| 23 } | |
| 24 | |
| 25 function store64(memory, pointer, val) { | |
| 26 store32(memory, pointer, val); | |
| 27 var high = (val / 0x10000) | 0; | |
| 28 store32(memory, pointer + 4, high); | |
| 29 } | |
| 30 | |
| 31 function load8(memory, pointer) { | |
| 32 return memory[pointer]; | |
| 33 } | |
| 34 | |
| 35 function load16(memory, pointer) { | |
| 36 return (memory[pointer + 0] << 0) + | |
| 37 (memory[pointer + 1] << 8); | |
| 38 } | |
| 39 | |
| 40 function load32(memory, pointer) { | |
| 41 return (memory[pointer + 0] << 0) + | |
| 42 (memory[pointer + 1] << 8) + | |
| 43 (memory[pointer + 2] << 16) + | |
| 44 (memory[pointer + 3] << 24); | |
| 45 } | |
| 46 | |
| 47 var kAlignment = 8; | |
| 48 | |
| 49 function align(size) { | |
| 50 return size + (kAlignment - (size % kAlignment)) % kAlignment; | |
| 51 } | |
| 52 | |
| 53 // Buffer ------------------------------------------------------------------- | |
| 54 | |
| 55 function Buffer(size) { | |
| 56 this.memory = new Uint8Array(size); | |
| 57 this.next = 0; | |
| 58 } | |
| 59 | |
| 60 Buffer.prototype.alloc = function(size) { | |
| 61 var pointer = this.next; | |
| 62 this.next += size; | |
| 63 if (this.next > this.memory.length) { | |
| 64 var newSize = (1.5 * (this.memory.length + size)) | 0; | |
| 65 this.grow(newSize); | |
| 66 } | |
| 67 return pointer; | |
| 68 }; | |
| 69 | |
| 70 Buffer.prototype.grow = function(size) { | |
| 71 var newMemory = new Uint8Array(size); | |
| 72 var oldMemory = this.memory; | |
| 73 for (var i = 0; i < oldMemory.length; ++i) | |
| 74 newMemory[i] = oldMemory[i]; | |
| 75 this.memory = newMemory; | |
| 76 }; | |
| 77 | |
| 78 Buffer.prototype.createViewOfAllocatedMemory = function() { | |
| 79 return new Uint8Array(this.memory.buffer, 0, this.next); | |
| 80 }; | |
| 81 | |
| 82 // Constants ---------------------------------------------------------------- | |
| 83 | |
| 84 var kArrayHeaderSize = 8; | |
| 85 var kStructHeaderSize = 8; | |
| 86 var kMessageHeaderSize = 8; | |
| 87 | |
| 88 // Decoder ------------------------------------------------------------------ | |
| 89 | |
| 90 function Decoder(memory, handles, base) { | |
| 91 this.memory = memory; | |
| 92 this.handles = handles; | |
| 93 this.base = base; | |
| 94 this.next = base; | |
| 95 this.viewU32 = new Uint32Array( | |
| 96 this.memory.buffer, 0, | |
| 97 Math.floor(this.memory.length / Uint32Array.BYTES_PER_ELEMENT)); | |
| 98 this.viewFloat = new Float32Array( | |
| 99 this.memory.buffer, 0, | |
| 100 Math.floor(this.memory.length / Float32Array.BYTES_PER_ELEMENT)); | |
| 101 } | |
| 102 | |
| 103 Decoder.prototype.skip = function(offset) { | |
| 104 this.next += offset; | |
| 105 }; | |
| 106 | |
| 107 Decoder.prototype.read8 = function() { | |
| 108 var result = load8(this.memory, this.next); | |
| 109 this.next += 1; | |
| 110 return result; | |
| 111 }; | |
| 112 | |
| 113 Decoder.prototype.read32 = function() { | |
| 114 var result = this.viewU32[this.next / this.viewU32.BYTES_PER_ELEMENT]; | |
| 115 this.next += this.viewU32.BYTES_PER_ELEMENT; | |
| 116 return result; | |
| 117 }; | |
| 118 | |
| 119 Decoder.prototype.read64 = function() { | |
| 120 var low = this.read32(); | |
| 121 var high = this.read32(); | |
| 122 return low + high * 0x100000000; | |
| 123 }; | |
| 124 | |
| 125 Decoder.prototype.decodeFloat = function() { | |
| 126 var result = this.viewFloat[this.next / this.viewFloat.BYTES_PER_ELEMENT]; | |
| 127 this.next += this.viewFloat.BYTES_PER_ELEMENT; | |
| 128 return result; | |
| 129 }; | |
| 130 | |
| 131 Decoder.prototype.decodePointer = function() { | |
| 132 // TODO(abarth): To correctly decode a pointer, we need to know the real | |
| 133 // base address of the array buffer. | |
| 134 var offsetPointer = this.next; | |
| 135 var offset = this.read64(); | |
| 136 if (!offset) | |
| 137 return 0; | |
| 138 return offsetPointer + offset; | |
| 139 }; | |
| 140 | |
| 141 Decoder.prototype.decodeAndCreateDecoder = function() { | |
| 142 return new Decoder(this.memory, this.handles, this.decodePointer()); | |
| 143 }; | |
| 144 | |
| 145 Decoder.prototype.decodeHandle = function() { | |
| 146 return this.handles[this.read32()]; | |
| 147 }; | |
| 148 | |
| 149 Decoder.prototype.decodeString = function() { | |
| 150 // TODO(abarth): We should really support UTF-8. We might want to | |
| 151 // jump out of the VM to decode the string directly from the array | |
| 152 // buffer using v8::String::NewFromUtf8. | |
| 153 var numberOfBytes = this.read32(); | |
| 154 var numberOfElements = this.read32(); | |
| 155 var val = new Array(numberOfElements); | |
| 156 var memory = this.memory; | |
| 157 var base = this.next; | |
| 158 for (var i = 0; i < numberOfElements; ++i) { | |
| 159 val[i] = String.fromCharCode(memory[base + i] & 0x7F); | |
| 160 } | |
| 161 this.next += numberOfElements; | |
| 162 return val.join(''); | |
| 163 }; | |
| 164 | |
| 165 Decoder.prototype.decodeArray = function(cls) { | |
| 166 var numberOfBytes = this.read32(); | |
| 167 var numberOfElements = this.read32(); | |
| 168 var val = new Array(numberOfElements); | |
| 169 for (var i = 0; i < numberOfElements; ++i) { | |
| 170 val[i] = cls.decode(this); | |
| 171 } | |
| 172 return val; | |
| 173 }; | |
| 174 | |
| 175 Decoder.prototype.decodeStructPointer = function(cls) { | |
| 176 return cls.decode(this.decodeAndCreateDecoder()); | |
| 177 }; | |
| 178 | |
| 179 Decoder.prototype.decodeArrayPointer = function(cls) { | |
| 180 return this.decodeAndCreateDecoder().decodeArray(cls); | |
| 181 }; | |
| 182 | |
| 183 Decoder.prototype.decodeStringPointer = function() { | |
| 184 return this.decodeAndCreateDecoder().decodeString(); | |
| 185 }; | |
| 186 | |
| 187 // Encoder ------------------------------------------------------------------ | |
| 188 | |
| 189 function Encoder(buffer, handles, base) { | |
| 190 this.buffer = buffer; | |
| 191 this.handles = handles; | |
| 192 this.base = base; | |
| 193 this.next = base; | |
| 194 } | |
| 195 | |
| 196 Encoder.prototype.skip = function(offset) { | |
| 197 this.next += offset; | |
| 198 }; | |
| 199 | |
| 200 Encoder.prototype.write8 = function(val) { | |
| 201 store8(this.buffer.memory, this.next, val); | |
| 202 this.next += 1; | |
| 203 }; | |
| 204 | |
| 205 Encoder.prototype.write32 = function(val) { | |
| 206 store32(this.buffer.memory, this.next, val); | |
| 207 this.next += 4; | |
| 208 }; | |
| 209 | |
| 210 Encoder.prototype.write64 = function(val) { | |
| 211 store64(this.buffer.memory, this.next, val); | |
| 212 this.next += 8; | |
| 213 }; | |
| 214 | |
| 215 Encoder.prototype.encodeFloat = function(val) { | |
| 216 var floatBuffer = new Float32Array(1); | |
| 217 floatBuffer[0] = val; | |
| 218 var buffer = new Uint8Array(floatBuffer.buffer, 0); | |
| 219 for (var i = 0; i < buffer.length; ++i) | |
| 220 this.buffer.memory[this.next++] = buffer[i]; | |
| 221 }; | |
| 222 | |
| 223 Encoder.prototype.encodePointer = function(pointer) { | |
| 224 if (!pointer) | |
| 225 return this.write64(0); | |
| 226 // TODO(abarth): To correctly encode a pointer, we need to know the real | |
| 227 // base address of the array buffer. | |
| 228 var offset = pointer - this.next; | |
| 229 this.write64(offset); | |
| 230 }; | |
| 231 | |
| 232 Encoder.prototype.createAndEncodeEncoder = function(size) { | |
| 233 var pointer = this.buffer.alloc(align(size)); | |
| 234 this.encodePointer(pointer); | |
| 235 return new Encoder(this.buffer, this.handles, pointer); | |
| 236 }; | |
| 237 | |
| 238 Encoder.prototype.encodeHandle = function(handle) { | |
| 239 this.handles.push(handle); | |
| 240 this.write32(this.handles.length - 1); | |
| 241 }; | |
| 242 | |
| 243 Encoder.prototype.encodeString = function(val) { | |
| 244 var numberOfElements = val.length; | |
| 245 var numberOfBytes = kArrayHeaderSize + numberOfElements; | |
| 246 this.write32(numberOfBytes); | |
| 247 this.write32(numberOfElements); | |
| 248 // TODO(abarth): We should really support UTF-8. We might want to | |
| 249 // jump out of the VM to encode the string directly from the array | |
| 250 // buffer using v8::String::WriteUtf8. | |
| 251 var memory = this.buffer.memory; | |
| 252 var base = this.next; | |
| 253 var len = val.length; | |
| 254 for (var i = 0; i < len; ++i) { | |
| 255 memory[base + i] = val.charCodeAt(i) & 0x7F; | |
| 256 } | |
| 257 this.next += len; | |
| 258 }; | |
| 259 | |
| 260 Encoder.prototype.encodeArray = function(cls, val) { | |
| 261 var numberOfElements = val.length; | |
| 262 var numberOfBytes = kArrayHeaderSize + cls.encodedSize * numberOfElements; | |
| 263 this.write32(numberOfBytes); | |
| 264 this.write32(numberOfElements); | |
| 265 for (var i = 0; i < numberOfElements; ++i) { | |
| 266 cls.encode(this, val[i]); | |
| 267 } | |
| 268 }; | |
| 269 | |
| 270 Encoder.prototype.encodeStructPointer = function(cls, val) { | |
| 271 var encoder = this.createAndEncodeEncoder(cls.encodedSize); | |
| 272 cls.encode(encoder, val); | |
| 273 }; | |
| 274 | |
| 275 Encoder.prototype.encodeArrayPointer = function(cls, val) { | |
| 276 var encodedSize = kArrayHeaderSize + cls.encodedSize * val.length; | |
| 277 var encoder = this.createAndEncodeEncoder(encodedSize); | |
| 278 encoder.encodeArray(cls, val); | |
| 279 }; | |
| 280 | |
| 281 Encoder.prototype.encodeStringPointer = function(val) { | |
| 282 // TODO(abarth): This won't be right once we support UTF-8. | |
| 283 var encodedSize = kArrayHeaderSize + val.length; | |
| 284 var encoder = this.createAndEncodeEncoder(encodedSize); | |
| 285 encoder.encodeString(val); | |
| 286 }; | |
| 287 | |
| 288 // Message ------------------------------------------------------------------ | |
| 289 | |
| 290 function Message(memory, handles) { | |
| 291 this.memory = memory; | |
| 292 this.handles = handles; | |
| 293 } | |
| 294 | |
| 295 // MessageBuilder ----------------------------------------------------------- | |
| 296 | |
| 297 function MessageBuilder(messageName, payloadSize) { | |
| 298 // Currently, we don't compute the payload size correctly ahead of time. | |
| 299 // Instead, we overwrite this field at the end. | |
| 300 var numberOfBytes = kMessageHeaderSize + payloadSize; | |
| 301 this.buffer = new Buffer(numberOfBytes); | |
| 302 this.handles = []; | |
| 303 var encoder = this.createEncoder(kMessageHeaderSize); | |
| 304 encoder.write32(numberOfBytes); | |
| 305 encoder.write32(messageName); | |
| 306 } | |
| 307 | |
| 308 MessageBuilder.prototype.createEncoder = function(size) { | |
| 309 var pointer = this.buffer.alloc(size); | |
| 310 return new Encoder(this.buffer, this.handles, pointer); | |
| 311 } | |
| 312 | |
| 313 MessageBuilder.prototype.encodeStruct = function(cls, val) { | |
| 314 cls.encode(this.createEncoder(cls.encodedSize), val); | |
| 315 }; | |
| 316 | |
| 317 MessageBuilder.prototype.finish = function() { | |
| 318 // TODO(abarth): Rather than resizing the buffer at the end, we could | |
| 319 // compute the size we need ahead of time, like we do in C++. | |
| 320 var memory = this.buffer.createViewOfAllocatedMemory(); | |
| 321 store32(memory, 0, memory.length); | |
| 322 var message = new Message(memory, this.handles); | |
| 323 this.buffer = null; | |
| 324 this.handles = null; | |
| 325 this.encoder = null; | |
| 326 return message; | |
| 327 }; | |
| 328 | |
| 329 // MessageReader ------------------------------------------------------------ | |
| 330 | |
| 331 function MessageReader(message) { | |
| 332 this.decoder = new Decoder(message.memory, message.handles, 0); | |
| 333 this.payloadSize = this.decoder.read32() - kMessageHeaderSize; | |
| 334 this.messageName = this.decoder.read32(); | |
| 335 } | |
| 336 | |
| 337 MessageReader.prototype.decodeStruct = function(cls) { | |
| 338 return cls.decode(this.decoder); | |
| 339 }; | |
| 340 | |
| 341 // Built-in types ----------------------------------------------------------- | |
| 342 | |
| 343 function Uint8() { | |
| 344 } | |
| 345 | |
| 346 Uint8.encodedSize = 1; | |
| 347 | |
| 348 Uint8.decode = function(decoder) { | |
| 349 return decoder.read8(); | |
| 350 }; | |
| 351 | |
| 352 Uint8.encode = function(encoder, val) { | |
| 353 encoder.write8(val); | |
| 354 }; | |
| 355 | |
| 356 function Uint16() { | |
| 357 } | |
| 358 | |
| 359 Uint16.encodedSize = 2; | |
| 360 | |
| 361 Uint16.decode = function(decoder) { | |
| 362 return decoder.read16(); | |
| 363 }; | |
| 364 | |
| 365 Uint16.encode = function(encoder, val) { | |
| 366 encoder.write16(val); | |
| 367 }; | |
| 368 | |
| 369 function Uint32() { | |
| 370 } | |
| 371 | |
| 372 Uint32.encodedSize = 4; | |
| 373 | |
| 374 Uint32.decode = function(decoder) { | |
| 375 return decoder.read32(); | |
| 376 }; | |
| 377 | |
| 378 Uint32.encode = function(encoder, val) { | |
| 379 encoder.write32(val); | |
| 380 }; | |
| 381 | |
| 382 function Uint64() { | |
| 383 }; | |
| 384 | |
| 385 Uint64.encodedSize = 8; | |
| 386 | |
| 387 Uint64.decode = function(decoder) { | |
| 388 return decoder.read64(); | |
| 389 }; | |
| 390 | |
| 391 Uint64.encode = function(encoder, val) { | |
| 392 encoder.write64(val); | |
| 393 }; | |
| 394 | |
| 395 function PointerTo(cls) { | |
| 396 this.cls = cls; | |
| 397 }; | |
| 398 | |
| 399 // TODO(abarth): Add missing types: | |
| 400 // * String | |
| 401 // * Float | |
| 402 // * Double | |
| 403 // * Signed integers | |
| 404 | |
| 405 PointerTo.prototype.encodedSize = 8; | |
| 406 | |
| 407 PointerTo.prototype.decode = function(decoder) { | |
| 408 return this.cls.decode(decoder.decodeAndCreateDecoder()); | |
| 409 }; | |
| 410 | |
| 411 PointerTo.prototype.encode = function(encoder, val) { | |
| 412 var objectEncoder = encoder.createAndEncodeEncoder(this.cls.encodedSize); | |
| 413 this.cls.encode(objectEncoder, val); | |
| 414 }; | |
| 415 | |
| 416 function ArrayOf(cls) { | |
| 417 this.cls = cls; | |
| 418 }; | |
| 419 | |
| 420 ArrayOf.prototype.encodedSize = 8; | |
| 421 | |
| 422 ArrayOf.prototype.decode = function(decoder) { | |
| 423 return decoder.decodeArrayPointer(self.cls); | |
| 424 }; | |
| 425 | |
| 426 ArrayOf.prototype.encode = function(encoder, val) { | |
| 427 encoder.encodeArrayPointer(self.cls, val); | |
| 428 }; | |
| 429 | |
| 430 function Handle() { | |
| 431 } | |
| 432 | |
| 433 Handle.encodedSize = 4; | |
| 434 | |
| 435 Handle.decode = function(decoder) { | |
| 436 return decoder.decodeHandle(); | |
| 437 }; | |
| 438 | |
| 439 Handle.encode = function(encoder, val) { | |
| 440 encoder.encodeHandle(val); | |
| 441 }; | |
| 442 | |
| 443 var exports = {}; | |
| 444 exports.align = align; | |
| 445 exports.Message = Message; | |
| 446 exports.MessageBuilder = MessageBuilder; | |
| 447 exports.MessageReader = MessageReader; | |
| 448 exports.kArrayHeaderSize = kArrayHeaderSize; | |
| 449 exports.kStructHeaderSize = kStructHeaderSize; | |
| 450 exports.kMessageHeaderSize = kMessageHeaderSize; | |
| 451 exports.Uint8 = Uint8; | |
| 452 exports.Uint16 = Uint16; | |
| 453 exports.Uint32 = Uint32; | |
| 454 exports.Uint64 = Uint64; | |
| 455 exports.PointerTo = PointerTo; | |
| 456 exports.ArrayOf = ArrayOf; | |
| 457 exports.Handle = Handle; | |
| 458 return exports; | |
| 459 }); | |
| OLD | NEW |