@@ -30,14 +30,14 @@ static char errbuf[1024];
30
30
31
31
typedef struct {
32
32
char key ; /* item letter character */
33
- item_func * func ; /* its extraction function */
33
+ item_func * extractor_func ; /* its extraction function */
34
34
const char * arg ; /* one string argument for func */
35
35
const char * field_name ; /* GELF extra field name */
36
36
} log_item ;
37
37
38
38
typedef struct {
39
- apr_socket_t * s ; /* Actual GELF connection */
40
- apr_sockaddr_t * sa ; /* GELF Address */
39
+ apr_socket_t * gelf_sock ; /* Actual GELF connection */
40
+ apr_sockaddr_t * gelf_addr ; /* GELF Address */
41
41
} gelf_connection ;
42
42
43
43
typedef struct {
@@ -95,7 +95,7 @@ void log_gelf_register_item(server_rec *server, apr_pool_t *p,
95
95
96
96
item = apr_array_push (log_item_list );
97
97
item -> key = key ;
98
- item -> func = func ;
98
+ item -> extractor_func = func ;
99
99
item -> field_name = field_name ;
100
100
if (arg )
101
101
item -> arg = arg ;
@@ -248,29 +248,29 @@ static apr_status_t log_gelf_get_gelf_connection(gelf_connection *gc, gelf_confi
248
248
"mod_log_gelf: Connecting to server: %s" , config -> server );
249
249
}
250
250
251
- rv = apr_sockaddr_info_get (& gc -> sa , config -> server , APR_INET , config -> port , 0 , pool );
251
+ rv = apr_sockaddr_info_get (& gc -> gelf_addr , config -> server , APR_INET , config -> port , 0 , pool );
252
252
if (rv != APR_SUCCESS ) {
253
253
ap_log_perror (APLOG_MARK , APLOG_ERR , 0 , pool ,
254
254
"mod_log_gelf: Error setting GELF recipient %s:%d" , config -> server , config -> port );
255
255
return rv ;
256
256
}
257
257
258
- rv = apr_socket_create (& gc -> s , gc -> sa -> family , type , proto , pool );
258
+ rv = apr_socket_create (& gc -> gelf_sock , gc -> gelf_addr -> family , type , proto , pool );
259
259
if (rv != APR_SUCCESS ) {
260
260
ap_log_perror (APLOG_MARK , APLOG_ERR , 0 , pool ,
261
261
"mod_log_gelf: Error opening GELF socket: %s" , apr_strerror (rv , errbuf , sizeof (errbuf )));
262
262
return rv ;
263
263
}
264
264
265
- rv = apr_socket_connect (gc -> s , gc -> sa );
265
+ rv = apr_socket_connect (gc -> gelf_sock , gc -> gelf_addr );
266
266
if (rv != APR_SUCCESS ) {
267
267
ap_log_perror (APLOG_MARK , APLOG_ERR , 0 , pool ,
268
268
"mod_log_gelf: Error connecting to GELF port: %s" , apr_strerror (rv , errbuf , sizeof (errbuf )));
269
269
return rv ;
270
270
}
271
271
272
272
/* set socket options */
273
- rv = apr_socket_opt_set (gc -> s , APR_SO_SNDBUF , SEND_BUFFER );
273
+ rv = apr_socket_opt_set (gc -> gelf_sock , APR_SO_SNDBUF , SEND_BUFFER );
274
274
if (rv != APR_SUCCESS ) {
275
275
ap_log_perror (APLOG_MARK , APLOG_ERR , 0 , pool ,
276
276
"mod_log_gelf: Error setting send buffer: %s" , apr_strerror (rv , errbuf , sizeof (errbuf )));
@@ -279,21 +279,21 @@ static apr_status_t log_gelf_get_gelf_connection(gelf_connection *gc, gelf_confi
279
279
280
280
if (config -> protocol == TCP ) {
281
281
/* TCP socket options */
282
- rv = apr_socket_opt_set (gc -> s , APR_SO_NONBLOCK , 0 );
282
+ rv = apr_socket_opt_set (gc -> gelf_sock , APR_SO_NONBLOCK , 0 );
283
283
if (rv != APR_SUCCESS ) {
284
284
ap_log_perror (APLOG_MARK , APLOG_ERR , 0 , pool ,
285
285
"mod_log_gelf: Error setting socket to blocking: %s" , apr_strerror (rv , errbuf , sizeof (errbuf )));
286
286
return rv ;
287
287
}
288
288
289
- rv = apr_socket_opt_set (gc -> s , APR_TCP_NODELAY , 1 );
289
+ rv = apr_socket_opt_set (gc -> gelf_sock , APR_TCP_NODELAY , 1 );
290
290
if (rv != APR_SUCCESS ) {
291
291
ap_log_perror (APLOG_MARK , APLOG_ERR , 0 , pool ,
292
292
"mod_log_gelf: Error setting socket TCP nodelay: %s" , apr_strerror (rv , errbuf , sizeof (errbuf )));
293
293
return rv ;
294
294
}
295
295
296
- rv = apr_socket_timeout_set (gc -> s , 0 );
296
+ rv = apr_socket_timeout_set (gc -> gelf_sock , 0 );
297
297
if (rv != APR_SUCCESS ) {
298
298
ap_log_perror (APLOG_MARK , APLOG_ERR , 0 , pool ,
299
299
"mod_log_gelf: Error setting socket timeout: %s" , apr_strerror (rv , errbuf , sizeof (errbuf )));
@@ -340,7 +340,7 @@ static apr_status_t gelf_pool_destruct(void* resource, void* params, apr_pool_t*
340
340
ap_log_perror (APLOG_MARK , APLOG_CRIT , 0 , pool , "mod_log_gelf: Removing socket from pool" );
341
341
}
342
342
gelf_connection * con = (gelf_connection * )resource ;
343
- apr_socket_close (con -> s );
343
+ apr_socket_close (con -> gelf_sock );
344
344
}
345
345
return APR_SUCCESS ;
346
346
}
@@ -469,7 +469,7 @@ char * log_gelf_make_json(request_rec *request) {
469
469
log_item * item = config -> parsed_fields [i ];
470
470
json_object * fval ;
471
471
if (item != NULL ) {
472
- fval = item -> func (request , (char * )item -> arg );
472
+ fval = item -> extractor_func (request , (char * )item -> arg );
473
473
if (fval != NULL ) {
474
474
json_object_object_add (object , item -> field_name , fval );
475
475
}
@@ -580,7 +580,7 @@ void log_gelf_send_message_udp(const transferData* payload, request_rec *request
580
580
"mod_log_gelf: Sending GELF message: %s" , (char * )payload -> data );
581
581
}
582
582
583
- rv = apr_socket_send (con -> s , payload -> data , & len );
583
+ rv = apr_socket_send (con -> gelf_sock , payload -> data , & len );
584
584
if (rv != APR_SUCCESS ) {
585
585
log_error (APLOG_MARK , APLOG_ERR , 0 , request -> server ,
586
586
"mod_log_gelf: Error writing to socket %d bytes. Error %s" ,
@@ -609,7 +609,7 @@ void log_gelf_send_message_tcp(const transferData* payload, request_rec *request
609
609
610
610
/* acquire a free socket, send message, release socket */
611
611
gelf_connection * con = log_gelf_connection_acquire (request );
612
- if (!con || !con -> s ) {
612
+ if (!con || !con -> gelf_sock ) {
613
613
return ;
614
614
}
615
615
@@ -618,7 +618,7 @@ void log_gelf_send_message_tcp(const transferData* payload, request_rec *request
618
618
"mod_log_gelf: Sending GELF message: %s" , gelf_payload );
619
619
}
620
620
621
- rv = apr_socket_send (con -> s , gelf_payload , & len );
621
+ rv = apr_socket_send (con -> gelf_sock , gelf_payload , & len );
622
622
if (rv != APR_SUCCESS ) {
623
623
log_error (APLOG_MARK , APLOG_ERR , 0 , request -> server ,
624
624
"mod_log_gelf: Error writing to socket %d bytes. Error %s" ,
0 commit comments