env_universal_common.h

#ifndef FISH_ENV_UNIVERSAL_COMMON_H
#define FISH_ENV_UNIVERSAL_COMMON_H

#include <wchar.h>

#include "util.h"

#define SET_STR L"SET"

#define SET_EXPORT_STR L"SET_EXPORT"

#define ERASE_STR L"ERASE"

#define BARRIER_STR L"BARRIER"

#define BARRIER_REPLY_STR L"BARRIER_REPLY"


#define SOCK_FILENAME "fishd.socket."

enum
{
        SET,
        SET_EXPORT,
        ERASE,
        BARRIER,
        BARRIER_REPLY,
}
        ;

#define ENV_UNIVERSAL_BUFFER_SIZE 1024

typedef struct connection
{
        int fd;
        dyn_queue_t unsent;
        int killme;
        buffer_t input;
        
        char buffer[ENV_UNIVERSAL_BUFFER_SIZE];

        int buffer_consumed;
        
        int buffer_used;
        

        struct connection *next;
}
        connection_t;

typedef struct 
{
        int count;
        char body[1];
}
        message_t;

void read_message( connection_t * );

void try_send_all( connection_t *c );

message_t *create_message( int type, const wchar_t *key, const wchar_t *val );

void env_universal_common_init(void (*cb)(int type, const wchar_t *key, const wchar_t *val ) );

void env_universal_common_destroy();

void env_universal_common_get_names( array_list_t *l,
                                                                         int show_exported,
                                                                         int show_unexported );

void env_universal_common_set( const wchar_t *key, const wchar_t *val, int export );

void env_universal_common_remove( const wchar_t *key );

wchar_t *env_universal_common_get( const wchar_t *name );

int env_universal_common_get_export( const wchar_t *name );

void enqueue_all( connection_t *c );

void connection_init( connection_t *c, int fd );

void connection_destroy( connection_t *c);

#endif

---