WebGPUAttributes.js 3.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197
  1. class WebGPUAttributes {
  2. constructor( device ) {
  3. this.buffers = new WeakMap();
  4. this.device = device;
  5. }
  6. get( attribute ) {
  7. attribute = this._getAttribute( attribute );
  8. return this.buffers.get( attribute );
  9. }
  10. remove( attribute ) {
  11. attribute = this._getAttribute( attribute );
  12. const data = this.buffers.get( attribute );
  13. if ( data ) {
  14. this._destroyBuffers( data );
  15. this.buffers.delete( attribute );
  16. }
  17. }
  18. update( attribute, isIndex = false, usage = null ) {
  19. attribute = this._getAttribute( attribute );
  20. let data = this.buffers.get( attribute );
  21. if ( data === undefined ) {
  22. if ( usage === null ) {
  23. usage = ( isIndex === true ) ? GPUBufferUsage.INDEX : GPUBufferUsage.VERTEX;
  24. }
  25. data = this._createBuffer( attribute, usage );
  26. this.buffers.set( attribute, data );
  27. } else if ( usage && usage !== data.usage ) {
  28. this._destroyBuffers( data );
  29. data = this._createBuffer( attribute, usage );
  30. this.buffers.set( attribute, data );
  31. } else if ( data.version < attribute.version ) {
  32. this._writeBuffer( data.buffer, attribute );
  33. data.version = attribute.version;
  34. }
  35. }
  36. async getArrayBuffer( attribute ) {
  37. const data = this.get( attribute );
  38. const device = this.device;
  39. const gpuBuffer = data.buffer;
  40. const size = gpuBuffer.size;
  41. let gpuReadBuffer = data.readBuffer;
  42. let needsUnmap = true;
  43. if ( gpuReadBuffer === null ) {
  44. gpuReadBuffer = device.createBuffer( {
  45. label: attribute.name,
  46. size,
  47. usage: GPUBufferUsage.COPY_DST | GPUBufferUsage.MAP_READ
  48. } );
  49. needsUnmap = false;
  50. data.readBuffer = gpuReadBuffer;
  51. }
  52. const cmdEncoder = device.createCommandEncoder( {} );
  53. cmdEncoder.copyBufferToBuffer(
  54. gpuBuffer,
  55. 0,
  56. gpuReadBuffer,
  57. 0,
  58. size
  59. );
  60. if ( needsUnmap ) gpuReadBuffer.unmap();
  61. const gpuCommands = cmdEncoder.finish();
  62. device.queue.submit( [ gpuCommands ] );
  63. await gpuReadBuffer.mapAsync( GPUMapMode.READ );
  64. const arrayBuffer = gpuReadBuffer.getMappedRange();
  65. return arrayBuffer;
  66. }
  67. _getAttribute( attribute ) {
  68. if ( attribute.isInterleavedBufferAttribute ) attribute = attribute.data;
  69. return attribute;
  70. }
  71. _createBuffer( attribute, usage ) {
  72. const array = attribute.array;
  73. const size = array.byteLength + ( ( 4 - ( array.byteLength % 4 ) ) % 4 ); // ensure 4 byte alignment, see #20441
  74. const buffer = this.device.createBuffer( {
  75. label: attribute.name,
  76. size,
  77. usage: usage | GPUBufferUsage.COPY_SRC | GPUBufferUsage.COPY_DST,
  78. mappedAtCreation: true
  79. } );
  80. new array.constructor( buffer.getMappedRange() ).set( array );
  81. buffer.unmap();
  82. attribute.onUploadCallback();
  83. return {
  84. version: attribute.version,
  85. buffer,
  86. readBuffer: null,
  87. usage
  88. };
  89. }
  90. _writeBuffer( buffer, attribute ) {
  91. const device = this.device;
  92. const array = attribute.array;
  93. const updateRange = attribute.updateRange;
  94. if ( updateRange.count === - 1 ) {
  95. // Not using update ranges
  96. device.queue.writeBuffer(
  97. buffer,
  98. 0,
  99. array,
  100. 0
  101. );
  102. } else {
  103. device.queue.writeBuffer(
  104. buffer,
  105. 0,
  106. array,
  107. updateRange.offset * array.BYTES_PER_ELEMENT,
  108. updateRange.count * array.BYTES_PER_ELEMENT
  109. );
  110. updateRange.count = - 1; // reset range
  111. }
  112. }
  113. _destroyBuffers( { buffer, readBuffer } ) {
  114. buffer.destroy();
  115. if ( readBuffer !== null ) readBuffer.destroy();
  116. }
  117. }
  118. export default WebGPUAttributes;