Index: third_party/grpc/src/php/ext/grpc/byte_buffer.c |
diff --git a/third_party/tcmalloc/chromium/src/base/thread_lister.c b/third_party/grpc/src/php/ext/grpc/byte_buffer.c |
similarity index 55% |
copy from third_party/tcmalloc/chromium/src/base/thread_lister.c |
copy to third_party/grpc/src/php/ext/grpc/byte_buffer.c |
index bc180dba7a9f2ba3b8261009c8af85f0b1d4a023..8be0a206073698d90a9890b27c977a74aaa937a2 100644 |
--- a/third_party/tcmalloc/chromium/src/base/thread_lister.c |
+++ b/third_party/grpc/src/php/ext/grpc/byte_buffer.c |
@@ -1,4 +1,6 @@ |
-/* Copyright (c) 2005-2007, Google Inc. |
+/* |
+ * |
+ * Copyright 2015, Google Inc. |
* All rights reserved. |
* |
* Redistribution and use in source and binary forms, with or without |
@@ -27,51 +29,50 @@ |
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
* OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
* |
- * --- |
- * Author: Markus Gutschke |
*/ |
+#ifdef HAVE_CONFIG_H |
#include "config.h" |
-#include <stdio.h> /* needed for NULL on some powerpc platforms (?!) */ |
-#ifdef HAVE_SYS_PRCTL |
-# include <sys/prctl.h> |
#endif |
-#include "base/thread_lister.h" |
-#include "base/linuxthreads.h" |
-/* Include other thread listers here that define THREADS macro |
- * only when they can provide a good implementation. |
- */ |
-#ifndef THREADS |
+#include <php.h> |
+#include <php_ini.h> |
+#include <ext/standard/info.h> |
+#include <ext/spl/spl_exceptions.h> |
+#include "php_grpc.h" |
-/* Default trivial thread lister for single-threaded applications, |
- * or if the multi-threading code has not been ported, yet. |
- */ |
+#include <string.h> |
-int ListAllProcessThreads(void *parameter, |
- ListAllProcessThreadsCallBack callback, ...) { |
- int rc; |
- va_list ap; |
- pid_t pid; |
+#include "byte_buffer.h" |
-#ifdef HAVE_SYS_PRCTL |
- int dumpable = prctl(PR_GET_DUMPABLE, 0); |
- if (!dumpable) |
- prctl(PR_SET_DUMPABLE, 1); |
-#endif |
- va_start(ap, callback); |
- pid = getpid(); |
- rc = callback(parameter, 1, &pid, ap); |
- va_end(ap); |
-#ifdef HAVE_SYS_PRCTL |
- if (!dumpable) |
- prctl(PR_SET_DUMPABLE, 0); |
-#endif |
- return rc; |
-} |
+#include <grpc/grpc.h> |
+#include <grpc/byte_buffer_reader.h> |
+#include <grpc/support/slice.h> |
-int ResumeAllProcessThreads(int num_threads, pid_t *thread_pids) { |
- return 1; |
+grpc_byte_buffer *string_to_byte_buffer(char *string, size_t length) { |
+ gpr_slice slice = gpr_slice_from_copied_buffer(string, length); |
+ grpc_byte_buffer *buffer = grpc_raw_byte_buffer_create(&slice, 1); |
+ gpr_slice_unref(slice); |
+ return buffer; |
} |
-#endif /* ifndef THREADS */ |
+void byte_buffer_to_string(grpc_byte_buffer *buffer, char **out_string, |
+ size_t *out_length) { |
+ if (buffer == NULL) { |
+ *out_string = NULL; |
+ *out_length = 0; |
+ return; |
+ } |
+ size_t length = grpc_byte_buffer_length(buffer); |
+ char *string = ecalloc(length + 1, sizeof(char)); |
+ size_t offset = 0; |
+ grpc_byte_buffer_reader reader; |
+ grpc_byte_buffer_reader_init(&reader, buffer); |
+ gpr_slice next; |
+ while (grpc_byte_buffer_reader_next(&reader, &next) != 0) { |
+ memcpy(string + offset, GPR_SLICE_START_PTR(next), GPR_SLICE_LENGTH(next)); |
+ offset += GPR_SLICE_LENGTH(next); |
+ } |
+ *out_string = string; |
+ *out_length = length; |
+} |