diff --git a/apps/packet-gateway/src/ebpf/packet_filter.c b/apps/packet-gateway/src/ebpf/packet_filter.c
new file mode 100644
index 0000000..6f0408b
--- /dev/null
+++ b/apps/packet-gateway/src/ebpf/packet_filter.c
@@ -0,0 +1,152 @@
+#include <linux/bpf.h>
+#include <linux/if_ether.h>
+#include <linux/ip.h>
+#include <linux/udp.h>
+#include <linux/tcp.h>
+#include <linux/icmp.h>
+#include <bpf/bpf_helpers.h>
+#include <bpf/bpf_endian.h>
+
+struct {
+    __uint(type, BPF_MAP_TYPE_HASH);
+    __uint(max_entries, 10240);
+    __type(key, __u32);      // IP address
+    __type(value, __u64);    // Byte count
+} packet_stats SEC(".maps");
+
+struct {
+    __uint(type, BPF_MAP_TYPE_HASH);
+    __uint(max_entries, 10240);
+    __type(key, __u32);      // IP address
+    __type(value, __s64);    // Credit balance (can be negative)
+} user_credits SEC(".maps");
+
+struct {
+    __uint(type, BPF_MAP_TYPE_HASH);
+    __uint(max_entries, 10240);
+    __type(key, __u32);      // IP address
+    __type(value, __u8);     // Block flag (0=allow, 1=block)
+} block_list SEC(".maps");
+
+struct {
+    __uint(type, BPF_MAP_TYPE_PERCPU_ARRAY);
+    __uint(max_entries, 1);
+    __type(key, __u32);
+    __type(value, __u64);
+} sync_interval SEC(".maps");
+
+#define BLOCK_THRESHOLD 0
+#define SYNC_INTERVAL_NS 1000000000ULL 
+
+static __always_inline __u32 get_packet_size(struct xdp_md *ctx) {
+    void *data_end = (void *)(long)ctx->data_end;
+    void *data = (void *)(long)ctx->data;
+    return data_end - data;
+}
+
+static __always_inline __u32 get_src_ip(struct xdp_md *ctx) {
+    void *data_end = (void *)(long)ctx->data_end;
+    void *data = (void *)(long)ctx->data;
+    
+    struct ethhdr *eth = data;
+    if ((void *)(eth + 1) > data_end)
+        return 0;
+        
+    if (eth->h_proto != __constant_htons(ETH_P_IP))
+        return 0;
+        
+    struct iphdr *ip = (void *)(eth + 1);
+    if ((void *)(ip + 1) > data_end)
+        return 0;
+        
+    return bpf_ntohl(ip->saddr);
+}
+
+static __always_inline __u32 get_dst_ip(struct xdp_md *ctx) {
+    void *data_end = (void *)(long)ctx->data_end;
+    void *data = (void *)(long)ctx->data;
+    
+    struct ethhdr *eth = data;
+    if ((void *)(eth + 1) > data_end)
+        return 0;
+        
+    if (eth->h_proto != __constant_htons(ETH_P_IP))
+        return 0;
+        
+    struct iphdr *ip = (void *)(eth + 1);
+    if ((void *)(ip + 1) > data_end)
+        return 0;
+        
+    return bpf_ntohl(ip->daddr);
+}
+
+static __always_inline bool should_block_packet(__u32 src_ip, __u32 dst_ip) {
+    __u8 *block_flag_src = bpf_map_lookup_elem(&block_list, &src_ip);
+    __u8 *block_flag_dst = bpf_map_lookup_elem(&block_list, &dst_ip);
+    
+    if (block_flag_src && *block_flag_src == 1)
+        return true;
+    if (block_flag_dst && *block_flag_dst == 1)
+        return true;
+        
+    __s64 *credit_src = bpf_map_lookup_elem(&user_credits, &src_ip);
+    if (credit_src && *credit_src <= BLOCK_THRESHOLD)
+        return true;
+        
+    return false;
+}
+
+static __always_inline void update_packet_stats(__u32 ip, __u32 bytes) {
+    __u64 *current_stats = bpf_map_lookup_elem(&packet_stats, &ip);
+    __u64 new_stats = bytes;
+    
+    if (current_stats) {
+        new_stats += *current_stats;
+    }
+    
+    bpf_map_update_elem(&packet_stats, &ip, &new_stats, BPF_ANY);
+}
+
+static __always_inline void update_credit_usage(__u32 ip, __u32 bytes) {
+    __s64 *current_credit = bpf_map_lookup_elem(&user_credits, &ip);
+    if (current_credit) {
+        __s64 new_credit = *current_credit - bytes;
+        bpf_map_update_elem(&user_credits, &ip, &new_credit, BPF_ANY);
+    }
+}
+
+SEC("xdp")
+int packet_filter(struct xdp_md *ctx) {
+    __u32 packet_size = get_packet_size(ctx);
+    if (packet_size < sizeof(struct ethhdr) + sizeof(struct iphdr))
+        return XDP_PASS;
+        
+    __u32 src_ip = get_src_ip(ctx);
+    __u32 dst_ip = get_dst_ip(ctx);
+    
+    if (src_ip == 0 || dst_ip == 0)
+        return XDP_PASS;
+        
+    if (should_block_packet(src_ip, dst_ip)) {
+        bpf_printk("Blocking packet from %x to %x - insufficient credit or blocked\n", 
+                   src_ip, dst_ip);
+        return XDP_DROP;
+    }
+    
+    update_packet_stats(src_ip, packet_size);
+    update_packet_stats(dst_ip, packet_size);
+    
+    update_credit_usage(src_ip, packet_size);
+    
+    return XDP_PASS;
+}
+
+SEC("xdp")
+int sync_stats(struct xdp_md *ctx) {
+    // This would be called periodically from userspace
+    // to sync eBPF map data to Redis
+    return XDP_PASS;
+}
+
+// License
+char _license[] SEC("license") = "GPL";