source: tests/heap.cfa@ 8bf9448

// 
// Cforall Version 1.0.0 Copyright (C) 2017 University of Waterloo
//
// The contents of this file are covered under the licence agreement in the
// file "LICENCE" distributed with Cforall.
// 
// heap.cfa -- 
// 
// Author           : Peter A. Buhr
// Created On       : Tue Nov  6 17:54:56 2018
// Last Modified By : Peter A. Buhr
// Last Modified On : Tue Dec 15 12:11:51 2020
// Update Count     : 79
// 

#include <thread.hfa>
#include <kernel.hfa>                                                                   // processor
#include <stdlib.hfa>                                                                   // *allocs
#include <malloc.h>                                                                             // malloc_*

// #include <time.hfa>
// #define __CFA_DEFAULT_PREEMPTION__ 1000`us
// //#define __CFA_DEFAULT_PREEMPTION__ 0

// Duration default_preemption() {
//      return __CFA_DEFAULT_PREEMPTION__;
// }

size_t default_heap_expansion() {
        return 10 * 1024 * 1024;
} // default_heap_expansion

size_t default_mmap_start() {
        return 512 * 1024 + 1;
} // default_mmap_start

thread Worker {
}; // Worker

void main( Worker & ) {
        enum { NoOfAllocs = 5000, NoOfMmaps = 10 };
        char * locns[NoOfAllocs];
        size_t amount;
        enum { limit = 64 * 1024 };                                                     // check alignments up to here

        // check alloc/free

        for ( j; 40 ) {
                for ( i; NoOfAllocs ) {
                        locns[i] = alloc( i );
                        //sout | (void *)locns[i];
                        for ( k; i ) locns[i][k] = '\345';
                } // for
                //sout | (char *)sbrk(0) - start | " bytes";

                for ( i; NoOfAllocs ) {
                        //sout | (void *)locns[i];
                        for ( k; i ) if ( locns[i][k] != '\345' ) abort( "new/delete corrupt storage1" );
                        free( locns[i] );
                } // for
                //sout | (char *)sbrk(0) - start | " bytes";

                for ( i; NoOfAllocs ) {
                        locns[i] = alloc( i );
                        //sout | (void *)locns[i];
                        for ( k; i ) locns[i][k] = '\345';
                } // for
                for ( i; NoOfAllocs - 1 -~= 0 ) {
                        //sout | (void *)locns[i];
                        for ( k; i ) if ( locns[i][k] != '\345' ) abort( "new/delete corrupt storage2" );
                        free( locns[i] );
                } // for
        } // for

        // check malloc/free (sbrk)

        for ( i; NoOfAllocs ) {
                size_t s = (i + 1) * 20;
                char * area = (char *)malloc( s );
                area[0] = '\345'; area[s - 1] = '\345';                 // fill first/last
                area[malloc_usable_size( area ) - 1] = '\345';  // fill ultimate byte
                free( area );
        } // for

        for ( i; NoOfAllocs ) {
                size_t s = i + 1;                                                               // +1 to make initialization simpler
                locns[i] = (char *)malloc( s );
                locns[i][0] = '\345'; locns[i][s - 1] = '\345'; // fill first/last
                locns[i][malloc_usable_size( locns[i] ) - 1] = '\345'; // fill ultimate byte
        } // for
        for ( i; NoOfAllocs ) {
                size_t s = i + 1;
                if ( locns[i][0] != '\345' || locns[i][s - 1] != '\345' ||
                         locns[i][malloc_usable_size( locns[i] ) - 1] != '\345' ) abort( "malloc/free corrupt storage" );
                free( locns[i] );
        } // for

        // check malloc/free (mmap)

        for ( i; NoOfMmaps ) {
                size_t s = i + default_mmap_start();                    // cross over point
                char * area = (char *)malloc( s );
                area[0] = '\345'; area[s - 1] = '\345';                 // fill first/last
                area[malloc_usable_size( area ) - 1] = '\345';  // fill ultimate byte
                free( area );
        } // for

        for ( i; NoOfMmaps ) {
                size_t s = i + default_mmap_start();                    // cross over point
                locns[i] = (char *)malloc( s );
                locns[i][0] = '\345'; locns[i][s - 1] = '\345'; // fill first/last
                locns[i][malloc_usable_size( locns[i] ) - 1] = '\345'; // fill ultimate byte
        } // for
        for ( i; NoOfMmaps ) {
                size_t s = i + default_mmap_start();                    // cross over point
                if ( locns[i][0] != '\345' || locns[i][s - 1] != '\345' ||
                         locns[i][malloc_usable_size( locns[i] ) - 1] != '\345' ) abort( "malloc/free corrupt storage" );
                free( locns[i] );
        } // for

        // check calloc/free (sbrk)

        for ( i; NoOfAllocs ) {
                size_t s = (i + 1) * 20;
                char * area = (char *)calloc( 5, s );
                if ( area[0] != '\0' || area[s - 1] != '\0' ||
                         area[malloc_size( area ) - 1] != '\0' ||
                         ! malloc_zero_fill( area ) ) abort( "calloc/free corrupt storage1" );
                area[0] = '\345'; area[s - 1] = '\345';                 // fill first/last
                area[malloc_usable_size( area ) - 1] = '\345';  // fill ultimate byte
                free( area );
        } // for

        for ( i; NoOfAllocs ) {
                size_t s = i + 1;
                locns[i] = (char *)calloc( 5, s );
                if ( locns[i][0] != '\0' || locns[i][s - 1] != '\0' ||
                         locns[i][malloc_size( locns[i] ) - 1] != '\0' ||
                         ! malloc_zero_fill( locns[i] ) ) abort( "calloc/free corrupt storage2" );
                locns[i][0] = '\345'; locns[i][s - 1] = '\345'; // fill first/last
                locns[i][malloc_usable_size( locns[i] ) - 1] = '\345'; // fill ultimate byte
        } // for
        for ( i; NoOfAllocs ) {
                size_t s = i + 1;
                if ( locns[i][0] != '\345' || locns[i][s - 1] != '\345' ||
                         locns[i][malloc_usable_size( locns[i] ) - 1] != '\345' ) abort( "calloc/free corrupt storage3" );
                free( locns[i] );
        } // for

        // check calloc/free (mmap)

        for ( i; NoOfMmaps ) {
                size_t s = i + default_mmap_start();                    // cross over point
                char * area = (char *)calloc( 1, s );
                if ( area[0] != '\0' || area[s - 1] != '\0' ) abort( "calloc/free corrupt storage4.1" );
                if ( area[malloc_size( area ) - 1] != '\0' ) abort( "calloc/free corrupt storage4.2" );
                if ( ! malloc_zero_fill( area ) ) abort( "calloc/free corrupt storage4.3" );
                area[0] = '\345'; area[s - 1] = '\345';                 // fill first/last
                area[malloc_usable_size( area ) - 1] = '\345';  // fill ultimate byte
                free( area );
        } // for

        for ( i; NoOfMmaps ) {
                size_t s = i + default_mmap_start();                    // cross over point
                locns[i] = (char *)calloc( 1, s );
                if ( locns[i][0] != '\0' || locns[i][s - 1] != '\0' ||
                         locns[i][malloc_size( locns[i] ) - 1] != '\0' ||
                         ! malloc_zero_fill( locns[i] ) ) abort( "calloc/free corrupt storage5" );
                locns[i][0] = '\345'; locns[i][s - 1] = '\345'; // fill first/last
                locns[i][malloc_usable_size( locns[i] ) - 1] = '\345'; // fill ultimate byte
        } // for
        for ( i; NoOfMmaps ) {
                size_t s = i + default_mmap_start();                    // cross over point
                if ( locns[i][0] != '\345' || locns[i][s - 1] != '\345' ||
                         locns[i][malloc_usable_size( locns[i] ) - 1] != '\345' ) abort( "calloc/free corrupt storage6" );
                free( locns[i] );
        } // for

        // check memalign/free (sbrk)

        for ( a; libAlign() ~= limit ~ a ) {                            // generate powers of 2
                //sout | alignments[a];
                for ( s; 1 ~ NoOfAllocs ) {                                             // allocation of size 0 can return null
                        char * area = (char *)memalign( a, s );
                        //sout | i | area;
                        if ( (size_t)area % a != 0 || malloc_alignment( area ) != a ) { // check for initial alignment
                                abort( "memalign/free bad alignment : memalign(%d,%d) = %p", (int)a, s, area );
                        } // if
                        area[0] = '\345'; area[s - 1] = '\345';         // fill first/last byte
                        area[malloc_usable_size( area ) - 1] = '\345'; // fill ultimate byte
                        free( area );
                } // for
        } // for

        // check memalign/free (mmap)

        for ( a; libAlign() ~= limit ~ a ) {                            // generate powers of 2
                //sout | alignments[a];
                for ( i; 1 ~ NoOfMmaps ) {
                        size_t s = i + default_mmap_start();            // cross over point
                        char * area = (char *)memalign( a, s );
                        //sout | i | area;
                        if ( (size_t)area % a != 0 || malloc_alignment( area ) != a ) { // check for initial alignment
                                abort( "memalign/free bad alignment : memalign(%d,%d) = %p", (int)a, (int)s, area );
                        } // if
                        area[0] = '\345'; area[s - 1] = '\345';         // fill first/last byte
                        area[malloc_usable_size( area ) - 1] = '\345'; // fill ultimate byte
                        free( area );
                } // for
        } // for

        // check malloc/resize/free (sbrk)

        for ( i; 2 ~ NoOfAllocs ~ 12 ) {
                // initial N byte allocation
                char * area = (char *)malloc( i );
                area[0] = '\345'; area[i - 1] = '\345';                 // fill first/penultimate byte

                // Do not start this loop index at 0 because resize of 0 bytes frees the storage.
                int prev = i;
                for ( s; i ~ 256 * 1024 ~ 26 ) {                                // start at initial memory request
                        if ( area[0] != '\345' || area[prev - 1] != '\345' ) abort( "malloc/resize/free corrupt storage" );
                        area = (char *)resize( area, s );                       // attempt to reuse storage
                        area[0] = area[s - 1] = '\345';                         // fill last byte
                        prev = s;
                } // for
                free( area );
        } // for

        // check malloc/resize/free (mmap)

        for ( i; 2 ~ NoOfAllocs ~ 12 ) {
                // initial N byte allocation
                size_t s = i + default_mmap_start();                    // cross over point
                char * area = (char *)malloc( s );
                area[0] = '\345'; area[s - 1] = '\345';                 // fill first/penultimate byte

                // Do not start this loop index at 0 because resize of 0 bytes frees the storage.
                int prev = s;
                for ( r; s ~ 256 * 1024 ~ 26 ) {                                // start at initial memory request
                        if ( area[0] != '\345' || area[prev - 1] != '\345' ) abort( "malloc/resize/free corrupt storage" );
                        area = (char *)resize( area, s );                       // attempt to reuse storage
                        area[0] = area[r - 1] = '\345';                         // fill last byte
                        prev = r;
                } // for
                free( area );
        } // for

        // check malloc/realloc/free (sbrk)

        for ( i; 2 ~ NoOfAllocs ~ 12 ) {
                // initial N byte allocation
                char * area = (char *)malloc( i );
                area[0] = '\345'; area[i - 1] = '\345';                 // fill first/penultimate byte

                // Do not start this loop index at 0 because realloc of 0 bytes frees the storage.
                int prev = i;
                for ( s; i ~ 256 * 1024 ~ 26 ) {                                // start at initial memory request
                        if ( area[0] != '\345' || area[prev - 1] != '\345' ) abort( "malloc/realloc/free corrupt storage" );
                        area = (char *)realloc( area, s );                      // attempt to reuse storage
                        area[s - 1] = '\345';                                           // fill last byte
                        prev = s;
                } // for
                free( area );
        } // for

        // check malloc/realloc/free (mmap)

        for ( i; 2 ~ NoOfAllocs ~ 12 ) {
                // initial N byte allocation
                size_t s = i + default_mmap_start();                    // cross over point
                char * area = (char *)malloc( s );
                area[0] = '\345'; area[s - 1] = '\345';                 // fill first/penultimate byte

                // Do not start this loop index at 0 because realloc of 0 bytes frees the storage.
                int prev = s;
                for ( r; s ~ 256 * 1024 ~ 26 ) {                                // start at initial memory request
                        if ( area[0] != '\345' || area[prev - 1] != '\345' ) abort( "malloc/realloc/free corrupt storage" );
                        area = (char *)realloc( area, s );                      // attempt to reuse storage
                        area[r - 1] = '\345';                                           // fill last byte
                        prev = r;
                } // for
                free( area );
        } // for

        // check calloc/realloc/free (sbrk)

        for ( i; 1 ~ 10_000 ~ 12 ) {
                // initial N byte allocation
                char * area = (char *)calloc( 5, i );
                if ( area[0] != '\0' || area[i - 1] != '\0' ||
                         area[malloc_size( area ) - 1] != '\0' ||
                         ! malloc_zero_fill( area ) ) abort( "calloc/realloc/free corrupt storage1" );

                // Do not start this loop index at 0 because realloc of 0 bytes frees the storage.
                for ( s; i ~ 256 * 1024 ~ 26 ) {                                // start at initial memory request
                        area = (char *)realloc( area, s );                      // attempt to reuse storage
                        if ( area[0] != '\0' || area[s - 1] != '\0' ||
                                 area[malloc_size( area ) - 1] != '\0' ||
                                 ! malloc_zero_fill( area ) ) abort( "calloc/realloc/free corrupt storage2" );
                } // for
                free( area );
        } // for

        // check calloc/realloc/free (mmap)

        for ( i; 1 ~ 10_000 ~ 12 ) {
                // initial N byte allocation
                size_t s = i + default_mmap_start();                    // cross over point
                char * area = (char *)calloc( 1, s );
                if ( area[0] != '\0' || area[s - 1] != '\0' ||
                         area[malloc_size( area ) - 1] != '\0' ||
                         ! malloc_zero_fill( area ) ) abort( "calloc/realloc/free corrupt storage3" );

                // Do not start this loop index at 0 because realloc of 0 bytes frees the storage.
                for ( r; i ~ 256 * 1024 ~ 26 ) {                                // start at initial memory request
                        area = (char *)realloc( area, r );                      // attempt to reuse storage
                        if ( area[0] != '\0' || area[r - 1] != '\0' ||
                                 area[malloc_size( area ) - 1] != '\0' ||
                                 ! malloc_zero_fill( area ) ) abort( "calloc/realloc/free corrupt storage4" );
                } // for
                free( area );
        } // for

        // check memalign/realloc/free

        amount = 2;
        for ( a; libAlign() ~= limit ~ a ) {                            // generate powers of 2
                // initial N byte allocation
                char * area = (char *)memalign( a, amount );    // aligned N-byte allocation
                //sout | alignments[a] | area;
                if ( (size_t)area % a != 0 || malloc_alignment( area ) != a ) { // check for initial alignment
                        abort( "memalign/realloc/free bad alignment : memalign(%d,%d) = %p", (int)a, (int)amount, area );
                } // if
                area[0] = '\345'; area[amount - 2] = '\345';    // fill first/penultimate byte

                // Do not start this loop index at 0 because realloc of 0 bytes frees the storage.
                for ( s; amount ~ 256 * 1024 ) {                                // start at initial memory request
                        if ( area[0] != '\345' || area[s - 2] != '\345' ) abort( "memalign/realloc/free corrupt storage" );
                        area = (char *)realloc( area, s );                      // attempt to reuse storage
                        //sout | i | area;
                        if ( (size_t)area % a != 0 ) {                          // check for initial alignment
                                abort( "memalign/realloc/free bad alignment %p", area );
                        } // if
                        area[s - 1] = '\345';                                           // fill last byte
                } // for
                free( area );
        } // for

        // check cmemalign/free

        for ( a; libAlign() ~= limit ~ a ) {                            // generate powers of 2
                //sout | alignments[a];
                for ( s; 1 ~ limit ) {                                                  // allocation of size 0 can return null
                        char * area = (char *)cmemalign( a, 1, s );
                        //sout | i | area;
                        if ( (size_t)area % a != 0 || malloc_alignment( area ) != a ) { // check for initial alignment
                                abort( "cmemalign/free bad alignment : cmemalign(%d,%d) = %p", (int)a, s, area );
                        } // if
                        if ( area[0] != '\0' || area[s - 1] != '\0' ||
                                 area[malloc_size( area ) - 1] != '\0' ||
                                 ! malloc_zero_fill( area ) ) abort( "cmemalign/free corrupt storage" );
                        area[0] = '\345'; area[s - 1] = '\345';         // fill first/last byte
                        free( area );
                } // for
        } // for

        // check cmemalign/realloc/free

        amount = 2;
        for ( a; libAlign() ~= limit ~ a ) {                            // generate powers of 2
                // initial N byte allocation
                char * area = (char *)cmemalign( a, 1, amount ); // aligned N-byte allocation
                //sout | alignments[a] | area;
                if ( (size_t)area % a != 0 || malloc_alignment( area ) != a ) { // check for initial alignment
                        abort( "cmemalign/realloc/free bad alignment : cmemalign(%d,%d) = %p", (int)a, (int)amount, area );
                } // if
                if ( area[0] != '\0' || area[amount - 1] != '\0' ||
                         area[malloc_size( area ) - 1] != '\0' ||
                         ! malloc_zero_fill( area ) ) abort( "cmemalign/realloc/free corrupt storage1" );
                area[0] = '\345'; area[amount - 2] = '\345';    // fill first/penultimate byte

                // Do not start this loop index at 0 because realloc of 0 bytes frees the storage.
                for ( s; amount ~ 256 * 1024 ) {                                // start at initial memory request
                        if ( area[0] != '\345' || area[s - 2] != '\345' ) abort( "cmemalign/realloc/free corrupt storage2" );
                        area = (char *)realloc( area, s );                      // attempt to reuse storage
                        //sout | i | area;
                        if ( (size_t)area % a != 0 || malloc_alignment( area ) != a ) { // check for initial alignment
                                abort( "cmemalign/realloc/free bad alignment %p", area );
                        } // if
                        if ( area[0] != '\345' || area[s - 1] != '\0' ||
                                 area[malloc_size( area ) - 1] != '\0' ||
                                 ! malloc_zero_fill( area ) ) abort( "cmemalign/realloc/free corrupt storage3" );
                        area[s - 1] = '\345';                                           // fill last byte
                } // for
                free( area );
        } // for

        // check memalign/resize with align/free

        amount = 2;
        for ( a; libAlign() ~= limit ~ a ) {                            // generate powers of 2
                // initial N byte allocation
                char * area = (char *)memalign( a, amount );    // aligned N-byte allocation
                //sout | alignments[a] | area | endl;
                if ( (size_t)area % a != 0 || malloc_alignment( area ) != a ) { // check for initial alignment
                        abort( "memalign/resize with align/free bad alignment : memalign(%d,%d) = %p", (int)a, (int)amount, area );
                } // if
                area[0] = '\345'; area[amount - 2] = '\345';    // fill first/penultimate byte

                // Do not start this loop index at 0 because resize of 0 bytes frees the storage.
                for ( s; amount ~ 256 * 1024 ) {                                // start at initial memory request
                        area = (char *)resize( area, a * 2, s );        // attempt to reuse storage
                        //sout | i | area | endl;
                        if ( (size_t)area % a * 2 != 0 ) {                      // check for initial alignment
                                abort( "memalign/resize with align/free bad alignment %p", area );
                        } // if
                        area[s - 1] = '\345';                                           // fill last byte
                } // for
                free( area );
        } // for

        // check memalign/realloc with align/free

        amount = 2;
        for ( a; libAlign() ~= limit ~ a ) {                            // generate powers of 2
                // initial N byte allocation
                char * area = (char *)memalign( a, amount );    // aligned N-byte allocation
                //sout | alignments[a] | area | endl;
                if ( (size_t)area % a != 0 || malloc_alignment( area ) != a ) { // check for initial alignment
                        abort( "memalign/realloc with align/free bad alignment : memalign(%d,%d) = %p", (int)a, (int)amount, area );
                } // if
                area[0] = '\345'; area[amount - 2] = '\345';    // fill first/penultimate byte

                // Do not start this loop index at 0 because realloc of 0 bytes frees the storage.
                for ( s; amount ~ 256 * 1024 ) {                                // start at initial memory request
                        if ( area[0] != '\345' || area[s - 2] != '\345' ) abort( "memalign/realloc/free corrupt storage" );
                        area = (char *)realloc( area, a * 2, s );       // attempt to reuse storage
                        //sout | i | area | endl;
                        if ( (size_t)area % a * 2 != 0 ) {                      // check for initial alignment
                                abort( "memalign/realloc with align/free bad alignment %p", area );
                        } // if
                        area[s - 1] = '\345';                                           // fill last byte
                } // for
                free( area );
        } // for

        // check cmemalign/realloc with align/free

        amount = 2;
        for ( size_t a = libAlign() + libAlign(); a <= limit; a += a ) { // generate powers of 2
                // initial N byte allocation
                char * area = (char *)cmemalign( a, 1, amount ); // aligned N-byte allocation
                //sout | alignments[a] | area | endl;
                if ( (size_t)area % a != 0 || malloc_alignment( area ) != a ) { // check for initial alignment
                        abort( "cmemalign/realloc with align/free bad alignment : cmemalign(%d,%d) = %p", (int)a, (int)amount, area );
                } // if
                if ( area[0] != '\0' || area[amount - 1] != '\0' ||
                         area[malloc_size( area ) - 1] != '\0' ||
                         ! malloc_zero_fill( area ) ) abort( "cmemalign/realloc with align/free corrupt storage1" );
                area[0] = '\345'; area[amount - 2] = '\345';    // fill first/penultimate byte

                // Do not start this loop index at 0 because realloc of 0 bytes frees the storage.
                for ( int s = amount; s < 256 * 1024; s += 1 ) { // start at initial memory request
                        if ( area[0] != '\345' || area[s - 2] != '\345' ) abort( "cmemalign/realloc with align/free corrupt storage2" );
                        area = (char *)realloc( area, a * 2, s );       // attempt to reuse storage
                        //sout | i | area | endl;
                        if ( (size_t)area % a * 2 != 0 || malloc_alignment( area ) != a * 2 ) { // check for initial alignment
                                abort( "cmemalign/realloc with align/free bad alignment %p %zd %zd", area, malloc_alignment( area ), a * 2 );
                        } // if
                        if ( area[s - 1] != '\0' || area[s - 1] != '\0' ||
                                 area[malloc_size( area ) - 1] != '\0' ||
                                 ! malloc_zero_fill( area ) ) abort( "cmemalign/realloc/free corrupt storage3" );
                        area[s - 1] = '\345';                                           // fill last byte
                } // for
                free( area );
        } // for

        //sout | "worker" | thisTask() | "successful completion";
} // Worker main

int main() {
        const unsigned int NoOfWorkers = 4;
        {
                processor processors[NoOfWorkers - 1] __attribute__(( unused )); // more than one processor
                Worker workers[NoOfWorkers] __attribute__(( unused ));
        }
        // checkFreeOn();
        // malloc_stats();
        printf( "done\n" );                                                                     // non-empty .expect file
}

// Local Variables: //
// tab-width: 4 //
// compile-command: "cfa -nodebug -O2 heap.cfa" //
// End: //