2626
2727#include "logdna.h"
2828
29+ #define LOGDNA_META_KEY "meta"
30+ #define LOGDNA_LEVEL_KEY "level"
31+ #define LOGDNA_SEVERITY_KEY "severity"
32+ #define LOGDNA_FILE_KEY "file"
33+ #define LOGDNA_APP_KEY "app"
34+
2935static inline int primary_key_check (msgpack_object k , char * name , int len )
3036{
3137 if (k .type != MSGPACK_OBJECT_STR ) {
@@ -74,11 +80,11 @@ static int record_append_primary_keys(struct flb_logdna *ctx,
7480 if (line_pck ) {
7581 for (i = 0 ; i < map -> via .map .size ; i ++ ) {
7682 k = map -> via .map .ptr [i ].key ;
77- if (primary_key_check (k , "meta" , 4 ) == FLB_TRUE ||
78- primary_key_check (k , "level" , 5 ) == FLB_TRUE ||
79- primary_key_check (k , "severity" , 8 ) == FLB_TRUE ||
80- primary_key_check (k , "file" , 4 ) == FLB_TRUE ||
81- primary_key_check (k , "app" , 3 ) == FLB_TRUE ) {
83+ if (primary_key_check (k , LOGDNA_META_KEY , sizeof ( LOGDNA_META_KEY ) - 1 ) == FLB_TRUE ||
84+ primary_key_check (k , LOGDNA_LEVEL_KEY , sizeof ( LOGDNA_LEVEL_KEY ) - 1 ) == FLB_TRUE ||
85+ primary_key_check (k , LOGDNA_SEVERITY_KEY , sizeof ( LOGDNA_SEVERITY_KEY ) - 1 ) == FLB_TRUE ||
86+ primary_key_check (k , LOGDNA_FILE_KEY , sizeof ( LOGDNA_FILE_KEY ) - 1 ) == FLB_TRUE ||
87+ primary_key_check (k , LOGDNA_APP_KEY , sizeof ( LOGDNA_APP_KEY ) - 1 ) == FLB_TRUE ) {
8288 continue ;
8389 }
8490 line_count ++ ;
@@ -93,41 +99,41 @@ static int record_append_primary_keys(struct flb_logdna *ctx,
9399
94100 /* Level - optional */
95101 if (!level &&
96- (primary_key_check (k , "level" , 5 ) == FLB_TRUE ||
97- primary_key_check (k , "severity" , 8 ) == FLB_TRUE )) {
102+ (primary_key_check (k , LOGDNA_LEVEL_KEY , sizeof ( LOGDNA_LEVEL_KEY ) - 1 ) == FLB_TRUE ||
103+ primary_key_check (k , LOGDNA_SEVERITY_KEY , sizeof ( LOGDNA_SEVERITY_KEY ) - 1 ) == FLB_TRUE )) {
98104 level = & k ;
99- msgpack_pack_str (mp_sbuf , 5 );
100- msgpack_pack_str_body (mp_sbuf , "level" , 5 );
105+ msgpack_pack_str (mp_sbuf , sizeof ( LOGDNA_LEVEL_KEY ) - 1 );
106+ msgpack_pack_str_body (mp_sbuf , LOGDNA_LEVEL_KEY , sizeof ( LOGDNA_LEVEL_KEY ) - 1 );
101107 msgpack_pack_object (mp_sbuf , v );
102108 c ++ ;
103109 is_primary = FLB_TRUE ;
104110 }
105111
106112 /* Meta - optional */
107- if (!meta && primary_key_check (k , "meta" , 4 ) == FLB_TRUE ) {
113+ if (!meta && primary_key_check (k , LOGDNA_META_KEY , sizeof ( LOGDNA_META_KEY ) - 1 ) == FLB_TRUE ) {
108114 meta = & k ;
109- msgpack_pack_str (mp_sbuf , 4 );
110- msgpack_pack_str_body (mp_sbuf , "meta" , 4 );
115+ msgpack_pack_str (mp_sbuf , sizeof ( LOGDNA_META_KEY ) - 1 );
116+ msgpack_pack_str_body (mp_sbuf , LOGDNA_META_KEY , sizeof ( LOGDNA_META_KEY ) - 1 );
111117 msgpack_pack_object (mp_sbuf , v );
112118 c ++ ;
113119 is_primary = FLB_TRUE ;
114120 }
115121
116122 /* File */
117- if (!file && primary_key_check (k , "file" , 4 ) == FLB_TRUE ) {
123+ if (!file && primary_key_check (k , LOGDNA_FILE_KEY , sizeof ( LOGDNA_FILE_KEY ) - 1 ) == FLB_TRUE ) {
118124 file = & k ;
119- msgpack_pack_str (mp_sbuf , 4 );
120- msgpack_pack_str_body (mp_sbuf , "file" , 4 );
125+ msgpack_pack_str (mp_sbuf , sizeof ( LOGDNA_FILE_KEY ) - 1 );
126+ msgpack_pack_str_body (mp_sbuf , LOGDNA_FILE_KEY , sizeof ( LOGDNA_FILE_KEY ) - 1 );
121127 msgpack_pack_object (mp_sbuf , v );
122128 c ++ ;
123129 is_primary = FLB_TRUE ;
124130 }
125131
126132 /* App */
127- if (!app && primary_key_check (k , "app" , 3 ) == FLB_TRUE ) {
133+ if (!app && primary_key_check (k , LOGDNA_APP_KEY , sizeof ( LOGDNA_APP_KEY ) - 1 ) == FLB_TRUE ) {
128134 app = & k ;
129- msgpack_pack_str (mp_sbuf , 3 );
130- msgpack_pack_str_body (mp_sbuf , "app" , 3 );
135+ msgpack_pack_str (mp_sbuf , sizeof ( LOGDNA_APP_KEY ) - 1 );
136+ msgpack_pack_str_body (mp_sbuf , LOGDNA_APP_KEY , sizeof ( LOGDNA_APP_KEY ) - 1 );
131137 msgpack_pack_object (mp_sbuf , v );
132138 c ++ ;
133139 is_primary = FLB_TRUE ;
@@ -141,17 +147,17 @@ static int record_append_primary_keys(struct flb_logdna *ctx,
141147
142148 /* Set the global file name if the record did not provided one */
143149 if (!file && ctx -> file ) {
144- msgpack_pack_str (mp_sbuf , 4 );
145- msgpack_pack_str_body (mp_sbuf , "file" , 4 );
150+ msgpack_pack_str (mp_sbuf , sizeof ( LOGDNA_FILE_KEY ) - 1 );
151+ msgpack_pack_str_body (mp_sbuf , LOGDNA_FILE_KEY , sizeof ( LOGDNA_FILE_KEY ) - 1 );
146152 msgpack_pack_str (mp_sbuf , flb_sds_len (ctx -> file ));
147153 msgpack_pack_str_body (mp_sbuf , ctx -> file , flb_sds_len (ctx -> file ));
148154 c ++ ;
149155 }
150156
151157 /* If no application name is set, set the default */
152158 if (!app ) {
153- msgpack_pack_str (mp_sbuf , 3 );
154- msgpack_pack_str_body (mp_sbuf , "app" , 3 );
159+ msgpack_pack_str (mp_sbuf , sizeof ( LOGDNA_APP_KEY ) - 1 );
160+ msgpack_pack_str_body (mp_sbuf , LOGDNA_APP_KEY , sizeof ( LOGDNA_APP_KEY ) - 1 );
155161 msgpack_pack_str (mp_sbuf , flb_sds_len (ctx -> app ));
156162 msgpack_pack_str_body (mp_sbuf , ctx -> app , flb_sds_len (ctx -> app ));
157163 c ++ ;
0 commit comments