CompilerContext.cs 54 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435
  1. #if FEAT_COMPILER
  2. //#define DEBUG_COMPILE
  3. using System;
  4. using System.Threading;
  5. using ProtoBuf.Meta;
  6. using ProtoBuf.Serializers;
  7. using System.Reflection;
  8. using System.Reflection.Emit;
  9. namespace ProtoBuf.Compiler
  10. {
  11. internal readonly struct CodeLabel
  12. {
  13. public readonly Label Value;
  14. public readonly int Index;
  15. public CodeLabel(Label value, int index)
  16. {
  17. this.Value = value;
  18. this.Index = index;
  19. }
  20. }
  21. internal sealed class CompilerContext
  22. {
  23. public TypeModel Model => model;
  24. readonly DynamicMethod method;
  25. static int next;
  26. internal CodeLabel DefineLabel()
  27. {
  28. CodeLabel result = new CodeLabel(il.DefineLabel(), nextLabel++);
  29. return result;
  30. }
  31. #if DEBUG_COMPILE
  32. static readonly string traceCompilePath;
  33. static CompilerContext()
  34. {
  35. traceCompilePath = System.IO.Path.Combine(System.IO.Directory.GetCurrentDirectory(),
  36. "TraceCompile.txt");
  37. Console.WriteLine("DEBUG_COMPILE enabled; writing to " + traceCompilePath);
  38. }
  39. #endif
  40. [System.Diagnostics.Conditional("DEBUG_COMPILE")]
  41. private void TraceCompile(string value)
  42. {
  43. #if DEBUG_COMPILE
  44. if (!string.IsNullOrWhiteSpace(value))
  45. {
  46. using (System.IO.StreamWriter sw = System.IO.File.AppendText(traceCompilePath))
  47. {
  48. sw.WriteLine(value);
  49. }
  50. }
  51. #endif
  52. }
  53. internal void MarkLabel(CodeLabel label)
  54. {
  55. il.MarkLabel(label.Value);
  56. TraceCompile("#: " + label.Index);
  57. }
  58. public static ProtoSerializer BuildSerializer(IProtoSerializer head, TypeModel model)
  59. {
  60. Type type = head.ExpectedType;
  61. try
  62. {
  63. CompilerContext ctx = new CompilerContext(type, true, true, model, typeof(object));
  64. ctx.LoadValue(ctx.InputValue);
  65. ctx.CastFromObject(type);
  66. ctx.WriteNullCheckedTail(type, head, null);
  67. ctx.Emit(OpCodes.Ret);
  68. return (ProtoSerializer)ctx.method.CreateDelegate(
  69. typeof(ProtoSerializer));
  70. }
  71. catch (Exception ex)
  72. {
  73. string name = type.FullName;
  74. if (string.IsNullOrEmpty(name)) name = type.Name;
  75. throw new InvalidOperationException("It was not possible to prepare a serializer for: " + name, ex);
  76. }
  77. }
  78. /*public static ProtoCallback BuildCallback(IProtoTypeSerializer head)
  79. {
  80. Type type = head.ExpectedType;
  81. CompilerContext ctx = new CompilerContext(type, true, true);
  82. using (Local typedVal = new Local(ctx, type))
  83. {
  84. ctx.LoadValue(Local.InputValue);
  85. ctx.CastFromObject(type);
  86. ctx.StoreValue(typedVal);
  87. CodeLabel[] jumpTable = new CodeLabel[4];
  88. for(int i = 0 ; i < jumpTable.Length ; i++) {
  89. jumpTable[i] = ctx.DefineLabel();
  90. }
  91. ctx.LoadReaderWriter();
  92. ctx.Switch(jumpTable);
  93. ctx.Return();
  94. for(int i = 0 ; i < jumpTable.Length ; i++) {
  95. ctx.MarkLabel(jumpTable[i]);
  96. if (head.HasCallbacks((TypeModel.CallbackType)i))
  97. {
  98. head.EmitCallback(ctx, typedVal, (TypeModel.CallbackType)i);
  99. }
  100. ctx.Return();
  101. }
  102. }
  103. ctx.Emit(OpCodes.Ret);
  104. return (ProtoCallback)ctx.method.CreateDelegate(
  105. typeof(ProtoCallback));
  106. }*/
  107. public static ProtoDeserializer BuildDeserializer(IProtoSerializer head, TypeModel model)
  108. {
  109. Type type = head.ExpectedType;
  110. CompilerContext ctx = new CompilerContext(type, false, true, model, typeof(object));
  111. using (Local typedVal = new Local(ctx, type))
  112. {
  113. if (!Helpers.IsValueType(type))
  114. {
  115. ctx.LoadValue(ctx.InputValue);
  116. ctx.CastFromObject(type);
  117. ctx.StoreValue(typedVal);
  118. }
  119. else
  120. {
  121. ctx.LoadValue(ctx.InputValue);
  122. CodeLabel notNull = ctx.DefineLabel(), endNull = ctx.DefineLabel();
  123. ctx.BranchIfTrue(notNull, true);
  124. ctx.LoadAddress(typedVal, type);
  125. ctx.EmitCtor(type);
  126. ctx.Branch(endNull, true);
  127. ctx.MarkLabel(notNull);
  128. ctx.LoadValue(ctx.InputValue);
  129. ctx.CastFromObject(type);
  130. ctx.StoreValue(typedVal);
  131. ctx.MarkLabel(endNull);
  132. }
  133. head.EmitRead(ctx, typedVal);
  134. if (head.ReturnsValue)
  135. {
  136. ctx.StoreValue(typedVal);
  137. }
  138. ctx.LoadValue(typedVal);
  139. ctx.CastToObject(type);
  140. }
  141. ctx.Emit(OpCodes.Ret);
  142. return (ProtoDeserializer)ctx.method.CreateDelegate(
  143. typeof(ProtoDeserializer));
  144. }
  145. internal void Return()
  146. {
  147. Emit(OpCodes.Ret);
  148. }
  149. static bool IsObject(Type type)
  150. {
  151. return type == typeof(object);
  152. }
  153. internal void CastToObject(Type type)
  154. {
  155. if (IsObject(type))
  156. { }
  157. else if (Helpers.IsValueType(type))
  158. {
  159. il.Emit(OpCodes.Box, type);
  160. TraceCompile(OpCodes.Box + ": " + type);
  161. }
  162. else
  163. {
  164. il.Emit(OpCodes.Castclass, MapType(typeof(object)));
  165. TraceCompile(OpCodes.Castclass + ": " + type);
  166. }
  167. }
  168. internal void CastFromObject(Type type)
  169. {
  170. if (IsObject(type))
  171. { }
  172. else if (Helpers.IsValueType(type))
  173. {
  174. switch (MetadataVersion)
  175. {
  176. case ILVersion.Net1:
  177. il.Emit(OpCodes.Unbox, type);
  178. il.Emit(OpCodes.Ldobj, type);
  179. TraceCompile(OpCodes.Unbox + ": " + type);
  180. TraceCompile(OpCodes.Ldobj + ": " + type);
  181. break;
  182. default:
  183. il.Emit(OpCodes.Unbox_Any, type);
  184. TraceCompile(OpCodes.Unbox_Any + ": " + type);
  185. break;
  186. }
  187. }
  188. else
  189. {
  190. il.Emit(OpCodes.Castclass, type);
  191. TraceCompile(OpCodes.Castclass + ": " + type);
  192. }
  193. }
  194. private readonly bool isStatic;
  195. private readonly RuntimeTypeModel.SerializerPair[] methodPairs;
  196. internal MethodBuilder GetDedicatedMethod(int metaKey, bool read)
  197. {
  198. if (methodPairs == null) return null;
  199. // but if we *do* have pairs, we demand that we find a match...
  200. for (int i = 0; i < methodPairs.Length; i++)
  201. {
  202. if (methodPairs[i].MetaKey == metaKey) { return read ? methodPairs[i].Deserialize : methodPairs[i].Serialize; }
  203. }
  204. throw new ArgumentException("Meta-key not found", "metaKey");
  205. }
  206. internal int MapMetaKeyToCompiledKey(int metaKey)
  207. {
  208. if (metaKey < 0 || methodPairs == null) return metaKey; // all meta, or a dummy/wildcard key
  209. for (int i = 0; i < methodPairs.Length; i++)
  210. {
  211. if (methodPairs[i].MetaKey == metaKey) return i;
  212. }
  213. throw new ArgumentException("Key could not be mapped: " + metaKey.ToString(), "metaKey");
  214. }
  215. private readonly bool isWriter;
  216. private readonly bool nonPublic;
  217. internal bool NonPublic { get { return nonPublic; } }
  218. private readonly Local inputValue;
  219. public Local InputValue { get { return inputValue; } }
  220. private readonly string assemblyName;
  221. internal CompilerContext(ILGenerator il, bool isStatic, bool isWriter, RuntimeTypeModel.SerializerPair[] methodPairs, TypeModel model, ILVersion metadataVersion, string assemblyName, Type inputType, string traceName)
  222. {
  223. if (string.IsNullOrEmpty(assemblyName)) throw new ArgumentNullException(nameof(assemblyName));
  224. this.assemblyName = assemblyName;
  225. this.isStatic = isStatic;
  226. this.methodPairs = methodPairs ?? throw new ArgumentNullException(nameof(methodPairs));
  227. this.il = il ?? throw new ArgumentNullException(nameof(il));
  228. // nonPublic = false; <== implicit
  229. this.isWriter = isWriter;
  230. this.model = model ?? throw new ArgumentNullException(nameof(model));
  231. this.metadataVersion = metadataVersion;
  232. if (inputType != null) this.inputValue = new Local(null, inputType);
  233. TraceCompile(">> " + traceName);
  234. }
  235. private CompilerContext(Type associatedType, bool isWriter, bool isStatic, TypeModel model, Type inputType)
  236. {
  237. metadataVersion = ILVersion.Net2;
  238. this.isStatic = isStatic;
  239. this.isWriter = isWriter;
  240. this.model = model ?? throw new ArgumentNullException(nameof(model));
  241. nonPublic = true;
  242. Type[] paramTypes;
  243. Type returnType;
  244. if (isWriter)
  245. {
  246. returnType = typeof(void);
  247. paramTypes = new Type[] { typeof(object), typeof(ProtoWriter) };
  248. }
  249. else
  250. {
  251. returnType = typeof(object);
  252. paramTypes = new Type[] { typeof(object), typeof(ProtoReader) };
  253. }
  254. int uniqueIdentifier;
  255. #if PLAT_NO_INTERLOCKED
  256. uniqueIdentifier = ++next;
  257. #else
  258. uniqueIdentifier = Interlocked.Increment(ref next);
  259. #endif
  260. method = new DynamicMethod("proto_" + uniqueIdentifier.ToString(), returnType, paramTypes, associatedType
  261. #if COREFX
  262. .GetTypeInfo()
  263. #endif
  264. .IsInterface ? typeof(object) : associatedType, true);
  265. this.il = method.GetILGenerator();
  266. if (inputType != null) this.inputValue = new Local(null, inputType);
  267. TraceCompile(">> " + method.Name);
  268. }
  269. private readonly ILGenerator il;
  270. private void Emit(OpCode opcode)
  271. {
  272. il.Emit(opcode);
  273. TraceCompile(opcode.ToString());
  274. }
  275. public void LoadValue(string value)
  276. {
  277. if (value == null)
  278. {
  279. LoadNullRef();
  280. }
  281. else
  282. {
  283. il.Emit(OpCodes.Ldstr, value);
  284. TraceCompile(OpCodes.Ldstr + ": " + value);
  285. }
  286. }
  287. public void LoadValue(float value)
  288. {
  289. il.Emit(OpCodes.Ldc_R4, value);
  290. TraceCompile(OpCodes.Ldc_R4 + ": " + value);
  291. }
  292. public void LoadValue(double value)
  293. {
  294. il.Emit(OpCodes.Ldc_R8, value);
  295. TraceCompile(OpCodes.Ldc_R8 + ": " + value);
  296. }
  297. public void LoadValue(long value)
  298. {
  299. il.Emit(OpCodes.Ldc_I8, value);
  300. TraceCompile(OpCodes.Ldc_I8 + ": " + value);
  301. }
  302. public void LoadValue(int value)
  303. {
  304. switch (value)
  305. {
  306. case 0: Emit(OpCodes.Ldc_I4_0); break;
  307. case 1: Emit(OpCodes.Ldc_I4_1); break;
  308. case 2: Emit(OpCodes.Ldc_I4_2); break;
  309. case 3: Emit(OpCodes.Ldc_I4_3); break;
  310. case 4: Emit(OpCodes.Ldc_I4_4); break;
  311. case 5: Emit(OpCodes.Ldc_I4_5); break;
  312. case 6: Emit(OpCodes.Ldc_I4_6); break;
  313. case 7: Emit(OpCodes.Ldc_I4_7); break;
  314. case 8: Emit(OpCodes.Ldc_I4_8); break;
  315. case -1: Emit(OpCodes.Ldc_I4_M1); break;
  316. default:
  317. if (value >= -128 && value <= 127)
  318. {
  319. il.Emit(OpCodes.Ldc_I4_S, (sbyte)value);
  320. TraceCompile(OpCodes.Ldc_I4_S + ": " + value);
  321. }
  322. else
  323. {
  324. il.Emit(OpCodes.Ldc_I4, value);
  325. TraceCompile(OpCodes.Ldc_I4 + ": " + value);
  326. }
  327. break;
  328. }
  329. }
  330. MutableList locals = new MutableList();
  331. internal LocalBuilder GetFromPool(Type type)
  332. {
  333. int count = locals.Count;
  334. for (int i = 0; i < count; i++)
  335. {
  336. LocalBuilder item = (LocalBuilder)locals[i];
  337. if (item != null && item.LocalType == type)
  338. {
  339. locals[i] = null; // remove from pool
  340. return item;
  341. }
  342. }
  343. LocalBuilder result = il.DeclareLocal(type);
  344. TraceCompile("$ " + result + ": " + type);
  345. return result;
  346. }
  347. //
  348. internal void ReleaseToPool(LocalBuilder value)
  349. {
  350. int count = locals.Count;
  351. for (int i = 0; i < count; i++)
  352. {
  353. if (locals[i] == null)
  354. {
  355. locals[i] = value; // released into existing slot
  356. return;
  357. }
  358. }
  359. locals.Add(value); // create a new slot
  360. }
  361. public void LoadReaderWriter()
  362. {
  363. Emit(isStatic ? OpCodes.Ldarg_1 : OpCodes.Ldarg_2);
  364. }
  365. public void StoreValue(Local local)
  366. {
  367. if (local == this.InputValue)
  368. {
  369. byte b = isStatic ? (byte)0 : (byte)1;
  370. il.Emit(OpCodes.Starg_S, b);
  371. TraceCompile(OpCodes.Starg_S + ": $" + b);
  372. }
  373. else
  374. {
  375. switch (local.Value.LocalIndex)
  376. {
  377. case 0: Emit(OpCodes.Stloc_0); break;
  378. case 1: Emit(OpCodes.Stloc_1); break;
  379. case 2: Emit(OpCodes.Stloc_2); break;
  380. case 3: Emit(OpCodes.Stloc_3); break;
  381. default:
  382. OpCode code = UseShortForm(local) ? OpCodes.Stloc_S : OpCodes.Stloc;
  383. il.Emit(code, local.Value);
  384. TraceCompile(code + ": $" + local.Value);
  385. break;
  386. }
  387. }
  388. }
  389. public void LoadValue(Local local)
  390. {
  391. if (local == null) { /* nothing to do; top of stack */}
  392. else if (local == this.InputValue)
  393. {
  394. Emit(isStatic ? OpCodes.Ldarg_0 : OpCodes.Ldarg_1);
  395. }
  396. else
  397. {
  398. switch (local.Value.LocalIndex)
  399. {
  400. case 0: Emit(OpCodes.Ldloc_0); break;
  401. case 1: Emit(OpCodes.Ldloc_1); break;
  402. case 2: Emit(OpCodes.Ldloc_2); break;
  403. case 3: Emit(OpCodes.Ldloc_3); break;
  404. default:
  405. OpCode code = UseShortForm(local) ? OpCodes.Ldloc_S : OpCodes.Ldloc;
  406. il.Emit(code, local.Value);
  407. TraceCompile(code + ": $" + local.Value);
  408. break;
  409. }
  410. }
  411. }
  412. public Local GetLocalWithValue(Type type, Compiler.Local fromValue)
  413. {
  414. if (fromValue != null)
  415. {
  416. if (fromValue.Type == type) return fromValue.AsCopy();
  417. // otherwise, load onto the stack and let the default handling (below) deal with it
  418. LoadValue(fromValue);
  419. if (!Helpers.IsValueType(type) && (fromValue.Type == null || !type.IsAssignableFrom(fromValue.Type)))
  420. { // need to cast
  421. Cast(type);
  422. }
  423. }
  424. // need to store the value from the stack
  425. Local result = new Local(this, type);
  426. StoreValue(result);
  427. return result;
  428. }
  429. internal void EmitBasicRead(string methodName, Type expectedType)
  430. {
  431. MethodInfo method = MapType(typeof(ProtoReader)).GetMethod(
  432. methodName, BindingFlags.Public | BindingFlags.NonPublic | BindingFlags.Instance);
  433. if (method == null || method.ReturnType != expectedType
  434. || method.GetParameters().Length != 0) throw new ArgumentException("methodName");
  435. LoadReaderWriter();
  436. EmitCall(method);
  437. }
  438. internal void EmitBasicRead(Type helperType, string methodName, Type expectedType)
  439. {
  440. MethodInfo method = helperType.GetMethod(
  441. methodName, BindingFlags.Public | BindingFlags.NonPublic | BindingFlags.Static);
  442. if (method == null || method.ReturnType != expectedType
  443. || method.GetParameters().Length != 1) throw new ArgumentException("methodName");
  444. LoadReaderWriter();
  445. EmitCall(method);
  446. }
  447. internal void EmitBasicWrite(string methodName, Compiler.Local fromValue)
  448. {
  449. if (string.IsNullOrEmpty(methodName)) throw new ArgumentNullException("methodName");
  450. LoadValue(fromValue);
  451. LoadReaderWriter();
  452. EmitCall(GetWriterMethod(methodName));
  453. }
  454. private MethodInfo GetWriterMethod(string methodName)
  455. {
  456. Type writerType = MapType(typeof(ProtoWriter));
  457. MethodInfo[] methods = writerType.GetMethods(BindingFlags.Public | BindingFlags.NonPublic | BindingFlags.Static);
  458. foreach (MethodInfo method in methods)
  459. {
  460. if (method.Name != methodName) continue;
  461. ParameterInfo[] pis = method.GetParameters();
  462. if (pis.Length == 2 && pis[1].ParameterType == writerType) return method;
  463. }
  464. throw new ArgumentException("No suitable method found for: " + methodName, "methodName");
  465. }
  466. internal void EmitWrite(Type helperType, string methodName, Compiler.Local valueFrom)
  467. {
  468. if (string.IsNullOrEmpty(methodName)) throw new ArgumentNullException("methodName");
  469. MethodInfo method = helperType.GetMethod(
  470. methodName, BindingFlags.Public | BindingFlags.NonPublic | BindingFlags.Static);
  471. if (method == null || method.ReturnType != MapType(typeof(void))) throw new ArgumentException("methodName");
  472. LoadValue(valueFrom);
  473. LoadReaderWriter();
  474. EmitCall(method);
  475. }
  476. public void EmitCall(MethodInfo method) { EmitCall(method, null); }
  477. public void EmitCall(MethodInfo method, Type targetType)
  478. {
  479. Helpers.DebugAssert(method != null);
  480. MemberInfo member = method;
  481. CheckAccessibility(ref member);
  482. OpCode opcode;
  483. if (method.IsStatic || Helpers.IsValueType(method.DeclaringType))
  484. {
  485. opcode = OpCodes.Call;
  486. }
  487. else
  488. {
  489. opcode = OpCodes.Callvirt;
  490. if (targetType != null && Helpers.IsValueType(targetType) && !Helpers.IsValueType(method.DeclaringType))
  491. {
  492. Constrain(targetType);
  493. }
  494. }
  495. il.EmitCall(opcode, method, null);
  496. TraceCompile(opcode + ": " + method + " on " + method.DeclaringType + (targetType == null ? "" : (" via " + targetType)));
  497. }
  498. /// <summary>
  499. /// Pushes a null reference onto the stack. Note that this should only
  500. /// be used to return a null (or set a variable to null); for null-tests
  501. /// use BranchIfTrue / BranchIfFalse.
  502. /// </summary>
  503. public void LoadNullRef()
  504. {
  505. Emit(OpCodes.Ldnull);
  506. }
  507. private int nextLabel;
  508. internal void WriteNullCheckedTail(Type type, IProtoSerializer tail, Compiler.Local valueFrom)
  509. {
  510. if (Helpers.IsValueType(type))
  511. {
  512. Type underlyingType = Helpers.GetUnderlyingType(type);
  513. if (underlyingType == null)
  514. { // not a nullable T; can invoke directly
  515. tail.EmitWrite(this, valueFrom);
  516. }
  517. else
  518. { // nullable T; check HasValue
  519. using (Compiler.Local valOrNull = GetLocalWithValue(type, valueFrom))
  520. {
  521. LoadAddress(valOrNull, type);
  522. LoadValue(type.GetProperty("HasValue"));
  523. CodeLabel @end = DefineLabel();
  524. BranchIfFalse(@end, false);
  525. LoadAddress(valOrNull, type);
  526. EmitCall(type.GetMethod("GetValueOrDefault", Helpers.EmptyTypes));
  527. tail.EmitWrite(this, null);
  528. MarkLabel(@end);
  529. }
  530. }
  531. }
  532. else
  533. { // ref-type; do a null-check
  534. LoadValue(valueFrom);
  535. CopyValue();
  536. CodeLabel hasVal = DefineLabel(), @end = DefineLabel();
  537. BranchIfTrue(hasVal, true);
  538. DiscardValue();
  539. Branch(@end, false);
  540. MarkLabel(hasVal);
  541. tail.EmitWrite(this, null);
  542. MarkLabel(@end);
  543. }
  544. }
  545. internal void ReadNullCheckedTail(Type type, IProtoSerializer tail, Compiler.Local valueFrom)
  546. {
  547. Type underlyingType;
  548. if (Helpers.IsValueType(type) && (underlyingType = Helpers.GetUnderlyingType(type)) != null)
  549. {
  550. if (tail.RequiresOldValue)
  551. {
  552. // we expect the input value to be in valueFrom; need to unpack it from T?
  553. using (Local loc = GetLocalWithValue(type, valueFrom))
  554. {
  555. LoadAddress(loc, type);
  556. EmitCall(type.GetMethod("GetValueOrDefault", Helpers.EmptyTypes));
  557. }
  558. }
  559. else
  560. {
  561. Helpers.DebugAssert(valueFrom == null); // not expecting a valueFrom in this case
  562. }
  563. tail.EmitRead(this, null); // either unwrapped on the stack or not provided
  564. if (tail.ReturnsValue)
  565. {
  566. // now re-wrap the value
  567. EmitCtor(type, underlyingType);
  568. }
  569. return;
  570. }
  571. // either a ref-type of a non-nullable struct; treat "as is", even if null
  572. // (the type-serializer will handle the null case; it needs to allow null
  573. // inputs to perform the correct type of subclass creation)
  574. tail.EmitRead(this, valueFrom);
  575. }
  576. public void EmitCtor(Type type)
  577. {
  578. EmitCtor(type, Helpers.EmptyTypes);
  579. }
  580. public void EmitCtor(ConstructorInfo ctor)
  581. {
  582. if (ctor == null) throw new ArgumentNullException("ctor");
  583. MemberInfo ctorMember = ctor;
  584. CheckAccessibility(ref ctorMember);
  585. il.Emit(OpCodes.Newobj, ctor);
  586. TraceCompile(OpCodes.Newobj + ": " + ctor.DeclaringType);
  587. }
  588. public void InitLocal(Type type, Compiler.Local target)
  589. {
  590. LoadAddress(target, type, evenIfClass: true); // for class, initobj is a load-null, store-indirect
  591. il.Emit(OpCodes.Initobj, type);
  592. TraceCompile(OpCodes.Initobj + ": " + type);
  593. }
  594. public void EmitCtor(Type type, params Type[] parameterTypes)
  595. {
  596. Helpers.DebugAssert(type != null);
  597. Helpers.DebugAssert(parameterTypes != null);
  598. if (Helpers.IsValueType(type) && parameterTypes.Length == 0)
  599. {
  600. il.Emit(OpCodes.Initobj, type);
  601. TraceCompile(OpCodes.Initobj + ": " + type);
  602. }
  603. else
  604. {
  605. ConstructorInfo ctor = Helpers.GetConstructor(type
  606. #if COREFX
  607. .GetTypeInfo()
  608. #endif
  609. , parameterTypes, true);
  610. if (ctor == null) throw new InvalidOperationException("No suitable constructor found for " + type.FullName);
  611. EmitCtor(ctor);
  612. }
  613. }
  614. BasicList knownTrustedAssemblies, knownUntrustedAssemblies;
  615. bool InternalsVisible(Assembly assembly)
  616. {
  617. if (string.IsNullOrEmpty(assemblyName)) return false;
  618. if (knownTrustedAssemblies != null)
  619. {
  620. if (knownTrustedAssemblies.IndexOfReference(assembly) >= 0)
  621. {
  622. return true;
  623. }
  624. }
  625. if (knownUntrustedAssemblies != null)
  626. {
  627. if (knownUntrustedAssemblies.IndexOfReference(assembly) >= 0)
  628. {
  629. return false;
  630. }
  631. }
  632. bool isTrusted = false;
  633. Type attributeType = MapType(typeof(System.Runtime.CompilerServices.InternalsVisibleToAttribute));
  634. if (attributeType == null) return false;
  635. #if COREFX
  636. foreach (System.Runtime.CompilerServices.InternalsVisibleToAttribute attrib in assembly.GetCustomAttributes(attributeType))
  637. #else
  638. foreach (System.Runtime.CompilerServices.InternalsVisibleToAttribute attrib in assembly.GetCustomAttributes(attributeType, false))
  639. #endif
  640. {
  641. if (attrib.AssemblyName == assemblyName || attrib.AssemblyName.StartsWith(assemblyName + ","))
  642. {
  643. isTrusted = true;
  644. break;
  645. }
  646. }
  647. if (isTrusted)
  648. {
  649. if (knownTrustedAssemblies == null) knownTrustedAssemblies = new BasicList();
  650. knownTrustedAssemblies.Add(assembly);
  651. }
  652. else
  653. {
  654. if (knownUntrustedAssemblies == null) knownUntrustedAssemblies = new BasicList();
  655. knownUntrustedAssemblies.Add(assembly);
  656. }
  657. return isTrusted;
  658. }
  659. internal void CheckAccessibility(ref MemberInfo member)
  660. {
  661. if (member == null)
  662. {
  663. throw new ArgumentNullException(nameof(member));
  664. }
  665. #if !COREFX
  666. Type type;
  667. #endif
  668. if (!NonPublic)
  669. {
  670. if (member is FieldInfo && member.Name.StartsWith("<") & member.Name.EndsWith(">k__BackingField"))
  671. {
  672. var propName = member.Name.Substring(1, member.Name.Length - 17);
  673. var prop = member.DeclaringType.GetProperty(propName, BindingFlags.Public | BindingFlags.Instance | BindingFlags.Static);
  674. if (prop != null) member = prop;
  675. }
  676. bool isPublic;
  677. #if COREFX
  678. if (member is TypeInfo)
  679. {
  680. TypeInfo ti = (TypeInfo)member;
  681. do
  682. {
  683. isPublic = ti.IsNestedPublic || ti.IsPublic || ((ti.IsNested || ti.IsNestedAssembly || ti.IsNestedFamORAssem) && InternalsVisible(ti.Assembly));
  684. } while (isPublic && ti.IsNested && (ti = ti.DeclaringType.GetTypeInfo()) != null);
  685. }
  686. else if (member is FieldInfo)
  687. {
  688. FieldInfo field = ((FieldInfo)member);
  689. isPublic = field.IsPublic || ((field.IsAssembly || field.IsFamilyOrAssembly) && InternalsVisible(Helpers.GetAssembly(field.DeclaringType)));
  690. }
  691. else if (member is PropertyInfo)
  692. {
  693. isPublic = true; // defer to get/set
  694. }
  695. else if (member is ConstructorInfo)
  696. {
  697. ConstructorInfo ctor = ((ConstructorInfo)member);
  698. isPublic = ctor.IsPublic || ((ctor.IsAssembly || ctor.IsFamilyOrAssembly) && InternalsVisible(Helpers.GetAssembly(ctor.DeclaringType)));
  699. }
  700. else if (member is MethodInfo)
  701. {
  702. MethodInfo method = ((MethodInfo)member);
  703. isPublic = method.IsPublic || ((method.IsAssembly || method.IsFamilyOrAssembly) && InternalsVisible(Helpers.GetAssembly(method.DeclaringType)));
  704. if (!isPublic)
  705. {
  706. // allow calls to TypeModel protected methods, and methods we are in the process of creating
  707. if (
  708. member is MethodBuilder ||
  709. member.DeclaringType == MapType(typeof(TypeModel)))
  710. isPublic = true;
  711. }
  712. }
  713. else
  714. {
  715. throw new NotSupportedException(member.GetType().Name);
  716. }
  717. #else
  718. MemberTypes memberType = member.MemberType;
  719. switch (memberType)
  720. {
  721. case MemberTypes.TypeInfo:
  722. // top-level type
  723. type = (Type)member;
  724. isPublic = type.IsPublic || InternalsVisible(type.Assembly);
  725. break;
  726. case MemberTypes.NestedType:
  727. type = (Type)member;
  728. do
  729. {
  730. isPublic = type.IsNestedPublic || type.IsPublic || ((type.DeclaringType == null || type.IsNestedAssembly || type.IsNestedFamORAssem) && InternalsVisible(type.Assembly));
  731. } while (isPublic && (type = type.DeclaringType) != null); // ^^^ !type.IsNested, but not all runtimes have that
  732. break;
  733. case MemberTypes.Field:
  734. FieldInfo field = ((FieldInfo)member);
  735. isPublic = field.IsPublic || ((field.IsAssembly || field.IsFamilyOrAssembly) && InternalsVisible(field.DeclaringType.Assembly));
  736. break;
  737. case MemberTypes.Constructor:
  738. ConstructorInfo ctor = ((ConstructorInfo)member);
  739. isPublic = ctor.IsPublic || ((ctor.IsAssembly || ctor.IsFamilyOrAssembly) && InternalsVisible(ctor.DeclaringType.Assembly));
  740. break;
  741. case MemberTypes.Method:
  742. MethodInfo method = ((MethodInfo)member);
  743. isPublic = method.IsPublic || ((method.IsAssembly || method.IsFamilyOrAssembly) && InternalsVisible(method.DeclaringType.Assembly));
  744. if (!isPublic)
  745. {
  746. // allow calls to TypeModel protected methods, and methods we are in the process of creating
  747. if (
  748. member is MethodBuilder ||
  749. member.DeclaringType == MapType(typeof(TypeModel))) isPublic = true;
  750. }
  751. break;
  752. case MemberTypes.Property:
  753. isPublic = true; // defer to get/set
  754. break;
  755. default:
  756. throw new NotSupportedException(memberType.ToString());
  757. }
  758. #endif
  759. if (!isPublic)
  760. {
  761. #if COREFX
  762. if (member is TypeInfo)
  763. {
  764. throw new InvalidOperationException("Non-public type cannot be used with full dll compilation: " +
  765. ((TypeInfo)member).FullName);
  766. }
  767. else
  768. {
  769. throw new InvalidOperationException("Non-public member cannot be used with full dll compilation: " +
  770. member.DeclaringType.FullName + "." + member.Name);
  771. }
  772. #else
  773. switch (memberType)
  774. {
  775. case MemberTypes.TypeInfo:
  776. case MemberTypes.NestedType:
  777. throw new InvalidOperationException("Non-public type cannot be used with full dll compilation: " +
  778. ((Type)member).FullName);
  779. default:
  780. throw new InvalidOperationException("Non-public member cannot be used with full dll compilation: " +
  781. member.DeclaringType.FullName + "." + member.Name);
  782. }
  783. #endif
  784. }
  785. }
  786. }
  787. public void LoadValue(FieldInfo field)
  788. {
  789. MemberInfo member = field;
  790. CheckAccessibility(ref member);
  791. if (member is PropertyInfo)
  792. {
  793. LoadValue((PropertyInfo)member);
  794. }
  795. else
  796. {
  797. OpCode code = field.IsStatic ? OpCodes.Ldsfld : OpCodes.Ldfld;
  798. il.Emit(code, field);
  799. TraceCompile(code + ": " + field + " on " + field.DeclaringType);
  800. }
  801. }
  802. public void StoreValue(FieldInfo field)
  803. {
  804. MemberInfo member = field;
  805. CheckAccessibility(ref member);
  806. if (member is PropertyInfo)
  807. {
  808. StoreValue((PropertyInfo)member);
  809. }
  810. else
  811. {
  812. OpCode code = field.IsStatic ? OpCodes.Stsfld : OpCodes.Stfld;
  813. il.Emit(code, field);
  814. TraceCompile(code + ": " + field + " on " + field.DeclaringType);
  815. }
  816. }
  817. public void LoadValue(PropertyInfo property)
  818. {
  819. MemberInfo member = property;
  820. CheckAccessibility(ref member);
  821. EmitCall(Helpers.GetGetMethod(property, true, true));
  822. }
  823. public void StoreValue(PropertyInfo property)
  824. {
  825. MemberInfo member = property;
  826. CheckAccessibility(ref member);
  827. EmitCall(Helpers.GetSetMethod(property, true, true));
  828. }
  829. //internal void EmitInstance()
  830. //{
  831. // if (isStatic) throw new InvalidOperationException();
  832. // Emit(OpCodes.Ldarg_0);
  833. //}
  834. internal static void LoadValue(ILGenerator il, int value)
  835. {
  836. switch (value)
  837. {
  838. case 0: il.Emit(OpCodes.Ldc_I4_0); break;
  839. case 1: il.Emit(OpCodes.Ldc_I4_1); break;
  840. case 2: il.Emit(OpCodes.Ldc_I4_2); break;
  841. case 3: il.Emit(OpCodes.Ldc_I4_3); break;
  842. case 4: il.Emit(OpCodes.Ldc_I4_4); break;
  843. case 5: il.Emit(OpCodes.Ldc_I4_5); break;
  844. case 6: il.Emit(OpCodes.Ldc_I4_6); break;
  845. case 7: il.Emit(OpCodes.Ldc_I4_7); break;
  846. case 8: il.Emit(OpCodes.Ldc_I4_8); break;
  847. case -1: il.Emit(OpCodes.Ldc_I4_M1); break;
  848. default: il.Emit(OpCodes.Ldc_I4, value); break;
  849. }
  850. }
  851. private bool UseShortForm(Local local)
  852. {
  853. return local.Value.LocalIndex < 256;
  854. }
  855. internal void LoadAddress(Local local, Type type, bool evenIfClass = false)
  856. {
  857. if (evenIfClass || Helpers.IsValueType(type))
  858. {
  859. if (local == null)
  860. {
  861. throw new InvalidOperationException("Cannot load the address of the head of the stack");
  862. }
  863. if (local == this.InputValue)
  864. {
  865. il.Emit(OpCodes.Ldarga_S, (isStatic ? (byte)0 : (byte)1));
  866. TraceCompile(OpCodes.Ldarga_S + ": $" + (isStatic ? 0 : 1));
  867. }
  868. else
  869. {
  870. OpCode code = UseShortForm(local) ? OpCodes.Ldloca_S : OpCodes.Ldloca;
  871. il.Emit(code, local.Value);
  872. TraceCompile(code + ": $" + local.Value);
  873. }
  874. }
  875. else
  876. { // reference-type; already *is* the address; just load it
  877. LoadValue(local);
  878. }
  879. }
  880. internal void Branch(CodeLabel label, bool @short)
  881. {
  882. OpCode code = @short ? OpCodes.Br_S : OpCodes.Br;
  883. il.Emit(code, label.Value);
  884. TraceCompile(code + ": " + label.Index);
  885. }
  886. internal void BranchIfFalse(CodeLabel label, bool @short)
  887. {
  888. OpCode code = @short ? OpCodes.Brfalse_S : OpCodes.Brfalse;
  889. il.Emit(code, label.Value);
  890. TraceCompile(code + ": " + label.Index);
  891. }
  892. internal void BranchIfTrue(CodeLabel label, bool @short)
  893. {
  894. OpCode code = @short ? OpCodes.Brtrue_S : OpCodes.Brtrue;
  895. il.Emit(code, label.Value);
  896. TraceCompile(code + ": " + label.Index);
  897. }
  898. internal void BranchIfEqual(CodeLabel label, bool @short)
  899. {
  900. OpCode code = @short ? OpCodes.Beq_S : OpCodes.Beq;
  901. il.Emit(code, label.Value);
  902. TraceCompile(code + ": " + label.Index);
  903. }
  904. //internal void TestEqual()
  905. //{
  906. // Emit(OpCodes.Ceq);
  907. //}
  908. internal void CopyValue()
  909. {
  910. Emit(OpCodes.Dup);
  911. }
  912. internal void BranchIfGreater(CodeLabel label, bool @short)
  913. {
  914. OpCode code = @short ? OpCodes.Bgt_S : OpCodes.Bgt;
  915. il.Emit(code, label.Value);
  916. TraceCompile(code + ": " + label.Index);
  917. }
  918. internal void BranchIfLess(CodeLabel label, bool @short)
  919. {
  920. OpCode code = @short ? OpCodes.Blt_S : OpCodes.Blt;
  921. il.Emit(code, label.Value);
  922. TraceCompile(code + ": " + label.Index);
  923. }
  924. internal void DiscardValue()
  925. {
  926. Emit(OpCodes.Pop);
  927. }
  928. public void Subtract()
  929. {
  930. Emit(OpCodes.Sub);
  931. }
  932. public void Switch(CodeLabel[] jumpTable)
  933. {
  934. const int MAX_JUMPS = 128;
  935. if (jumpTable.Length <= MAX_JUMPS)
  936. {
  937. // simple case
  938. Label[] labels = new Label[jumpTable.Length];
  939. for (int i = 0; i < labels.Length; i++)
  940. {
  941. labels[i] = jumpTable[i].Value;
  942. }
  943. TraceCompile(OpCodes.Switch.ToString());
  944. il.Emit(OpCodes.Switch, labels);
  945. }
  946. else
  947. {
  948. // too many to jump easily (especially on Android) - need to split up (note: uses a local pulled from the stack)
  949. using (Local val = GetLocalWithValue(MapType(typeof(int)), null))
  950. {
  951. int count = jumpTable.Length, offset = 0;
  952. int blockCount = count / MAX_JUMPS;
  953. if ((count % MAX_JUMPS) != 0) blockCount++;
  954. Label[] blockLabels = new Label[blockCount];
  955. for (int i = 0; i < blockCount; i++)
  956. {
  957. blockLabels[i] = il.DefineLabel();
  958. }
  959. CodeLabel endOfSwitch = DefineLabel();
  960. LoadValue(val);
  961. LoadValue(MAX_JUMPS);
  962. Emit(OpCodes.Div);
  963. TraceCompile(OpCodes.Switch.ToString());
  964. il.Emit(OpCodes.Switch, blockLabels);
  965. Branch(endOfSwitch, false);
  966. Label[] innerLabels = new Label[MAX_JUMPS];
  967. for (int blockIndex = 0; blockIndex < blockCount; blockIndex++)
  968. {
  969. il.MarkLabel(blockLabels[blockIndex]);
  970. int itemsThisBlock = Math.Min(MAX_JUMPS, count);
  971. count -= itemsThisBlock;
  972. if (innerLabels.Length != itemsThisBlock) innerLabels = new Label[itemsThisBlock];
  973. int subtract = offset;
  974. for (int j = 0; j < itemsThisBlock; j++)
  975. {
  976. innerLabels[j] = jumpTable[offset++].Value;
  977. }
  978. LoadValue(val);
  979. if (subtract != 0) // switches are always zero-based
  980. {
  981. LoadValue(subtract);
  982. Emit(OpCodes.Sub);
  983. }
  984. TraceCompile(OpCodes.Switch.ToString());
  985. il.Emit(OpCodes.Switch, innerLabels);
  986. if (count != 0)
  987. { // force default to the very bottom
  988. Branch(endOfSwitch, false);
  989. }
  990. }
  991. Helpers.DebugAssert(count == 0, "Should use exactly all switch items");
  992. MarkLabel(endOfSwitch);
  993. }
  994. }
  995. }
  996. internal void EndFinally()
  997. {
  998. il.EndExceptionBlock();
  999. TraceCompile("EndExceptionBlock");
  1000. }
  1001. internal void BeginFinally()
  1002. {
  1003. il.BeginFinallyBlock();
  1004. TraceCompile("BeginFinallyBlock");
  1005. }
  1006. internal void EndTry(CodeLabel label, bool @short)
  1007. {
  1008. OpCode code = @short ? OpCodes.Leave_S : OpCodes.Leave;
  1009. il.Emit(code, label.Value);
  1010. TraceCompile(code + ": " + label.Index);
  1011. }
  1012. internal CodeLabel BeginTry()
  1013. {
  1014. CodeLabel label = new CodeLabel(il.BeginExceptionBlock(), nextLabel++);
  1015. TraceCompile("BeginExceptionBlock: " + label.Index);
  1016. return label;
  1017. }
  1018. internal void Constrain(Type type)
  1019. {
  1020. il.Emit(OpCodes.Constrained, type);
  1021. TraceCompile(OpCodes.Constrained + ": " + type);
  1022. }
  1023. internal void TryCast(Type type)
  1024. {
  1025. il.Emit(OpCodes.Isinst, type);
  1026. TraceCompile(OpCodes.Isinst + ": " + type);
  1027. }
  1028. internal void Cast(Type type)
  1029. {
  1030. il.Emit(OpCodes.Castclass, type);
  1031. TraceCompile(OpCodes.Castclass + ": " + type);
  1032. }
  1033. public IDisposable Using(Local local)
  1034. {
  1035. return new UsingBlock(this, local);
  1036. }
  1037. private sealed class UsingBlock : IDisposable
  1038. {
  1039. private Local local;
  1040. CompilerContext ctx;
  1041. CodeLabel label;
  1042. /// <summary>
  1043. /// Creates a new "using" block (equivalent) around a variable;
  1044. /// the variable must exist, and note that (unlike in C#) it is
  1045. /// the variables *final* value that gets disposed. If you need
  1046. /// *original* disposal, copy your variable first.
  1047. ///
  1048. /// It is the callers responsibility to ensure that the variable's
  1049. /// scope fully-encapsulates the "using"; if not, the variable
  1050. /// may be re-used (and thus re-assigned) unexpectedly.
  1051. /// </summary>
  1052. public UsingBlock(CompilerContext ctx, Local local)
  1053. {
  1054. if (ctx == null) throw new ArgumentNullException("ctx");
  1055. if (local == null) throw new ArgumentNullException("local");
  1056. Type type = local.Type;
  1057. // check if **never** disposable
  1058. if ((Helpers.IsValueType(type) || Helpers.IsSealed(type)) &&
  1059. !ctx.MapType(typeof(IDisposable)).IsAssignableFrom(type))
  1060. {
  1061. return; // nothing to do! easiest "using" block ever
  1062. // (note that C# wouldn't allow this as a "using" block,
  1063. // but we'll be generous and simply not do anything)
  1064. }
  1065. this.local = local;
  1066. this.ctx = ctx;
  1067. label = ctx.BeginTry();
  1068. }
  1069. public void Dispose()
  1070. {
  1071. if (local == null || ctx == null) return;
  1072. ctx.EndTry(label, false);
  1073. ctx.BeginFinally();
  1074. Type disposableType = ctx.MapType(typeof(IDisposable));
  1075. MethodInfo dispose = disposableType.GetMethod("Dispose");
  1076. Type type = local.Type;
  1077. // remember that we've already (in the .ctor) excluded the case
  1078. // where it *cannot* be disposable
  1079. if (Helpers.IsValueType(type))
  1080. {
  1081. ctx.LoadAddress(local, type);
  1082. switch (ctx.MetadataVersion)
  1083. {
  1084. case ILVersion.Net1:
  1085. ctx.LoadValue(local);
  1086. ctx.CastToObject(type);
  1087. break;
  1088. default:
  1089. ctx.Constrain(type);
  1090. break;
  1091. }
  1092. ctx.EmitCall(dispose);
  1093. }
  1094. else
  1095. {
  1096. Compiler.CodeLabel @null = ctx.DefineLabel();
  1097. if (disposableType.IsAssignableFrom(type))
  1098. { // *known* to be IDisposable; just needs a null-check
  1099. ctx.LoadValue(local);
  1100. ctx.BranchIfFalse(@null, true);
  1101. ctx.LoadAddress(local, type);
  1102. }
  1103. else
  1104. { // *could* be IDisposable; test via "as"
  1105. using (Compiler.Local disp = new Compiler.Local(ctx, disposableType))
  1106. {
  1107. ctx.LoadValue(local);
  1108. ctx.TryCast(disposableType);
  1109. ctx.CopyValue();
  1110. ctx.StoreValue(disp);
  1111. ctx.BranchIfFalse(@null, true);
  1112. ctx.LoadAddress(disp, disposableType);
  1113. }
  1114. }
  1115. ctx.EmitCall(dispose);
  1116. ctx.MarkLabel(@null);
  1117. }
  1118. ctx.EndFinally();
  1119. this.local = null;
  1120. this.ctx = null;
  1121. label = new CodeLabel(); // default
  1122. }
  1123. }
  1124. internal void Add()
  1125. {
  1126. Emit(OpCodes.Add);
  1127. }
  1128. internal void LoadLength(Local arr, bool zeroIfNull)
  1129. {
  1130. Helpers.DebugAssert(arr.Type.IsArray && arr.Type.GetArrayRank() == 1);
  1131. if (zeroIfNull)
  1132. {
  1133. Compiler.CodeLabel notNull = DefineLabel(), done = DefineLabel();
  1134. LoadValue(arr);
  1135. CopyValue(); // optimised for non-null case
  1136. BranchIfTrue(notNull, true);
  1137. DiscardValue();
  1138. LoadValue(0);
  1139. Branch(done, true);
  1140. MarkLabel(notNull);
  1141. Emit(OpCodes.Ldlen);
  1142. Emit(OpCodes.Conv_I4);
  1143. MarkLabel(done);
  1144. }
  1145. else
  1146. {
  1147. LoadValue(arr);
  1148. Emit(OpCodes.Ldlen);
  1149. Emit(OpCodes.Conv_I4);
  1150. }
  1151. }
  1152. internal void CreateArray(Type elementType, Local length)
  1153. {
  1154. LoadValue(length);
  1155. il.Emit(OpCodes.Newarr, elementType);
  1156. TraceCompile(OpCodes.Newarr + ": " + elementType);
  1157. }
  1158. internal void LoadArrayValue(Local arr, Local i)
  1159. {
  1160. Type type = arr.Type;
  1161. Helpers.DebugAssert(type.IsArray && arr.Type.GetArrayRank() == 1);
  1162. type = type.GetElementType();
  1163. Helpers.DebugAssert(type != null, "Not an array: " + arr.Type.FullName);
  1164. LoadValue(arr);
  1165. LoadValue(i);
  1166. switch (Helpers.GetTypeCode(type))
  1167. {
  1168. case ProtoTypeCode.SByte: Emit(OpCodes.Ldelem_I1); break;
  1169. case ProtoTypeCode.Int16: Emit(OpCodes.Ldelem_I2); break;
  1170. case ProtoTypeCode.Int32: Emit(OpCodes.Ldelem_I4); break;
  1171. case ProtoTypeCode.Int64: Emit(OpCodes.Ldelem_I8); break;
  1172. case ProtoTypeCode.Byte: Emit(OpCodes.Ldelem_U1); break;
  1173. case ProtoTypeCode.UInt16: Emit(OpCodes.Ldelem_U2); break;
  1174. case ProtoTypeCode.UInt32: Emit(OpCodes.Ldelem_U4); break;
  1175. case ProtoTypeCode.UInt64: Emit(OpCodes.Ldelem_I8); break; // odd, but this is what C# does...
  1176. case ProtoTypeCode.Single: Emit(OpCodes.Ldelem_R4); break;
  1177. case ProtoTypeCode.Double: Emit(OpCodes.Ldelem_R8); break;
  1178. default:
  1179. if (Helpers.IsValueType(type))
  1180. {
  1181. il.Emit(OpCodes.Ldelema, type);
  1182. il.Emit(OpCodes.Ldobj, type);
  1183. TraceCompile(OpCodes.Ldelema + ": " + type);
  1184. TraceCompile(OpCodes.Ldobj + ": " + type);
  1185. }
  1186. else
  1187. {
  1188. Emit(OpCodes.Ldelem_Ref);
  1189. }
  1190. break;
  1191. }
  1192. }
  1193. internal void LoadValue(Type type)
  1194. {
  1195. il.Emit(OpCodes.Ldtoken, type);
  1196. TraceCompile(OpCodes.Ldtoken + ": " + type);
  1197. EmitCall(MapType(typeof(System.Type)).GetMethod("GetTypeFromHandle"));
  1198. }
  1199. internal void ConvertToInt32(ProtoTypeCode typeCode, bool uint32Overflow)
  1200. {
  1201. switch (typeCode)
  1202. {
  1203. case ProtoTypeCode.Byte:
  1204. case ProtoTypeCode.SByte:
  1205. case ProtoTypeCode.Int16:
  1206. case ProtoTypeCode.UInt16:
  1207. Emit(OpCodes.Conv_I4);
  1208. break;
  1209. case ProtoTypeCode.Int32:
  1210. break;
  1211. case ProtoTypeCode.Int64:
  1212. Emit(OpCodes.Conv_Ovf_I4);
  1213. break;
  1214. case ProtoTypeCode.UInt32:
  1215. Emit(uint32Overflow ? OpCodes.Conv_Ovf_I4_Un : OpCodes.Conv_Ovf_I4);
  1216. break;
  1217. case ProtoTypeCode.UInt64:
  1218. Emit(OpCodes.Conv_Ovf_I4_Un);
  1219. break;
  1220. default:
  1221. throw new InvalidOperationException("ConvertToInt32 not implemented for: " + typeCode.ToString());
  1222. }
  1223. }
  1224. internal void ConvertFromInt32(ProtoTypeCode typeCode, bool uint32Overflow)
  1225. {
  1226. switch (typeCode)
  1227. {
  1228. case ProtoTypeCode.SByte: Emit(OpCodes.Conv_Ovf_I1); break;
  1229. case ProtoTypeCode.Byte: Emit(OpCodes.Conv_Ovf_U1); break;
  1230. case ProtoTypeCode.Int16: Emit(OpCodes.Conv_Ovf_I2); break;
  1231. case ProtoTypeCode.UInt16: Emit(OpCodes.Conv_Ovf_U2); break;
  1232. case ProtoTypeCode.Int32: break;
  1233. case ProtoTypeCode.UInt32: Emit(uint32Overflow ? OpCodes.Conv_Ovf_U4 : OpCodes.Conv_U4); break;
  1234. case ProtoTypeCode.Int64: Emit(OpCodes.Conv_I8); break;
  1235. case ProtoTypeCode.UInt64: Emit(OpCodes.Conv_U8); break;
  1236. default: throw new InvalidOperationException();
  1237. }
  1238. }
  1239. internal void LoadValue(decimal value)
  1240. {
  1241. if (value == 0M)
  1242. {
  1243. LoadValue(typeof(decimal).GetField("Zero"));
  1244. }
  1245. else
  1246. {
  1247. int[] bits = decimal.GetBits(value);
  1248. LoadValue(bits[0]); // lo
  1249. LoadValue(bits[1]); // mid
  1250. LoadValue(bits[2]); // hi
  1251. LoadValue((int)(((uint)bits[3]) >> 31)); // isNegative (bool, but int for CLI purposes)
  1252. LoadValue((bits[3] >> 16) & 0xFF); // scale (byte, but int for CLI purposes)
  1253. EmitCtor(MapType(typeof(decimal)), new Type[] { MapType(typeof(int)), MapType(typeof(int)), MapType(typeof(int)), MapType(typeof(bool)), MapType(typeof(byte)) });
  1254. }
  1255. }
  1256. internal void LoadValue(Guid value)
  1257. {
  1258. if (value == Guid.Empty)
  1259. {
  1260. LoadValue(typeof(Guid).GetField("Empty"));
  1261. }
  1262. else
  1263. { // note we're adding lots of shorts/bytes here - but at the IL level they are I4, not I1/I2 (which barely exist)
  1264. byte[] bytes = value.ToByteArray();
  1265. int i = (bytes[0]) | (bytes[1] << 8) | (bytes[2] << 16) | (bytes[3] << 24);
  1266. LoadValue(i);
  1267. short s = (short)((bytes[4]) | (bytes[5] << 8));
  1268. LoadValue(s);
  1269. s = (short)((bytes[6]) | (bytes[7] << 8));
  1270. LoadValue(s);
  1271. for (i = 8; i <= 15; i++)
  1272. {
  1273. LoadValue(bytes[i]);
  1274. }
  1275. EmitCtor(MapType(typeof(Guid)), new Type[] { MapType(typeof(int)), MapType(typeof(short)), MapType(typeof(short)),
  1276. MapType(typeof(byte)), MapType(typeof(byte)), MapType(typeof(byte)), MapType(typeof(byte)), MapType(typeof(byte)), MapType(typeof(byte)), MapType(typeof(byte)), MapType(typeof(byte)) });
  1277. }
  1278. }
  1279. //internal void LoadValue(bool value)
  1280. //{
  1281. // Emit(value ? OpCodes.Ldc_I4_1 : OpCodes.Ldc_I4_0);
  1282. //}
  1283. internal void LoadSerializationContext()
  1284. {
  1285. LoadReaderWriter();
  1286. LoadValue((isWriter ? typeof(ProtoWriter) : typeof(ProtoReader)).GetProperty("Context"));
  1287. }
  1288. private readonly TypeModel model;
  1289. internal Type MapType(Type type)
  1290. {
  1291. return model.MapType(type);
  1292. }
  1293. private readonly ILVersion metadataVersion;
  1294. public ILVersion MetadataVersion { get { return metadataVersion; } }
  1295. public enum ILVersion
  1296. {
  1297. Net1, Net2
  1298. }
  1299. internal bool AllowInternal(PropertyInfo property)
  1300. {
  1301. return NonPublic ? true : InternalsVisible(Helpers.GetAssembly(property.DeclaringType));
  1302. }
  1303. }
  1304. }
  1305. #endif