Changeset 680 for pjproject/branches/symbian/pjlib/src/pj/os_core_symbian.cpp

Timestamp:

Aug 14, 2006 12:55:27 AM (18 years ago)

Author:

ismangil

Message:

Work in progress. Compile and links cleanly. Executes in console mode still buggy.

File:

• pjproject/branches/symbian/pjlib/src/pj/os_core_symbian.cpp (modified) (6 diffs)

pjproject/branches/symbian/pjlib/src/pj/os_core_symbian.cpp

@@ -66 +66 @@
  * This is the main entry for all threads.
  */
-TInt *thread_main(TAny *param)
+TInt thread_main(TAny *param)
 {
     pj_thread_t *rec = (pj_thread_t *) param;
-    TInt *result;
+    TInt result;
     /* pj_status_t rc; */
 
@@ -75 +75 @@
 
     /* Call user's entry! */
-    result = (TInt*)(long)(*rec->proc)(rec->arg);
+    result = (TInt)(*rec->proc)(rec->arg);
 
     /* Done. */
@@ -119 +119 @@
     rec->proc = proc;
     rec->arg = arg;
-    _LIT( KThreadName, "A name");
-    rc = rec->thread.Create(KThreadName, thread_main, 4096, KMinHeapSize, 256*16, rec->arg, EOwnerProcess);
+    _LIT( KThreadName, "Athread");
+    rc = rec->thread.Create(KThreadName, thread_main, 4096, KMinHeapSize, 256*16, rec->arg, EOwnerThread);
     if (rc != 0) {
         return PJ_RETURN_OS_ERROR(rc);
@@ -131 +131 @@
 }
 
+/*
+ * pj_thread-get_name()
+ */
+PJ_DEF(const char*) pj_thread_get_name(pj_thread_t *p)
+{
+    pj_thread_t *rec = (pj_thread_t*)p;
+
+    return rec->obj_name;
+}
+
+/*
+ * pj_thread_resume()
+ */
+PJ_DEF(pj_status_t) pj_thread_resume(pj_thread_t *p)
+{
+    pj_status_t rc;
+
+    pj_thread_t *rec = (pj_thread_t*)p;
+
+    rec->thread.Resume();
+
+    rc = PJ_SUCCESS;
+
+    return rc;
+}
+
+/*
+ * pj_thread_this()
+ */
+PJ_DEF(pj_thread_t*) pj_thread_this(void)
+{
+    // TODO
+    return NULL;
+}
+
+/*
+ * pj_thread_join()
+ */
+PJ_DEF(pj_status_t) pj_thread_join(pj_thread_t *p)
+{
+    pj_thread_t *rec = (pj_thread_t *)p;
+    TRequestStatus result;
+
+    //PJ_LOG(6, (pj_thread_this()->obj_name, "Joining thread %s", p->obj_name));
+
+    rec->thread.Rendezvous(result);
+
+    return PJ_SUCCESS;
+}
+
+/*
+ * pj_thread_destroy()
+ */
+PJ_DEF(pj_status_t) pj_thread_destroy(pj_thread_t *p)
+{
+    pj_thread_t *rec = (pj_thread_t *)p;
+    rec->thread.Kill(1);
+        
+
+    return PJ_SUCCESS;
+}
+
+/*
+ * pj_thread_sleep()
+ */
+PJ_DEF(pj_status_t) pj_thread_sleep(unsigned msec)
+{
+    if (sleep(msec * 1000) == 0)
+        return PJ_SUCCESS;
+}
+
+
 ///////////////////////////////////////////////////////////////////////////////
 /*
  * pj_thread_local_alloc()
  */
+
 PJ_DEF(pj_status_t) pj_thread_local_alloc(long *index)
 {
@@ -175 +248 @@
                                             pj_mutex_t **mutex )
 {
+    (*mutex) = (pj_mutex_t *)1;
     return PJ_SUCCESS;
 }
@@ -187 +261 @@
 
 /*
+ * pj_mutex_trylock()
+ */
+PJ_DEF(pj_status_t) pj_mutex_trylock(pj_mutex_t *mutex)
+{
+    return PJ_SUCCESS;
+}
+
+/*
  * pj_mutex_unlock()
  */