Acquires at least one, and (greedily) at most max

! * \brief Builds HTTP request headers for SIG4 auth requests to AWS * \param sauth stream for auth header * \param sdate stream for date * \param

cleanup the previous sessions for restart

! * \brief Returns datetime in ISO8601 format * Example: 20131222T043039Z * \param time * \return datetime in above format as string */

NOLINT(*)

! * \brief creates query string from keys and values in params * \param params query keys and values * \param is_canonical whether or not to produc

implement ResetPartition.

! * \brief Signs the request as per SIG4 Auth scheme * https://docs.aws.amazon.com/AmazonS3/latest/API/sigv4-auth-using-authorization-header.html *

! \brief size of the data */

Print summary of certain result map.

! * \brief A faster implementation of atof(). Unlike std::atof(), this function * returns float type. Note that this function does not check

handle non fatal failures @param cid

! \return Get head pointer of child structure */

! * \brief Thread join * \note join() may not be called on auto-remove threads */

! * \brief Check whether the thread is joinable * \return true if the thread is joinable */

convert c string back to python string

! * \brief Call request_shutdown() on all threads in this ThreadGroup * \param make_all_joinable If true, remove all auto_remove flags from chil

! \brief swap two optional */

Swaps this queue's state with the other's. Not thread-safe. Swapping two queues does not invalidate their tokens, however the tokens that were created

! * \brief A generic inplace byte swapping function. * \param data The data pointer. * \param elem_bytes The number of bytes of the data elements

get debug option from env variable.

find the error field of the header

helper function to find next recordio head

! * \brief Returns credential scope as per AWS SIG4 authentication for S3 requests * \param time * \param region s3 region * \return credential sc

! * \brief Returns datetime in YYYYMMDD format * Example: 20131222T043039Z * \param time * \return datetime in above format as string */

! * \brief get field information of each field. * \return field information */

! * \brief Returns keys of canonical_headers separated with semicolon * as per AWS SIG4 authentication * \param canonical_headers * \return signed

! * \brief Load the parameters from JSON. * \param reader JSONReader used for loading. * \throw ParamError when something go wrong. */

get stack trace logging depth from env variable.

! * \brief Converts hash to hex representation * \param hash unsigned char array with hash * \param size size of hash * \return string in hex repr

! * \brief Write the parameters in JSON format. * \param writer JSONWriter used for writing. */

implement set value

implement set head to default value

By default skip the first frame because that belongs to ~LogMessageFatal

! \brief allocate a new memory of size */

! * \brief deallocate a piece of memory * \param p The pointer to the memory to be de-allocated. */

! * \brief Check if the ThreadGroup is empty * \return true if the ThreadGroup is empty */

free the containers that have not yet been launched @param containers

Get the memory in MB from memory string. mem_str: str String representation of memory requirement. Returns ------- mem_mb: i

get the slurm command for setting the environment

Only fails (returns nullptr) if memory allocation fails

Useful for traversing the list when there's no contention (e.g. to destroy remaining nodes)

! * \brief Check whether the thread is set to auto-remove itself from the ThreadGroup owner * when exiting * \return true if the

Process a file.

! * \brief Signal to this thread that a thread shutdown/exit is requested. * \note This is a candidate for overrise in a derived class which

! * \brief reset the pointer to nullptr. */