| Index: net/udp/udp_socket_unittest.cc
|
| diff --git a/net/udp/udp_socket_unittest.cc b/net/udp/udp_socket_unittest.cc
|
| index 066b47c43c3d2cff29ee8b5578c4b51a64ab4c64..5165d3d93a639a6a5036fd16b611a9c2592f1e38 100644
|
| --- a/net/udp/udp_socket_unittest.cc
|
| +++ b/net/udp/udp_socket_unittest.cc
|
| @@ -32,10 +32,10 @@ class UDPSocketTest : public PlatformTest {
|
|
|
| // Blocks until data is read from the socket.
|
| std::string RecvFromSocket(UDPServerSocket* socket) {
|
| - TestOldCompletionCallback callback;
|
| + TestCompletionCallback callback;
|
|
|
| int rv = socket->RecvFrom(buffer_, kMaxRead, &recv_from_address_,
|
| - &callback);
|
| + callback.callback());
|
| if (rv == ERR_IO_PENDING)
|
| rv = callback.WaitForResult();
|
| if (rv < 0)
|
| @@ -55,7 +55,7 @@ class UDPSocketTest : public PlatformTest {
|
| int SendToSocket(UDPServerSocket* socket,
|
| std::string msg,
|
| const IPEndPoint& address) {
|
| - TestOldCompletionCallback callback;
|
| + TestCompletionCallback callback;
|
|
|
| int length = msg.length();
|
| scoped_refptr<StringIOBuffer> io_buffer(new StringIOBuffer(msg));
|
| @@ -65,7 +65,7 @@ class UDPSocketTest : public PlatformTest {
|
| int bytes_sent = 0;
|
| while (buffer->BytesRemaining()) {
|
| int rv = socket->SendTo(buffer, buffer->BytesRemaining(),
|
| - address, &callback);
|
| + address, callback.callback());
|
| if (rv == ERR_IO_PENDING)
|
| rv = callback.WaitForResult();
|
| if (rv <= 0)
|
| @@ -77,9 +77,9 @@ class UDPSocketTest : public PlatformTest {
|
| }
|
|
|
| std::string ReadSocket(UDPClientSocket* socket) {
|
| - TestOldCompletionCallback callback;
|
| + TestCompletionCallback callback;
|
|
|
| - int rv = socket->Read(buffer_, kMaxRead, &callback);
|
| + int rv = socket->Read(buffer_, kMaxRead, callback.callback());
|
| if (rv == ERR_IO_PENDING)
|
| rv = callback.WaitForResult();
|
| if (rv < 0)
|
| @@ -90,7 +90,7 @@ class UDPSocketTest : public PlatformTest {
|
| // Loop until |msg| has been written to the socket or until an
|
| // error occurs.
|
| int WriteSocket(UDPClientSocket* socket, std::string msg) {
|
| - TestOldCompletionCallback callback;
|
| + TestCompletionCallback callback;
|
|
|
| int length = msg.length();
|
| scoped_refptr<StringIOBuffer> io_buffer(new StringIOBuffer(msg));
|
| @@ -99,7 +99,8 @@ class UDPSocketTest : public PlatformTest {
|
|
|
| int bytes_sent = 0;
|
| while (buffer->BytesRemaining()) {
|
| - int rv = socket->Write(buffer, buffer->BytesRemaining(), &callback);
|
| + int rv = socket->Write(buffer, buffer->BytesRemaining(),
|
| + callback.callback());
|
| if (rv == ERR_IO_PENDING)
|
| rv = callback.WaitForResult();
|
| if (rv <= 0)
|
| @@ -433,9 +434,9 @@ TEST_F(UDPSocketTest, CloseWithPendingRead) {
|
| int rv = server.Listen(bind_address);
|
| EXPECT_EQ(OK, rv);
|
|
|
| - TestOldCompletionCallback callback;
|
| + TestCompletionCallback callback;
|
| IPEndPoint from;
|
| - rv = server.RecvFrom(buffer_, kMaxRead, &from, &callback);
|
| + rv = server.RecvFrom(buffer_, kMaxRead, &from, callback.callback());
|
| EXPECT_EQ(rv, ERR_IO_PENDING);
|
|
|
| server.Close();
|
|
|