Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 8 additions & 0 deletions Runtime/Scripts/Audio.meta

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@
using LiveKit.Internal;
using Unity.Collections;

using LiveKit.Internal.FFI;
namespace LiveKit
{
public class AudioFrame : IDisposable
Expand Down
Original file line number Diff line number Diff line change
@@ -1,8 +1,9 @@
using System;
using LiveKit.Internal.FFIClients.Requests;
using LiveKit.Internal.FFI.Requests;
using LiveKit.Internal;
using LiveKit.Proto;

using LiveKit.Internal.FFI;
namespace LiveKit
{
public sealed class AudioResampler : IDisposable
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3,8 +3,10 @@
using LiveKit.Internal;
using LiveKit.Proto;
using System.Runtime.InteropServices;
using LiveKit.Internal.FFIClients.Requests;
using LiveKit.Internal.FFI.Requests;

using LiveKit.Internal.Threading;
using LiveKit.Internal.FFI;
namespace LiveKit
{
/// <summary>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@
using UnityEngine;
using LiveKit.Internal;

using LiveKit.Internal.Threading;
namespace LiveKit
{
/// <summary>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@
using System.Collections.Generic;
using LiveKit.Proto;
using LiveKit.Internal;
using LiveKit.Internal.FFIClients.Requests;
using LiveKit.Internal.FFI.Requests;

#if UNITY_IOS && !UNITY_EDITOR
using System.Runtime.InteropServices;
Expand All @@ -13,6 +13,7 @@
using UnityEngine.Android;
#endif

using LiveKit.Internal.FFI;
namespace LiveKit
{
#if UNITY_IOS && !UNITY_EDITOR
Expand Down
Original file line number Diff line number Diff line change
@@ -1,8 +1,9 @@
using System;
using LiveKit.Proto;
using LiveKit.Internal;
using LiveKit.Internal.FFIClients.Requests;
using LiveKit.Internal.FFI.Requests;

using LiveKit.Internal.FFI;
namespace LiveKit
{
/// <summary>
Expand Down
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
using System;
using System.Buffers;
using LiveKit.Internal.FFIClients.Pools.Memory;
using LiveKit.Internal.FFI.Pools.Memory;

namespace LiveKit.Internal
namespace LiveKit
{
// Basic RingBuffer implementation (used WebRtc_RingBuffer as reference)
// The one from com.unity.collections is dealing element per element, which is not efficient when dealing with bytes
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3,12 +3,13 @@
using System.Collections.Generic;
using LiveKit.Proto;
using LiveKit.Internal;
using LiveKit.Internal.FFIClients.Requests;
using LiveKit.Internal.FFI.Requests;
using Unity.Collections;
using Unity.Collections.LowLevel.Unsafe;
using System.Diagnostics;
using System.Threading;

using LiveKit.Internal.FFI;
namespace LiveKit
{
/// <summary>
Expand Down
8 changes: 8 additions & 0 deletions Runtime/Scripts/Core.meta

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

3 changes: 2 additions & 1 deletion Runtime/Scripts/E2EE.cs → Runtime/Scripts/Core/E2EE.cs
Original file line number Diff line number Diff line change
@@ -1,8 +1,9 @@
using System.Collections.Generic;
using LiveKit.Internal;
using LiveKit.Internal.FFIClients.Requests;
using LiveKit.Internal.FFI.Requests;
using LiveKit.Proto;

using LiveKit.Internal.FFI;
namespace LiveKit
{
public enum EncryptionType
Expand Down
File renamed without changes.
Original file line number Diff line number Diff line change
Expand Up @@ -4,9 +4,11 @@
using System.Threading.Tasks;
using LiveKit.Internal;
using LiveKit.Proto;
using LiveKit.Internal.FFIClients.Requests;
using LiveKit.Internal.FFI.Requests;
using System.Diagnostics;

using LiveKit.Internal.Threading;
using LiveKit.Internal.FFI;
namespace LiveKit
{
public delegate Task<string> RpcHandler(RpcInvocationData data);
Expand Down
6 changes: 4 additions & 2 deletions Runtime/Scripts/Room.cs → Runtime/Scripts/Core/Room.cs
Original file line number Diff line number Diff line change
Expand Up @@ -3,9 +3,11 @@
using LiveKit.Internal;
using LiveKit.Proto;
using System.Runtime.InteropServices;
using LiveKit.Internal.FFIClients.Requests;
using LiveKit.Internal.FFI.Requests;
using UnityEngine;

using LiveKit.Internal.Threading;
using LiveKit.Internal.FFI;
namespace LiveKit
{
public enum IceTransportType
Expand Down Expand Up @@ -654,7 +656,7 @@ internal Participant GetParticipant(string identity)
}
}

public sealed class ConnectInstruction : YieldInstruction
public sealed class ConnectInstruction : LiveKit.Internal.Threading.YieldInstruction
{
private ulong _asyncId;
private Room _room;
Expand Down
File renamed without changes.
File renamed without changes.
File renamed without changes.
File renamed without changes.
4 changes: 3 additions & 1 deletion Runtime/Scripts/Track.cs → Runtime/Scripts/Core/Track.cs
Original file line number Diff line number Diff line change
@@ -1,8 +1,10 @@
using System;
using LiveKit.Proto;
using LiveKit.Internal;
using LiveKit.Internal.FFIClients.Requests;
using LiveKit.Internal.FFI.Requests;

using LiveKit.Internal.Threading;
using LiveKit.Internal.FFI;
namespace LiveKit
{
public interface ITrack
Expand Down
File renamed without changes.
Original file line number Diff line number Diff line change
@@ -1,7 +1,8 @@
using LiveKit.Internal;
using LiveKit.Internal.FFIClients.Requests;
using LiveKit.Internal.FFI.Requests;
using LiveKit.Proto;

using LiveKit.Internal.FFI;
namespace LiveKit
{
public class TrackPublication
Expand Down
8 changes: 8 additions & 0 deletions Runtime/Scripts/DataStreams.meta

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Original file line number Diff line number Diff line change
@@ -1,10 +1,11 @@
using System;
using System.Collections.Generic;
using System.Linq;
using LiveKit.Internal.FFIClients.Requests;
using LiveKit.Internal.FFI.Requests;
using LiveKit.Internal;
using LiveKit.Proto;

using LiveKit.Internal.FFI;
namespace LiveKit
{
/// <summary>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,8 @@
using LiveKit.Internal;
using LiveKit.Proto;

using LiveKit.Internal.Threading;
using LiveKit.Internal.FFI;
namespace LiveKit
{
/// <summary>
Expand Down
Original file line number Diff line number Diff line change
@@ -1,9 +1,11 @@
using System;
using LiveKit.Internal;
using LiveKit.Internal.FFIClients.Requests;
using LiveKit.Internal.FFI.Requests;
using LiveKit.Proto;
using UnityEngine;

using LiveKit.Internal.Threading;
using LiveKit.Internal.FFI;
namespace LiveKit
{
/// <summary>
Expand Down
Original file line number Diff line number Diff line change
@@ -1,9 +1,10 @@
using System;
using System.Collections.Generic;
using LiveKit.Internal.FFIClients.Requests;
using LiveKit.Internal.FFI.Requests;
using LiveKit.Internal;
using LiveKit.Proto;

using LiveKit.Internal.FFI;
namespace LiveKit
{
/// <summary>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -4,16 +4,16 @@
using UnityEngine;
using Google.Protobuf;
using System.Threading;
using LiveKit.Internal.FFIClients;
using LiveKit.Internal.FFIClients.Pools;
using LiveKit.Internal.FFIClients.Pools.Memory;
using LiveKit.Internal.FFI;
using LiveKit.Internal.FFI.Pools;
using LiveKit.Internal.FFI.Pools.Memory;
using UnityEngine.Pool;

#if UNITY_EDITOR
using UnityEditor;
#endif

namespace LiveKit.Internal
namespace LiveKit.Internal.FFI
{
#if UNITY_EDITOR
[InitializeOnLoad]
Expand Down Expand Up @@ -64,7 +64,7 @@ internal sealed class FfiClient : IFFIClient
// Data Track
public event DataTrackStreamEventReceivedDelegate? DataTrackStreamEventReceived;

public FfiClient() : this(Pools.NewFfiResponsePool(), new ArrayMemoryPool())
public FfiClient() : this(PoolFactory.NewFfiResponsePool(), new ArrayMemoryPool())
{
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
using System.Runtime.InteropServices;
using LiveKit.Proto;

namespace LiveKit.Internal
namespace LiveKit.Internal.FFI
{
[UnmanagedFunctionPointer(CallingConvention.Cdecl)]

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@
using System.Runtime.ConstrainedExecution;
using LiveKit.Proto;

namespace LiveKit.Internal
namespace LiveKit.Internal.FFI
{
public class FfiHandle : SafeHandle
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,8 @@
using LiveKit.Internal;
using LiveKit.Proto;

namespace LiveKit
using LiveKit.Internal.Threading;
namespace LiveKit.Internal.FFI
{
/// <summary>
/// Generic yield instruction for one-shot FFI callbacks that follow the standard pattern:
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
using System.Reflection;
using LiveKit.Proto;

namespace LiveKit.Internal.FFIClients
namespace LiveKit.Internal.FFI
{
public static class FfiRequestExtensions
{
Expand Down
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
using System;
using LiveKit.Proto;

namespace LiveKit.Internal.FFIClients
namespace LiveKit.Internal.FFI
{
public readonly struct FfiResponseWrap : IDisposable
{
Expand Down
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
using System;
using LiveKit.Proto;

namespace LiveKit.Internal.FFIClients
namespace LiveKit.Internal.FFI
{
/// <summary>
/// Thread-safe interface for sending requests to the FFI layer
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@

using FfiHandleId = System.IntPtr;

namespace LiveKit.Internal
namespace LiveKit.Internal.FFI
{
[SuppressUnmanagedCodeSecurity]
internal static class NativeMethods
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
namespace LiveKit.Internal.FFIClients.Pools
namespace LiveKit.Internal.FFI.Pools
{
public interface IMultiPool
{
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
using System.Buffers;

namespace LiveKit.Internal.FFIClients.Pools.Memory
namespace LiveKit.Internal.FFI.Pools.Memory
{
public class ArrayMemoryPool : IMemoryPool
{
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
using Google.Protobuf;

namespace LiveKit.Internal.FFIClients.Pools.Memory
namespace LiveKit.Internal.FFI.Pools.Memory
{
public interface IMemoryPool
{
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
using System;

namespace LiveKit.Internal.FFIClients.Pools.Memory
namespace LiveKit.Internal.FFI.Pools.Memory
{
public readonly struct MemoryWrap : IDisposable
{
Expand Down
Original file line number Diff line number Diff line change
@@ -1,11 +1,10 @@
using System;
using LiveKit.Internal.FFIClients.Pools.ObjectPool;
using LiveKit.Proto;
using UnityEngine.Pool;

namespace LiveKit.Internal.FFIClients.Pools//
namespace LiveKit.Internal.FFI.Pools
{
public static class Pools
public static class PoolFactory
{
public static IObjectPool<FfiResponse> NewFfiResponsePool()
{
Expand Down
Original file line number Diff line number Diff line change
@@ -1,9 +1,8 @@
using System;
using System.Collections.Concurrent;
using LiveKit.Internal.FFIClients.Pools.ObjectPool;
using UnityEngine.Pool;

namespace LiveKit.Internal.FFIClients.Pools
namespace LiveKit.Internal.FFI.Pools
{
public class ThreadSafeMultiPool : IMultiPool
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
using System.Collections.Concurrent;
using UnityEngine.Pool;

namespace LiveKit.Internal.FFIClients.Pools.ObjectPool
namespace LiveKit.Internal.FFI.Pools
{
public class ThreadSafeObjectPool<T> : IObjectPool<T> where T : class
{
Expand Down
Loading
Loading