Loading plugins/youtube/youtube.cpp +6 −10 Original line number Diff line number Diff line Loading @@ -125,7 +125,8 @@ namespace blogi { void SyncYoutube(const int tid,int channel_id,libhtmlpp::HtmlString &out){ std::string json; libhttppp::HttpResponse res; size_t hsize=0,cpos; size_t hsize=0; int cpos=0; bool chunked=false; dbpp::SQL sql; dbpp::DBResult dbres; Loading Loading @@ -163,7 +164,7 @@ namespace blogi { std::shared_ptr<char[]> data(new char[16384], std::default_delete<char[]>()); int recv,tries=0,chunklen=0; int recv,chunklen=0; try{ for(;;){ Loading Loading @@ -203,15 +204,12 @@ namespace blogi { json.resize(rlen); } tries=0; if(!chunked){ do{ try{ json.append(data.get()+cpos,recv); rlen-=recv; if(rlen>0){ tries=0; for(;;){ cpos=0; for(;;){ Loading @@ -235,7 +233,7 @@ namespace blogi { }while(rlen>0); }else{ size_t readed=0; int readed=0; for(;;){ if(recv - cpos > 0){ Loading @@ -247,7 +245,7 @@ namespace blogi { readed=0; } size_t len = (chunklen - readed) < (recv - cpos) ? (chunklen - readed) : (recv - cpos); int len = (chunklen - readed) < (recv - cpos) ? (chunklen - readed) : (recv - cpos); json.append(data.get()+cpos,len); cpos+=len; Loading Loading @@ -289,7 +287,6 @@ namespace blogi { } try{ enum json_type type = json_object_get_type(youindex); struct json_object *ytems; ytems = json_object_object_get(youindex,"items"); int fcount = json_object_array_length(ytems); Loading @@ -298,7 +295,6 @@ namespace blogi { Args->database[tid]->exec(sql,dbres); for(int i =0; i<fcount; ++i) { int ii=0; json_object_object_foreach(json_object_array_get_idx(ytems,i), key, val) { if(strcmp(key,"id")==0 && val){ struct json_object *yid; Loading Loading @@ -408,7 +404,7 @@ namespace blogi { return true; } private: int readchunk(const char *data,size_t datasize,size_t &pos){ int readchunk(const char *data,int datasize,int &pos){ int start=pos; char value[512]; Loading Loading
plugins/youtube/youtube.cpp +6 −10 Original line number Diff line number Diff line Loading @@ -125,7 +125,8 @@ namespace blogi { void SyncYoutube(const int tid,int channel_id,libhtmlpp::HtmlString &out){ std::string json; libhttppp::HttpResponse res; size_t hsize=0,cpos; size_t hsize=0; int cpos=0; bool chunked=false; dbpp::SQL sql; dbpp::DBResult dbres; Loading Loading @@ -163,7 +164,7 @@ namespace blogi { std::shared_ptr<char[]> data(new char[16384], std::default_delete<char[]>()); int recv,tries=0,chunklen=0; int recv,chunklen=0; try{ for(;;){ Loading Loading @@ -203,15 +204,12 @@ namespace blogi { json.resize(rlen); } tries=0; if(!chunked){ do{ try{ json.append(data.get()+cpos,recv); rlen-=recv; if(rlen>0){ tries=0; for(;;){ cpos=0; for(;;){ Loading @@ -235,7 +233,7 @@ namespace blogi { }while(rlen>0); }else{ size_t readed=0; int readed=0; for(;;){ if(recv - cpos > 0){ Loading @@ -247,7 +245,7 @@ namespace blogi { readed=0; } size_t len = (chunklen - readed) < (recv - cpos) ? (chunklen - readed) : (recv - cpos); int len = (chunklen - readed) < (recv - cpos) ? (chunklen - readed) : (recv - cpos); json.append(data.get()+cpos,len); cpos+=len; Loading Loading @@ -289,7 +287,6 @@ namespace blogi { } try{ enum json_type type = json_object_get_type(youindex); struct json_object *ytems; ytems = json_object_object_get(youindex,"items"); int fcount = json_object_array_length(ytems); Loading @@ -298,7 +295,6 @@ namespace blogi { Args->database[tid]->exec(sql,dbres); for(int i =0; i<fcount; ++i) { int ii=0; json_object_object_foreach(json_object_array_get_idx(ytems,i), key, val) { if(strcmp(key,"id")==0 && val){ struct json_object *yid; Loading Loading @@ -408,7 +404,7 @@ namespace blogi { return true; } private: int readchunk(const char *data,size_t datasize,size_t &pos){ int readchunk(const char *data,int datasize,int &pos){ int start=pos; char value[512]; Loading