Function _sr_session_source_remove

libsigrok4DSL/session.c:463–522

* Remove the source belonging to the specified channel. * * @todo Add more error checks and logging. * * @param channel The channel for which the source should be removed. * * @return SR_OK upon success, SR_ERR_ARG upon invalid arguments, or * SR_ERR_MALLOC upon memory allocation errors, SR_ERR_BUG upon * internal errors. */

 *         internal errors.
 */
static int _sr_session_source_remove(gintptr poll_object)
{
	struct source *new_sources;
	GPollFD *new_pollfds;
	unsigned int old;

	if (session == NULL){
		sr_err("_sr_session_source_remove(), session is null.");
		return SR_ERR_CALL_STATUS;
	}

	if (!session->sources || !session->num_sources) {
		sr_err("%s: sources was NULL", __func__);
		return SR_ERR_BUG;
	}

	for (old = 0; old < session->num_sources; old++) {
		if (session->sources[old].poll_object == poll_object)
			break;
	}

	/* fd not found, nothing to do */
	if (old == session->num_sources)
		return SR_OK;

    session->num_sources -= 1;

    if (session->num_sources == 0) {
        session->source_timeout = -1;
        g_free(session->pollfds);
        g_free(session->sources);
        session->pollfds = NULL;
        session->sources = NULL;
    } 
	else {
        if (old != session->num_sources) {
            memmove(&session->pollfds[old], &session->pollfds[old+1],
                (session->num_sources - old) * sizeof(GPollFD));
            memmove(&session->sources[old], &session->sources[old+1],
                (session->num_sources - old) * sizeof(struct source));
        }

        new_pollfds = g_try_realloc(session->pollfds, sizeof(GPollFD) * session->num_sources);
        if (!new_pollfds && session->num_sources > 0) {
            sr_err("%s: new_pollfds malloc failed", __func__);
            return SR_ERR_MALLOC;
        }

        new_sources = g_try_realloc(session->sources, sizeof(struct source) * session->num_sources);
        if (!new_sources && session->num_sources > 0) {
            sr_err("%s: new_sources malloc failed", __func__);
            return SR_ERR_MALLOC;
        }

        session->pollfds = new_pollfds;
        session->sources = new_sources;
    }