|
41 | 41 | package com.oracle.truffle.nfi.backend.libffi; |
42 | 42 |
|
43 | 43 | import com.oracle.truffle.api.CompilerDirectives; |
| 44 | +import com.oracle.truffle.api.dsl.Bind; |
44 | 45 | import com.oracle.truffle.api.dsl.Cached; |
45 | 46 | import com.oracle.truffle.api.dsl.Fallback; |
46 | | -import com.oracle.truffle.api.dsl.NodeChild; |
47 | 47 | import com.oracle.truffle.api.dsl.Specialization; |
48 | 48 | import com.oracle.truffle.api.interop.InteropLibrary; |
49 | 49 | import com.oracle.truffle.api.interop.UnsupportedMessageException; |
|
59 | 59 | import com.oracle.truffle.nfi.backend.libffi.LibFFIType.ObjectType; |
60 | 60 | import com.oracle.truffle.nfi.backend.libffi.LibFFIType.StringType; |
61 | 61 | import com.oracle.truffle.nfi.backend.libffi.NativeArgumentBuffer.TypeTag; |
62 | | -import com.oracle.truffle.nfi.backend.libffi.SerializeArgumentNodeFactory.SerializeByteArrayNodeGen; |
63 | | -import com.oracle.truffle.nfi.backend.libffi.SerializeArgumentNodeFactory.SerializeDoubleArrayNodeGen; |
64 | | -import com.oracle.truffle.nfi.backend.libffi.SerializeArgumentNodeFactory.SerializeFloatArrayNodeGen; |
65 | | -import com.oracle.truffle.nfi.backend.libffi.SerializeArgumentNodeFactory.SerializeIntArrayNodeGen; |
66 | | -import com.oracle.truffle.nfi.backend.libffi.SerializeArgumentNodeFactory.SerializeLongArrayNodeGen; |
67 | | -import com.oracle.truffle.nfi.backend.libffi.SerializeArgumentNodeFactory.SerializeShortArrayNodeGen; |
| 62 | +import com.oracle.truffle.nfi.backend.libffi.SerializeArgumentNodeFactory.GetByteArrayTagNodeGen; |
| 63 | +import com.oracle.truffle.nfi.backend.libffi.SerializeArgumentNodeFactory.GetDoubleArrayTagNodeGen; |
| 64 | +import com.oracle.truffle.nfi.backend.libffi.SerializeArgumentNodeFactory.GetFloatArrayTagNodeGen; |
| 65 | +import com.oracle.truffle.nfi.backend.libffi.SerializeArgumentNodeFactory.GetIntArrayTagNodeGen; |
| 66 | +import com.oracle.truffle.nfi.backend.libffi.SerializeArgumentNodeFactory.GetLongArrayTagNodeGen; |
| 67 | +import com.oracle.truffle.nfi.backend.libffi.SerializeArgumentNodeFactory.GetShortArrayTagNodeGen; |
68 | 68 |
|
69 | 69 | abstract class SerializeArgumentNode extends Node { |
70 | 70 |
|
@@ -347,207 +347,141 @@ public boolean isAdoptable() { |
347 | 347 | } |
348 | 348 | } |
349 | 349 |
|
350 | | - abstract static class UnwrapHostObjectNode extends Node { |
| 350 | + abstract static class GetTypeTagNode extends Node { |
351 | 351 |
|
352 | | - abstract Object execute(Object value); |
353 | | - |
354 | | - final boolean isHostObject(Object value) { |
355 | | - LibFFIContext ctx = LibFFIContext.get(this); |
356 | | - return ctx.env.isHostObject(value); |
357 | | - } |
358 | | - |
359 | | - @Specialization(guards = "isHostObject(value)") |
360 | | - Object doHostObject(Object value) { |
361 | | - return LibFFIContext.get(this).env.asHostObject(value); |
362 | | - } |
| 352 | + abstract TypeTag execute(Object value); |
363 | 353 |
|
364 | 354 | @Fallback |
365 | | - Object doOther(@SuppressWarnings("unused") Object value) { |
366 | | - return null; |
367 | | - } |
368 | | - } |
369 | | - |
370 | | - abstract static class ObjectDummy extends Node { |
371 | | - |
372 | | - static ObjectDummy create() { |
| 355 | + TypeTag doOther(@SuppressWarnings("unused") Object value) { |
373 | 356 | return null; |
374 | 357 | } |
375 | | - |
376 | | - abstract Object execute(); |
377 | 358 | } |
378 | 359 |
|
379 | | - abstract static class BufferDummy extends Node { |
380 | | - |
381 | | - static BufferDummy create() { |
382 | | - return null; |
383 | | - } |
384 | | - |
385 | | - abstract NativeArgumentBuffer execute(); |
386 | | - } |
387 | | - |
388 | | - @NodeChild(value = "value", type = ObjectDummy.class, implicit = true) |
389 | | - @NodeChild(value = "buffer", type = BufferDummy.class, implicit = true) |
390 | | - @NodeChild(value = "hostObject", type = UnwrapHostObjectNode.class, executeWith = "value", implicit = true) |
391 | 360 | abstract static class SerializeArrayNode extends SerializeArgumentNode { |
392 | 361 |
|
393 | | - SerializeArrayNode(CachedTypeInfo type) { |
394 | | - super(type); |
395 | | - } |
| 362 | + @Child GetTypeTagNode getTypeTag; |
396 | 363 |
|
397 | | - static SerializeArrayNode create(ArrayType type) { |
| 364 | + SerializeArrayNode(ArrayType type) { |
| 365 | + super(type); |
398 | 366 | switch (type.elementType) { |
399 | 367 | case UINT8: |
400 | 368 | case SINT8: |
401 | | - return SerializeByteArrayNodeGen.create(type); |
| 369 | + getTypeTag = GetByteArrayTagNodeGen.create(); |
| 370 | + break; |
402 | 371 | case UINT16: |
403 | 372 | case SINT16: |
404 | | - return SerializeShortArrayNodeGen.create(type); |
| 373 | + getTypeTag = GetShortArrayTagNodeGen.create(); |
| 374 | + break; |
405 | 375 | case UINT32: |
406 | 376 | case SINT32: |
407 | | - return SerializeIntArrayNodeGen.create(type); |
| 377 | + getTypeTag = GetIntArrayTagNodeGen.create(); |
| 378 | + break; |
408 | 379 | case UINT64: |
409 | 380 | case SINT64: |
410 | | - return SerializeLongArrayNodeGen.create(type); |
| 381 | + getTypeTag = GetLongArrayTagNodeGen.create(); |
| 382 | + break; |
411 | 383 | case FLOAT: |
412 | | - return SerializeFloatArrayNodeGen.create(type); |
| 384 | + getTypeTag = GetFloatArrayTagNodeGen.create(); |
| 385 | + break; |
413 | 386 | case DOUBLE: |
414 | | - return SerializeDoubleArrayNodeGen.create(type); |
| 387 | + getTypeTag = GetDoubleArrayTagNodeGen.create(); |
| 388 | + break; |
415 | 389 | default: |
416 | 390 | throw CompilerDirectives.shouldNotReachHere(type.elementType.name()); |
417 | 391 | } |
418 | 392 | } |
419 | 393 |
|
420 | | - @Specialization(guards = "hostObject == null") |
421 | | - void doInteropObject(Object value, NativeArgumentBuffer buffer, Object hostObject, |
422 | | - @Cached(parameters = "type") SerializePointerNode serialize) throws UnsupportedTypeException { |
423 | | - assert hostObject == null; |
424 | | - serialize.execute(value, buffer); |
| 394 | + final boolean isHostObject(Object value) { |
| 395 | + return LibFFIContext.get(this).env.isHostObject(value); |
425 | 396 | } |
426 | | - } |
427 | | - |
428 | | - abstract static class SerializeByteArrayNode extends SerializeArrayNode { |
429 | 397 |
|
430 | | - SerializeByteArrayNode(ArrayType type) { |
431 | | - super(type); |
| 398 | + final Object asHostObject(Object value) { |
| 399 | + return LibFFIContext.get(this).env.asHostObject(value); |
432 | 400 | } |
433 | 401 |
|
434 | | - @Specialization |
435 | | - void putBooleanArray(Object value, NativeArgumentBuffer buffer, boolean[] array) { |
436 | | - assert LibFFIContext.get(this).env.asHostObject(value) == array; |
437 | | - buffer.putObject(TypeTag.BOOLEAN_ARRAY, array, type.size); |
| 402 | + @Specialization(guards = {"isHostObject(value)", "tag != null"}) |
| 403 | + void doHostObject(@SuppressWarnings("unused") Object value, NativeArgumentBuffer buffer, |
| 404 | + @Bind("asHostObject(value)") Object hostObject, |
| 405 | + @Bind("getTypeTag.execute(hostObject)") TypeTag tag) { |
| 406 | + buffer.putObject(tag, hostObject, type.size); |
438 | 407 | } |
439 | 408 |
|
440 | | - @Specialization |
441 | | - void putByteArray(Object value, NativeArgumentBuffer buffer, byte[] array) { |
442 | | - assert LibFFIContext.get(this).env.asHostObject(value) == array; |
443 | | - buffer.putObject(TypeTag.BYTE_ARRAY, array, type.size); |
| 409 | + @Specialization(guards = "tag != null") |
| 410 | + void doArray(Object value, NativeArgumentBuffer buffer, |
| 411 | + @Bind("getTypeTag.execute(value)") TypeTag tag) { |
| 412 | + buffer.putObject(tag, value, type.size); |
444 | 413 | } |
445 | 414 |
|
446 | 415 | @Fallback |
447 | | - @SuppressWarnings("unused") |
448 | | - void doError(Object value, NativeArgumentBuffer buffer, Object array) throws UnsupportedTypeException { |
449 | | - throw UnsupportedTypeException.create(new Object[]{value}); |
| 416 | + void doInteropObject(Object value, NativeArgumentBuffer buffer, |
| 417 | + @Cached(parameters = "type") SerializePointerNode serialize) throws UnsupportedTypeException { |
| 418 | + serialize.execute(value, buffer); |
450 | 419 | } |
451 | 420 | } |
452 | 421 |
|
453 | | - abstract static class SerializeShortArrayNode extends SerializeArrayNode { |
454 | | - |
455 | | - SerializeShortArrayNode(ArrayType type) { |
456 | | - super(type); |
457 | | - } |
| 422 | + abstract static class GetByteArrayTagNode extends GetTypeTagNode { |
458 | 423 |
|
459 | 424 | @Specialization |
460 | | - void putShortArray(Object value, NativeArgumentBuffer buffer, short[] array) { |
461 | | - assert LibFFIContext.get(this).env.asHostObject(value) == array; |
462 | | - buffer.putObject(TypeTag.SHORT_ARRAY, array, type.size); |
| 425 | + TypeTag doBooleanArray(boolean[] array) { |
| 426 | + assert array != null; |
| 427 | + return TypeTag.BOOLEAN_ARRAY; |
463 | 428 | } |
464 | 429 |
|
465 | 430 | @Specialization |
466 | | - void putCharArray(Object value, NativeArgumentBuffer buffer, char[] array) { |
467 | | - assert LibFFIContext.get(this).env.asHostObject(value) == array; |
468 | | - buffer.putObject(TypeTag.CHAR_ARRAY, array, type.size); |
469 | | - } |
470 | | - |
471 | | - @Fallback |
472 | | - @SuppressWarnings("unused") |
473 | | - void doError(Object value, NativeArgumentBuffer buffer, Object array) throws UnsupportedTypeException { |
474 | | - throw UnsupportedTypeException.create(new Object[]{value}); |
| 431 | + TypeTag doByteArray(byte[] array) { |
| 432 | + assert array != null; |
| 433 | + return TypeTag.BYTE_ARRAY; |
475 | 434 | } |
476 | 435 | } |
477 | 436 |
|
478 | | - abstract static class SerializeIntArrayNode extends SerializeArrayNode { |
479 | | - |
480 | | - SerializeIntArrayNode(ArrayType type) { |
481 | | - super(type); |
482 | | - } |
| 437 | + abstract static class GetShortArrayTagNode extends GetTypeTagNode { |
483 | 438 |
|
484 | 439 | @Specialization |
485 | | - void putIntArray(Object value, NativeArgumentBuffer buffer, int[] array) { |
486 | | - assert LibFFIContext.get(this).env.asHostObject(value) == array; |
487 | | - buffer.putObject(TypeTag.INT_ARRAY, array, type.size); |
| 440 | + TypeTag doShortArray(short[] array) { |
| 441 | + assert array != null; |
| 442 | + return TypeTag.SHORT_ARRAY; |
488 | 443 | } |
489 | 444 |
|
490 | | - @Fallback |
491 | | - @SuppressWarnings("unused") |
492 | | - void doError(Object value, NativeArgumentBuffer buffer, Object array) throws UnsupportedTypeException { |
493 | | - throw UnsupportedTypeException.create(new Object[]{value}); |
| 445 | + @Specialization |
| 446 | + TypeTag doCharArray(char[] array) { |
| 447 | + assert array != null; |
| 448 | + return TypeTag.CHAR_ARRAY; |
494 | 449 | } |
495 | 450 | } |
496 | 451 |
|
497 | | - abstract static class SerializeLongArrayNode extends SerializeArrayNode { |
498 | | - |
499 | | - SerializeLongArrayNode(ArrayType type) { |
500 | | - super(type); |
501 | | - } |
| 452 | + abstract static class GetIntArrayTagNode extends GetTypeTagNode { |
502 | 453 |
|
503 | 454 | @Specialization |
504 | | - void putLongArray(Object value, NativeArgumentBuffer buffer, long[] array) { |
505 | | - assert LibFFIContext.get(this).env.asHostObject(value) == array; |
506 | | - buffer.putObject(TypeTag.LONG_ARRAY, array, type.size); |
507 | | - } |
508 | | - |
509 | | - @Fallback |
510 | | - @SuppressWarnings("unused") |
511 | | - void doError(Object value, NativeArgumentBuffer buffer, Object array) throws UnsupportedTypeException { |
512 | | - throw UnsupportedTypeException.create(new Object[]{value}); |
| 455 | + TypeTag doIntArray(int[] array) { |
| 456 | + assert array != null; |
| 457 | + return TypeTag.INT_ARRAY; |
513 | 458 | } |
514 | 459 | } |
515 | 460 |
|
516 | | - abstract static class SerializeFloatArrayNode extends SerializeArrayNode { |
517 | | - |
518 | | - SerializeFloatArrayNode(ArrayType type) { |
519 | | - super(type); |
520 | | - } |
| 461 | + abstract static class GetLongArrayTagNode extends GetTypeTagNode { |
521 | 462 |
|
522 | 463 | @Specialization |
523 | | - void putFloatArray(Object value, NativeArgumentBuffer buffer, float[] array) { |
524 | | - assert LibFFIContext.get(this).env.asHostObject(value) == array; |
525 | | - buffer.putObject(TypeTag.FLOAT_ARRAY, array, type.size); |
526 | | - } |
527 | | - |
528 | | - @Fallback |
529 | | - @SuppressWarnings("unused") |
530 | | - void doError(Object value, NativeArgumentBuffer buffer, Object array) throws UnsupportedTypeException { |
531 | | - throw UnsupportedTypeException.create(new Object[]{value}); |
| 464 | + TypeTag doLongArray(long[] array) { |
| 465 | + assert array != null; |
| 466 | + return TypeTag.LONG_ARRAY; |
532 | 467 | } |
533 | 468 | } |
534 | 469 |
|
535 | | - abstract static class SerializeDoubleArrayNode extends SerializeArrayNode { |
536 | | - |
537 | | - SerializeDoubleArrayNode(ArrayType type) { |
538 | | - super(type); |
539 | | - } |
| 470 | + abstract static class GetFloatArrayTagNode extends GetTypeTagNode { |
540 | 471 |
|
541 | 472 | @Specialization |
542 | | - void putDoubleArray(Object value, NativeArgumentBuffer buffer, double[] array) { |
543 | | - assert LibFFIContext.get(this).env.asHostObject(value) == array; |
544 | | - buffer.putObject(TypeTag.DOUBLE_ARRAY, array, type.size); |
| 473 | + TypeTag doFloatArray(float[] array) { |
| 474 | + assert array != null; |
| 475 | + return TypeTag.FLOAT_ARRAY; |
545 | 476 | } |
| 477 | + } |
546 | 478 |
|
547 | | - @Fallback |
548 | | - @SuppressWarnings("unused") |
549 | | - void doError(Object value, NativeArgumentBuffer buffer, Object array) throws UnsupportedTypeException { |
550 | | - throw UnsupportedTypeException.create(new Object[]{value}); |
| 479 | + abstract static class GetDoubleArrayTagNode extends GetTypeTagNode { |
| 480 | + |
| 481 | + @Specialization |
| 482 | + TypeTag doDoubleArray(double[] array) { |
| 483 | + assert array != null; |
| 484 | + return TypeTag.DOUBLE_ARRAY; |
551 | 485 | } |
552 | 486 | } |
553 | 487 | } |
0 commit comments