池州网站制作优化,招聘网站怎么做介绍,wordpress mysql口令,万网 wordpress寻求帮助
由于自己第一次读开源代码#xff0c;所以完全没有方法#xff0c;所以第一步是疯狂Google
brpc学习最佳实践
如何阅读源代码
最终找到一篇比较好的文章 如何阅读一份源代码#xff1f;
制定计划
目前自己的大计划是一年能够改写brpc
所以小计划是当前一个月…寻求帮助
由于自己第一次读开源代码所以完全没有方法所以第一步是疯狂Google
brpc学习最佳实践
如何阅读源代码
最终找到一篇比较好的文章 如何阅读一份源代码
制定计划
目前自己的大计划是一年能够改写brpc
所以小计划是当前一个月先搞清楚brpc的基本框架了解基本结构
制定以上计划的原因如下
自己第一次读大型开源项目这个brpc涉及的知识点较多工程庞大而且十分经典实用所以应该深入学习
第一周实践
阅读技巧 https://www.codedump.info/post/20200605-how-to-read-code-v2020/
然后跟着brpc学习 慢慢来的 2020年09月28日16:33:07 发现其中AutoReset类是第一个简单易懂的类___继续加油
IOBuf
声明在iobuf.h,然后实现在iobuf_inl.h 和 iobuf.cpp 中
cntn问题__TODO
size_t IOBuf::cutn(std::string* out, size_t n) {if (n 0) {return 0;}const size_t len length();if (n len) {n len;}const size_t old_size out-size();out-resize(out-size() n);return cutn((*out)[old_size], n);
}这个cntn在if (n len)处的操作有点迷惑因为凭空就把n缩小了
cut_until理解
brpc之iobuf中说道: cut_until从前到后开始cut直到遇到字符匹配到delim如果没有匹配到返回-1; 需要注意的地方时这个地方delim字符串的长度不能超过unsiged long的长度因为brpc中将字符串hash到一个unsigned long型的整数然后遍历匹配的时候也将IOBuf中的字符串hash到一个unsigned long类型的整数与delim进行比较这个地方比较精巧的是hash的时候使用位移操作向左移后面的字符串会把前面的字符串冲掉因此复杂度从 O(N*M) 降到O(N)其中N为block中字符串的长度M为delim的长度
我一开始不懂后面想到其实可能是因为这个hash只能对字符一直加和但是不能取模因为取模就会导致类似hash碰撞的事情所以就不一定是真的字符匹配了(我猜的)
append_from_file_descriptor 读fd___ 有点精妙
看一下实现代码主要做了三件事
循环block准备好readv函数的参数地址将block的可写首地址和可写长度依次获取放入到iovec的数组中 调用pread函数将读取到的内容写入到上面准备的地址获取读取的总长度nr 整理现有的block因为现有的Block可能很多写满了。
ssize_t IOPortal::pappend_from_file_descriptor(int fd, off_t offset, size_t max_count) {iovec vec[MAX_APPEND_IOVEC];int nvec 0;size_t space 0;Block* prev_p NULL;Block* p _block;// Prepare at most MAX_APPEND_IOVEC blocks or space of blocks max_countdo {if (p NULL) {p iobuf::acquire_tls_block();if (BAIDU_UNLIKELY(!p)) {errno ENOMEM;return -1;}if (prev_p ! NULL) {prev_p-portal_next p;} else {_block p;}}vec[nvec].iov_base p-data p-size;vec[nvec].iov_len std::min(p-left_space(), max_count - space);space vec[nvec].iov_len;nvec;if (space max_count || nvec MAX_APPEND_IOVEC) {break;}prev_p p;p p-portal_next;} while (1);ssize_t nr 0;if (offset 0) {nr readv(fd, vec, nvec);} else {static iobuf::iov_function preadv_func iobuf::get_preadv_func();nr preadv_func(fd, vec, nvec, offset);}if (nr 0) { // -1 or 0if (empty()) {return_cached_blocks();}return nr;}size_t total_len nr;do {const size_t len std::min(total_len, _block-left_space());total_len - len;const IOBuf::BlockRef r { _block-size, (uint32_t)len, _block };_push_back_ref(r);_block-size len;if (_block-full()) {Block* const saved_next _block-portal_next;_block-dec_ref(); // _block may be deleted_block saved_next;}} while (total_len);return nr;
}inline ssize_t IOPortal::append_from_file_descriptor(int fd, size_t max_count) {return pappend_from_file_descriptor(fd, -1, max_count);
}Containers
flatmap
hash
有趣的[]源码
template typename _K, typename _T, typename _H, typename _E, bool _S
_T FlatMap_K, _T, _H, _E, _S::operator[](const key_type key) {const size_t index flatmap_mod(_hashfn(key), _nbucket);Bucket first_node _buckets[index];if (!first_node.is_valid()) {_size;if (_S) {bit_array_set(_thumbnail, index);}new (first_node) Bucket(key);return first_node.element().second_ref();}if (_eql(first_node.element().first_ref(), key)) {return first_node.element().second_ref();}Bucket *p first_node.next;if (NULL p) {if (is_too_crowded(_size)) {if (resize(_nbucket 1)) {return operator[](key);}// fail to resize is OK}_size;Bucket* newp new (_pool.get()) Bucket(key);first_node.next newp;return newp-element().second_ref();}while (1) {if (_eql(p-element().first_ref(), key)) {return p-element().second_ref();}if (NULL p-next) {if (is_too_crowded(_size)) {if (resize(_nbucket 1)) {return operator[](key);}// fail to resize is OK}_size;Bucket* newp new (_pool.get()) Bucket(key);p-next newp;return newp-element().second_ref();}p p-next;}
}
TODO_code_双缓冲数据 DoublyBufferedData
2020年10月01日19:22:10 今天花了一段时间看完了官方参考资料https://github.com/apache/incubator-brpc/blob/master/docs/cn/lalb.md
感觉很有计算含量所以明天继续看一下代码___2020年10月02日19:01:46 决定暂时宏观层面先学习所以这个细致代码暂缓
protobuf
client
https://github.com/apache/incubator-brpc/blob/master/docs/cn/client.md
TODO未懂含义_c_murmurhash or c_md5
TODO
默认是IOBuf是small view只有在两个refs种都存储了不同的的Block之后才自动转为BigView可以参考iobuf.cpp:601行____这里没有看懂2020年09月29日20:54:48
