mirror of https://github.com/aria2/aria2
commit
8f5eaa4bbb
|
@ -115,7 +115,7 @@ public:
|
||||||
void findAll(OutputIterator out, const std::string& hostname,
|
void findAll(OutputIterator out, const std::string& hostname,
|
||||||
uint16_t port) const
|
uint16_t port) const
|
||||||
{
|
{
|
||||||
std::shared_ptr<CacheEntry> target(new CacheEntry(hostname, port));
|
auto target = std::make_shared<CacheEntry>(hostname, port);
|
||||||
auto i = entries_.find(target);
|
auto i = entries_.find(target);
|
||||||
if (i != entries_.end()) {
|
if (i != entries_.end()) {
|
||||||
(*i)->getAllGoodAddrs(out);
|
(*i)->getAllGoodAddrs(out);
|
||||||
|
|
|
@ -49,13 +49,11 @@ struct HttpRequestConnectChain : public ControlChain<ConnectCommand*> {
|
||||||
virtual ~HttpRequestConnectChain() {}
|
virtual ~HttpRequestConnectChain() {}
|
||||||
virtual int run(ConnectCommand* t, DownloadEngine* e) CXX11_OVERRIDE
|
virtual int run(ConnectCommand* t, DownloadEngine* e) CXX11_OVERRIDE
|
||||||
{
|
{
|
||||||
std::shared_ptr<SocketRecvBuffer> socketRecvBuffer(
|
auto b = std::make_shared<SocketRecvBuffer>(t->getSocket());
|
||||||
new SocketRecvBuffer(t->getSocket()));
|
auto k = std::make_shared<HttpConnection>(t->getCuid(), t->getSocket(), b);
|
||||||
std::shared_ptr<HttpConnection> httpConnection(
|
|
||||||
new HttpConnection(t->getCuid(), t->getSocket(), socketRecvBuffer));
|
|
||||||
auto c = make_unique<HttpRequestCommand>(
|
auto c = make_unique<HttpRequestCommand>(
|
||||||
t->getCuid(), t->getRequest(), t->getFileEntry(), t->getRequestGroup(),
|
t->getCuid(), t->getRequest(), t->getFileEntry(), t->getRequestGroup(),
|
||||||
httpConnection, e, t->getSocket());
|
k, e, t->getSocket());
|
||||||
c->setProxyRequest(t->getProxyRequest());
|
c->setProxyRequest(t->getProxyRequest());
|
||||||
c->setStatus(Command::STATUS_ONESHOT_REALTIME);
|
c->setStatus(Command::STATUS_ONESHOT_REALTIME);
|
||||||
e->setNoWait(true);
|
e->setNoWait(true);
|
||||||
|
|
|
@ -168,7 +168,7 @@ int translateEvents(EventPoll::EventType events)
|
||||||
|
|
||||||
bool PortEventPoll::addEvents(sock_t socket, const PortEventPoll::KEvent& event)
|
bool PortEventPoll::addEvents(sock_t socket, const PortEventPoll::KEvent& event)
|
||||||
{
|
{
|
||||||
std::shared_ptr<KSocketEntry> socketEntry(new KSocketEntry(socket));
|
auto socketEntry = std::make_shared<KSocketEntry>(socket);
|
||||||
KSocketEntrySet::iterator i = socketEntries_.lower_bound(socketEntry);
|
KSocketEntrySet::iterator i = socketEntries_.lower_bound(socketEntry);
|
||||||
int r = 0;
|
int r = 0;
|
||||||
int errNum = 0;
|
int errNum = 0;
|
||||||
|
@ -220,7 +220,7 @@ bool PortEventPoll::addEvents(sock_t socket, Command* command, int events,
|
||||||
bool PortEventPoll::deleteEvents(sock_t socket,
|
bool PortEventPoll::deleteEvents(sock_t socket,
|
||||||
const PortEventPoll::KEvent& event)
|
const PortEventPoll::KEvent& event)
|
||||||
{
|
{
|
||||||
std::shared_ptr<KSocketEntry> socketEntry(new KSocketEntry(socket));
|
auto socketEntry = std::make_shared<KSocketEntry>(socket);
|
||||||
KSocketEntrySet::iterator i = socketEntries_.find(socketEntry);
|
KSocketEntrySet::iterator i = socketEntries_.find(socketEntry);
|
||||||
if (i == socketEntries_.end()) {
|
if (i == socketEntries_.end()) {
|
||||||
A2_LOG_DEBUG(fmt("Socket %d is not found in SocketEntries.", socket));
|
A2_LOG_DEBUG(fmt("Socket %d is not found in SocketEntries.", socket));
|
||||||
|
@ -271,8 +271,7 @@ bool PortEventPoll::deleteEvents(sock_t socket, Command* command,
|
||||||
bool PortEventPoll::addNameResolver(
|
bool PortEventPoll::addNameResolver(
|
||||||
const std::shared_ptr<AsyncNameResolver>& resolver, Command* command)
|
const std::shared_ptr<AsyncNameResolver>& resolver, Command* command)
|
||||||
{
|
{
|
||||||
std::shared_ptr<KAsyncNameResolverEntry> entry(
|
auto entry = std::make_shared<KAsyncNameResolverEntry>(resolver, command);
|
||||||
new KAsyncNameResolverEntry(resolver, command));
|
|
||||||
KAsyncNameResolverEntrySet::iterator itr = nameResolverEntries_.find(entry);
|
KAsyncNameResolverEntrySet::iterator itr = nameResolverEntries_.find(entry);
|
||||||
if (itr == nameResolverEntries_.end()) {
|
if (itr == nameResolverEntries_.end()) {
|
||||||
nameResolverEntries_.insert(entry);
|
nameResolverEntries_.insert(entry);
|
||||||
|
@ -287,8 +286,7 @@ bool PortEventPoll::addNameResolver(
|
||||||
bool PortEventPoll::deleteNameResolver(
|
bool PortEventPoll::deleteNameResolver(
|
||||||
const std::shared_ptr<AsyncNameResolver>& resolver, Command* command)
|
const std::shared_ptr<AsyncNameResolver>& resolver, Command* command)
|
||||||
{
|
{
|
||||||
std::shared_ptr<KAsyncNameResolverEntry> entry(
|
auto entry = std::make_shared<KAsyncNameResolverEntry>(resolver, command);
|
||||||
new KAsyncNameResolverEntry(resolver, command));
|
|
||||||
KAsyncNameResolverEntrySet::iterator itr = nameResolverEntries_.find(entry);
|
KAsyncNameResolverEntrySet::iterator itr = nameResolverEntries_.find(entry);
|
||||||
if (itr == nameResolverEntries_.end()) {
|
if (itr == nameResolverEntries_.end()) {
|
||||||
return false;
|
return false;
|
||||||
|
|
|
@ -55,8 +55,8 @@ WebSocketResponseCommand::~WebSocketResponseCommand() = default;
|
||||||
void WebSocketResponseCommand::afterSend(
|
void WebSocketResponseCommand::afterSend(
|
||||||
const std::shared_ptr<HttpServer>& httpServer, DownloadEngine* e)
|
const std::shared_ptr<HttpServer>& httpServer, DownloadEngine* e)
|
||||||
{
|
{
|
||||||
std::shared_ptr<WebSocketSession> wsSession(
|
auto wsSession = std::make_shared<WebSocketSession>(
|
||||||
new WebSocketSession(httpServer->getSocket(), getDownloadEngine()));
|
httpServer->getSocket(), getDownloadEngine());
|
||||||
auto command = make_unique<WebSocketInteractionCommand>(
|
auto command = make_unique<WebSocketInteractionCommand>(
|
||||||
getCuid(), wsSession, e, wsSession->getSocket());
|
getCuid(), wsSession, e, wsSession->getSocket());
|
||||||
wsSession->setCommand(command.get());
|
wsSession->setCommand(command.get());
|
||||||
|
|
Loading…
Reference in New Issue