Lines Matching refs:client_data
197 ClientData& client_data = it->second; in OnDisconnect() local
198 SharedRingBuffer& shmem = client_data.shmem; in OnDisconnect()
208 DataSourceInstanceID ds_id = client_data.data_source_instance_id; in OnDisconnect()
232 ClientData& client_data = it->second; in HandleUnwindBatch() local
233 SharedRingBuffer& shmem = client_data.shmem; in HandleUnwindBatch()
239 uint64_t reparses_before = client_data.metadata.reparses; in HandleUnwindBatch()
243 HandleBuffer(buf, &client_data.metadata, in HandleUnwindBatch()
244 client_data.data_source_instance_id, in HandleUnwindBatch()
245 client_data.sock->peer_pid(), delegate_); in HandleUnwindBatch()
249 if (reparses_before < client_data.metadata.reparses) { in HandleUnwindBatch()
323 ClientData client_data{ in HandleHandoffSocket() local
330 client_data_.emplace(peer_pid, std::move(client_data)); in HandleHandoffSocket()
346 ClientData& client_data = it->second; in HandleDisconnectSocket() local
348 client_data.sock->Shutdown(/* notify= */ true); in HandleDisconnectSocket()