all-headers.js 711 B

123456789101112131415161718192021222324
  1. "use strict";
  2. Object.defineProperty(exports, "__esModule", {
  3. value: true
  4. });
  5. exports.writeToTrackingBuffer = writeToTrackingBuffer;
  6. const TYPE = {
  7. QUERY_NOTIFICATIONS: 1,
  8. TXN_DESCRIPTOR: 2,
  9. TRACE_ACTIVITY: 3
  10. };
  11. const TXNDESCRIPTOR_HEADER_DATA_LEN = 4 + 8;
  12. const TXNDESCRIPTOR_HEADER_LEN = 4 + 2 + TXNDESCRIPTOR_HEADER_DATA_LEN;
  13. function writeToTrackingBuffer(buffer, txnDescriptor, outstandingRequestCount) {
  14. buffer.writeUInt32LE(0);
  15. buffer.writeUInt32LE(TXNDESCRIPTOR_HEADER_LEN);
  16. buffer.writeUInt16LE(TYPE.TXN_DESCRIPTOR);
  17. buffer.writeBuffer(txnDescriptor);
  18. buffer.writeUInt32LE(outstandingRequestCount);
  19. const data = buffer.data;
  20. data.writeUInt32LE(data.length, 0);
  21. return buffer;
  22. }