@@ -25,15 +25,9 @@ typedef struct client_data_t {
2525parser_t parser ;
2626}client_data_t ;
2727
28- static client_data_t * create_client_data (int id ) {
29- client_data_t * cd = malloc (sizeof (client_data_t ));
30- cd -> id = id ;
31- cd -> parser = parser_create ();
32- return cd ;
33- }
34-
3528clog_t clg ;
3629static bool queue_for_transaction_finish (void * stream ,void * clientdata ,int node ,xid_t xid ,char cmd );
30+ static client_data_t * create_client_data (int id );
3731static void free_client_data (client_data_t * cd );
3832static void onconnect (void * stream ,void * * clientdata );
3933static void ondisconnect (void * stream ,void * clientdata );
@@ -55,6 +49,13 @@ static void usage(char *prog);
5549#define CLIENT_ID (X ) (((client_data_t*)(X))->id)
5650#define CLIENT_PARSER (X ) (((client_data_t*)(X))->parser)
5751
52+ static client_data_t * create_client_data (int id ) {
53+ client_data_t * cd = malloc (sizeof (client_data_t ));
54+ cd -> id = id ;
55+ cd -> parser = parser_create ();
56+ return cd ;
57+ }
58+
5859static void free_client_data (client_data_t * cd ) {
5960parser_destroy (cd -> parser );
6061free (cd );