Проект распределённой нелинейной нейросети для энтузиастов

 /* 
 * 
 * soma 2. 0. 0
 * 
 * Компиляция
 * %d - путь к исходнику
 * %f - имя исходника
 * %e - имя объектного фалйла
 * libsoma.so - имя результата компиляции библиотеки
 * 
 * gcc -fPIC -c "%f"
 * gcc -shared -o "%d/lib%e.so" "%d/%e.o"
 * 
 * gcc "%d/%e.o" -L. -o -lfstdin "%d/lib%e.so"
 *
 * 
 */
 
unsigned char soma_version = 303; 
 
#include <stdio.h>
#include <stdlib.h>
#include <limits.h>
 
typedef char ( *callback )  ( char ) ;
 
struct neuron
{
    char weight;
    unsigned short comp;
    unsigned char  cell;
    unsigned short out;
};
 
struct input_data
{
    FILE *fp;
    char *input;
    callback function_pointer;
}data_pointer;
 
//65536*256 структур считывать 100 с лишним мегабайт.
struct n
 
char network_work ( struct input_data data_pointer ) 
{
    int i, n, real;
    struct neuron *neuron_table;
    
    while ( !feof ( data_pointer.fp )  ) 
    {
        if (  ( real = fread ( &neuron_table, sizeof ( struct neuron ) , USHRT_MAX * CHAR_MAX, data_pointer.fp )  )  > 0 ) 
        {
            fseek ( data_pointer.fp, - ( USHRT_MAX * CHAR_MAX ) , SEEK_CUR ) ;
            fwrite ( &neuron_table, sizeof ( struct neuron ) , real, data_pointer.fp ) ;
            free ( neuron_table ) ;
        }
        else
            return -1;
    }
 
    data_pointer.function_pointer ( 0 ) ;
    
    return 0;
}
 
/*
 * Один компьютер с индексом, один файл базы данных около 200-250 МБ,
 *  256 ячеек по 65536 нейронов
 */
FILE *open_neuron_file ( char *fname, char state ) 
{
    struct neuron new_neuron;
    FILE *fp;
    unsigned short i;
    
    if ( state == 0 ) 
    {
        if ( ( fp = fopen ( fname, "w" ) ) != NULL )
        {
            fclose(fp);
        
            if ( ( fp = fopen ( fname, "ab+" ) ) != NULL ) ;
            {
                for ( i = 0; i < USHRT_MAX; i++ ) 
                    fwrite ( &new_neuron, sizeof ( struct neuron ) , UCHAR_MAX, fp ) ;
            }
        }
    }
    else if ( state == 1 )
        fp = fopen ( fname, "ab+" ) ;
        
    return fp;
}

 /* 
 * 
 * soma 0. 0. 0
 * 
 * 
 * gcc -fPIC -c "%f"
 * gcc -shared -o "%d/lib%e.so" "%d/%e.o"
 * 
 * gcc "%d/%e.o" -L. -o -lfstdin "%d/lib%e.so"
 *
 *  
 */
 
#include <stdio.h>
#include <stdlib.h>
 
unsigned char SomaVersion = 100;
 
struct st
{
    unsigned char in;
    unsigned short index;
    unsigned char weigh;
    unsigned char out;
}*table;
 
typedef char (*callback)(unsigned char);
 
struct Data
{
    FILE *fp;
    unsigned char in;
    unsigned short index;
    callback pFUNC;
}pData;
 
 
 
 
 
 
int SomaStart(struct Data pData)
{
    int size = 40000000; // 200 Mb
    int real, i;
    struct st tableA[2];
    
    while ((table = realloc(table, size * sizeof(struct st))) == NULL && 
            size > 2000000)
    {
        size = size - 2000000; // -10 Mb
    }
    if (table != NULL)
    {
        char stimul = 0;
        
        while (!feof(pData.fp))
        {
            if ((real = fread(&table, sizeof(struct st), size, pData.fp)) > 0)
            {
                for (i = 0; i < real; i++)
                {
                    if (table[i + 1].weigh > table[i].weigh)
                    {
                        tableA[2] = table[i];
                        table[i] = table[i + 1];
                        table[i + 1] = tableA[2];   
                    }
                    
 
                    
                    if (stimul == 1)
                        break;
                }
                fseek(pData.fp, -real, SEEK_CUR);
                fwrite(&table, sizeof(struct st), real, pData.fp);
                
            }
            else
                return -1;
        }
                
        if (stimul == 0)
        {
            tableA[0].in = pData.in;
            tableA[0].index = pData.index;
            fseek(pData.fp, 0, SEEK_END);
            
            stimul = pData.pFUNC(tableA[0].out);
            if ( stimul == 1)
            {
                    if (tableA[0].weigh < 255)
                        tableA[0].weigh = table[0].weigh + 1;   
            }
            else if (stimul == -1)
                tableA[0].out = tableA[0].out + 1;
                
            fwrite(&tableA[0], sizeof(struct st), 1, pData.fp); 
        }
        fseek(pData.fp, 3, SEEK_SET);
    }
    
    free(table);
 
return 0;
}
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
struct fType
{
char S; 
char F; 
unsigned char version;
};
 
FILE *COMemFile(char *fname)
{
    FILE *fp;
    struct fType FT = {'S','F', 100};
 
    if ((fp = fopen(fname, "rb+")) == NULL)
    {
        if ((fp = fopen(fname, "wb")) == NULL)
            return NULL;
        else if ((fwrite(&FT, sizeof(struct fType), 1, fp)) > 0)
        {
            fclose(fp);
                if ((fp = fopen(fname, "rb+")) == NULL)
                    return NULL;
        }
        else
        {
            fclose(fp);
            return NULL;
        }
    }
    else
        fread(&FT, sizeof(struct fType), 1, fp);
            if (FT.S != 'S' || FT.F != 'F' || FT.version != SomaVersion)
            {
                fclose(fp);
                return NULL;
            }
return fp;
}