Index: native_client_sdk/src/examples/demo/nacl_io/handlers.c |
diff --git a/native_client_sdk/src/examples/demo/nacl_io/handlers.c b/native_client_sdk/src/examples/demo/nacl_io/handlers.c |
deleted file mode 100644 |
index 4fef3507fffc15bb015da3dc120d5bc4200bdbba..0000000000000000000000000000000000000000 |
--- a/native_client_sdk/src/examples/demo/nacl_io/handlers.c |
+++ /dev/null |
@@ -1,1114 +0,0 @@ |
-/* Copyright (c) 2012 The Chromium Authors. All rights reserved. |
- * Use of this source code is governed by a BSD-style license that can be |
- * found in the LICENSE file. */ |
- |
-#include "handlers.h" |
- |
-#include <arpa/inet.h> |
-#include <assert.h> |
-#include <errno.h> |
-#include <limits.h> |
-#include <netdb.h> |
-#include <netinet/in.h> |
-#include <stdio.h> |
-#include <stdlib.h> |
-#include <string.h> |
-#include <unistd.h> |
- |
-#include <sys/types.h> |
-#include <sys/socket.h> |
-#include <sys/stat.h> |
- |
-#include "nacl_io/osdirent.h" |
- |
-#include "nacl_io_demo.h" |
- |
-#define MAX_OPEN_FILES 10 |
-#define MAX_OPEN_DIRS 10 |
-#define MAX_PARAMS 4 |
- |
-#if defined(WIN32) |
-#define stat _stat |
-#endif |
- |
-/** |
- * A mapping from int -> FILE*, so the JavaScript messages can refer to an open |
- * File. |
- */ |
-static FILE* g_OpenFiles[MAX_OPEN_FILES]; |
- |
-/** |
- * A mapping from int -> DIR*, so the JavaScript messages can refer to an open |
- * Directory. |
- */ |
-static void* g_OpenDirs[MAX_OPEN_DIRS]; |
- |
-/** |
- * A collection of the most recently allocated parameter strings. This makes |
- * the Handle* functions below easier to write because they don't have to |
- * manually deallocate the strings they're using. |
- */ |
-static char* g_ParamStrings[MAX_PARAMS]; |
- |
-/** |
- * Add |object| to |map| and return the index it was added at. |
- * @param[in] map The map to add the object to. |
- * @param[in] max_map_size The maximum map size. |
- * @param[in] object The object to add to the map. |
- * @return int The index of the added object, or -1 if there is no more space. |
- */ |
-static int AddToMap(void** map, int max_map_size, void* object) { |
- int i; |
- assert(object != NULL); |
- for (i = 0; i < max_map_size; ++i) { |
- if (map[i] == NULL) { |
- map[i] = object; |
- return i; |
- } |
- } |
- |
- return -1; |
-} |
- |
-/** |
- * Remove an object at index |i| from |map|. |
- * @param[in] map The map to remove from. |
- * @param[in] max_map_size The size of the map. |
- * @param[in] i The index to remove. |
- */ |
-static void RemoveFromMap(void** map, int max_map_size, int i) { |
- assert(i >= 0 && i < max_map_size); |
- map[i] = NULL; |
-} |
- |
-/** |
- * Add the file to the g_OpenFiles map. |
- * @param[in] file The file to add to g_OpenFiles. |
- * @return int The index of the FILE in g_OpenFiles, or -1 if there are too many |
- * open files. |
- */ |
-static int AddFileToMap(FILE* file) { |
- return AddToMap((void**)g_OpenFiles, MAX_OPEN_FILES, file); |
-} |
- |
-/** |
- * Remove the file from the g_OpenFiles map. |
- * @param[in] i The index of the file handle to remove. |
- */ |
-static void RemoveFileFromMap(int i) { |
- RemoveFromMap((void**)g_OpenFiles, MAX_OPEN_FILES, i); |
-} |
- |
-/* Win32 doesn't support DIR/opendir/readdir/closedir. */ |
-#if !defined(WIN32) |
-/** |
- * Add the dir to the g_OpenDirs map. |
- * @param[in] dir The dir to add to g_OpenDirs. |
- * @return int The index of the DIR in g_OpenDirs, or -1 if there are too many |
- * open dirs. |
- */ |
-static int AddDirToMap(DIR* dir) { |
- return AddToMap((void**)g_OpenDirs, MAX_OPEN_DIRS, dir); |
-} |
- |
-/** |
- * Remove the dir from the g_OpenDirs map. |
- * @param[in] i The index of the dir handle to remove. |
- */ |
-static void RemoveDirFromMap(int i) { |
- RemoveFromMap((void**)g_OpenDirs, MAX_OPEN_DIRS, i); |
-} |
-#endif |
- |
-/** |
- * Get the number of parameters. |
- * @param[in] params The parameter array. |
- * @return uint32_t The number of parameters in the array. |
- */ |
-static uint32_t GetNumParams(struct PP_Var params) { |
- return g_ppb_var_array->GetLength(params); |
-} |
- |
-/** |
- * Get a parameter at |index| as a string. |
- * @param[in] params The parameter array. |
- * @param[in] index The index in |params| to get. |
- * @param[out] out_string The output string. |
- * @param[out] out_string_len The length of the output string. |
- * @param[out] out_error An error message, if this operation failed. |
- * @return int 0 if successful, otherwise 1. |
- */ |
-static int GetParamString(struct PP_Var params, |
- uint32_t index, |
- char** out_string, |
- uint32_t* out_string_len, |
- const char** out_error) { |
- if (index >= MAX_PARAMS) { |
- *out_error = PrintfToNewString("Param index %u >= MAX_PARAMS (%d)", |
- index, MAX_PARAMS); |
- return 1; |
- } |
- |
- struct PP_Var value = g_ppb_var_array->Get(params, index); |
- if (value.type != PP_VARTYPE_STRING) { |
- *out_error = |
- PrintfToNewString("Expected param at index %d to be a string", index); |
- return 1; |
- } |
- |
- uint32_t length; |
- const char* var_str = g_ppb_var->VarToUtf8(value, &length); |
- |
- char* string = (char*)malloc(length + 1); |
- memcpy(string, var_str, length); |
- string[length] = 0; |
- |
- /* Put the allocated string in g_ParamStrings. This keeps us from leaking |
- * each parameter string, without having to do manual cleanup in every |
- * Handle* function below. |
- */ |
- free(g_ParamStrings[index]); |
- g_ParamStrings[index] = string; |
- |
- |
- *out_string = string; |
- *out_string_len = length; |
- return 0; |
-} |
- |
-/** |
- * Get a parameter at |index| as a FILE*. |
- * @param[in] params The parameter array. |
- * @param[in] index The index in |params| to get. |
- * @param[out] out_file The output FILE*. |
- * @param[out] out_file_index The index of the output FILE* in g_OpenFiles. |
- * @param[out] out_error An error message, if this operation failed. |
- * @return int 0 if successful, otherwise 1. |
- */ |
-static int GetParamFile(struct PP_Var params, |
- uint32_t index, |
- FILE** out_file, |
- int32_t* out_file_index, |
- const char** out_error) { |
- struct PP_Var value = g_ppb_var_array->Get(params, index); |
- if (value.type != PP_VARTYPE_INT32) { |
- *out_error = |
- PrintfToNewString("Expected param at index %d to be an int32", index); |
- return 1; |
- } |
- |
- int32_t file_index = value.value.as_int; |
- if (file_index < 0 || file_index >= MAX_OPEN_FILES) { |
- *out_error = PrintfToNewString("File index %d is out range", file_index); |
- return 1; |
- } |
- |
- if (g_OpenFiles[file_index] == NULL) { |
- *out_error = PrintfToNewString("File index %d is not open", file_index); |
- return 1; |
- } |
- |
- *out_file = g_OpenFiles[file_index]; |
- *out_file_index = file_index; |
- return 0; |
-} |
- |
-/** |
- * Get a parameter at |index| as a DIR*. |
- * @param[in] params The parameter array. |
- * @param[in] index The index in |params| to get. |
- * @param[out] out_file The output DIR*. |
- * @param[out] out_file_index The index of the output DIR* in g_OpenDirs. |
- * @param[out] out_error An error message, if this operation failed. |
- * @return int 0 if successful, otherwise 1. |
- */ |
-static int GetParamDir(struct PP_Var params, |
- uint32_t index, |
- DIR** out_dir, |
- int32_t* out_dir_index, |
- const char** out_error) { |
- struct PP_Var value = g_ppb_var_array->Get(params, index); |
- if (value.type != PP_VARTYPE_INT32) { |
- *out_error = |
- PrintfToNewString("Expected param at index %d to be an int32", index); |
- return 1; |
- } |
- |
- int32_t dir_index = value.value.as_int; |
- if (dir_index < 0 || dir_index >= MAX_OPEN_DIRS) { |
- *out_error = PrintfToNewString("Dir at index %d is out range", dir_index); |
- return 1; |
- } |
- |
- if (g_OpenDirs[dir_index] == NULL) { |
- *out_error = PrintfToNewString("Dir index %d is not open", dir_index); |
- return 1; |
- } |
- |
- *out_dir = g_OpenDirs[dir_index]; |
- *out_dir_index = dir_index; |
- return 0; |
-} |
- |
-/** |
- * Get a parameter at |index| as an int. |
- * @param[in] params The parameter array. |
- * @param[in] index The index in |params| to get. |
- * @param[out] out_file The output int32_t. |
- * @param[out] out_error An error message, if this operation failed. |
- * @return int 0 if successful, otherwise 1. |
- */ |
-static int GetParamInt(struct PP_Var params, |
- uint32_t index, |
- int32_t* out_int, |
- const char** out_error) { |
- struct PP_Var value = g_ppb_var_array->Get(params, index); |
- if (value.type != PP_VARTYPE_INT32) { |
- *out_error = |
- PrintfToNewString("Expected param at index %d to be an int32", index); |
- return 1; |
- } |
- |
- *out_int = value.value.as_int; |
- return 0; |
-} |
- |
-/** |
- * Create a response PP_Var to send back to JavaScript. |
- * @param[out] response_var The response PP_Var. |
- * @param[in] cmd The name of the function that is being executed. |
- * @param[out] out_error An error message, if this call failed. |
- */ |
-static void CreateResponse(struct PP_Var* response_var, |
- const char* cmd, |
- const char** out_error) { |
- PP_Bool result; |
- |
- struct PP_Var dict_var = g_ppb_var_dictionary->Create(); |
- struct PP_Var cmd_key = CStrToVar("cmd"); |
- struct PP_Var cmd_value = CStrToVar(cmd); |
- |
- result = g_ppb_var_dictionary->Set(dict_var, cmd_key, cmd_value); |
- g_ppb_var->Release(cmd_key); |
- g_ppb_var->Release(cmd_value); |
- |
- if (!result) { |
- g_ppb_var->Release(dict_var); |
- *out_error = |
- PrintfToNewString("Unable to set \"cmd\" key in result dictionary"); |
- return; |
- } |
- |
- struct PP_Var args_key = CStrToVar("args"); |
- struct PP_Var args_value = g_ppb_var_array->Create(); |
- result = g_ppb_var_dictionary->Set(dict_var, args_key, args_value); |
- g_ppb_var->Release(args_key); |
- g_ppb_var->Release(args_value); |
- |
- if (!result) { |
- g_ppb_var->Release(dict_var); |
- *out_error = |
- PrintfToNewString("Unable to set \"args\" key in result dictionary"); |
- return; |
- } |
- |
- *response_var = dict_var; |
-} |
- |
-/** |
- * Append a PP_Var to the response dictionary. |
- * @param[in,out] response_var The response PP_var. |
- * @param[in] value The value to add to the response args. |
- * @param[out] out_error An error message, if this call failed. |
- */ |
-static void AppendResponseVar(struct PP_Var* response_var, |
- struct PP_Var value, |
- const char** out_error) { |
- struct PP_Var args_value = GetDictVar(*response_var, "args"); |
- uint32_t args_length = g_ppb_var_array->GetLength(args_value); |
- PP_Bool result = g_ppb_var_array->Set(args_value, args_length, value); |
- if (!result) { |
- // Release the dictionary that was there before. |
- g_ppb_var->Release(*response_var); |
- |
- // Return an error message instead. |
- *response_var = PP_MakeUndefined(); |
- *out_error = PrintfToNewString("Unable to append value to result"); |
- return; |
- } |
-} |
- |
-/** |
- * Append an int to the response dictionary. |
- * @param[in,out] response_var The response PP_var. |
- * @param[in] value The value to add to the response args. |
- * @param[out] out_error An error message, if this call failed. |
- */ |
-static void AppendResponseInt(struct PP_Var* response_var, |
- int32_t value, |
- const char** out_error) { |
- AppendResponseVar(response_var, PP_MakeInt32(value), out_error); |
-} |
- |
-/** |
- * Append a string to the response dictionary. |
- * @param[in,out] response_var The response PP_var. |
- * @param[in] value The value to add to the response args. |
- * @param[out] out_error An error message, if this call failed. |
- */ |
-static void AppendResponseString(struct PP_Var* response_var, |
- const char* value, |
- const char** out_error) { |
- struct PP_Var value_var = CStrToVar(value); |
- AppendResponseVar(response_var, value_var, out_error); |
- g_ppb_var->Release(value_var); |
-} |
- |
-#define CHECK_PARAM_COUNT(name, expected) \ |
- if (GetNumParams(params) != expected) { \ |
- *out_error = PrintfToNewString(#name " takes " #expected " parameters." \ |
- " Got %d", GetNumParams(params)); \ |
- return 1; \ |
- } |
- |
-#define PARAM_STRING(index, var) \ |
- char* var; \ |
- uint32_t var##_len; \ |
- if (GetParamString(params, index, &var, &var##_len, out_error)) { \ |
- return 1; \ |
- } |
- |
-#define PARAM_FILE(index, var) \ |
- FILE* var; \ |
- int32_t var##_index; \ |
- if (GetParamFile(params, index, &var, &var##_index, out_error)) { \ |
- return 1; \ |
- } |
- |
-#define PARAM_DIR(index, var) \ |
- DIR* var; \ |
- int32_t var##_index; \ |
- if (GetParamDir(params, index, &var, &var##_index, out_error)) { \ |
- return 1; \ |
- } |
- |
-#define PARAM_INT(index, var) \ |
- int32_t var; \ |
- if (GetParamInt(params, index, &var, out_error)) { \ |
- return 1; \ |
- } |
- |
-#define CREATE_RESPONSE(name) CreateResponse(output, #name, out_error) |
-#define RESPONSE_STRING(var) AppendResponseString(output, var, out_error) |
-#define RESPONSE_INT(var) AppendResponseInt(output, var, out_error) |
- |
-/** |
- * Handle a call to fopen() made by JavaScript. |
- * |
- * fopen expects 2 parameters: |
- * 0: the path of the file to open |
- * 1: the mode string |
- * on success, fopen returns a result in |output|: |
- * 0: "fopen" |
- * 1: the filename opened |
- * 2: the file index |
- * on failure, fopen returns an error string in |out_error|. |
- */ |
-int HandleFopen(struct PP_Var params, |
- struct PP_Var* output, |
- const char** out_error) { |
- CHECK_PARAM_COUNT(fopen, 2); |
- PARAM_STRING(0, filename); |
- PARAM_STRING(1, mode); |
- |
- FILE* file = fopen(filename, mode); |
- |
- if (!file) { |
- *out_error = PrintfToNewString("fopen returned a NULL FILE*"); |
- return 1; |
- } |
- |
- int file_index = AddFileToMap(file); |
- if (file_index == -1) { |
- *out_error = PrintfToNewString("Example only allows %d open file handles", |
- MAX_OPEN_FILES); |
- return 1; |
- } |
- |
- CREATE_RESPONSE(fopen); |
- RESPONSE_STRING(filename); |
- RESPONSE_INT(file_index); |
- return 0; |
-} |
- |
-/** |
- * Handle a call to fwrite() made by JavaScript. |
- * |
- * fwrite expects 2 parameters: |
- * 0: The index of the file (which is mapped to a FILE*) |
- * 1: A string to write to the file |
- * on success, fwrite returns a result in |output|: |
- * 0: "fwrite" |
- * 1: the file index |
- * 2: the number of bytes written |
- * on failure, fwrite returns an error string in |out_error|. |
- */ |
-int HandleFwrite(struct PP_Var params, |
- struct PP_Var* output, |
- const char** out_error) { |
- CHECK_PARAM_COUNT(fwrite, 2); |
- PARAM_FILE(0, file); |
- PARAM_STRING(1, data); |
- |
- size_t bytes_written = fwrite(data, 1, data_len, file); |
- if (ferror(file)) { |
- *out_error = PrintfToNewString("Wrote %d bytes, but ferror() returns true", |
- bytes_written); |
- return 1; |
- } |
- |
- CREATE_RESPONSE(fwrite); |
- RESPONSE_INT(file_index); |
- RESPONSE_INT(bytes_written); |
- return 0; |
-} |
- |
-/** |
- * Handle a call to fread() made by JavaScript. |
- * |
- * fread expects 2 parameters: |
- * 0: The index of the file (which is mapped to a FILE*) |
- * 1: The number of bytes to read from the file. |
- * on success, fread returns a result in |output|: |
- * 0: "fread" |
- * 1: the file index |
- * 2: the data read from the file |
- * on failure, fread returns an error string in |out_error|. |
- */ |
-int HandleFread(struct PP_Var params, |
- struct PP_Var* output, |
- const char** out_error) { |
- CHECK_PARAM_COUNT(fread, 2); |
- PARAM_FILE(0, file); |
- PARAM_INT(1, data_len); |
- |
- char* buffer = (char*)malloc(data_len + 1); |
- size_t bytes_read = fread(buffer, 1, data_len, file); |
- buffer[bytes_read] = 0; |
- |
- if (ferror(file)) { |
- *out_error = PrintfToNewString("Read %d bytes, but ferror() returns true", |
- bytes_read); |
- free(buffer); |
- return 1; |
- } |
- |
- CREATE_RESPONSE(fread); |
- RESPONSE_INT(file_index); |
- RESPONSE_STRING(buffer); |
- free(buffer); |
- return 0; |
-} |
- |
-/** |
- * Handle a call to fseek() made by JavaScript. |
- * |
- * fseek expects 3 parameters: |
- * 0: The index of the file (which is mapped to a FILE*) |
- * 1: The offset to seek to |
- * 2: An integer representing the whence parameter of standard fseek. |
- * whence = 0: seek from the beginning of the file |
- * whence = 1: seek from the current file position |
- * whence = 2: seek from the end of the file |
- * on success, fseek returns a result in |output|: |
- * 0: "fseek" |
- * 1: the file index |
- * 2: The new file position |
- * on failure, fseek returns an error string in |out_error|. |
- */ |
-int HandleFseek(struct PP_Var params, |
- struct PP_Var* output, |
- const char** out_error) { |
- CHECK_PARAM_COUNT(fseek, 3); |
- PARAM_FILE(0, file); |
- PARAM_INT(1, offset); |
- PARAM_INT(2, whence); |
- |
- int result = fseek(file, offset, whence); |
- if (result) { |
- *out_error = PrintfToNewString("fseek returned error %d", result); |
- return 1; |
- } |
- |
- offset = ftell(file); |
- if (offset < 0) { |
- *out_error = PrintfToNewString( |
- "fseek succeeded, but ftell returned error %d", offset); |
- return 1; |
- } |
- |
- CREATE_RESPONSE(fseek); |
- RESPONSE_INT(file_index); |
- RESPONSE_INT(offset); |
- return 0; |
-} |
- |
-/** |
- * Handle a call to fflush() made by JavaScript. |
- * |
- * fflush expects 1 parameters: |
- * 0: The index of the file (which is mapped to a FILE*) |
- * on success, fflush returns a result in |output|: |
- * 0: "fflush" |
- * 1: the file index |
- * on failure, fflush returns an error string in |out_error|. |
- */ |
-int HandleFflush(struct PP_Var params, |
- struct PP_Var* output, |
- const char** out_error) { |
- CHECK_PARAM_COUNT(fflush, 1); |
- PARAM_FILE(0, file); |
- |
- fflush(file); |
- |
- CREATE_RESPONSE(fflush); |
- RESPONSE_INT(file_index); |
- return 0; |
-} |
- |
-/** |
- * Handle a call to fclose() made by JavaScript. |
- * |
- * fclose expects 1 parameter: |
- * 0: The index of the file (which is mapped to a FILE*) |
- * on success, fclose returns a result in |output|: |
- * 0: "fclose" |
- * 1: the file index |
- * on failure, fclose returns an error string in |out_error|. |
- */ |
-int HandleFclose(struct PP_Var params, |
- struct PP_Var* output, |
- const char** out_error) { |
- CHECK_PARAM_COUNT(fclose, 1); |
- PARAM_FILE(0, file); |
- |
- int result = fclose(file); |
- if (result) { |
- *out_error = PrintfToNewString("fclose returned error %d", result); |
- return 1; |
- } |
- |
- RemoveFileFromMap(file_index); |
- |
- CREATE_RESPONSE(fclose); |
- RESPONSE_INT(file_index); |
- return 0; |
-} |
- |
-/** |
- * Handle a call to stat() made by JavaScript. |
- * |
- * stat expects 1 parameter: |
- * 0: The name of the file |
- * on success, stat returns a result in |output|: |
- * 0: "stat" |
- * 1: the file name |
- * 2: the size of the file |
- * on failure, stat returns an error string in |out_error|. |
- */ |
-int HandleStat(struct PP_Var params, |
- struct PP_Var* output, |
- const char** out_error) { |
- CHECK_PARAM_COUNT(stat, 1); |
- PARAM_STRING(0, filename); |
- |
- struct stat buf; |
- memset(&buf, 0, sizeof(buf)); |
- int result = stat(filename, &buf); |
- |
- if (result == -1) { |
- *out_error = PrintfToNewString("stat returned error %d", errno); |
- return 1; |
- } |
- |
- CREATE_RESPONSE(stat); |
- RESPONSE_STRING(filename); |
- RESPONSE_INT(buf.st_size); |
- return 0; |
-} |
- |
-/** |
- * Handle a call to opendir() made by JavaScript. |
- * |
- * opendir expects 1 parameter: |
- * 0: The name of the directory |
- * on success, opendir returns a result in |output|: |
- * 0: "opendir" |
- * 1: the directory name |
- * 2: the index of the directory |
- * on failure, opendir returns an error string in |out_error|. |
- */ |
-int HandleOpendir(struct PP_Var params, |
- struct PP_Var* output, |
- const char** out_error) { |
-#if defined(WIN32) |
- *out_error = PrintfToNewString("Win32 does not support opendir"); |
- return 1; |
-#else |
- CHECK_PARAM_COUNT(opendir, 1); |
- PARAM_STRING(0, dirname); |
- |
- DIR* dir = opendir(dirname); |
- |
- if (!dir) { |
- *out_error = PrintfToNewString("opendir returned a NULL DIR*"); |
- return 1; |
- } |
- |
- int dir_index = AddDirToMap(dir); |
- if (dir_index == -1) { |
- *out_error = PrintfToNewString("Example only allows %d open dir handles", |
- MAX_OPEN_DIRS); |
- return 1; |
- } |
- |
- CREATE_RESPONSE(opendir); |
- RESPONSE_STRING(dirname); |
- RESPONSE_INT(dir_index); |
- return 0; |
-#endif |
-} |
- |
-/** |
- * Handle a call to readdir() made by JavaScript. |
- * |
- * readdir expects 1 parameter: |
- * 0: The index of the directory (which is mapped to a DIR*) |
- * on success, opendir returns a result in |output|: |
- * 0: "readdir" |
- * 1: the inode number of the entry |
- * 2: the name of the entry |
- * if there are no more entries, |output| contains: |
- * 0: "readdir" |
- * on failure, readdir returns an error string in |out_error|. |
- */ |
-int HandleReaddir(struct PP_Var params, |
- struct PP_Var* output, |
- const char** out_error) { |
-#if defined(WIN32) |
- *out_error = PrintfToNewString("Win32 does not support readdir"); |
- return 1; |
-#else |
- CHECK_PARAM_COUNT(readdir, 1); |
- PARAM_DIR(0, dir); |
- |
- struct dirent* entry = readdir(dir); |
- |
- CREATE_RESPONSE(readdir); |
- RESPONSE_INT(dir_index); |
- if (entry != NULL) { |
- RESPONSE_INT(entry->d_ino); |
- RESPONSE_STRING(entry->d_name); |
- } |
- return 0; |
-#endif |
-} |
- |
-/** |
- * Handle a call to closedir() made by JavaScript. |
- * |
- * closedir expects 1 parameter: |
- * 0: The index of the directory (which is mapped to a DIR*) |
- * on success, closedir returns a result in |output|: |
- * 0: "closedir" |
- * 1: the name of the directory |
- * on failure, closedir returns an error string in |out_error|. |
- */ |
-int HandleClosedir(struct PP_Var params, |
- struct PP_Var* output, |
- const char** out_error) { |
-#if defined(WIN32) |
- *out_error = PrintfToNewString("Win32 does not support closedir"); |
- return 1; |
-#else |
- CHECK_PARAM_COUNT(closedir, 1); |
- PARAM_DIR(0, dir); |
- |
- int result = closedir(dir); |
- if (result) { |
- *out_error = PrintfToNewString("closedir returned error %d", result); |
- return 1; |
- } |
- |
- RemoveDirFromMap(dir_index); |
- |
- CREATE_RESPONSE(closedir); |
- RESPONSE_INT(dir_index); |
- return 0; |
-#endif |
-} |
- |
-/** |
- * Handle a call to mkdir() made by JavaScript. |
- * |
- * mkdir expects 1 parameter: |
- * 0: The name of the directory |
- * 1: The mode to use for the new directory, in octal. |
- * on success, mkdir returns a result in |output|: |
- * 0: "mkdir" |
- * 1: the name of the directory |
- * on failure, mkdir returns an error string in |out_error|. |
- */ |
-int HandleMkdir(struct PP_Var params, |
- struct PP_Var* output, |
- const char** out_error) { |
- CHECK_PARAM_COUNT(mkdir, 2); |
- PARAM_STRING(0, dirname); |
- PARAM_INT(1, mode); |
- |
- int result = mkdir(dirname, mode); |
- |
- if (result != 0) { |
- *out_error = PrintfToNewString("mkdir returned error: %d", errno); |
- return 1; |
- } |
- |
- CREATE_RESPONSE(mkdir); |
- RESPONSE_STRING(dirname); |
- return 0; |
-} |
- |
-/** |
- * Handle a call to rmdir() made by JavaScript. |
- * |
- * rmdir expects 1 parameter: |
- * 0: The name of the directory to remove |
- * on success, rmdir returns a result in |output|: |
- * 0: "rmdir" |
- * 1: the name of the directory |
- * on failure, rmdir returns an error string in |out_error|. |
- */ |
-int HandleRmdir(struct PP_Var params, |
- struct PP_Var* output, |
- const char** out_error) { |
- CHECK_PARAM_COUNT(rmdir, 1); |
- PARAM_STRING(0, dirname); |
- |
- int result = rmdir(dirname); |
- |
- if (result != 0) { |
- *out_error = PrintfToNewString("rmdir returned error: %d", errno); |
- return 1; |
- } |
- |
- CREATE_RESPONSE(rmdir); |
- RESPONSE_STRING(dirname); |
- return 0; |
-} |
- |
-/** |
- * Handle a call to chdir() made by JavaScript. |
- * |
- * chdir expects 1 parameter: |
- * 0: The name of the directory |
- * on success, chdir returns a result in |output|: |
- * 0: "chdir" |
- * 1: the name of the directory |
- * on failure, chdir returns an error string in |out_error|. |
- */ |
-int HandleChdir(struct PP_Var params, |
- struct PP_Var* output, |
- const char** out_error) { |
- CHECK_PARAM_COUNT(chdir, 1); |
- PARAM_STRING(0, dirname); |
- |
- int result = chdir(dirname); |
- |
- if (result != 0) { |
- *out_error = PrintfToNewString("chdir returned error: %d", errno); |
- return 1; |
- } |
- |
- CREATE_RESPONSE(chdir); |
- RESPONSE_STRING(dirname); |
- return 0; |
-} |
- |
-/** |
- * Handle a call to getcwd() made by JavaScript. |
- * |
- * getcwd expects 0 parameters. |
- * on success, getcwd returns a result in |output|: |
- * 0: "getcwd" |
- * 1: the current working directory |
- * on failure, getcwd returns an error string in |out_error|. |
- */ |
-int HandleGetcwd(struct PP_Var params, |
- struct PP_Var* output, |
- const char** out_error) { |
- CHECK_PARAM_COUNT(getcwd, 0); |
- |
- char cwd[PATH_MAX]; |
- char* result = getcwd(cwd, PATH_MAX); |
- if (result == NULL) { |
- *out_error = PrintfToNewString("getcwd returned error: %d", errno); |
- return 1; |
- } |
- |
- CREATE_RESPONSE(getcwd); |
- RESPONSE_STRING(cwd); |
- return 0; |
-} |
- |
-/** |
- * Handle a call to getaddrinfo() made by JavaScript. |
- * |
- * getaddrinfo expects 1 parameter: |
- * 0: The name of the host to look up. |
- * on success, getaddrinfo returns a result in |output|: |
- * 0: "getaddrinfo" |
- * 1: The canonical name |
- * 2*n+2: Host name |
- * 2*n+3: Address type (either "AF_INET" or "AF_INET6") |
- * on failure, getaddrinfo returns an error string in |out_error|. |
- */ |
-int HandleGetaddrinfo(struct PP_Var params, |
- struct PP_Var* output, |
- const char** out_error) { |
- CHECK_PARAM_COUNT(getaddrinfo, 2); |
- PARAM_STRING(0, name); |
- PARAM_STRING(1, family); |
- |
- struct addrinfo hints; |
- memset(&hints, 0, sizeof(hints)); |
- hints.ai_flags = AI_CANONNAME; |
- if (!strcmp(family, "AF_INET")) |
- hints.ai_family = AF_INET; |
- else if (!strcmp(family, "AF_INET6")) |
- hints.ai_family = AF_INET6; |
- else if (!strcmp(family, "AF_UNSPEC")) |
- hints.ai_family = AF_UNSPEC; |
- else { |
- *out_error = PrintfToNewString("getaddrinfo uknown family: %s", family); |
- return 1; |
- } |
- |
- struct addrinfo* ai; |
- int rtn = getaddrinfo(name, NULL, &hints, &ai); |
- if (rtn != 0) { |
- *out_error = PrintfToNewString("getaddrinfo failed, error is \"%s\"", |
- gai_strerror(rtn)); |
- return 2; |
- } |
- |
- CREATE_RESPONSE(getaddrinfo); |
- RESPONSE_STRING(ai->ai_canonname); |
- struct addrinfo* current = ai; |
- while (current) { |
- char addr_str[INET6_ADDRSTRLEN]; |
- if (ai->ai_family == AF_INET6) { |
- struct sockaddr_in6* in6 = (struct sockaddr_in6*)current->ai_addr; |
- inet_ntop( |
- ai->ai_family, &in6->sin6_addr.s6_addr, addr_str, sizeof(addr_str)); |
- } else if (ai->ai_family == AF_INET) { |
- struct sockaddr_in* in = (struct sockaddr_in*)current->ai_addr; |
- inet_ntop(ai->ai_family, &in->sin_addr, addr_str, sizeof(addr_str)); |
- } |
- |
- RESPONSE_STRING(addr_str); |
- RESPONSE_STRING(ai->ai_family == AF_INET ? "AF_INET" : "AF_INET6"); |
- |
- current = current->ai_next; |
- } |
- |
- freeaddrinfo(ai); |
- return 0; |
-} |
- |
-/** |
- * Handle a call to gethostbyname() made by JavaScript. |
- * |
- * gethostbyname expects 1 parameter: |
- * 0: The name of the host to look up. |
- * on success, gethostbyname returns a result in |output|: |
- * 0: "gethostbyname" |
- * 1: Host name |
- * 2: Address type (either "AF_INET" or "AF_INET6") |
- * 3: The first address. |
- * 4+ The second, third, etc. addresses. |
- * on failure, gethostbyname returns an error string in |out_error|. |
- */ |
-int HandleGethostbyname(struct PP_Var params, |
- struct PP_Var* output, |
- const char** out_error) { |
- CHECK_PARAM_COUNT(gethostbyname, 1); |
- PARAM_STRING(0, name); |
- |
- struct hostent* info = gethostbyname(name); |
- if (!info) { |
- *out_error = PrintfToNewString("gethostbyname failed, error is \"%s\"", |
- hstrerror(h_errno)); |
- return 1; |
- } |
- |
- CREATE_RESPONSE(gethostbyname); |
- RESPONSE_STRING(info->h_name); |
- RESPONSE_STRING(info->h_addrtype == AF_INET ? "AF_INET" : "AF_INET6"); |
- |
- struct in_addr** addr_list = (struct in_addr**)info->h_addr_list; |
- int i; |
- for (i = 0; addr_list[i] != NULL; i++) { |
- if (info->h_addrtype == AF_INET) { |
- RESPONSE_STRING(inet_ntoa(*addr_list[i])); |
- } else { // IPv6 |
- char addr_str[INET6_ADDRSTRLEN]; |
- inet_ntop(AF_INET6, addr_list[i], addr_str, sizeof(addr_str)); |
- RESPONSE_STRING(addr_str); |
- } |
- } |
- return 0; |
-} |
- |
-/** |
- * Handle a call to connect() made by JavaScript. |
- * |
- * connect expects 2 parameters: |
- * 0: The hostname to connect to. |
- * 1: The port number to connect to. |
- * on success, connect returns a result in |output|: |
- * 0: "connect" |
- * 1: The socket file descriptor. |
- * on failure, connect returns an error string in |out_error|. |
- */ |
-int HandleConnect(struct PP_Var params, |
- struct PP_Var* output, |
- const char** out_error) { |
- CHECK_PARAM_COUNT(connect, 2); |
- PARAM_STRING(0, hostname); |
- PARAM_INT(1, port); |
- |
- // Lookup host |
- struct hostent* hostent = gethostbyname(hostname); |
- if (hostent == NULL) { |
- *out_error = PrintfToNewString("gethostbyname() returned error: %d", errno); |
- return 1; |
- } |
- |
- struct sockaddr_in addr; |
- socklen_t addrlen = sizeof(addr); |
- addr.sin_family = AF_INET; |
- addr.sin_port = htons(port); |
- memcpy(&addr.sin_addr.s_addr, hostent->h_addr_list[0], hostent->h_length); |
- |
- int sock = socket(AF_INET, SOCK_STREAM, 0); |
- if (sock < 0) { |
- *out_error = PrintfToNewString("socket() failed: %s", strerror(errno)); |
- return 1; |
- } |
- |
- int result = connect(sock, (struct sockaddr*)&addr, addrlen); |
- if (result != 0) { |
- *out_error = PrintfToNewString("connect() failed: %s", strerror(errno)); |
- close(sock); |
- return 1; |
- } |
- |
- CREATE_RESPONSE(connect); |
- RESPONSE_INT(sock); |
- return 0; |
-} |
- |
-/** |
- * Handle a call to send() made by JavaScript. |
- * |
- * send expects 2 parameters: |
- * 0: The socket file descriptor to send using. |
- * 1: The NULL terminated string to send. |
- * on success, send returns a result in |output|: |
- * 0: "send" |
- * 1: The number of bytes sent. |
- * on failure, send returns an error string in |out_error|. |
- */ |
-int HandleSend(struct PP_Var params, |
- struct PP_Var* output, |
- const char** out_error) { |
- CHECK_PARAM_COUNT(send, 2); |
- PARAM_INT(0, sock); |
- PARAM_STRING(1, buffer); |
- |
- int result = send(sock, buffer, strlen(buffer), 0); |
- if (result <= 0) { |
- *out_error = PrintfToNewString("send failed: %s", strerror(errno)); |
- return 1; |
- } |
- |
- CREATE_RESPONSE(send); |
- RESPONSE_INT(result); |
- return 0; |
-} |
- |
-/** |
- * Handle a call to recv() made by JavaScript. |
- * |
- * recv expects 2 parameters: |
- * 0: The socket file descriptor to recv from. |
- * 1: The size of the buffer to pass to recv. |
- * on success, send returns a result in |output|: |
- * 0: "recv" |
- * 1: The number of bytes received. |
- * 2: The data received. |
- * on failure, recv returns an error string in |out_error|. |
- */ |
-int HandleRecv(struct PP_Var params, |
- struct PP_Var* output, |
- const char** out_error) { |
- CHECK_PARAM_COUNT(recv, 2); |
- PARAM_INT(0, sock); |
- PARAM_INT(1, buffersize); |
- |
- if (buffersize < 0 || buffersize > 65 * 1024) { |
- *out_error = |
- PrintfToNewString("recv buffersize must be between 0 and 65k."); |
- return 1; |
- } |
- |
- char* buffer = alloca(buffersize); |
- memset(buffer, 0, buffersize); |
- int result = recv(sock, buffer, buffersize, 0); |
- if (result <= 0) { |
- *out_error = PrintfToNewString("recv failed: %s", strerror(errno)); |
- return 1; |
- } |
- |
- CREATE_RESPONSE(recv); |
- RESPONSE_INT(result); |
- RESPONSE_STRING(buffer); |
- return 0; |
-} |
- |
-/** |
- * Handle a call to close() made by JavaScript. |
- * |
- * close expects 1 parameters: |
- * 0: The socket file descriptor to close. |
- * on success, close returns a result in |output|: |
- * 0: "close" |
- * 1: The socket file descriptor closed. |
- * on failure, close returns an error string in |out_error|. |
- */ |
-int HandleClose(struct PP_Var params, |
- struct PP_Var* output, |
- const char** out_error) { |
- CHECK_PARAM_COUNT(close, 1); |
- PARAM_INT(0, sock); |
- |
- int result = close(sock); |
- if (result != 0) { |
- *out_error = PrintfToNewString("close returned error: %d", errno); |
- return 1; |
- } |
- |
- CREATE_RESPONSE(close); |
- RESPONSE_INT(sock); |
- return 0; |
-} |