| OLD | NEW |
| 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "native_client/src/shared/ppapi_proxy/plugin_ppb_url_loader.h" | 5 #include "native_client/src/shared/ppapi_proxy/plugin_ppb_url_loader.h" |
| 6 | 6 |
| 7 #include <stdio.h> | 7 #include <stdio.h> |
| 8 #include <string.h> | 8 #include <string.h> |
| 9 #include "native_client/src/include/nacl_macros.h" | 9 #include "native_client/src/include/nacl_macros.h" |
| 10 #include "native_client/src/include/portability.h" | 10 #include "native_client/src/include/portability.h" |
| 11 #include "native_client/src/shared/ppapi_proxy/plugin_callback.h" | 11 #include "native_client/src/shared/ppapi_proxy/plugin_callback.h" |
| 12 #include "native_client/src/shared/ppapi_proxy/plugin_globals.h" | 12 #include "native_client/src/shared/ppapi_proxy/plugin_globals.h" |
| 13 #include "native_client/src/shared/ppapi_proxy/utility.h" | 13 #include "native_client/src/shared/ppapi_proxy/utility.h" |
| 14 #include "native_client/src/shared/srpc/nacl_srpc.h" | 14 #include "native_client/src/shared/srpc/nacl_srpc.h" |
| 15 #include "ppapi/c/pp_completion_callback.h" | 15 #include "ppapi/c/pp_completion_callback.h" |
| 16 #include "ppapi/c/pp_errors.h" | 16 #include "ppapi/c/pp_errors.h" |
| 17 #include "ppapi/c/ppb_url_loader.h" | 17 #include "ppapi/c/ppb_url_loader.h" |
| 18 #include "srpcgen/ppb_rpc.h" | 18 #include "srpcgen/ppb_rpc.h" |
| 19 | 19 |
| 20 namespace ppapi_proxy { | 20 namespace ppapi_proxy { |
| 21 | 21 |
| 22 namespace { | 22 namespace { |
| 23 | 23 |
| 24 PP_Resource Create(PP_Instance instance) { | 24 PP_Resource Create(PP_Instance instance) { |
| 25 DebugPrintf("PPB_URLLoader::Create: instance=%"NACL_PRIu32"\n", instance); | 25 DebugPrintf("PPB_URLLoader::Create: instance=%"NACL_PRId32"\n", instance); |
| 26 | 26 |
| 27 PP_Resource resource; | 27 PP_Resource resource; |
| 28 NaClSrpcError srpc_result = | 28 NaClSrpcError srpc_result = |
| 29 PpbURLLoaderRpcClient::PPB_URLLoader_Create( | 29 PpbURLLoaderRpcClient::PPB_URLLoader_Create( |
| 30 GetMainSrpcChannel(), instance, &resource); | 30 GetMainSrpcChannel(), instance, &resource); |
| 31 DebugPrintf("PPB_URLLoader::Create: %s\n", NaClSrpcErrorString(srpc_result)); | 31 DebugPrintf("PPB_URLLoader::Create: %s\n", NaClSrpcErrorString(srpc_result)); |
| 32 | 32 |
| 33 if (srpc_result == NACL_SRPC_RESULT_OK) | 33 if (srpc_result == NACL_SRPC_RESULT_OK) |
| 34 return resource; | 34 return resource; |
| 35 return kInvalidResourceId; | 35 return kInvalidResourceId; |
| 36 } | 36 } |
| 37 | 37 |
| 38 PP_Bool IsURLLoader(PP_Resource resource) { | 38 PP_Bool IsURLLoader(PP_Resource resource) { |
| 39 DebugPrintf("PPB_URLLoader::IsURLLoader: resource=%"NACL_PRIu32"\n", | 39 DebugPrintf("PPB_URLLoader::IsURLLoader: resource=%"NACL_PRId32"\n", |
| 40 resource); | 40 resource); |
| 41 | 41 |
| 42 int32_t is_url_loader; | 42 int32_t is_url_loader; |
| 43 NaClSrpcError srpc_result = | 43 NaClSrpcError srpc_result = |
| 44 PpbURLLoaderRpcClient::PPB_URLLoader_IsURLLoader( | 44 PpbURLLoaderRpcClient::PPB_URLLoader_IsURLLoader( |
| 45 GetMainSrpcChannel(), resource, &is_url_loader); | 45 GetMainSrpcChannel(), resource, &is_url_loader); |
| 46 DebugPrintf("PPB_URLLoader::IsURLLoader: %s\n", | 46 DebugPrintf("PPB_URLLoader::IsURLLoader: %s\n", |
| 47 NaClSrpcErrorString(srpc_result)); | 47 NaClSrpcErrorString(srpc_result)); |
| 48 | 48 |
| 49 if (srpc_result == NACL_SRPC_RESULT_OK && is_url_loader) | 49 if (srpc_result == NACL_SRPC_RESULT_OK && is_url_loader) |
| 50 return PP_TRUE; | 50 return PP_TRUE; |
| 51 return PP_FALSE; | 51 return PP_FALSE; |
| 52 } | 52 } |
| 53 | 53 |
| 54 int32_t Open(PP_Resource loader, | 54 int32_t Open(PP_Resource loader, |
| 55 PP_Resource request, | 55 PP_Resource request, |
| 56 struct PP_CompletionCallback callback) { | 56 struct PP_CompletionCallback callback) { |
| 57 DebugPrintf("PPB_URLLoader::Open: loader=%"NACL_PRIu32"\n", loader); | 57 DebugPrintf("PPB_URLLoader::Open: loader=%"NACL_PRId32"\n", loader); |
| 58 DebugPrintf("PPB_URLLoader::Open: request=%"NACL_PRIu32"\n", request); | 58 DebugPrintf("PPB_URLLoader::Open: request=%"NACL_PRId32"\n", request); |
| 59 | 59 |
| 60 int32_t callback_id = | 60 int32_t callback_id = |
| 61 CompletionCallbackTable::Get()->AddCallback(callback); | 61 CompletionCallbackTable::Get()->AddCallback(callback); |
| 62 if (callback_id == 0) // Just like Chrome, for now disallow blocking calls. | 62 if (callback_id == 0) // Just like Chrome, for now disallow blocking calls. |
| 63 return PP_ERROR_BLOCKS_MAIN_THREAD; | 63 return PP_ERROR_BLOCKS_MAIN_THREAD; |
| 64 | 64 |
| 65 int32_t pp_error; | 65 int32_t pp_error; |
| 66 NaClSrpcError srpc_result = | 66 NaClSrpcError srpc_result = |
| 67 PpbURLLoaderRpcClient::PPB_URLLoader_Open( | 67 PpbURLLoaderRpcClient::PPB_URLLoader_Open( |
| 68 GetMainSrpcChannel(), loader, request, callback_id, &pp_error); | 68 GetMainSrpcChannel(), loader, request, callback_id, &pp_error); |
| 69 DebugPrintf("PPB_URLLoader::Open: %s\n", NaClSrpcErrorString(srpc_result)); | 69 DebugPrintf("PPB_URLLoader::Open: %s\n", NaClSrpcErrorString(srpc_result)); |
| 70 | 70 |
| 71 if (srpc_result != NACL_SRPC_RESULT_OK) | 71 if (srpc_result != NACL_SRPC_RESULT_OK) |
| 72 pp_error = PP_ERROR_FAILED; | 72 pp_error = PP_ERROR_FAILED; |
| 73 return MayForceCallback(callback, pp_error); | 73 return MayForceCallback(callback, pp_error); |
| 74 } | 74 } |
| 75 | 75 |
| 76 int32_t FollowRedirect(PP_Resource loader, | 76 int32_t FollowRedirect(PP_Resource loader, |
| 77 struct PP_CompletionCallback callback) { | 77 struct PP_CompletionCallback callback) { |
| 78 DebugPrintf("PPB_URLLoader::FollowRedirect: loader=%"NACL_PRIu32"\n", loader); | 78 DebugPrintf("PPB_URLLoader::FollowRedirect: loader=%"NACL_PRId32"\n", loader); |
| 79 | 79 |
| 80 int32_t callback_id = | 80 int32_t callback_id = |
| 81 CompletionCallbackTable::Get()->AddCallback(callback); | 81 CompletionCallbackTable::Get()->AddCallback(callback); |
| 82 if (callback_id == 0) // Just like Chrome, for now disallow blocking calls. | 82 if (callback_id == 0) // Just like Chrome, for now disallow blocking calls. |
| 83 return PP_ERROR_BLOCKS_MAIN_THREAD; | 83 return PP_ERROR_BLOCKS_MAIN_THREAD; |
| 84 | 84 |
| 85 int32_t pp_error; | 85 int32_t pp_error; |
| 86 NaClSrpcError srpc_result = | 86 NaClSrpcError srpc_result = |
| 87 PpbURLLoaderRpcClient::PPB_URLLoader_FollowRedirect( | 87 PpbURLLoaderRpcClient::PPB_URLLoader_FollowRedirect( |
| 88 GetMainSrpcChannel(), loader, callback_id, &pp_error); | 88 GetMainSrpcChannel(), loader, callback_id, &pp_error); |
| 89 DebugPrintf("PPB_URLLoader::FollowRedirect: %s\n", | 89 DebugPrintf("PPB_URLLoader::FollowRedirect: %s\n", |
| 90 NaClSrpcErrorString(srpc_result)); | 90 NaClSrpcErrorString(srpc_result)); |
| 91 | 91 |
| 92 if (srpc_result != NACL_SRPC_RESULT_OK) | 92 if (srpc_result != NACL_SRPC_RESULT_OK) |
| 93 pp_error = PP_ERROR_FAILED; | 93 pp_error = PP_ERROR_FAILED; |
| 94 return MayForceCallback(callback, pp_error); | 94 return MayForceCallback(callback, pp_error); |
| 95 } | 95 } |
| 96 | 96 |
| 97 PP_Bool GetUploadProgress(PP_Resource loader, | 97 PP_Bool GetUploadProgress(PP_Resource loader, |
| 98 int64_t* bytes_sent, | 98 int64_t* bytes_sent, |
| 99 int64_t* total_bytes_to_be_sent) { | 99 int64_t* total_bytes_to_be_sent) { |
| 100 DebugPrintf("PPB_URLLoader::GetUploadProgress: loader=%"NACL_PRIu32"\n", | 100 DebugPrintf("PPB_URLLoader::GetUploadProgress: loader=%"NACL_PRId32"\n", |
| 101 loader); | 101 loader); |
| 102 | 102 |
| 103 int32_t success; | 103 int32_t success; |
| 104 NaClSrpcError srpc_result = | 104 NaClSrpcError srpc_result = |
| 105 PpbURLLoaderRpcClient::PPB_URLLoader_GetUploadProgress( | 105 PpbURLLoaderRpcClient::PPB_URLLoader_GetUploadProgress( |
| 106 GetMainSrpcChannel(), | 106 GetMainSrpcChannel(), |
| 107 loader, | 107 loader, |
| 108 bytes_sent, | 108 bytes_sent, |
| 109 total_bytes_to_be_sent, | 109 total_bytes_to_be_sent, |
| 110 &success); | 110 &success); |
| 111 DebugPrintf("PPB_URLLoader::GetUploadProgress: %s\n", | 111 DebugPrintf("PPB_URLLoader::GetUploadProgress: %s\n", |
| 112 NaClSrpcErrorString(srpc_result)); | 112 NaClSrpcErrorString(srpc_result)); |
| 113 | 113 |
| 114 if (srpc_result == NACL_SRPC_RESULT_OK && success) | 114 if (srpc_result == NACL_SRPC_RESULT_OK && success) |
| 115 return PP_TRUE; | 115 return PP_TRUE; |
| 116 return PP_FALSE; | 116 return PP_FALSE; |
| 117 } | 117 } |
| 118 | 118 |
| 119 PP_Bool GetDownloadProgress(PP_Resource loader, | 119 PP_Bool GetDownloadProgress(PP_Resource loader, |
| 120 int64_t* bytes_received, | 120 int64_t* bytes_received, |
| 121 int64_t* total_bytes_to_be_received) { | 121 int64_t* total_bytes_to_be_received) { |
| 122 DebugPrintf("PPB_URLLoader::GetDownloadProgress: loader=%"NACL_PRIu32"\n", | 122 DebugPrintf("PPB_URLLoader::GetDownloadProgress: loader=%"NACL_PRId32"\n", |
| 123 loader); | 123 loader); |
| 124 | 124 |
| 125 int32_t success; | 125 int32_t success; |
| 126 NaClSrpcError srpc_result = | 126 NaClSrpcError srpc_result = |
| 127 PpbURLLoaderRpcClient::PPB_URLLoader_GetDownloadProgress( | 127 PpbURLLoaderRpcClient::PPB_URLLoader_GetDownloadProgress( |
| 128 GetMainSrpcChannel(), | 128 GetMainSrpcChannel(), |
| 129 loader, | 129 loader, |
| 130 bytes_received, | 130 bytes_received, |
| 131 total_bytes_to_be_received, | 131 total_bytes_to_be_received, |
| 132 &success); | 132 &success); |
| 133 DebugPrintf("PPB_URLLoader::GetDownloadProgress: %s\n", | 133 DebugPrintf("PPB_URLLoader::GetDownloadProgress: %s\n", |
| 134 NaClSrpcErrorString(srpc_result)); | 134 NaClSrpcErrorString(srpc_result)); |
| 135 | 135 |
| 136 if (srpc_result == NACL_SRPC_RESULT_OK && success) | 136 if (srpc_result == NACL_SRPC_RESULT_OK && success) |
| 137 return PP_TRUE; | 137 return PP_TRUE; |
| 138 return PP_FALSE; | 138 return PP_FALSE; |
| 139 } | 139 } |
| 140 | 140 |
| 141 PP_Resource GetResponseInfo(PP_Resource loader) { | 141 PP_Resource GetResponseInfo(PP_Resource loader) { |
| 142 DebugPrintf("PPB_URLLoader::GetResponseInfo: loader=%"NACL_PRIu32"\n", | 142 DebugPrintf("PPB_URLLoader::GetResponseInfo: loader=%"NACL_PRId32"\n", |
| 143 loader); | 143 loader); |
| 144 | 144 |
| 145 PP_Resource response; | 145 PP_Resource response; |
| 146 NaClSrpcError srpc_result = | 146 NaClSrpcError srpc_result = |
| 147 PpbURLLoaderRpcClient::PPB_URLLoader_GetResponseInfo( | 147 PpbURLLoaderRpcClient::PPB_URLLoader_GetResponseInfo( |
| 148 GetMainSrpcChannel(), | 148 GetMainSrpcChannel(), |
| 149 loader, | 149 loader, |
| 150 &response); | 150 &response); |
| 151 | 151 |
| 152 if (srpc_result == NACL_SRPC_RESULT_OK) | 152 if (srpc_result == NACL_SRPC_RESULT_OK) |
| 153 return response; | 153 return response; |
| 154 return kInvalidResourceId; | 154 return kInvalidResourceId; |
| 155 } | 155 } |
| 156 | 156 |
| 157 int32_t ReadResponseBody(PP_Resource loader, | 157 int32_t ReadResponseBody(PP_Resource loader, |
| 158 void* buffer, | 158 void* buffer, |
| 159 int32_t bytes_to_read, | 159 int32_t bytes_to_read, |
| 160 struct PP_CompletionCallback callback) { | 160 struct PP_CompletionCallback callback) { |
| 161 DebugPrintf("PPB_URLLoader::ReadResponseBody: loader=%"NACL_PRIu32"\n", | 161 DebugPrintf("PPB_URLLoader::ReadResponseBody: loader=%"NACL_PRId32"\n", |
| 162 loader); | 162 loader); |
| 163 if (bytes_to_read < 0) | 163 if (bytes_to_read < 0) |
| 164 bytes_to_read = 0; | 164 bytes_to_read = 0; |
| 165 nacl_abi_size_t buffer_size = bytes_to_read; | 165 nacl_abi_size_t buffer_size = bytes_to_read; |
| 166 | 166 |
| 167 int32_t callback_id = | 167 int32_t callback_id = |
| 168 CompletionCallbackTable::Get()->AddCallback(callback, buffer); | 168 CompletionCallbackTable::Get()->AddCallback(callback, buffer); |
| 169 if (callback_id == 0) // Just like Chrome, for now disallow blocking calls. | 169 if (callback_id == 0) // Just like Chrome, for now disallow blocking calls. |
| 170 return PP_ERROR_BLOCKS_MAIN_THREAD; | 170 return PP_ERROR_BLOCKS_MAIN_THREAD; |
| 171 | 171 |
| (...skipping 10 matching lines...) Expand all Loading... |
| 182 DebugPrintf("PPB_URLLoader::ReadResponseBody: %s\n", | 182 DebugPrintf("PPB_URLLoader::ReadResponseBody: %s\n", |
| 183 NaClSrpcErrorString(srpc_result)); | 183 NaClSrpcErrorString(srpc_result)); |
| 184 | 184 |
| 185 if (srpc_result != NACL_SRPC_RESULT_OK) | 185 if (srpc_result != NACL_SRPC_RESULT_OK) |
| 186 pp_error_or_bytes = PP_ERROR_FAILED; | 186 pp_error_or_bytes = PP_ERROR_FAILED; |
| 187 return MayForceCallback(callback, pp_error_or_bytes); | 187 return MayForceCallback(callback, pp_error_or_bytes); |
| 188 } | 188 } |
| 189 | 189 |
| 190 int32_t FinishStreamingToFile(PP_Resource loader, | 190 int32_t FinishStreamingToFile(PP_Resource loader, |
| 191 struct PP_CompletionCallback callback) { | 191 struct PP_CompletionCallback callback) { |
| 192 DebugPrintf("PPB_URLLoader::FinishStreamingToFile: loader=%"NACL_PRIu32"\n", | 192 DebugPrintf("PPB_URLLoader::FinishStreamingToFile: loader=%"NACL_PRId32"\n", |
| 193 loader); | 193 loader); |
| 194 | 194 |
| 195 int32_t callback_id = | 195 int32_t callback_id = |
| 196 CompletionCallbackTable::Get()->AddCallback(callback); | 196 CompletionCallbackTable::Get()->AddCallback(callback); |
| 197 if (callback_id == 0) // Just like Chrome, for now disallow blocking calls. | 197 if (callback_id == 0) // Just like Chrome, for now disallow blocking calls. |
| 198 return PP_ERROR_BLOCKS_MAIN_THREAD; | 198 return PP_ERROR_BLOCKS_MAIN_THREAD; |
| 199 | 199 |
| 200 int32_t pp_error; | 200 int32_t pp_error; |
| 201 NaClSrpcError srpc_result = | 201 NaClSrpcError srpc_result = |
| 202 PpbURLLoaderRpcClient::PPB_URLLoader_FinishStreamingToFile( | 202 PpbURLLoaderRpcClient::PPB_URLLoader_FinishStreamingToFile( |
| 203 GetMainSrpcChannel(), loader, callback_id, &pp_error); | 203 GetMainSrpcChannel(), loader, callback_id, &pp_error); |
| 204 | 204 |
| 205 if (srpc_result != NACL_SRPC_RESULT_OK) | 205 if (srpc_result != NACL_SRPC_RESULT_OK) |
| 206 pp_error = PP_ERROR_FAILED; | 206 pp_error = PP_ERROR_FAILED; |
| 207 return MayForceCallback(callback, pp_error); | 207 return MayForceCallback(callback, pp_error); |
| 208 } | 208 } |
| 209 | 209 |
| 210 void Close(PP_Resource loader) { | 210 void Close(PP_Resource loader) { |
| 211 DebugPrintf("PPB_URLLoader::Close: loader=%"NACL_PRIu32"\n", loader); | 211 DebugPrintf("PPB_URLLoader::Close: loader=%"NACL_PRId32"\n", loader); |
| 212 | 212 |
| 213 NaClSrpcError srpc_result = | 213 NaClSrpcError srpc_result = |
| 214 PpbURLLoaderRpcClient::PPB_URLLoader_Close( | 214 PpbURLLoaderRpcClient::PPB_URLLoader_Close( |
| 215 GetMainSrpcChannel(), loader); | 215 GetMainSrpcChannel(), loader); |
| 216 DebugPrintf("PPB_URLLoader::Close: %s\n", NaClSrpcErrorString(srpc_result)); | 216 DebugPrintf("PPB_URLLoader::Close: %s\n", NaClSrpcErrorString(srpc_result)); |
| 217 } | 217 } |
| 218 | 218 |
| 219 } // namespace | 219 } // namespace |
| 220 | 220 |
| 221 const PPB_URLLoader* PluginURLLoader::GetInterface() { | 221 const PPB_URLLoader* PluginURLLoader::GetInterface() { |
| 222 static const PPB_URLLoader url_loader_interface = { | 222 static const PPB_URLLoader url_loader_interface = { |
| 223 Create, | 223 Create, |
| 224 IsURLLoader, | 224 IsURLLoader, |
| 225 Open, | 225 Open, |
| 226 FollowRedirect, | 226 FollowRedirect, |
| 227 GetUploadProgress, | 227 GetUploadProgress, |
| 228 GetDownloadProgress, | 228 GetDownloadProgress, |
| 229 GetResponseInfo, | 229 GetResponseInfo, |
| 230 ReadResponseBody, | 230 ReadResponseBody, |
| 231 FinishStreamingToFile, | 231 FinishStreamingToFile, |
| 232 Close, | 232 Close, |
| 233 }; | 233 }; |
| 234 return &url_loader_interface; | 234 return &url_loader_interface; |
| 235 } | 235 } |
| 236 | 236 |
| 237 } // namespace ppapi_proxy | 237 } // namespace ppapi_proxy |
| OLD | NEW |