summaryrefslogtreecommitdiff
path: root/perf/src/Ice/raw/cpp/Server.cpp
diff options
context:
space:
mode:
authorBernard Normier <bernard@zeroc.com>2012-10-23 16:19:38 -0400
committerBernard Normier <bernard@zeroc.com>2012-10-23 16:19:38 -0400
commitada25bad3511a359eb28cf48f018d6a42e166f10 (patch)
tree430749f887a1c6f708c2d4a23b3e3ec4ef18ef2c /perf/src/Ice/raw/cpp/Server.cpp
parentRuby 1.8 fix (diff)
downloadice-ada25bad3511a359eb28cf48f018d6a42e166f10.tar.bz2
ice-ada25bad3511a359eb28cf48f018d6a42e166f10.tar.xz
ice-ada25bad3511a359eb28cf48f018d6a42e166f10.zip
Fixed ICE-4855: expand tabs to space (8) for .php, .cpp, .h, .java and .cs files
Diffstat (limited to 'perf/src/Ice/raw/cpp/Server.cpp')
-rw-r--r--perf/src/Ice/raw/cpp/Server.cpp258
1 files changed, 129 insertions, 129 deletions
diff --git a/perf/src/Ice/raw/cpp/Server.cpp b/perf/src/Ice/raw/cpp/Server.cpp
index 3fccab79d42..094cbab127a 100644
--- a/perf/src/Ice/raw/cpp/Server.cpp
+++ b/perf/src/Ice/raw/cpp/Server.cpp
@@ -89,7 +89,7 @@ const char closeConnectionMsg = 4;
// The request header, batch request header and reply header.
//
-const char magic[] = { 0x49, 0x63, 0x65, 0x50 }; // 'I', 'c', 'e', 'P'
+const char magic[] = { 0x49, 0x63, 0x65, 0x50 }; // 'I', 'c', 'e', 'P'
const char requestHdr[] =
{
@@ -189,7 +189,7 @@ readSize(char* base, int& offset)
int sz = base[offset++];
if(sz == 255)
{
- return getInt(base, offset);
+ return getInt(base, offset);
}
return sz;
}
@@ -199,14 +199,14 @@ rawcmp(char* src, int srcLen, char* dest, int offset, int len)
{
if(srcLen != len)
{
- return false;
+ return false;
}
for(int i = 0; i < len; ++i)
{
- if(src[i] != dest[i+offset])
- {
- return false;
- }
+ if(src[i] != dest[i+offset])
+ {
+ return false;
+ }
}
return true;
}
@@ -232,7 +232,7 @@ run(SOCKET fd)
if(::send(fd, header, sizeof(header), 0) != sizeof(header))
{
- return;
+ return;
}
char req[500042];
@@ -269,113 +269,113 @@ run(SOCKET fd)
//
while(true)
{
- int len = 0;
- while(len != sizeof(header))
- {
- int n = ::recv(fd, &header[len], sizeof(header) - len, 0);
- if(n <= 0)
- {
- return;
- }
- len += n;
- }
-
- assert(header[0] == Protocol::magic[0] && header[1] == Protocol::magic[1] &&
- header[2] == Protocol::magic[2] && header[3] == Protocol::magic[3]);
-
- offset = 4;
- char pMajor = header[offset++];
- assert(pMajor == Protocol::protocolMajor);
- //char pMinor = header[offset++];
- offset++;
-
- char eMajor = header[offset++];
- assert(eMajor == Protocol::encodingMajor);
- //char eMinor = header[offset++];
- offset++;
-
- char messageType = header[offset++];
- //char compress = header[offset++];
- offset++;
- int size = getInt(header, offset);
- //Console.WriteLine("size: " + size);
-
- if(messageType == Protocol::closeConnectionMsg)
- {
- return;
- }
- if(messageType != Protocol::requestMsg)
- {
- cerr << "unexpected message: " << messageType << endl;
- return;
- }
-
- size -= Protocol::headerSize;
- if(size < 0 || size > sizeof(req))
- {
- cerr << "booting client: unsupported size" << endl;
- return;
- }
- //assert(size <= req.Length);
-
- len = 0;
- while(len != size)
- {
- int n = ::recv(fd, &req[len], size - len, 0);
- if(n <= 0)
- {
- return;
- }
- //Console.WriteLine("read: " + n);
- len += n;
- }
-
- offset = 0;
- int requestId = getInt(req, offset);
-
- // id
- int sz = readSize(req, offset);
- offset += sz;
- sz = readSize(req, offset);
- offset += sz;
- assert(req[offset] == 0);
- ++offset; // facet
- // operation
- sz = readSize(req, offset);
-
- if(!rawcmp(opIceIsA, sizeof(opIceIsA)-1, req, offset, sz) &&
- !rawcmp(opIcePing, sizeof(opIcePing)-1, req, offset, sz) &&
- !rawcmp(opSendByteSeq, sizeof(opSendByteSeq)-1, req, offset, sz))
- {
- string op(&req[offset], sz);
- cerr << "unsupported op: " << op << endl;
- return;
- }
-
-
- char* r;
- int l;
- if(rawcmp(opIceIsA, sizeof(opIceIsA)-1, req, offset, sz))
- {
- r = isaReply;
- l = sizeof(isaReply);
- }
- else
- {
- r = reply;
- l = sizeof(reply);
- }
-
- //
- // Compose the reply.
- //
- offset = 14;
- putInt(r, offset, requestId);
-
- if(::send(fd, r, l, 0) != l)
- {
- return;
- }
+ int len = 0;
+ while(len != sizeof(header))
+ {
+ int n = ::recv(fd, &header[len], sizeof(header) - len, 0);
+ if(n <= 0)
+ {
+ return;
+ }
+ len += n;
+ }
+
+ assert(header[0] == Protocol::magic[0] && header[1] == Protocol::magic[1] &&
+ header[2] == Protocol::magic[2] && header[3] == Protocol::magic[3]);
+
+ offset = 4;
+ char pMajor = header[offset++];
+ assert(pMajor == Protocol::protocolMajor);
+ //char pMinor = header[offset++];
+ offset++;
+
+ char eMajor = header[offset++];
+ assert(eMajor == Protocol::encodingMajor);
+ //char eMinor = header[offset++];
+ offset++;
+
+ char messageType = header[offset++];
+ //char compress = header[offset++];
+ offset++;
+ int size = getInt(header, offset);
+ //Console.WriteLine("size: " + size);
+
+ if(messageType == Protocol::closeConnectionMsg)
+ {
+ return;
+ }
+ if(messageType != Protocol::requestMsg)
+ {
+ cerr << "unexpected message: " << messageType << endl;
+ return;
+ }
+
+ size -= Protocol::headerSize;
+ if(size < 0 || size > sizeof(req))
+ {
+ cerr << "booting client: unsupported size" << endl;
+ return;
+ }
+ //assert(size <= req.Length);
+
+ len = 0;
+ while(len != size)
+ {
+ int n = ::recv(fd, &req[len], size - len, 0);
+ if(n <= 0)
+ {
+ return;
+ }
+ //Console.WriteLine("read: " + n);
+ len += n;
+ }
+
+ offset = 0;
+ int requestId = getInt(req, offset);
+
+ // id
+ int sz = readSize(req, offset);
+ offset += sz;
+ sz = readSize(req, offset);
+ offset += sz;
+ assert(req[offset] == 0);
+ ++offset; // facet
+ // operation
+ sz = readSize(req, offset);
+
+ if(!rawcmp(opIceIsA, sizeof(opIceIsA)-1, req, offset, sz) &&
+ !rawcmp(opIcePing, sizeof(opIcePing)-1, req, offset, sz) &&
+ !rawcmp(opSendByteSeq, sizeof(opSendByteSeq)-1, req, offset, sz))
+ {
+ string op(&req[offset], sz);
+ cerr << "unsupported op: " << op << endl;
+ return;
+ }
+
+
+ char* r;
+ int l;
+ if(rawcmp(opIceIsA, sizeof(opIceIsA)-1, req, offset, sz))
+ {
+ r = isaReply;
+ l = sizeof(isaReply);
+ }
+ else
+ {
+ r = reply;
+ l = sizeof(reply);
+ }
+
+ //
+ // Compose the reply.
+ //
+ offset = 14;
+ putInt(r, offset, requestId);
+
+ if(::send(fd, r, l, 0) != l)
+ {
+ return;
+ }
}
}
@@ -399,7 +399,7 @@ main(int argc, char* argv[])
#else
cerr << "Create socket failed! " << errno << endl;
#endif
- return EXIT_FAILURE;
+ return EXIT_FAILURE;
}
struct sockaddr_in addr;
@@ -411,32 +411,32 @@ main(int argc, char* argv[])
if(bind(fd, reinterpret_cast<struct sockaddr*>(&addr), int(sizeof(addr))) == SOCKET_ERROR)
{
cerr << "Bind failed!" << endl;
- return EXIT_FAILURE;
+ return EXIT_FAILURE;
}
if(::listen(fd, 5) == SOCKET_ERROR)
{
cerr << "Listen failed!" << endl;
- return EXIT_FAILURE;
+ return EXIT_FAILURE;
}
cout << "Server ready" << endl;
while(true)
{
- SOCKET fd2 = ::accept(fd, 0, 0);
- if(fd2 == INVALID_SOCKET)
- {
- cerr << "Accept failed!" << endl;
- return EXIT_FAILURE;
- }
- cout << "Accepted new client" << endl;
- run(fd2);
- cout << "Disconnected client" << endl;
+ SOCKET fd2 = ::accept(fd, 0, 0);
+ if(fd2 == INVALID_SOCKET)
+ {
+ cerr << "Accept failed!" << endl;
+ return EXIT_FAILURE;
+ }
+ cout << "Accepted new client" << endl;
+ run(fd2);
+ cout << "Disconnected client" << endl;
#ifdef WIN32
- ::closesocket(fd2);
+ ::closesocket(fd2);
#else
- ::close(fd2);
+ ::close(fd2);
#endif
}