Skip to content

Commit

Permalink
screencast: remove on_event
Browse files Browse the repository at this point in the history
  • Loading branch information
columbarius committed Jun 14, 2021
1 parent 4c3d4d8 commit 5c33970
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 51 deletions.
1 change: 0 additions & 1 deletion include/screencast_common.h
Original file line number Diff line number Diff line change
Expand Up @@ -85,7 +85,6 @@ struct xdpw_screencast_instance {
bool initialized;

// pipewire
struct spa_source *event;
struct pw_stream *stream;
struct spa_hook stream_listener;
struct spa_video_info_raw pwr_format;
Expand Down
50 changes: 0 additions & 50 deletions src/screencast/pipewire_screencast.c
Original file line number Diff line number Diff line change
Expand Up @@ -66,51 +66,6 @@ static inline struct spa_pod *build_format(struct spa_pod_builder *b, uint32_t f
return spa_pod_builder_pop(b, &f[0]);
}

static void pwr_on_event(void *data, uint64_t expirations) {
struct xdpw_screencast_instance *cast = data;
struct pw_buffer *pw_buf;
struct spa_buffer *spa_buf;
struct spa_meta_header *h;
struct spa_data *d;

logprint(TRACE, "********************");
logprint(TRACE, "pipewire: event fired");

if ((pw_buf = pw_stream_dequeue_buffer(cast->stream)) == NULL) {
logprint(WARN, "pipewire: out of buffers");
goto out;
}

spa_buf = pw_buf->buffer;
d = spa_buf->datas;
if ((d[0].data) == NULL) {
logprint(TRACE, "pipewire: data pointer undefined");
goto out;
}
if ((h = spa_buffer_find_meta_data(spa_buf, SPA_META_Header, sizeof(*h)))) {
h->pts = -1;
h->flags = 0;
h->seq = cast->seq++;
h->dts_offset = 0;
}

writeFrameData(d[0].data, cast->simple_frame.data, cast->simple_frame.height,
cast->simple_frame.stride, cast->simple_frame.y_invert);

logprint(TRACE, "pipewire: pointer %p", d[0].data);
logprint(TRACE, "pipewire: size %d", d[0].maxsize);
logprint(TRACE, "pipewire: stride %d", d[0].chunk->stride);
logprint(TRACE, "pipewire: width %d", cast->simple_frame.width);
logprint(TRACE, "pipewire: height %d", cast->simple_frame.height);
logprint(TRACE, "pipewire: y_invert %d", cast->simple_frame.y_invert);
logprint(TRACE, "********************");

pw_stream_queue_buffer(cast->stream, pw_buf);

out:
xdpw_wlr_frame_free(cast);
}

static void pwr_handle_stream_state_changed(void *data,
enum pw_stream_state old, enum pw_stream_state state, const char *error) {
struct xdpw_screencast_instance *cast = data;
Expand Down Expand Up @@ -334,11 +289,6 @@ void xdpw_pwr_stream_create(struct xdpw_screencast_instance *cast) {
}
cast->pwr_stream_state = false;

/* make an event to signal frame ready */
cast->event =
pw_loop_add_event(state->pw_loop, pwr_on_event, cast);
logprint(DEBUG, "pipewire: registered event %p", cast->event);

enum spa_video_format format = xdpw_format_pw_from_wl_shm(cast);

const struct spa_pod *param = build_format(&b, format,
Expand Down

0 comments on commit 5c33970

Please sign in to comment.