Skip to content

Commit 6f8b166

Browse files
committed
Cosmetic
1 parent 7f1aaf1 commit 6f8b166

File tree

2 files changed

+1
-21
lines changed

2 files changed

+1
-21
lines changed

c_src/jstream.c

Lines changed: 0 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -7,9 +7,6 @@
77
#include "erl_nif.h"
88
#include "jsonx_str.h"
99

10-
#include <stdio.h>
11-
#define LOG(...) fprintf(stderr, __VA_ARGS__ )
12-
1310
typedef struct{
1411
ERL_NIF_TERM am_true;
1512
ERL_NIF_TERM am_false;
@@ -203,7 +200,6 @@ parse_null(State* st){
203200

204201
static inline ERL_NIF_TERM
205202
parse_key(State *st){
206-
//LOG("...parse key: %s\r\n", st->cur);
207203
ERL_NIF_TERM key;
208204
switch(look_ah(st)){
209205
case '\"' :
@@ -213,7 +209,6 @@ parse_key(State *st){
213209
if(look_ah(st) == ':'){
214210
st->m_state = KEY_COMPLETTE;
215211
st->cur++;
216-
//LOG("...parse key: %s\r\n", st->cur);
217212
return enif_make_tuple2(st->env, st->priv->am_map_key, key);
218213
}
219214
case '\0' :
@@ -255,11 +250,8 @@ ERL_NIF_TERM
255250
get_event_nif(ErlNifEnv* env, int argc, const ERL_NIF_TERM argv[]){
256251
State *st;
257252
assert(enif_get_resource(env, argv[0], stream_RSTYPE, (void**)&st));
258-
//LOG("=== top: %p,top: '%s', cur: '%s' m_state: == %d\r\n", st->top, st->top, st->cur, st->m_state);
259-
//LOG("*top %c\r\n", *st->top);
260253
switch(*st->top){
261254
case '[' :
262-
//LOG("case [ : top: %p,top: '%s', cur: '%s' m_state: == %d\r\n", st->top, st->top, st->cur, st->m_state);
263255
if(st->m_state == COMPLETTE){
264256
switch(look_ah(st)){
265257
case ',' : st->m_state = COMMA; st->cur++; return parse0(st);
@@ -277,21 +269,17 @@ get_event_nif(ErlNifEnv* env, int argc, const ERL_NIF_TERM argv[]){
277269
}
278270
break;
279271
case '{' :
280-
//LOG(" case { : top: %p,top: '%s', cur: '%s' m_state: == %d\r\n", st->top, st->top, st->cur, st->m_state);
281272
if(st->m_state == COMPLETTE){
282-
//LOG(" COMPLETTE case { : top: %p,top: '%s', cur: '%s' m_state: == %d\r\n", st->top, st->top, st->cur, st->m_state);
283273
switch(look_ah(st)){
284274
case ',' : st->m_state = COMMA; st->cur++; return parse_key(st);
285275
case '}' : st->m_state = COMPLETTE; st->cur++; st->top--; return st->priv->am_end_map;
286276
case '\0': st->cur++; return st->priv->am_parse_buf;
287277
}
288278
}else if(st->m_state == KEY_COMPLETTE){
289-
//LOG(" KEY_COMPLETTE case { : top: %p,top: '%s', cur: '%s' m_state: == %d\r\n", st->top, st->top, st->cur, st->m_state);
290279
return parse0(st);
291280
}else if(st->m_state == COMMA){
292281
return parse_key(st);
293282
}else if(st->m_state == START){
294-
//LOG(" START_MAP case { : top: %p,top: '%s', cur: '%s' m_state: == %d\r\n", st->top, st->top, st->cur, st->m_state);
295283
switch(look_ah(st)){
296284
case '\0': st->cur++; return st->priv->am_parse_buf;
297285
case '}' : st->m_state = COMPLETTE; st->cur++; st->top--; return st->priv->am_end_map;
@@ -300,7 +288,6 @@ get_event_nif(ErlNifEnv* env, int argc, const ERL_NIF_TERM argv[]){
300288
}
301289
break;
302290
case '\0':
303-
//LOG("case 0: top: %p,top: '%s', cur: '%s' m_state: == %d\r\n", st->top, st->top, st->cur, st->m_state);
304291
if(st->m_state == COMPLETTE){
305292
ERL_NIF_TERM rest;
306293
look_ah(st);
@@ -314,9 +301,7 @@ get_event_nif(ErlNifEnv* env, int argc, const ERL_NIF_TERM argv[]){
314301
}
315302
break;
316303
case 'e':
317-
//LOG(" case e: top: %p,top: '%s', cur: '%s' m_state: == %d\r\n", st->top, st->top, st->cur, st->m_state);
318304
default :
319-
//LOG("default: top: %p,top: '%s', cur: '%s' m_state: == %d\r\n", st->top, st->top, st->cur, st->m_state);
320305
break;
321306
}
322307
return make_error(st, st->priv->am_esyntax);
@@ -333,7 +318,6 @@ update_decoder_nif(ErlNifEnv* env, int argc, const ERL_NIF_TERM argv[]){
333318
size_t stack_size = (st->top + 1 - st->bin.data);
334319

335320
size_t free = st->bin.size - stack_size - sizeof(ERL_NIF_TERM);
336-
////LOG("--- update_decoder_nif: free: %d, input.size: %d, stack_size:%d cur: %s\r\n", free, input.size, stack_size, st->cur);
337321
if(input.size > free){
338322
enif_realloc_binary(&st->bin, input.size + stack_size + sizeof(ERL_NIF_TERM));
339323
st->top = st->bin.data + stack_size - 1;
@@ -345,7 +329,6 @@ update_decoder_nif(ErlNifEnv* env, int argc, const ERL_NIF_TERM argv[]){
345329
memcpy(st->cur, input.data, input.size);
346330
*((ERL_NIF_TERM*)(st->cur + input.size)) = 0U;
347331
}
348-
////LOG("+++ update_decoder_nif: free: %d, input.size: %d, stack_size:%d cur: %s\r\n", free, input.size, stack_size, st->cur);
349332
return st->priv->am_ok;
350333
}
351334

@@ -371,9 +354,6 @@ make_stream_resource_nif(ErlNifEnv* env, int argc, const ERL_NIF_TERM argv[]){
371354
ERL_NIF_TERM ret = enif_make_resource(env, (void *)st);
372355
enif_release_resource(st);
373356
return ret;
374-
// error:
375-
// enif_release_resource(dec_entry);
376-
// return enif_make_badarg(env);
377357
}
378358

379359
static ErlNifFunc

test/jstream_test.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -108,6 +108,6 @@ obj_chunks_test() ->
108108
parse_buf,end_map,parse_buf,end_array,end_map,{parse_end,<<>>}]
109109
= jstream_test:all_events_from_blist([<<"{\"key\":">>, <<"[1234567,2345,">>, <<"{">>,<<"}">>, <<"]}">>]).
110110

111-
obj_chunks_ERR_test() ->
111+
obj_chunks_err_test() ->
112112
[start_map,parse_buf,{map_key,<<"k1">>},parse_buf,true,parse_buf,{error,invalid_json}]
113113
= jstream_test:all_events_from_blist([<<"{">>,<<"\"k1\":">>, <<"true ,">>, <<",\"k2\":">>,<<"false">>,<<"}">>]).

0 commit comments

Comments
 (0)