1 files changed, 121 insertions, 0 deletions
diff --git a/libgupc/smp/upc_addr.c b/libgupc/smp/upc_addr.c
new file mode 100644
index 00000000000..efe0ae88e88
--- /dev/null
+++ b/libgupc/smp/upc_addr.c
@@ -0,0 +1,121 @@
+/* Copyright (C) 2001-2016 Free Software Foundation, Inc.
+   This file is part of the UPC runtime Library.
+   Written by Gary Funck <gary@intrepid.com>
+   and Nenad Vukicevic <nenad@intrepid.com>
+
+This file is part of GCC.
+
+GCC is free software; you can redistribute it and/or modify
+it under the terms of the GNU General Public License as published by
+the Free Software Foundation; either version 3, or (at your option)
+any later version.
+
+GCC is distributed in the hope that it will be useful,
+but WITHOUT ANY WARRANTY; without even the implied warranty of
+MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+GNU General Public License for more details.
+
+Under Section 7 of GPL version 3, you are granted additional
+permissions described in the GCC Runtime Library Exception, version
+3.1, as published by the Free Software Foundation.
+
+You should have received a copy of the GNU General Public License and
+a copy of the GCC Runtime Library Exception along with this program;
+see the files COPYING3 and COPYING.RUNTIME respectively.  If not, see
+<http://www.gnu.org/licenses/>.  */
+
+#include "upc_config.h"
+#include "upc_sysdep.h"
+#include "upc_defs.h"
+#include "upc_sup.h"
+
+void *
+__cvtaddr (upc_shared_ptr_t p)
+{
+  upc_info_p u = __upc_info;
+  void *addr;
+  if (!u)
+    __upc_fatal ("UPC runtime not initialized");
+  if (GUPCR_PTS_IS_NULL (p))
+    return (void *) 0;
+  addr = __upc_sptr_to_addr (p);
+  return addr;
+}
+
+void *
+__getaddr (upc_shared_ptr_t p)
+{
+  upc_info_p u = __upc_info;
+  void *addr;
+  if (!u)
+    __upc_fatal ("UPC runtime not initialized");
+  if (GUPCR_PTS_IS_NULL (p))
+    return (void *) 0;
+  if ((int)GUPCR_PTS_THREAD(p) != MYTHREAD)
+    __upc_fatal ("Invalid conversion of shared address to local pointer;\nthread does not have affinity to shared address");
+  addr = __upc_sptr_to_addr (p);
+  return addr;
+}
+
+size_t
+upc_threadof (upc_shared_ptr_t p)
+{
+  upc_info_p u = __upc_info;
+  if (!u)
+    __upc_fatal ("UPC runtime not initialized");
+  if ((int)GUPCR_PTS_THREAD(p) >= THREADS)
+    __upc_fatal ("Thread number in shared address is out of range");
+  return GUPCR_PTS_THREAD (p);
+}
+
+size_t
+upc_phaseof (upc_shared_ptr_t p)
+{
+  upc_info_p u = __upc_info;
+  if (!u)
+    __upc_fatal ("UPC runtime not initialized");
+  if ((int)GUPCR_PTS_THREAD(p) >= THREADS)
+    __upc_fatal ("Thread number in shared address is out of range");
+  return GUPCR_PTS_PHASE (p);
+}
+
+upc_shared_ptr_t
+upc_resetphase (upc_shared_ptr_t p)
+{
+  upc_shared_ptr_t result;
+  result = p;
+  GUPCR_PTS_SET_PHASE (result, 0);
+  return result;
+}
+
+size_t
+upc_addrfield (upc_shared_ptr_t p)
+{
+  upc_info_p u = __upc_info;
+  if (!u)
+    __upc_fatal ("UPC runtime not initialized");
+  if ((int)GUPCR_PTS_THREAD(p) >= THREADS)
+    __upc_fatal ("Thread number in shared address is out of range");
+  return (size_t) GUPCR_PTS_VADDR (p);
+}
+
+size_t
+upc_affinitysize (size_t totalsize, size_t nbytes, size_t threadid)
+{ 
+  size_t result;
+  if (nbytes == 0 || totalsize == 0 || nbytes >= totalsize)
+      result = (size_t) (threadid == 0 ? totalsize : 0);
+  else
+    {
+      size_t const nblocks = (totalsize / nbytes);
+      size_t const cutoff = (nblocks % THREADS);
+      if (threadid < cutoff)
+	result = (size_t) ((nblocks + THREADS - 1) / THREADS) * nbytes;
+      else if (threadid > cutoff)
+	result = (size_t) (nblocks / THREADS) * nbytes;
+      else /* threadid == cutoff */
+	result = (size_t) ((nblocks / THREADS) * nbytes)
+			   + totalsize - nblocks * nbytes;
+    }
+  return result;
+}