pcshareMgr/inc/sharethread.h File Reference

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Functions
gboolean	shareThread_start (shareMgr_t *share_parms)
gboolean	shareThread_stop (void)
gboolean	shareThread_wait (int timeout_sec)

---

Function Documentation

gboolean shareThread_start

(

shareMgr_t *

share_parms

)

Copyright (C) 2005-2008 iRex Technologies B.V. All rights reserved.

Definition at line 237 of file sharethread.c.

{
    GThread* thread = NULL;
    GError*  error = NULL;

    DL_LOGPRINTF("entry");
    if (g_share_thread)
    {
        DL_ERRORPRINTF("share thread already running");
        return FALSE;
    }

    // create the share thread
    g_share_abort = FALSE;
    thread = g_thread_create(shareThread, share_parms, FALSE, &error);
    if (error != NULL)
    {
        DL_ERRORPRINTF("Failed to create share thread - %s [%d]", error->message, error->code);
        g_free(error);
        error = NULL;
    }
    else
    {
        g_share_thread = thread;
    }

    return TRUE;
}

Here is the call graph for this function:

gboolean shareThread_stop

(

void

)

Definition at line 266 of file sharethread.c.

{
    DL_LOGPRINTF("entry");

    if (g_share_thread)
    {
        // stop the share thread
        g_share_abort = TRUE;

        // stop any process spawned by shareThread
        pid_t pid = get_forkexec_child_pid();
        if (pid > 0)
        {
            kill(pid, SIGTERM);
        }

        // stop fileCopy that might be running on shareThread
        fileCopy_abort();

        return TRUE;
    }
    else
    {
        DL_ERRORPRINTF("share thread not running");
        return FALSE;
    }
}

Here is the call graph for this function:

gboolean shareThread_wait

(

int

timeout_sec

)

Definition at line 294 of file sharethread.c.

{
    int max_ticks = 2 * timeout_sec;

    DL_LOGPRINTF("entry");

    if (g_share_thread)
    {
        // sorry don't like busy-wait, but g_thread_join has no timeout option
        while (g_share_thread  &&  --max_ticks >= 0)
        {
            g_usleep(500*1000L);
        }
        return TRUE;
    }
    else
    {
        DL_ERRORPRINTF("share thread not running");
        return FALSE;
    }
}