syslog-ng source
stomp.c File Reference
#include "stomp.h"
#include "host-resolve.h"
#include "str-utils.h"
#include "messages.h"
#include <errno.h>
#include <stdlib.h>
#include <string.h>
#include <stdio.h>
#include <poll.h>
#include <unistd.h>
Include dependency graph for stomp.c:

Macros

#define STOMP_PARSE_HEADER   1
 
#define STOMP_PARSE_DATA   2
 
#define STOMP_PARSE_ERROR   0
 

Functions

void stomp_frame_init (stomp_frame *frame, const char *command, int command_len)
 
void stomp_frame_add_header (stomp_frame *frame, const char *name, const char *value)
 
void stomp_frame_add_header_len (stomp_frame *frame, const char *name, int name_len, const char *value, int value_len)
 
void stomp_frame_set_body (stomp_frame *frame, const char *body, int body_len)
 
int stomp_frame_deinit (stomp_frame *frame)
 
int stomp_connect (stomp_connection **connection_ref, char *hostname, int port)
 
int stomp_disconnect (stomp_connection **connection_ref)
 
int stomp_parse_frame (GString *data, stomp_frame *frame)
 
int stomp_receive_frame (stomp_connection *connection, stomp_frame *frame)
 
GString * create_gstring_from_frame (stomp_frame *frame)
 
int stomp_write (stomp_connection *connection, stomp_frame *frame)
 

Macro Definition Documentation

◆ STOMP_PARSE_DATA

#define STOMP_PARSE_DATA   2

◆ STOMP_PARSE_ERROR

#define STOMP_PARSE_ERROR   0

◆ STOMP_PARSE_HEADER

#define STOMP_PARSE_HEADER   1

Function Documentation

◆ create_gstring_from_frame()

GString* create_gstring_from_frame ( stomp_frame frame)

◆ stomp_connect()

int stomp_connect ( stomp_connection **  connection_ref,
char *  hostname,
int  port 
)

◆ stomp_disconnect()

int stomp_disconnect ( stomp_connection **  connection_ref)

◆ stomp_frame_add_header()

void stomp_frame_add_header ( stomp_frame frame,
const char *  name,
const char *  value 
)

◆ stomp_frame_add_header_len()

void stomp_frame_add_header_len ( stomp_frame frame,
const char *  name,
int  name_len,
const char *  value,
int  value_len 
)

◆ stomp_frame_deinit()

int stomp_frame_deinit ( stomp_frame frame)

◆ stomp_frame_init()

void stomp_frame_init ( stomp_frame frame,
const char *  command,
int  command_len 
)

◆ stomp_frame_set_body()

void stomp_frame_set_body ( stomp_frame frame,
const char *  body,
int  body_len 
)

◆ stomp_parse_frame()

int stomp_parse_frame ( GString *  data,
stomp_frame frame 
)

◆ stomp_receive_frame()

int stomp_receive_frame ( stomp_connection connection,
stomp_frame frame 
)

◆ stomp_write()

int stomp_write ( stomp_connection connection,
stomp_frame frame 
)