Method and system for facilitating atomicity assurance on metadata and data bundled storage

A computer system for storing data and metadata in a data stream, the system comprising:

• a processor;
• and
• a memory coupled to the processor and storing instructions, which when executed by the processor cause the processor to perform a method, wherein the computer system comprises a storage device, the method comprising:
• receiving a first stream of data to be written to the storage device, wherein the first stream includes a plurality of I/O requests associated with data and corresponding metadata;
• in response to determining that residual data associated with a preceding I/O request of the first stream exists in a data buffer:
• appending, to the residual data, a first portion of data from a current I/O request to obtain a first page of data;
• writing a remainder portion of the current I/O request to the data buffer to obtain current residual data;
• and
• writing the first page of data to the storage device at a current physical page address, wherein the current physical page address is retrieved from a data structure based on a logical page address associated with the first page;
• and
• determining whether the current residual data corresponds to an end of the first stream, which comprises:
• retrieving, from the data structure, a second physical page address corresponding to a next logical page address associated with a next I/O request;
• responsive to determining that the second physical page address is null, setting the second physical page address to an invalid and not null physical page address;
• responsive to waiting a predetermined period of time, retrieving the second physical page address from the data structure;
• and
• responsive to determining that the second physical page address has been updated and is null, determining that the second physical page address has been trimmed and that the current residual data corresponds to the end of the first stream.

A non-transitory computer-readable storage medium storing instructions that when executed by a computer cause the computer to perform a method, the method comprising:

• receiving a first stream of data to be written to a storage device, wherein the first stream includes a plurality of I/O requests associated with data and corresponding metadata;
• in response to determining that residual data associated with a preceding I/O request of the first stream exists in a data buffer:
• appending, to the residual data, a first portion of data from a current I/O request to obtain a first page of data;
• writing a remainder portion of the current I/O request to the data buffer to obtain current residual data;
• and
• writing the first page of data to the storage device at a current physical page address, wherein the current physical page address is retrieved from a data structure based on a logical page address associated with the first page;
• and
• determining whether the current residual data corresponds to an end of the first stream, which comprises:
• retrieving, from the data structure, a second physical page address corresponding to a next logical page address associated with a next I/O request;
• responsive to determining that the second physical page address is null, setting the second physical page address to an invalid and not null physical page address;
• responsive to waiting a predetermined period of time, retrieving the second physical page address from the data structure;
• and
• responsive to determining that the second physical page address has been updated and is null, determining that the second physical page address has been trimmed and that the current residual data corresponds to the end of the first stream.