stream.h

Go to the documentation of this file.

#ifndef STREAM_H
#define STREAM_H

#include <stdint.h>
#include <stdio.h>
#include <pbl.h>
#include <ev.h>

#include "modules/cque.h"

typedef struct ksnStreamMapData {
    
    int created;        
    int pipe_in[2];     
    ev_io w_in;         
    int pipe_out[2];    
    ev_io w_out;        
    void *ke;           
    void *key;          
    size_t key_len;     
    ksnCQueData *cq;    
    
} ksnStreamMapData;

typedef struct ksnStreamData {
    
    const char *stream_name;
    const char *peer_name;   
    int fd_in;
    int fd_out;
    
} ksnStreamData;

enum stream_cmd {
    
    CMD_ST_NONE,
    CMD_ST_CREATE,          
    CMD_ST_CREATE_GOT,      
    CMD_ST_CREATED,         
    CMD_ST_DATA,            
    CMD_ST_CLOSE,           
    CMD_ST_CLOSE_GOT,       
    CMD_ST_CLOSE_NOTREMOVE  
};

struct stream_packet {
    
    uint8_t cmd;        
    uint16_t data_len;  
    uint8_t stream_name_len; 
    char data[];        
};

typedef struct ksnStreamClass {
    
    void *ke;           
    PblMap* map;        
    
} ksnStreamClass;

#ifdef  __cplusplus
extern "C" {
#endif

ksnStreamClass *ksnStreamInit(void *ke);
void ksnStreamDestroy(ksnStreamClass *ks);
int ksnStreamCreate(ksnStreamClass *ks, char *to_peer, char *stream_name, 
        int send_f);
int ksnStreamClose(ksnStreamClass *ks, char *to_peer, char *stream_name, 
        int send_f);
int ksnStreamClosePeer(ksnStreamClass *ks, const char *peer_name);
ksnStreamData *ksnStreamGetDataFromMap(ksnStreamData *sd, ksnStreamMapData *smd);
ksnStreamMapData *ksnStreamGetMapData(ksnStreamClass *ks, void *key, size_t key_len);
/*
 * Get output stream FD
 * 
 * @param ks Pointer to ksnStreamClass
 * @param key Key buffer
 * @param key_len Key buffer length
 * 
 * @return Output stream FD
 */
//#define ksnStreamGetOutFd(ks, key, key_len) ksnStreamGetMapData(ks, key, key_len)->pipe_out[1]
/*
 * Get input stream FD
 * 
 * @param ks Pointer to ksnStreamClass
 * @param key Key buffer
 * @param key_len Key buffer length
 * 
 * @return Output stream FD
 */
//#define ksnStreamGetInFd(ks, key, key_len) ksnStreamGetData(ks, key, key_len)->pipe_in[0]
//#define ksnStreamGetInFd(sd) sd->pipe_in[0]

#ifdef  __cplusplus
}
#endif

#endif  /* STREAM_H */