diff --git a/mindspore/ccsrc/minddata/dataset/engine/cache/cache_request.cc b/mindspore/ccsrc/minddata/dataset/engine/cache/cache_request.cc index c5bdf1d4bc5..8df1e62ee2b 100644 --- a/mindspore/ccsrc/minddata/dataset/engine/cache/cache_request.cc +++ b/mindspore/ccsrc/minddata/dataset/engine/cache/cache_request.cc @@ -14,7 +14,7 @@ * limitations under the License. */ #include "minddata/dataset/engine/cache/cache_request.h" -#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) +#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) && !defined(__APPLE__) #include #include #include diff --git a/mindspore/ccsrc/minddata/dataset/util/services.cc b/mindspore/ccsrc/minddata/dataset/util/services.cc index 14d37f057fb..572a1e94d13 100644 --- a/mindspore/ccsrc/minddata/dataset/util/services.cc +++ b/mindspore/ccsrc/minddata/dataset/util/services.cc @@ -16,7 +16,7 @@ #include "minddata/dataset/util/services.h" #include -#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) +#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) && !defined(__APPLE__) #include #else #include @@ -39,7 +39,7 @@ std::map Services::unique_id_list_ = {}; uint64_t Services::unique_id_count_ = 0; std::mutex Services::unique_id_mutex_; -#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) +#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) && !defined(__APPLE__) std::string Services::GetUserName() { char user[LOGIN_NAME_MAX]; (void)getlogin_r(user, sizeof(user)); diff --git a/mindspore/ccsrc/minddata/dataset/util/services.h b/mindspore/ccsrc/minddata/dataset/util/services.h index 04ae867fa18..92692add3e0 100644 --- a/mindspore/ccsrc/minddata/dataset/util/services.h +++ b/mindspore/ccsrc/minddata/dataset/util/services.h @@ -66,7 +66,7 @@ class Services { std::shared_ptr GetServiceMemPool() { return pool_; } -#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) +#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) && !defined(__APPLE__) static std::string GetUserName(); static std::string GetHostName(); diff --git a/mindspore/ccsrc/minddata/dataset/util/sig_handler.cc b/mindspore/ccsrc/minddata/dataset/util/sig_handler.cc index 62e7217cdab..0282f27e8a8 100644 --- a/mindspore/ccsrc/minddata/dataset/util/sig_handler.cc +++ b/mindspore/ccsrc/minddata/dataset/util/sig_handler.cc @@ -25,7 +25,7 @@ namespace mindspore { namespace dataset { // Register the custom signal handlers -#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) +#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) && !defined(__APPLE__) void RegisterHandlers() { struct sigaction new_int_action; diff --git a/mindspore/ccsrc/minddata/dataset/util/sig_handler.h b/mindspore/ccsrc/minddata/dataset/util/sig_handler.h index 3f6d86da920..b4c8544c1a5 100644 --- a/mindspore/ccsrc/minddata/dataset/util/sig_handler.h +++ b/mindspore/ccsrc/minddata/dataset/util/sig_handler.h @@ -22,7 +22,7 @@ namespace mindspore { namespace dataset { // Register the custom signal handlers -#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) +#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) && !defined(__APPLE__) extern void RegisterHandlers(); // A signal handler for SIGINT. Drives interrupt to watchdog diff --git a/mindspore/ccsrc/minddata/dataset/util/task.cc b/mindspore/ccsrc/minddata/dataset/util/task.cc index 7f54727ae60..04d280f157a 100644 --- a/mindspore/ccsrc/minddata/dataset/util/task.cc +++ b/mindspore/ccsrc/minddata/dataset/util/task.cc @@ -42,7 +42,7 @@ void Task::operator()() { #endif MS_LOG(DEBUG) << my_name_ << " Thread ID " << ss.str() << " Started."; -#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) +#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) && !defined(__APPLE__) native_handle_ = pthread_self(); #endif @@ -200,7 +200,7 @@ Status Task::OverrideInterruptRc(const Status &rc) { return rc; } -#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) +#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) && !defined(__APPLE__) pthread_t Task::GetNativeHandle() const { return native_handle_; } #endif diff --git a/mindspore/ccsrc/minddata/dataset/util/task.h b/mindspore/ccsrc/minddata/dataset/util/task.h index ed327101f40..5a1d4c6e966 100644 --- a/mindspore/ccsrc/minddata/dataset/util/task.h +++ b/mindspore/ccsrc/minddata/dataset/util/task.h @@ -16,7 +16,7 @@ #ifndef MINDSPORE_CCSRC_MINDDATA_DATASET_UTIL_TASK_H_ #define MINDSPORE_CCSRC_MINDDATA_DATASET_UTIL_TASK_H_ -#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) +#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) && !defined(__APPLE__) #include #endif #include @@ -100,7 +100,7 @@ class Task : public IntrpResource { static Status OverrideInterruptRc(const Status &rc); -#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) +#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) && !defined(__APPLE__) pthread_t GetNativeHandle() const; #endif @@ -120,7 +120,7 @@ class Task : public IntrpResource { volatile bool running_; volatile bool caught_severe_exception_; -#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) +#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) && !defined(__APPLE__) pthread_t native_handle_; #else uint64_t native_handle_; diff --git a/mindspore/ccsrc/minddata/dataset/util/task_manager.cc b/mindspore/ccsrc/minddata/dataset/util/task_manager.cc index 5e426b0c7e0..f994ab6de1d 100644 --- a/mindspore/ccsrc/minddata/dataset/util/task_manager.cc +++ b/mindspore/ccsrc/minddata/dataset/util/task_manager.cc @@ -124,7 +124,7 @@ TaskManager::TaskManager() try : global_interrupt_(0), master_->is_master_ = true; #if !defined(_WIN32) && !defined(_WIN64) gMyTask = master_.get(); -#if !defined(__ANDROID__) && !defined(ANDROID) +#if !defined(__ANDROID__) && !defined(ANDROID) && !defined(__APPLE__) // Initialize the semaphore for the watchdog errno_t rc = sem_init(&sem_, 0, 0); if (rc == -1) { @@ -147,14 +147,14 @@ TaskManager::~TaskManager() { watchdog_grp_ = nullptr; watchdog_ = nullptr; } -#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) +#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) && !defined(__APPLE__) (void)sem_destroy(&sem_); #endif } Status TaskManager::DoServiceStart() { MS_LOG(INFO) << "Starting Task Manager."; -#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) +#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) && !defined(__APPLE__) // Create a watchdog for control-c std::shared_ptr mp = Services::GetInstance().GetServiceMemPool(); // A dummy group just for the watchdog. We aren't really using it. But most code assumes a thread must @@ -183,7 +183,7 @@ Status TaskManager::DoServiceStop() { Status TaskManager::WatchDog() { TaskManager::FindMe()->Post(); -#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) +#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) && !defined(__APPLE__) errno_t err = sem_wait(&sem_); if (err == -1) { RETURN_STATUS_UNEXPECTED("Errno = " + std::to_string(errno)); diff --git a/mindspore/ccsrc/minddata/dataset/util/task_manager.h b/mindspore/ccsrc/minddata/dataset/util/task_manager.h index 0724d27cc06..1d20171b619 100644 --- a/mindspore/ccsrc/minddata/dataset/util/task_manager.h +++ b/mindspore/ccsrc/minddata/dataset/util/task_manager.h @@ -16,7 +16,7 @@ #ifndef MINDSPORE_CCSRC_MINDDATA_DATASET_UTIL_TASK_MANAGER_H_ #define MINDSPORE_CCSRC_MINDDATA_DATASET_UTIL_TASK_MANAGER_H_ -#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) +#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) && !defined(__APPLE__) #include #include // for sig_atomic_t #endif @@ -92,7 +92,7 @@ class TaskManager : public Service { static void InterruptMaster(const Status &rc = Status::OK()); static void WakeUpWatchDog() { -#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) +#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) && !defined(__APPLE__) TaskManager &tm = TaskManager::GetInstance(); (void)sem_post(&tm.sem_); #endif @@ -113,7 +113,7 @@ class TaskManager : public Service { std::shared_ptr master_; List lru_; List free_lst_; -#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) +#if !defined(_WIN32) && !defined(_WIN64) && !defined(__ANDROID__) && !defined(ANDROID) && !defined(__APPLE__) sem_t sem_; #endif TaskGroup *watchdog_grp_;