“Mongodb 源码阅读笔记”的版本间的差异
来自Dennis的知识库
Dennis zhuang(讨论 | 贡献) (以“ == 网络层 == * 具体实现在 src/mongo/util/net 目录下: <pre> ├── abstract_message_port.h ├── asio_message_port.cpp ├── asio_message_por...”为内容创建页面) |
Dennis zhuang(讨论 | 贡献) (→网络层) |
||
第47行: | 第47行: | ||
</pre> | </pre> | ||
− | * 针对上层提供的服务接口定义在 src/mongo/transport 下,核心就是 transport_layer 和 | + | * 针对上层提供的服务接口定义在 src/mongo/transport 下,核心就是 transport_layer , transport_layer_legacy 和 service_entry_point,具体的关系是 TransportLayer 持有一个 acceptor ,当连接进来,包装成 session,然后调用ServiceEntryPoint.startSession 方法,进入一个读取请求-处理请求-应答请求的循环。 这里可能为了兼容老的代码,transport_layer_legacy 实现了 TransportLayer,并兼容老的代码。 ServiceEntryPoint 的子类 ServiceEntryPointImpl 里实现了 startSession 和 _sessionLoop 框架,每个连接启动一个线程处理: |
+ | |||
+ | <pre> | ||
+ | //service_entry_point_impl.cpp | ||
+ | void ServiceEntryPointImpl::startSession(transport::SessionHandle session) { | ||
+ | // Pass ownership of the transport::SessionHandle into our worker thread. When this | ||
+ | // thread exits, the session will end. | ||
+ | launchWrappedServiceEntryWorkerThread( | ||
+ | std::move(session), [this](const transport::SessionHandle& session) { | ||
+ | _nWorkers.fetchAndAdd(1); | ||
+ | auto guard = MakeGuard([&] { _nWorkers.fetchAndSubtract(1); }); | ||
+ | |||
+ | _sessionLoop(session); | ||
+ | }); | ||
+ | } | ||
+ | |||
+ | void ServiceEntryPointImpl::_sessionLoop(const transport::SessionHandle& session) { | ||
+ | Message inMessage; | ||
+ | bool inExhaust = false; | ||
+ | int64_t counter = 0; | ||
+ | |||
+ | while (true) { | ||
+ | ... | ||
+ | } | ||
+ | } | ||
+ | </pre> |
2017年5月24日 (三) 07:23的版本
网络层
- 具体实现在 src/mongo/util/net 目录下:
├── abstract_message_port.h ├── asio_message_port.cpp ├── asio_message_port.h ├── asio_ssl_context.cpp ├── asio_ssl_context.h ├── hostandport.cpp ├── hostandport.h ├── hostandport_test.cpp ├── hostname_canonicalization.cpp ├── hostname_canonicalization.h ├── listen.cpp ├── listen.h ├── message.cpp ├── message.h ├── message_port.cpp ├── message_port.h ├── message_port_mock.cpp ├── message_port_mock.h ├── message_port_startup_param.cpp ├── message_port_startup_param.h ├── op_msg.cpp ├── op_msg.h ├── sock.cpp ├── sock.h ├── sock_test.cpp ├── sockaddr.cpp ├── sockaddr.h ├── socket_exception.cpp ├── socket_exception.h ├── socket_poll.cpp ├── socket_poll.h ├── ssl_expiration.cpp ├── ssl_expiration.h ├── ssl_manager.cpp ├── ssl_manager.h ├── ssl_options.cpp ├── ssl_options.h ├── ssl_types.h ├── thread_idle_callback.cpp └── thread_idle_callback.h
- 针对上层提供的服务接口定义在 src/mongo/transport 下,核心就是 transport_layer , transport_layer_legacy 和 service_entry_point,具体的关系是 TransportLayer 持有一个 acceptor ,当连接进来,包装成 session,然后调用ServiceEntryPoint.startSession 方法,进入一个读取请求-处理请求-应答请求的循环。 这里可能为了兼容老的代码,transport_layer_legacy 实现了 TransportLayer,并兼容老的代码。 ServiceEntryPoint 的子类 ServiceEntryPointImpl 里实现了 startSession 和 _sessionLoop 框架,每个连接启动一个线程处理:
//service_entry_point_impl.cpp void ServiceEntryPointImpl::startSession(transport::SessionHandle session) { // Pass ownership of the transport::SessionHandle into our worker thread. When this // thread exits, the session will end. launchWrappedServiceEntryWorkerThread( std::move(session), [this](const transport::SessionHandle& session) { _nWorkers.fetchAndAdd(1); auto guard = MakeGuard([&] { _nWorkers.fetchAndSubtract(1); }); _sessionLoop(session); }); } void ServiceEntryPointImpl::_sessionLoop(const transport::SessionHandle& session) { Message inMessage; bool inExhaust = false; int64_t counter = 0; while (true) { ... } }