add vs 2017 project

Author: danielshaving

src/redis/redis.sln

@@ -0,0 +1,31 @@
+
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio 15
+VisualStudioVersion = 15.0.27703.2035
+MinimumVisualStudioVersion = 10.0.40219.1
+Project("{8BC9CEB8-8B4A-11D0-8D11-00A0C91BC942}") = "redis", "redis\redis.vcxproj", "{80D62D1F-BDEC-446E-BC7C-D17268B3457F}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|x64 = Debug|x64
+		Debug|x86 = Debug|x86
+		Release|x64 = Release|x64
+		Release|x86 = Release|x86
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{80D62D1F-BDEC-446E-BC7C-D17268B3457F}.Debug|x64.ActiveCfg = Debug|x64
+		{80D62D1F-BDEC-446E-BC7C-D17268B3457F}.Debug|x64.Build.0 = Debug|x64
+		{80D62D1F-BDEC-446E-BC7C-D17268B3457F}.Debug|x86.ActiveCfg = Debug|Win32
+		{80D62D1F-BDEC-446E-BC7C-D17268B3457F}.Debug|x86.Build.0 = Debug|Win32
+		{80D62D1F-BDEC-446E-BC7C-D17268B3457F}.Release|x64.ActiveCfg = Release|x64
+		{80D62D1F-BDEC-446E-BC7C-D17268B3457F}.Release|x64.Build.0 = Release|x64
+		{80D62D1F-BDEC-446E-BC7C-D17268B3457F}.Release|x86.ActiveCfg = Release|Win32
+		{80D62D1F-BDEC-446E-BC7C-D17268B3457F}.Release|x86.Build.0 = Release|Win32
+	EndGlobalSection
+	GlobalSection(SolutionProperties) = preSolution
+		HideSolutionNode = FALSE
+	EndGlobalSection
+	GlobalSection(ExtensibilityGlobals) = postSolution
+		SolutionGuid = {34BAA9D4-2C26-4368-A0F4-571B8A73277D}
+	EndGlobalSection
+EndGlobal

src/redis/redis/acceptor.cc

@@ -0,0 +1,61 @@
+#include "acceptor.h"
+#include "log.h"
+
+Acceptor::Acceptor(EventLoop *loop, const char *ip, int16_t port)
+	:loop(loop),
+	channel(loop, Socket::createTcpSocket(ip, port)),
+	sockfd(channel.getfd()),
+#ifndef _WIN32
+	idleFd(::open("/dev/null", O_RDONLY | O_CLOEXEC)),
+#endif
+	listenning(false)
+{
+#ifndef _WIN32
+	assert(idleFd >= 0);
+#endif
+	channel.setReadCallback(std::bind(&Acceptor::handleRead, this));
+}
+
+Acceptor::~Acceptor()
+{
+	channel.disableAll();
+	channel.remove();
+	Socket::close(sockfd);
+}
+
+void Acceptor::handleRead()
+{
+	loop->assertInLoopThread();
+	struct sockaddr_in6 address;
+	socklen_t len = sizeof(address);
+#ifdef __linux__
+	int32_t connfd = ::accept4(sockfd, (struct sockaddr*)&address,
+		&len, SOCK_NONBLOCK | SOCK_CLOEXEC);
+#else
+	int32_t connfd = ::accept(sockfd, (struct sockaddr*)&address, &len);
+#endif
+
+	if (connfd >= 0)
+	{
+		if (newConnectionCallback)
+		{
+			socket.setSocketNonBlock(connfd);
+			newConnectionCallback(connfd);
+		}
+		else
+		{
+			Socket::close(sockfd);
+		}
+	}
+	else
+	{
+
+	}
+}
+
+void Acceptor::listen()
+{
+	loop->assertInLoopThread();
+	listenning = true;
+	channel.enableReading();
+}

src/redis/redis/acceptor.h

@@ -0,0 +1,39 @@
+#pragma once
+#include "all.h"
+#include "channel.h"
+#include "eventloop.h"
+#include "socket.h"
+
+class Acceptor
+{
+public:
+	typedef std::function<void(int32_t)> NewConnectionCallback;
+	Acceptor(EventLoop *loop, const char *ip, int16_t port);
+	~Acceptor();
+
+	void setNewConnectionCallback(const NewConnectionCallback &&cb)
+	{
+		newConnectionCallback = std::move(cb);
+	}
+
+	bool getlistenning() const
+	{
+		return listenning;
+	}
+
+	void listen();
+	void handleRead();
+
+private:
+	Acceptor(const Acceptor&);
+	void operator=(const Acceptor&);
+
+	EventLoop *loop;
+	Socket socket;
+	Channel channel;
+	int32_t sockfd;
+
+	NewConnectionCallback newConnectionCallback;
+	bool listenning;
+	bool idleFd;
+};