1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199
|
/* ****************************************************************************
*
* Copyright (c) Microsoft Corporation.
*
* This source code is subject to terms and conditions of the Microsoft Public License. A
* copy of the license can be found in the License.html file at the root of this distribution. If
* you cannot locate the Microsoft Public License, please send an email to
* dlr@microsoft.com. By using this source code in any fashion, you are agreeing to be bound
* by the terms of the Microsoft Public License.
*
* You must not remove this notice, or any other, from this software.
*
*
* ***************************************************************************/
using System;
using System.Linq.Expressions;
using System.Reflection;
using System.Runtime.CompilerServices;
using Microsoft.Scripting.Generation;
using Microsoft.Scripting.Utils;
using AstUtils = Microsoft.Scripting.Ast.Utils;
namespace Microsoft.Scripting.Interpreter {
public sealed class LightLambdaCompileEventArgs : EventArgs {
public Delegate Compiled { get; private set; }
internal LightLambdaCompileEventArgs(Delegate compiled) {
Compiled = compiled;
}
}
public partial class LightLambda {
private readonly StrongBox<object>[] _closure;
private readonly Interpreter _interpreter;
private static readonly CacheDict<Type, Func<LightLambda, Delegate>> _runCache = new CacheDict<Type, Func<LightLambda, Delegate>>(100);
// Adaptive compilation support
private readonly LightDelegateCreator _delegateCreator;
private Delegate _compiled;
/// <summary>
/// Provides notification that the LightLambda has been compiled.
/// </summary>
public event EventHandler<LightLambdaCompileEventArgs> Compile;
internal LightLambda(LightDelegateCreator delegateCreator, StrongBox<object>[] closure) {
_delegateCreator = delegateCreator;
_closure = closure;
_interpreter = delegateCreator.Interpreter;
}
private static MethodInfo GetRunMethodOrFastCtor(Type delegateType, out Func<LightLambda, Delegate> fastCtor) {
lock (_runCache) {
if (_runCache.TryGetValue(delegateType, out fastCtor)) {
return null;
}
return MakeRunMethodOrFastCtor(delegateType, out fastCtor);
}
}
private static MethodInfo MakeRunMethodOrFastCtor(Type delegateType, out Func<LightLambda, Delegate> fastCtor) {
var method = delegateType.GetMethod("Invoke");
var paramInfos = method.GetParameters();
Type[] paramTypes;
string name = "Run";
fastCtor = null;
if (paramInfos.Length >= MaxParameters) {
return null;
}
if (method.ReturnType == typeof(void)) {
name += "Void";
paramTypes = new Type[paramInfos.Length];
} else {
paramTypes = new Type[paramInfos.Length + 1];
paramTypes[paramTypes.Length - 1] = method.ReturnType;
}
MethodInfo runMethod;
if (method.ReturnType == typeof(void) && paramTypes.Length == 2 &&
paramInfos[0].ParameterType.IsByRef && paramInfos[1].ParameterType.IsByRef) {
runMethod = typeof(LightLambda).GetMethod("RunVoidRef2", BindingFlags.NonPublic | BindingFlags.Instance);
paramTypes[0] = paramInfos[0].ParameterType.GetElementType();
paramTypes[1] = paramInfos[1].ParameterType.GetElementType();
} else if (method.ReturnType == typeof(void) && paramTypes.Length == 0) {
return typeof(LightLambda).GetMethod("RunVoid0", BindingFlags.NonPublic | BindingFlags.Instance);
} else {
for (int i = 0; i < paramInfos.Length; i++) {
paramTypes[i] = paramInfos[i].ParameterType;
if (paramTypes[i].IsByRef) {
return null;
}
}
if (DelegateHelpers.MakeDelegate(paramTypes) == delegateType) {
name = "Make" + name + paramInfos.Length;
MethodInfo ctorMethod = typeof(LightLambda).GetMethod(name, BindingFlags.NonPublic | BindingFlags.Static).MakeGenericMethod(paramTypes);
_runCache[delegateType] = fastCtor = (Func<LightLambda, Delegate>)Delegate.CreateDelegate(typeof(Func<LightLambda, Delegate>), ctorMethod);
return null;
}
runMethod = typeof(LightLambda).GetMethod(name + paramInfos.Length, BindingFlags.NonPublic | BindingFlags.Instance);
}
return runMethod.MakeGenericMethod(paramTypes);
}
//TODO enable sharing of these custom delegates
private Delegate CreateCustomDelegate(Type delegateType) {
var method = delegateType.GetMethod("Invoke");
var paramInfos = method.GetParameters();
var parameters = new ParameterExpression[paramInfos.Length];
var parametersAsObject = new Expression[paramInfos.Length];
for (int i = 0; i < paramInfos.Length; i++) {
ParameterExpression parameter = Expression.Parameter(paramInfos[i].ParameterType, paramInfos[i].Name);
parameters[i] = parameter;
parametersAsObject[i] = Expression.Convert(parameter, typeof(object));
}
var data = Expression.NewArrayInit(typeof(object), parametersAsObject);
var self = AstUtils.Constant(this);
var runMethod = typeof(LightLambda).GetMethod("Run");
var body = Expression.Convert(Expression.Call(self, runMethod, data), method.ReturnType);
var lambda = Expression.Lambda(delegateType, body, parameters);
return lambda.Compile();
}
internal Delegate MakeDelegate(Type delegateType) {
Func<LightLambda, Delegate> fastCtor;
var method = GetRunMethodOrFastCtor(delegateType, out fastCtor);
if (fastCtor != null) {
return fastCtor(this);
} else if (method == null) {
return CreateCustomDelegate(delegateType);
}
return Delegate.CreateDelegate(delegateType, this, method);
}
private bool TryGetCompiled() {
// Use the compiled delegate if available.
if (_delegateCreator.HasCompiled) {
_compiled = _delegateCreator.CreateCompiledDelegate(_closure);
// Send it to anyone who's interested.
var compileEvent = Compile;
if (compileEvent != null && _delegateCreator.SameDelegateType) {
compileEvent(this, new LightLambdaCompileEventArgs(_compiled));
}
return true;
}
_delegateCreator.UpdateExecutionCount();
return false;
}
private InterpretedFrame MakeFrame() {
return new InterpretedFrame(_interpreter, _closure);
}
internal void RunVoidRef2<T0, T1>(ref T0 arg0, ref T1 arg1) {
if (_compiled != null || TryGetCompiled()) {
((ActionRef<T0, T1>)_compiled)(ref arg0, ref arg1);
return;
}
// copy in and copy out for today...
var frame = MakeFrame();
frame.Data[0] = arg0;
frame.Data[1] = arg1;
frame.BoxLocals();
var ret = _interpreter.Run(frame);
arg0 = (T0)frame.Data[0];
arg1 = (T1)frame.Data[1];
}
public object Run(params object[] arguments) {
if (_compiled != null || TryGetCompiled()) {
return _compiled.DynamicInvoke(arguments);
}
var frame = MakeFrame();
for (int i = 0; i < arguments.Length; i++) {
frame.Data[i] = arguments[i];
}
frame.BoxLocals();
object ret = _interpreter.Run(frame);
return ret;
}
}
}
|