Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(99)

Side by Side Diff: test/cctest/test-sockets.cc

Issue 27089: Fixed lint errors.... (Closed) Base URL: http://v8.googlecode.com/svn/branches/bleeding_edge/
Patch Set: Created 11 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
« no previous file with comments | « src/platform-win32.cc ('k') | no next file » | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright 2009 the V8 project authors. All rights reserved. 1 // Copyright 2009 the V8 project authors. All rights reserved.
2 2
3 #include "v8.h" 3 #include "v8.h"
4 #include "platform.h" 4 #include "platform.h"
5 #include "cctest.h" 5 #include "cctest.h"
6 6
7 7
8 using namespace ::v8::internal; 8 using namespace ::v8::internal;
9 9
10 10
11 static const char* kPort = "5858"; 11 static const char* kPort = "5858";
12 static const char* kLocalhost = "localhost"; 12 static const char* kLocalhost = "localhost";
13 13
14 class SocketListenerThread : public Thread { 14 class SocketListenerThread : public Thread {
15 public: 15 public:
16 SocketListenerThread(int data_size) : data_size_(data_size), 16 explicit SocketListenerThread(int data_size)
17 server_(NULL), client_(NULL), 17 : data_size_(data_size), server_(NULL), client_(NULL),
18 listening_(OS::CreateSemaphore(0)) { 18 listening_(OS::CreateSemaphore(0)) {
19 data_ = new char[data_size_]; 19 data_ = new char[data_size_];
20 } 20 }
21 ~SocketListenerThread() { 21 ~SocketListenerThread() {
22 // Close both sockets. 22 // Close both sockets.
23 delete client_; 23 delete client_;
24 delete server_; 24 delete server_;
25 } 25 }
26 26
27 void Run(); 27 void Run();
28 void WaitForListening() { listening_->Wait(); } 28 void WaitForListening() { listening_->Wait(); }
(...skipping 14 matching lines...) Expand all
43 // Create the server socket and bind it to the requested port. 43 // Create the server socket and bind it to the requested port.
44 server_ = OS::CreateSocket(); 44 server_ = OS::CreateSocket();
45 CHECK(server_ != NULL); 45 CHECK(server_ != NULL);
46 ok = server_->Bind(5858); 46 ok = server_->Bind(5858);
47 CHECK(ok); 47 CHECK(ok);
48 48
49 // Listen for new connections. 49 // Listen for new connections.
50 ok = server_->Listen(1); 50 ok = server_->Listen(1);
51 CHECK(ok); 51 CHECK(ok);
52 listening_->Signal(); 52 listening_->Signal();
53 53
54 // Accept a connection. 54 // Accept a connection.
55 client_ = server_->Accept(); 55 client_ = server_->Accept();
56 CHECK(client_ != NULL); 56 CHECK(client_ != NULL);
57 57
58 // Read the expected niumber of bytes of data. 58 // Read the expected niumber of bytes of data.
59 int bytes_read = 0; 59 int bytes_read = 0;
60 while (bytes_read < data_size_) { 60 while (bytes_read < data_size_) {
61 bytes_read += client_->Receive(data_ + bytes_read, data_size_ - bytes_read); 61 bytes_read += client_->Receive(data_ + bytes_read, data_size_ - bytes_read);
62 } 62 }
63 } 63 }
64 64
65 65
66 static void SendAndReceive(char *data, int len) { 66 static void SendAndReceive(char *data, int len) {
67 bool ok; 67 bool ok;
68 68
69 // Create a socket listener. 69 // Create a socket listener.
70 SocketListenerThread* listener = new SocketListenerThread(len); 70 SocketListenerThread* listener = new SocketListenerThread(len);
71 listener->Start(); 71 listener->Start();
72 listener->WaitForListening(); 72 listener->WaitForListening();
73 73
74 // Connect and write some data. 74 // Connect and write some data.
75 Socket* client = OS::CreateSocket(); 75 Socket* client = OS::CreateSocket();
76 CHECK(client != NULL); 76 CHECK(client != NULL);
77 ok = client->Connect(kLocalhost, kPort); 77 ok = client->Connect(kLocalhost, kPort);
78 CHECK(ok); 78 CHECK(ok);
79 79
80 // Send all the data. 80 // Send all the data.
81 ok = client->SendAll(data, len); 81 ok = client->SendAll(data, len);
82 CHECK(ok); 82 CHECK(ok);
83 83
(...skipping 41 matching lines...) Expand 10 before | Expand all | Expand 10 after
125 } 125 }
126 126
127 127
128 TEST(HToNNToH) { 128 TEST(HToNNToH) {
129 uint16_t x = 1234; 129 uint16_t x = 1234;
130 CHECK_EQ(x, Socket::NToH(Socket::HToN(x))); 130 CHECK_EQ(x, Socket::NToH(Socket::HToN(x)));
131 131
132 uint32_t y = 12345678; 132 uint32_t y = 12345678;
133 CHECK(y == Socket::NToH(Socket::HToN(y))); 133 CHECK(y == Socket::NToH(Socket::HToN(y)));
134 } 134 }
OLDNEW
« no previous file with comments | « src/platform-win32.cc ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698