当前位置：首页 > news >正文

杭州做网站的公司温州seo网站推广

news 2025/7/8 20:35:23

杭州做网站的公司,温州seo网站推广,四平网络推广公司,和一卡通一样做巡更的网站有哪些寻求帮助由于自己第一次读开源代码，所以完全没有方法，所以第一步是疯狂Google brpc学习最佳实践如何阅读源代码最终找到一篇比较好的文章如何阅读一份源代码？ 制定计划目前自己的大计划是一年能够改写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;}
}