1 /* ****************************************************************
3 * Copyright 2016 Samsung Electronics All Rights Reserved.
7 * Licensed under the Apache License, Version 2.0 (the "License");
8 * you may not use this file except in compliance with the License.
9 * You may obtain a copy of the License at
11 * http://www.apache.org/licenses/LICENSE-2.0
13 * Unless required by applicable law or agreed to in writing, software
14 * distributed under the License is distributed on an "AS IS" BASIS,
15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16 * See the License for the specific language governing permissions and
17 * limitations under the License.
19 ******************************************************************/
23 #include "caleclient.h"
24 #include "camanagerleutil.h"
25 #include "camanagerdevice.h"
26 #include "caleautoconnector.h"
27 #include "cacommonutil.h"
31 #define TAG "OIC_CA_LE_AUTO_CONN"
33 static const size_t MAX_RETRY_COUNT = 5;
34 static const size_t TIMEOUT = 1000000;
35 static const size_t WAITING_TIME = 500000;
37 static ca_mutex g_connectRetryMutex = NULL;
38 static ca_cond g_connectRetryCond = NULL;
40 static ca_mutex g_recoveryMutex = NULL;
41 static ca_cond g_recoveryCond = NULL;
43 CAResult_t CAManagerInitLEAutoConnection()
45 if (NULL == g_connectRetryMutex)
47 g_connectRetryMutex = ca_mutex_new();
48 if (NULL == g_connectRetryMutex)
50 OIC_LOG(ERROR, TAG, "ca_mutex_new has failed");
51 return CA_STATUS_FAILED;
55 if (NULL == g_connectRetryCond)
57 g_connectRetryCond = ca_cond_new();
58 if (NULL == g_connectRetryCond)
60 OIC_LOG(ERROR, TAG, "ca_cond_new has failed");
61 return CA_STATUS_FAILED;
65 if (NULL == g_recoveryMutex)
67 g_recoveryMutex = ca_mutex_new();
68 if (NULL == g_recoveryMutex)
70 OIC_LOG(ERROR, TAG, "ca_mutex_new has failed");
71 return CA_STATUS_FAILED;
75 if (NULL == g_recoveryCond)
77 g_recoveryCond = ca_cond_new();
78 if (NULL == g_recoveryCond)
80 OIC_LOG(ERROR, TAG, "ca_cond_new has failed");
81 return CA_STATUS_FAILED;
88 void CAManagerTerminateLEAutoConnection()
90 if (g_connectRetryCond)
92 ca_cond_signal(g_connectRetryCond);
93 ca_cond_free(g_connectRetryCond);
94 g_connectRetryCond = NULL;
97 if (g_connectRetryMutex)
99 ca_mutex_free(g_connectRetryMutex);
100 g_connectRetryMutex = NULL;
105 ca_cond_signal(g_recoveryCond);
106 ca_cond_free(g_recoveryCond);
107 g_recoveryCond = NULL;
112 ca_mutex_free(g_recoveryMutex);
113 g_recoveryMutex = NULL;
117 CAResult_t CAManagerStartAutoConnection(JNIEnv *env, jstring remote_le_address)
119 VERIFY_NON_NULL(env, TAG, "env is null");
120 VERIFY_NON_NULL(remote_le_address, TAG, "remote_le_address is null");
122 OIC_LOG(DEBUG, TAG, "IN - CAManagerStartAutoConnection");
124 if (true == CAManagerGetAutoConnectionFlag(env, remote_le_address))
126 OIC_LOG(INFO, TAG, "auto connecting.");
127 return CA_STATUS_FAILED;
130 ca_mutex_lock(g_connectRetryMutex);
132 for (size_t retry_cnt = 0 ; retry_cnt < MAX_RETRY_COUNT ; retry_cnt++)
134 // there is retry logic 5 times when connectGatt call has failed
135 // because BT adapter might be not ready yet.
136 if (NULL == CAManagerConnectGatt(env, remote_le_address))
138 OIC_LOG_V(INFO, TAG, "retry will be started at least %d times after delay 1sec",
139 MAX_RETRY_COUNT - retry_cnt - 1);
140 if (ca_cond_wait_for(g_connectRetryCond, g_connectRetryMutex, TIMEOUT) == 0)
142 OIC_LOG(INFO, TAG, "request to connect gatt was canceled");
143 ca_mutex_unlock(g_connectRetryMutex);
146 // time out. retry connection
150 OIC_LOG(INFO, TAG, "ConnectGatt has called successfully");
154 ca_mutex_unlock(g_connectRetryMutex);
155 OIC_LOG(DEBUG, TAG, "OUT - CAManagerStartAutoConnection");
159 jobject CAManagerConnectGatt(JNIEnv *env, jstring remote_le_address)
161 VERIFY_NON_NULL_RET(env, TAG, "env", NULL);
162 VERIFY_NON_NULL_RET(remote_le_address, TAG, "remote_le_address", NULL);
164 OIC_LOG(DEBUG, TAG, "IN - CAManagerConnectGatt");
166 jobject jni_bluetooth = CAManagerGetRemoteDevice(env, remote_le_address);
169 OIC_LOG(ERROR, TAG, "jni_bluetooth is null");
173 if (!CAManagerIsDeviceBonded(env, jni_bluetooth))
175 OIC_LOG(INFO, TAG, "device is BONDED_NONE");
178 // request to connection with AutoConnection Flag
179 OIC_LOG(INFO, TAG, "request to gatt connection for auto connection");
180 jobject newGatt = (jobject)CALEClientConnect(env, jni_bluetooth, JNI_TRUE);
183 OIC_LOG(INFO, TAG, "re-connection will be started");
187 // set flag auto connection is requested.
188 CAManagerSetAutoConnectionFlag(env, remote_le_address, true);
190 OIC_LOG(DEBUG, TAG, "OUT - CAManagerConnectGatt");
194 CAResult_t CAManagerProcessRecovery(JNIEnv *env, uint16_t adapter_state)
196 VERIFY_NON_NULL(env, TAG, "env");
197 OIC_LOG(DEBUG, TAG, "IN - CAManagerProcessRecovery");
199 ca_mutex_lock(g_recoveryMutex);
200 CAResult_t res = CA_STATUS_OK;
202 switch(adapter_state)
205 // adapter will be enabled automatically after WAITING_TIME.
206 if (ca_cond_wait_for(g_recoveryCond, g_recoveryMutex, WAITING_TIME) == 0)
208 OIC_LOG(INFO, TAG, "BT recovery was canceled");
213 if (!CAManagerControlAdapter(env, true))
215 OIC_LOG(ERROR, TAG, "BT recovery(enable) failure");
216 res = CA_STATUS_FAILED;
219 CAManagerSetBTRecovery(false);
222 if (!CAManagerControlAdapter(env, false))
224 OIC_LOG(ERROR, TAG, "BT recovery(disable) failure");
225 res = CA_STATUS_FAILED;
227 CAManagerSetBTRecovery(true);
233 ca_mutex_unlock(g_recoveryMutex);
234 OIC_LOG(DEBUG, TAG, "OUT - CAManagerProcessRecovery");