grpc: Fix 32-bit architecture targets

grpc/grpc-client/src/nativeMain/kotlin/kotlinx/rpc/grpc/client/GrpcCallCredentials.native.kt

@@ -30,6 +30,7 @@ private class CredentialsPluginState(
     val coroutineContext: CoroutineContext,
 )
 
+@OptIn(UnsafeNumber::class)
 private fun getMetadataCallback(
     state: COpaquePointer?,
     context: CValue<grpc_auth_metadata_context>,
@@ -121,6 +122,7 @@ private fun destroyCallback(state: COpaquePointer?) {
     state?.asStableRef<CredentialsPluginState>()?.dispose()
 }
 
+@OptIn(UnsafeNumber::class)
 internal fun GrpcCallCredentials.createRaw(
     coroutineContext: CoroutineContext,
 ): CPointer<grpc_call_credentials>? = memScoped {

grpc/grpc-client/src/nativeMain/kotlin/kotlinx/rpc/grpc/client/internal/NativeClientCall.kt

@@ -13,6 +13,7 @@ import kotlinx.cinterop.ByteVar
 import kotlinx.cinterop.CPointer
 import kotlinx.cinterop.CPointerVar
 import kotlinx.cinterop.ExperimentalForeignApi
+import kotlinx.cinterop.UnsafeNumber
 import kotlinx.cinterop.alloc
 import kotlinx.cinterop.allocArray
 import kotlinx.cinterop.convert
@@ -326,6 +327,7 @@ internal class NativeClientCall<Request, Response>(
         }
     }
 
+    @OptIn(UnsafeNumber::class)
     private fun sendAndReceiveInitialMetadata(headers: GrpcMetadata) {
         // sending and receiving initial metadata
         val arena = Arena()

grpc/grpc-client/src/nativeMain/kotlin/kotlinx/rpc/grpc/client/internal/NativeManagedChannel.kt

@@ -12,6 +12,7 @@ import kotlinx.atomicfu.atomic
 import kotlinx.cinterop.CPointer
 import kotlinx.cinterop.ExperimentalForeignApi
 import kotlinx.cinterop.MemScope
+import kotlinx.cinterop.UnsafeNumber
 import kotlinx.cinterop.alloc
 import kotlinx.cinterop.allocArray
 import kotlinx.cinterop.convert
@@ -215,6 +216,7 @@ internal sealed class GrpcArg(val key: String) {
         }
 }
 
+@OptIn(UnsafeNumber::class)
 private fun List<GrpcArg>.toRaw(memScope: MemScope): grpc_channel_args {
     with(memScope) {
         val arr = allocArray<grpc_arg>(size) {

grpc/grpc-core/src/nativeMain/kotlin/kotlinx/rpc/grpc/GrpcMetadata.native.kt

@@ -8,6 +8,7 @@ package kotlinx.rpc.grpc
 
 import kotlinx.cinterop.ExperimentalForeignApi
 import kotlinx.cinterop.NativePlacement
+import kotlinx.cinterop.UnsafeNumber
 import kotlinx.cinterop.addressOf
 import kotlinx.cinterop.alloc
 import kotlinx.cinterop.allocArray
@@ -62,6 +63,7 @@ public actual class GrpcMetadataKey<T> actual constructor(name: String, public v
 public actual class GrpcMetadata actual constructor() {
     internal val map: LinkedHashMap<String, MutableList<ByteArray>> = linkedMapOf()
 
+    @OptIn(UnsafeNumber::class)
     public constructor(raw: grpc_metadata_array) : this() {
         for (i in 0 until raw.count.toInt()) {
             val metadata = raw.metadata?.get(i)
@@ -73,6 +75,7 @@ public actual class GrpcMetadata actual constructor() {
         }
     }
 
+    @OptIn(UnsafeNumber::class)
     @InternalRpcApi
     public fun NativePlacement.allocRawGrpcMetadata(): grpc_metadata_array {
         val raw = alloc<grpc_metadata_array>()
@@ -91,7 +94,7 @@ public actual class GrpcMetadata actual constructor() {
             for (entry in values) {
                 val size = entry.size.toULong()
                 val valSlice = entry.usePinned { pinned ->
-                    grpc_slice_from_copied_buffer(pinned.addressOf(0), size)
+                    grpc_slice_from_copied_buffer(pinned.addressOf(0), size.convert())
                 }
                 // we create a fresh reference for each entry
                 val keySliceRef = grpc_slice_ref(keySlice)

grpc/grpc-core/src/nativeMain/kotlin/kotlinx/rpc/grpc/internal/CompletionQueue.kt

@@ -15,6 +15,7 @@ import kotlinx.cinterop.CFunction
 import kotlinx.cinterop.CPointer
 import kotlinx.cinterop.ExperimentalForeignApi
 import kotlinx.cinterop.StableRef
+import kotlinx.cinterop.UnsafeNumber
 import kotlinx.cinterop.alloc
 import kotlinx.cinterop.asStableRef
 import kotlinx.cinterop.convert
@@ -126,6 +127,7 @@ public class CompletionQueue {
      * Submits a batch operation to the queue.
      * See [BatchResult] for possible outcomes.
      */
+    @OptIn(UnsafeNumber::class)
     public fun runBatch(call: CPointer<grpc_call>, ops: CPointer<grpc_op>, nOps: ULong): BatchResult {
         if (_shutdownDone.isCompleted) return BatchResult.CQShutdown
 
@@ -149,7 +151,7 @@ public class CompletionQueue {
                 return BatchResult.CQShutdown
             }
 
-            err = grpc_call_start_batch(call, ops, nOps, tag, null)
+            err = grpc_call_start_batch(call, ops, nOps.convert(), tag, null)
         }
 
         if (err != grpc_call_error.GRPC_CALL_OK) {
@@ -212,6 +214,7 @@ private fun shutdownCb(functor: CPointer<grpc_completion_queue_functor>?, ok: In
 private val OPS_COMPLETE_CB = staticCFunction(::opsCompleteCb)
 private val SHUTDOWN_CB = staticCFunction(::shutdownCb)
 
+@OptIn(UnsafeNumber::class)
 private fun newCbTag(
     userData: Any,
     cb: CPointer<CFunction<(CPointer<grpc_completion_queue_functor>?, Int) -> Unit>>,

grpc/grpc-core/src/nativeMain/kotlin/kotlinx/rpc/grpc/internal/utils.native.kt

@@ -10,6 +10,7 @@ import kotlinx.cinterop.ByteVar
 import kotlinx.cinterop.CPointer
 import kotlinx.cinterop.CValue
 import kotlinx.cinterop.ExperimentalForeignApi
+import kotlinx.cinterop.UnsafeNumber
 import kotlinx.cinterop.addressOf
 import kotlinx.cinterop.alloc
 import kotlinx.cinterop.allocArray
@@ -49,7 +50,7 @@ import platform.posix.memcpy
 
 
 @InternalRpcApi
-@OptIn(ExperimentalForeignApi::class, InternalIoApi::class, UnsafeIoApi::class)
+@OptIn(ExperimentalForeignApi::class, InternalIoApi::class, UnsafeIoApi::class, UnsafeNumber::class)
 public fun Sink.writeFully(buffer: CPointer<ByteVar>, offset: Long, length: Long) {
     var consumed = 0L
     while (consumed < length) {
@@ -66,6 +67,7 @@ public fun Sink.writeFully(buffer: CPointer<ByteVar>, offset: Long, length: Long
     }
 }
 
+@OptIn(UnsafeNumber::class)
 @InternalRpcApi
 public fun grpc_slice.toByteArray(): ByteArray = memScoped {
     val out = ByteArray(len().toInt())
@@ -98,6 +100,7 @@ public fun CPointer<grpc_byte_buffer>.toKotlin(): Buffer = memScoped {
     return out
 }
 
+@OptIn(UnsafeNumber::class)
 @InternalRpcApi
 public fun Source.toGrpcByteBuffer(): CPointer<grpc_byte_buffer> {
     if (this is Buffer) return toGrpcByteBuffer()
@@ -109,29 +112,30 @@ public fun Source.toGrpcByteBuffer(): CPointer<grpc_byte_buffer> {
         val n = readAtMostTo(tmp, 0, tmp.size)
         if (n <= 0) break
         tmp.usePinned {
-            slices += grpc_slice_from_copied_buffer(it.addressOf(0), n.toULong())
+            slices += grpc_slice_from_copied_buffer(it.addressOf(0), n.convert())
         }
     }
 
     return slices.toGrpcByteBuffer()
 }
 
 @InternalRpcApi
-@OptIn(UnsafeIoApi::class)
+@OptIn(UnsafeIoApi::class, UnsafeNumber::class)
 public fun Buffer.toGrpcByteBuffer(): CPointer<grpc_byte_buffer> {
     val slices = ArrayList<CValue<grpc_slice>>(4)
 
     while (size > 0L) {
         UnsafeBufferOperations.readFromHead(this) { arr, start, end ->
             val len = end - start
-            arr.usePinned { p -> slices += grpc_slice_from_copied_buffer(p.addressOf(start), len.toULong()) }
+            arr.usePinned { p -> slices += grpc_slice_from_copied_buffer(p.addressOf(start), len.convert()) }
             len
         }
     }
 
     return slices.toGrpcByteBuffer()
 }
 
+@OptIn(UnsafeNumber::class)
 private fun ArrayList<CValue<grpc_slice>>.toGrpcByteBuffer(): CPointer<grpc_byte_buffer> = memScoped {
     val count = if (isEmpty()) 1 else size
     val sliceArr = allocArray<grpc_slice>(count)
@@ -150,7 +154,7 @@ private fun ArrayList<CValue<grpc_slice>>.toGrpcByteBuffer(): CPointer<grpc_byte
     }
 
 
-    val buf = grpc_raw_byte_buffer_create(sliceArr, count.toULong())!!
+    val buf = grpc_raw_byte_buffer_create(sliceArr, count.convert())!!
     // unref each slice, as the buffer takes ownership
     [email protected] { grpc_slice_unref(it) }
 
@@ -166,10 +170,11 @@ public fun grpc_slice.startPtr(): CPointer<ByteVar> {
     }
 }
 
+@OptIn(UnsafeNumber::class)
 @InternalRpcApi
 public fun grpc_slice.len(): ULong {
     return if (this.refcount != null) {
-        this.data.refcounted.length
+        this.data.refcounted.length.convert()
     } else {
         this.data.inlined.length.convert()
     }
@@ -231,6 +236,7 @@ public fun grpc_metadata.destroy() {
     grpc_slice_unref(value.readValue())
 }
 
+@OptIn(UnsafeNumber::class)
 @InternalRpcApi
 public fun grpc_metadata_array.destroyEntries() {
     for (i in 0 until count.convert()) {

grpc/grpc-ktor-server/gradle.properties

@@ -5,18 +5,4 @@
 kotlinx.rpc.exclude.wasmWasi=true
 kotlinx.rpc.exclude.js=true
 kotlinx.rpc.exclude.wasmJs=true
-kotlinx.rpc.exclude.iosArm64=true
-kotlinx.rpc.exclude.iosX64=true
-kotlinx.rpc.exclude.iosSimulatorArm64=true
-kotlinx.rpc.exclude.linuxArm64=true
-kotlinx.rpc.exclude.linuxX64=true
-kotlinx.rpc.exclude.macosX64=true
 kotlinx.rpc.exclude.mingwX64=true
-kotlinx.rpc.exclude.tvosArm64=true
-kotlinx.rpc.exclude.tvosSimulatorArm64=true
-kotlinx.rpc.exclude.tvosX64=true
-kotlinx.rpc.exclude.watchosArm32=true
-kotlinx.rpc.exclude.watchosArm64=true
-kotlinx.rpc.exclude.watchosDeviceArm64=true
-kotlinx.rpc.exclude.watchosSimulatorArm64=true
-kotlinx.rpc.exclude.watchosX64=true

protobuf/protobuf-core/src/nativeMain/kotlin/kotlinx/rpc/protobuf/internal/WireEncoder.native.kt

@@ -65,7 +65,7 @@ internal class WireEncoderNative(private val sink: Sink) : WireEncoder {
      */
     private inner class Ctx {
         fun write(buf: CPointer<ByteVar>, size: Int): Boolean {
-            sink.writeFully(buf, 0L, size.toLong())
+            sink.writeFully(buf, 0L, size)
             return true
         }
     }

protobuf/protobuf-core/src/nativeMain/kotlin/kotlinx/rpc/protobuf/internal/bufferUnsafeExtensions.kt

@@ -12,8 +12,8 @@ import kotlinx.io.unsafe.UnsafeBufferOperations
 import platform.posix.memcpy
 
 
-@OptIn(ExperimentalForeignApi::class, InternalIoApi::class, UnsafeIoApi::class)
-internal fun Sink.writeFully(buffer: CPointer<ByteVar>, offset: Long, length: Long) {
+@OptIn(ExperimentalForeignApi::class, InternalIoApi::class, UnsafeIoApi::class, UnsafeNumber::class)
+internal fun Sink.writeFully(buffer: CPointer<ByteVar>, offset: Long, length: Int) {
     var consumed = 0L
     while (consumed < length) {
         UnsafeBufferOperations.writeToTail(this.buffer, 1) { array, start, endExclusive ->