mirror of https://github.com/grpc/grpc.git
Merge branch 'master' of https://github.com/grpc/grpc into memtracking
Nicolas "Pixel" Noble
9 years ago
commit
0cca082fd7
290 changed files with 7924 additions and 1950 deletions
@ -0,0 +1,59 @@ |
||||
#region Copyright notice and license |
||||
|
||||
// Copyright 2016, Google Inc. |
||||
// All rights reserved. |
||||
// |
||||
// Redistribution and use in source and binary forms, with or without |
||||
// modification, are permitted provided that the following conditions are |
||||
// met: |
||||
// |
||||
// * Redistributions of source code must retain the above copyright |
||||
// notice, this list of conditions and the following disclaimer. |
||||
// * Redistributions in binary form must reproduce the above |
||||
// copyright notice, this list of conditions and the following disclaimer |
||||
// in the documentation and/or other materials provided with the |
||||
// distribution. |
||||
// * Neither the name of Google Inc. nor the names of its |
||||
// contributors may be used to endorse or promote products derived from |
||||
// this software without specific prior written permission. |
||||
// |
||||
// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS |
||||
// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT |
||||
// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR |
||||
// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT |
||||
// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
||||
// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT |
||||
// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
||||
// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
||||
// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
||||
// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
||||
// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
||||
|
||||
#endregion |
||||
|
||||
using System; |
||||
using System.Reflection; |
||||
using Grpc.Core; |
||||
using Grpc.Core.Logging; |
||||
using NUnit.Common; |
||||
using NUnitLite; |
||||
|
||||
namespace Grpc.Core.Tests |
||||
{ |
||||
/// <summary> |
||||
/// Provides entry point for NUnitLite |
||||
/// </summary> |
||||
public class NUnitMain |
||||
{ |
||||
public static int Main(string[] args) |
||||
{ |
||||
// Make logger immune to NUnit capturing stdout and stderr to workaround https://github.com/nunit/nunit/issues/1406. |
||||
GrpcEnvironment.SetLogger(new TextWriterLogger(Console.Error)); |
||||
#if DOTNET5_4 |
||||
return new AutoRun(typeof(NUnitMain).GetTypeInfo().Assembly).Execute(args, new ExtendedTextWrapper(Console.Out), Console.In); |
||||
#else |
||||
return new AutoRun().Execute(args); |
||||
#endif |
||||
} |
||||
} |
||||
} |
||||
@ -0,0 +1,176 @@ |
||||
#region Copyright notice and license |
||||
|
||||
// Copyright 2015, Google Inc. |
||||
// All rights reserved. |
||||
// |
||||
// Redistribution and use in source and binary forms, with or without |
||||
// modification, are permitted provided that the following conditions are |
||||
// met: |
||||
// |
||||
// * Redistributions of source code must retain the above copyright |
||||
// notice, this list of conditions and the following disclaimer. |
||||
// * Redistributions in binary form must reproduce the above |
||||
// copyright notice, this list of conditions and the following disclaimer |
||||
// in the documentation and/or other materials provided with the |
||||
// distribution. |
||||
// * Neither the name of Google Inc. nor the names of its |
||||
// contributors may be used to endorse or promote products derived from |
||||
// this software without specific prior written permission. |
||||
// |
||||
// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS |
||||
// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT |
||||
// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR |
||||
// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT |
||||
// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
||||
// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT |
||||
// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
||||
// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
||||
// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
||||
// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
||||
// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
||||
|
||||
#endregion |
||||
|
||||
using System; |
||||
using System.Collections.Generic; |
||||
using System.Globalization; |
||||
using System.IO; |
||||
using Grpc.Core.Utils; |
||||
|
||||
namespace Grpc.Core.Logging |
||||
{ |
||||
/// <summary>Logger that logs to an arbitrary <c>System.IO.TextWriter</c>.</summary> |
||||
public class TextWriterLogger : ILogger |
||||
{ |
||||
// Format similar enough to C core log format except nanosecond precision is not supported. |
||||
const string DateTimeFormatString = "MMdd HH:mm:ss.ffffff"; |
||||
|
||||
readonly Func<TextWriter> textWriterProvider; |
||||
readonly Type forType; |
||||
readonly string forTypeString; |
||||
|
||||
/// <summary> |
||||
/// Creates a console logger not associated to any specific type and writes to given <c>System.IO.TextWriter</c>. |
||||
/// User is responsible for providing an instance of TextWriter that is thread-safe. |
||||
/// </summary> |
||||
public TextWriterLogger(TextWriter textWriter) : this(() => textWriter) |
||||
{ |
||||
GrpcPreconditions.CheckNotNull(textWriter); |
||||
} |
||||
|
||||
/// <summary> |
||||
/// Creates a console logger not associated to any specific type and writes to a <c>System.IO.TextWriter</c> obtained from given provider. |
||||
/// User is responsible for providing an instance of TextWriter that is thread-safe. |
||||
/// </summary> |
||||
public TextWriterLogger(Func<TextWriter> textWriterProvider) : this(textWriterProvider, null) |
||||
{ |
||||
} |
||||
|
||||
/// <summary>Creates a console logger that logs messsage specific for given type.</summary> |
||||
protected TextWriterLogger(Func<TextWriter> textWriterProvider, Type forType) |
||||
{ |
||||
this.textWriterProvider = GrpcPreconditions.CheckNotNull(textWriterProvider); |
||||
this.forType = forType; |
||||
if (forType != null) |
||||
{ |
||||
var namespaceStr = forType.Namespace ?? ""; |
||||
if (namespaceStr.Length > 0) |
||||
{ |
||||
namespaceStr += "."; |
||||
} |
||||
this.forTypeString = namespaceStr + forType.Name + " "; |
||||
} |
||||
else |
||||
{ |
||||
this.forTypeString = ""; |
||||
} |
||||
} |
||||
|
||||
/// <summary> |
||||
/// Returns a logger associated with the specified type. |
||||
/// </summary> |
||||
public virtual ILogger ForType<T>() |
||||
{ |
||||
if (typeof(T) == forType) |
||||
{ |
||||
return this; |
||||
} |
||||
return new TextWriterLogger(this.textWriterProvider, typeof(T)); |
||||
} |
||||
|
||||
/// <summary>Logs a message with severity Debug.</summary> |
||||
public void Debug(string message) |
||||
{ |
||||
Log("D", message); |
||||
} |
||||
|
||||
/// <summary>Logs a formatted message with severity Debug.</summary> |
||||
public void Debug(string format, params object[] formatArgs) |
||||
{ |
||||
Debug(string.Format(format, formatArgs)); |
||||
} |
||||
|
||||
/// <summary>Logs a message with severity Info.</summary> |
||||
public void Info(string message) |
||||
{ |
||||
Log("I", message); |
||||
} |
||||
|
||||
/// <summary>Logs a formatted message with severity Info.</summary> |
||||
public void Info(string format, params object[] formatArgs) |
||||
{ |
||||
Info(string.Format(format, formatArgs)); |
||||
} |
||||
|
||||
/// <summary>Logs a message with severity Warning.</summary> |
||||
public void Warning(string message) |
||||
{ |
||||
Log("W", message); |
||||
} |
||||
|
||||
/// <summary>Logs a formatted message with severity Warning.</summary> |
||||
public void Warning(string format, params object[] formatArgs) |
||||
{ |
||||
Warning(string.Format(format, formatArgs)); |
||||
} |
||||
|
||||
/// <summary>Logs a message and an associated exception with severity Warning.</summary> |
||||
public void Warning(Exception exception, string message) |
||||
{ |
||||
Warning(message + " " + exception); |
||||
} |
||||
|
||||
/// <summary>Logs a message with severity Error.</summary> |
||||
public void Error(string message) |
||||
{ |
||||
Log("E", message); |
||||
} |
||||
|
||||
/// <summary>Logs a formatted message with severity Error.</summary> |
||||
public void Error(string format, params object[] formatArgs) |
||||
{ |
||||
Error(string.Format(format, formatArgs)); |
||||
} |
||||
|
||||
/// <summary>Logs a message and an associated exception with severity Error.</summary> |
||||
public void Error(Exception exception, string message) |
||||
{ |
||||
Error(message + " " + exception); |
||||
} |
||||
|
||||
/// <summary>Gets the type associated with this logger.</summary> |
||||
protected Type AssociatedType |
||||
{ |
||||
get { return forType; } |
||||
} |
||||
|
||||
private void Log(string severityString, string message) |
||||
{ |
||||
textWriterProvider().WriteLine("{0}{1} {2}{3}", |
||||
severityString, |
||||
DateTime.Now.ToString(DateTimeFormatString, CultureInfo.InvariantCulture), |
||||
forTypeString, |
||||
message); |
||||
} |
||||
} |
||||
} |
||||
@ -0,0 +1,59 @@ |
||||
#region Copyright notice and license |
||||
|
||||
// Copyright 2016, Google Inc. |
||||
// All rights reserved. |
||||
// |
||||
// Redistribution and use in source and binary forms, with or without |
||||
// modification, are permitted provided that the following conditions are |
||||
// met: |
||||
// |
||||
// * Redistributions of source code must retain the above copyright |
||||
// notice, this list of conditions and the following disclaimer. |
||||
// * Redistributions in binary form must reproduce the above |
||||
// copyright notice, this list of conditions and the following disclaimer |
||||
// in the documentation and/or other materials provided with the |
||||
// distribution. |
||||
// * Neither the name of Google Inc. nor the names of its |
||||
// contributors may be used to endorse or promote products derived from |
||||
// this software without specific prior written permission. |
||||
// |
||||
// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS |
||||
// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT |
||||
// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR |
||||
// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT |
||||
// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
||||
// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT |
||||
// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
||||
// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
||||
// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
||||
// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
||||
// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
||||
|
||||
#endregion |
||||
|
||||
using System; |
||||
using System.Reflection; |
||||
using Grpc.Core; |
||||
using Grpc.Core.Logging; |
||||
using NUnit.Common; |
||||
using NUnitLite; |
||||
|
||||
namespace Grpc.Examples.Tests |
||||
{ |
||||
/// <summary> |
||||
/// Provides entry point for NUnitLite |
||||
/// </summary> |
||||
public class NUnitMain |
||||
{ |
||||
public static int Main(string[] args) |
||||
{ |
||||
// Make logger immune to NUnit capturing stdout and stderr to workaround https://github.com/nunit/nunit/issues/1406. |
||||
GrpcEnvironment.SetLogger(new TextWriterLogger(Console.Error)); |
||||
#if DOTNET5_4 |
||||
return new AutoRun(typeof(NUnitMain).GetTypeInfo().Assembly).Execute(args, new ExtendedTextWrapper(Console.Out), Console.In); |
||||
#else |
||||
return new AutoRun().Execute(args); |
||||
#endif |
||||
} |
||||
} |
||||
} |
||||
@ -0,0 +1,59 @@ |
||||
#region Copyright notice and license |
||||
|
||||
// Copyright 2016, Google Inc. |
||||
// All rights reserved. |
||||
// |
||||
// Redistribution and use in source and binary forms, with or without |
||||
// modification, are permitted provided that the following conditions are |
||||
// met: |
||||
// |
||||
// * Redistributions of source code must retain the above copyright |
||||
// notice, this list of conditions and the following disclaimer. |
||||
// * Redistributions in binary form must reproduce the above |
||||
// copyright notice, this list of conditions and the following disclaimer |
||||
// in the documentation and/or other materials provided with the |
||||
// distribution. |
||||
// * Neither the name of Google Inc. nor the names of its |
||||
// contributors may be used to endorse or promote products derived from |
||||
// this software without specific prior written permission. |
||||
// |
||||
// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS |
||||
// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT |
||||
// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR |
||||
// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT |
||||
// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
||||
// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT |
||||
// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
||||
// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
||||
// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
||||
// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
||||
// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
||||
|
||||
#endregion |
||||
|
||||
using System; |
||||
using System.Reflection; |
||||
using Grpc.Core; |
||||
using Grpc.Core.Logging; |
||||
using NUnit.Common; |
||||
using NUnitLite; |
||||
|
||||
namespace Grpc.HealthCheck.Tests |
||||
{ |
||||
/// <summary> |
||||
/// Provides entry point for NUnitLite |
||||
/// </summary> |
||||
public class NUnitMain |
||||
{ |
||||
public static int Main(string[] args) |
||||
{ |
||||
// Make logger immune to NUnit capturing stdout and stderr to workaround https://github.com/nunit/nunit/issues/1406. |
||||
GrpcEnvironment.SetLogger(new TextWriterLogger(Console.Error)); |
||||
#if DOTNET5_4 |
||||
return new AutoRun(typeof(NUnitMain).GetTypeInfo().Assembly).Execute(args, new ExtendedTextWrapper(Console.Out), Console.In); |
||||
#else |
||||
return new AutoRun().Execute(args); |
||||
#endif |
||||
} |
||||
} |
||||
} |
||||
@ -0,0 +1,59 @@ |
||||
#region Copyright notice and license |
||||
|
||||
// Copyright 2016, Google Inc. |
||||
// All rights reserved. |
||||
// |
||||
// Redistribution and use in source and binary forms, with or without |
||||
// modification, are permitted provided that the following conditions are |
||||
// met: |
||||
// |
||||
// * Redistributions of source code must retain the above copyright |
||||
// notice, this list of conditions and the following disclaimer. |
||||
// * Redistributions in binary form must reproduce the above |
||||
// copyright notice, this list of conditions and the following disclaimer |
||||
// in the documentation and/or other materials provided with the |
||||
// distribution. |
||||
// * Neither the name of Google Inc. nor the names of its |
||||
// contributors may be used to endorse or promote products derived from |
||||
// this software without specific prior written permission. |
||||
// |
||||
// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS |
||||
// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT |
||||
// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR |
||||
// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT |
||||
// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
||||
// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT |
||||
// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
||||
// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
||||
// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
||||
// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
||||
// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
||||
|
||||
#endregion |
||||
|
||||
using System; |
||||
using System.Reflection; |
||||
using Grpc.Core; |
||||
using Grpc.Core.Logging; |
||||
using NUnit.Common; |
||||
using NUnitLite; |
||||
|
||||
namespace Grpc.IntegrationTesting |
||||
{ |
||||
/// <summary> |
||||
/// Provides entry point for NUnitLite |
||||
/// </summary> |
||||
public class NUnitMain |
||||
{ |
||||
public static int Main(string[] args) |
||||
{ |
||||
// Make logger immune to NUnit capturing stdout and stderr to workaround https://github.com/nunit/nunit/issues/1406. |
||||
GrpcEnvironment.SetLogger(new TextWriterLogger(Console.Error)); |
||||
#if DOTNET5_4 |
||||
return new AutoRun(typeof(NUnitMain).GetTypeInfo().Assembly).Execute(args, new ExtendedTextWrapper(Console.Out), Console.In); |
||||
#else |
||||
return new AutoRun().Execute(args); |
||||
#endif |
||||
} |
||||
} |
||||
} |
||||
@ -0,0 +1,2 @@ |
||||
::nix::ii///ii/\a‡?=n;iI_!';&b.cii??nn!%i!*% |
||||
*; |
||||
@ -0,0 +1,2 @@ |
||||
:ipip~6:‡i:::1 |
||||
v:miP/ii:::/iu?n?n)i!= |
||||
@ -0,0 +1 @@ |
||||
i:i:‡ii:i?nip~??ni=niI&6.u/n_!'p~ |
||||
@ -0,0 +1 @@ |
||||
uni:/i:i:‡i:i:‡i??ni=niIi??ni=niI__!!i?n!i'p'pR2p~~ |
||||
@ -0,0 +1 @@ |
||||
i:i:‡i??ni=niI_!'p~ |
||||
@ -0,0 +1 @@ |
||||
:‡i?=niI_!';; |
||||
@ -0,0 +1 @@ |
||||
i:i?nip~&6.u/n |
||||
@ -0,0 +1,2 @@ |
||||
:unix://ii//a.b.ci?n!% |
||||
* |
||||
@ -0,0 +1 @@ |
||||
:‡i?P=niIii-i?%n'!%*i= |
||||
@ -0,0 +1 @@ |
||||
uni::.ilP:%:%i:i‡i:‡i?=nii?n(!ipRI_&/.i;;!?=ii/?n#lniiI_!*Kii!/?ni* |
||||
@ -0,0 +1 @@ |
||||
i:i:‡i:i:‡i??ni=niIi??ni=niI__!!'p'p~~ |
||||
@ -0,0 +1,2 @@ |
||||
unix:///a/:.:ii/i?nc!% |
||||
i* |
||||
@ -0,0 +1 @@ |
||||
ilP:%i:‡i?=niI_.i;;!ii/?nni*! |
||||
@ -0,0 +1 @@ |
||||
:‡i?P-niI%'i= |
||||
@ -0,0 +1 @@ |
||||
:%i:‡i?=niI_!ii/?ni*! |
||||
@ -0,0 +1 @@ |
||||
:iI/i?n!%š* |
||||
@ -0,0 +1 @@ |
||||
:%i:i‡?=#liI_!Kii/?ni* |
||||
@ -0,0 +1,2 @@ |
||||
::unix://ii//a‡?=niI_!';.b.ci?n!% |
||||
*; |
||||
@ -0,0 +1 @@ |
||||
uni::.i?n(!ipR&/ |
||||
@ -0,0 +1 @@ |
||||
::nix::ii///ii/\a:‡?=n;iI_!';&b.ciii |
||||
@ -0,0 +1 @@ |
||||
ilP:%:%i:i‡i:‡i?=niI_.i;;!?=ii/?n#lniiI_!*Kii!/?ni* |
||||
@ -0,0 +1,154 @@ |
||||
/*
|
||||
* |
||||
* Copyright 2016, Google Inc. |
||||
* All rights reserved. |
||||
* |
||||
* Redistribution and use in source and binary forms, with or without |
||||
* modification, are permitted provided that the following conditions are |
||||
* met: |
||||
* |
||||
* * Redistributions of source code must retain the above copyright |
||||
* notice, this list of conditions and the following disclaimer. |
||||
* * Redistributions in binary form must reproduce the above |
||||
* copyright notice, this list of conditions and the following disclaimer |
||||
* in the documentation and/or other materials provided with the |
||||
* distribution. |
||||
* * Neither the name of Google Inc. nor the names of its |
||||
* contributors may be used to endorse or promote products derived from |
||||
* this software without specific prior written permission. |
||||
* |
||||
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS |
||||
* "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT |
||||
* LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR |
||||
* A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT |
||||
* OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
||||
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT |
||||
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
||||
* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
||||
* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
||||
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
||||
* OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
||||
* |
||||
*/ |
||||
|
||||
#include <grpc/grpc.h> |
||||
#include <grpc/support/alloc.h> |
||||
|
||||
#include "src/core/ext/transport/chttp2/transport/chttp2_transport.h" |
||||
#include "src/core/lib/surface/channel.h" |
||||
#include "test/core/util/mock_endpoint.h" |
||||
|
||||
static const bool squelch = true; |
||||
|
||||
static void discard_write(gpr_slice slice) {} |
||||
|
||||
static void *tag(int n) { return (void *)(uintptr_t)n; } |
||||
|
||||
static void dont_log(gpr_log_func_args *args) {} |
||||
|
||||
int LLVMFuzzerTestOneInput(const uint8_t *data, size_t size) { |
||||
grpc_test_only_set_metadata_hash_seed(0); |
||||
if (squelch) gpr_set_log_function(dont_log); |
||||
grpc_init(); |
||||
grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT; |
||||
|
||||
grpc_endpoint *mock_endpoint = grpc_mock_endpoint_create(discard_write); |
||||
|
||||
grpc_completion_queue *cq = grpc_completion_queue_create(NULL); |
||||
grpc_transport *transport = |
||||
grpc_create_chttp2_transport(&exec_ctx, NULL, mock_endpoint, 1); |
||||
grpc_chttp2_transport_start_reading(&exec_ctx, transport, NULL, 0); |
||||
|
||||
grpc_channel *channel = grpc_channel_create( |
||||
&exec_ctx, "test-target", NULL, GRPC_CLIENT_DIRECT_CHANNEL, transport); |
||||
grpc_call *call = |
||||
grpc_channel_create_call(channel, NULL, 0, cq, "/foo", "localhost", |
||||
gpr_inf_future(GPR_CLOCK_REALTIME), NULL); |
||||
|
||||
grpc_metadata_array initial_metadata_recv; |
||||
grpc_metadata_array_init(&initial_metadata_recv); |
||||
grpc_byte_buffer *response_payload_recv = NULL; |
||||
grpc_metadata_array trailing_metadata_recv; |
||||
grpc_metadata_array_init(&trailing_metadata_recv); |
||||
grpc_status_code status; |
||||
char *details = NULL; |
||||
size_t details_capacity = 0; |
||||
|
||||
grpc_op ops[6]; |
||||
grpc_op *op = ops; |
||||
op->op = GRPC_OP_SEND_INITIAL_METADATA; |
||||
op->data.send_initial_metadata.count = 0; |
||||
op->flags = 0; |
||||
op->reserved = NULL; |
||||
op++; |
||||
op->op = GRPC_OP_SEND_CLOSE_FROM_CLIENT; |
||||
op->flags = 0; |
||||
op->reserved = NULL; |
||||
op++; |
||||
op->op = GRPC_OP_RECV_INITIAL_METADATA; |
||||
op->data.recv_initial_metadata = &initial_metadata_recv; |
||||
op->flags = 0; |
||||
op->reserved = NULL; |
||||
op++; |
||||
op->op = GRPC_OP_RECV_MESSAGE; |
||||
op->data.recv_message = &response_payload_recv; |
||||
op->flags = 0; |
||||
op->reserved = NULL; |
||||
op++; |
||||
op->op = GRPC_OP_RECV_STATUS_ON_CLIENT; |
||||
op->data.recv_status_on_client.trailing_metadata = &trailing_metadata_recv; |
||||
op->data.recv_status_on_client.status = &status; |
||||
op->data.recv_status_on_client.status_details = &details; |
||||
op->data.recv_status_on_client.status_details_capacity = &details_capacity; |
||||
op->flags = 0; |
||||
op->reserved = NULL; |
||||
op++; |
||||
grpc_call_error error = |
||||
grpc_call_start_batch(call, ops, (size_t)(op - ops), tag(1), NULL); |
||||
int requested_calls = 1; |
||||
GPR_ASSERT(GRPC_CALL_OK == error); |
||||
|
||||
grpc_mock_endpoint_put_read( |
||||
&exec_ctx, mock_endpoint, |
||||
gpr_slice_from_copied_buffer((const char *)data, size)); |
||||
|
||||
grpc_event ev; |
||||
while (1) { |
||||
grpc_exec_ctx_flush(&exec_ctx); |
||||
ev = grpc_completion_queue_next(cq, gpr_inf_past(GPR_CLOCK_REALTIME), NULL); |
||||
switch (ev.type) { |
||||
case GRPC_QUEUE_TIMEOUT: |
||||
goto done; |
||||
case GRPC_QUEUE_SHUTDOWN: |
||||
break; |
||||
case GRPC_OP_COMPLETE: |
||||
requested_calls--; |
||||
break; |
||||
} |
||||
} |
||||
|
||||
done: |
||||
if (requested_calls) { |
||||
grpc_call_cancel(call, NULL); |
||||
} |
||||
for (int i = 0; i < requested_calls; i++) { |
||||
ev = grpc_completion_queue_next(cq, gpr_inf_past(GPR_CLOCK_REALTIME), NULL); |
||||
GPR_ASSERT(ev.type == GRPC_OP_COMPLETE); |
||||
} |
||||
grpc_completion_queue_shutdown(cq); |
||||
for (int i = 0; i < requested_calls; i++) { |
||||
ev = grpc_completion_queue_next(cq, gpr_inf_past(GPR_CLOCK_REALTIME), NULL); |
||||
GPR_ASSERT(ev.type == GRPC_QUEUE_SHUTDOWN); |
||||
} |
||||
grpc_call_destroy(call); |
||||
grpc_completion_queue_destroy(cq); |
||||
grpc_metadata_array_destroy(&initial_metadata_recv); |
||||
grpc_metadata_array_destroy(&trailing_metadata_recv); |
||||
gpr_free(details); |
||||
grpc_channel_destroy(channel); |
||||
if (response_payload_recv != NULL) { |
||||
grpc_byte_buffer_destroy(response_payload_recv); |
||||
} |
||||
grpc_shutdown(); |
||||
return 0; |
||||
} |
||||
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
@ -0,0 +1 @@ |
||||
!鮮 |
||||
@ -0,0 +1 @@ |
||||
ｩ｡鮮 |
||||
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Some files were not shown because too many files have changed in this diff Show More
Loading…
Reference in new issue