【正文】 } sleep(1)。 } temperature_close(fdtemperature)。 light_close(fdlight)。 (*g_vm)DetachCurrentThread(g_vm)。 cflags[0] = 1。 return (void *)0。 } void * setctrlcl1(void *argc)。 void * naozhong1(void *argc)。 void * Mysocket(void *argc)。 void * shoumsg(void *argc) { pthread_detach(pthread_self())。 37 while(1) { sleep(10)。 pthread_mutex_lock(amp。gprs_rfid_mutex)。 if(ReceiveMes(1)== 2) { DeleteMes(1)。 pthread_mutex_unlock(amp。gprs_rfid_mutex)。 continue。 } int j。 for(j=0。j3。j++) DeleteMes(1)。 char buf[23]=+86。 strcat(buf,shoujihaoma)。 if(strcmp(gprs_mesbuf[0],buf)!=0) { pthread_mutex_unlock(amp。gprs_rfid_mutex)。 continue。 } if(strcmp(gprs_mesbuf[2],openair)==0) { int ledfd = ledopen()。 int i = 0。 ledset(ledfd, 8, amp。i)。 ledclose(ledfd)。 cflags[11] = 1。 SendMes(openair ok,shoujihaoma)。 } pthread_mutex_unlock(amp。gprs_rfid_mutex)。 } return (void *)0。 } JNIEXPORT void JNICALL Java__example_CtrHome_GasDev_initall (JNIEnv *env, jobject obj,jintArray intArray) { if(cflags[0]==0 ) 38 { initall()。 cflags[0] = 3。 } else { cflags[0] = 2 。 while(cflags[0]!= 1) 。 } jflags = intArray。 (*env)SetIntArrayRegion(env, jflags,0, 16, cflags)。 (*env)GetJavaVM(env,amp。g_vm)。 g_obj = (*env)NewGlobalRef(env,obj)。 pthread_t pt1。 pthread_create(amp。pt1,NULL,main_pthread,NULL)。 if(cflags[0]==3) { pthread_t pt2。 pthread_create(amp。pt2,NULL,setctrlcl1,NULL)。 pthread_t pt3。 pthread_create(amp。pt3,NULL,naozhong1,NULL)。 pthread_t pt4。 pthread_create(amp。pt4,NULL,shoumsg,NULL)。 pthread_t pt5。 pthread_create(amp。pt5,NULL,Mysocket,NULL)。 } return。 }。 JNIEXPORT void JNICALL Java__example_CtrHome_GasDev_zidongmoshi (JNIEnv *env, jobject obj, jint i) { cflags[3] = i。 } 39 JNIEXPORT void JNICALL Java__example_CtrHome_GasDev_setlight (JNIEnv *env, jobject obj, jint i) { cflags[9] = i。 } void * setctrlcl1(void *argc) { pthread_detach(pthread_self())。 int fd = stepmotor_open()。 int j。 while(1) { sleep(2)。 if((cflags[7]==1)amp。amp。(cflags[8]==1)amp。amp。(cflags[9]cflags[10])) { if(sem_trywait(amp。semcl)0) continue。 for(j=0。 j12。 j++) stepmotor_rollback(fd,20)。 cflags[8]=0。 sem_post(amp。semcl)。 } if((cflags[7]==2)amp。amp。(cflags[8]==0)amp。amp。(cflags[9]cflags[10])) { if(sem_trywait(amp。semcl)0) continue。 for(j=0。 j12。 j++) stepmotor_forward(fd,20)。 cflags[8]=1。 sem_post(amp。semcl)。 } if((cflags[8]==1)amp。amp。(cflags[10]=4000)) { int fd = ledopen()。 j = 1。 ledset(fd, 6, amp。j)。 ledclose(fd)。 cflags[13] = 0。 } 40 } stepmotor_close(fd)。 return (void *)0。 } JNIEXPORT void JNICALL Java__example_CtrHome_GasDev_setctrlcl (JNIEnv *env, jobject obj, jint i) { cflags[7] = i。 } void * setctrlcl2(void *argc) { pthread_detach(pthread_self())。 int i = (int)argc。 int fd = stepmotor_open()。 int j。 if(i == 1) { for(j=0。 j12。 j++) stepmotor_forward(fd,20)。 } else { for(j=0。 j12。 j++) stepmotor_rollback(fd,20)。 } stepmotor_close(fd)。 cflags[8] = i。 sem_post(amp。semcl)。 return (void *)0。 } JNIEXPORT void JNICALL Java__example_CtrHome_GasDev_setctrlcl2 (JNIEnv *env, jobject obj, jint i) { 41 if(i == cflags[8]) return 。 if( sem_trywait(amp。semcl) 0) return 。 pthread_t pt1。 pthread_create(amp。pt1,NULL,setctrlcl2,(void *)i)。 return 。 } JNIEXPORT void JNICALL Java__example_CtrHome_GasDev_setled (JNIEnv *env, jobject obj, jint i) { int fd = ledopen()。 int j。 if(i == 13) { cflags[13] = !cflags[13]。 j = !cflags[13]。 ledset(fd,6, amp。j)。 } if(i == 14) { cflags[14] = !cflags[14]。 j = !cflags[14]。 ledset(fd,5, amp。j)。 } if(i == 0) { j = 1。 ledset(fd,5, amp。j)。 ledset(fd,6, amp。j)。 cflags[13] = 0。 cflags[14] = 0。 } if(i == 1) { j = 0。 ledset(fd,5, amp。j)。 ledset(fd,6, amp。j)。 cflags[13] = 1。 cflags[14] = 1。 } 42 ledclose(fd)。 } void * naozhong1(void *argc) { pthread_detach(pthread_self())。 time_t tp。 struct tm *s_tm。 int fd = beeopen()。 int fd2 = hongwai_open()。 int fd1 = gas_open()。 int fd3 = motor_open()。 int fd4 = ledopen()。 int j,k。 while(1) { tp = time(NULL)。 s_tm = localtime(amp。tp)。 gas_iotcl(fd1,amp。k)。 if((k3000)amp。amp。(cflags[12]!=2)) { motor_foreward(fd3)。 cflags[12]=1。 } else if(cflags[12] ==1) { motor_stop(fd3)。 cflags[12]=0。 } if(((cflags[16]/10000)==1)amp。amp。((s_tmtm_hour)==(cflags[16]%10000/100))amp。amp。((s_tmtm_min)==(cflags[16]%100))) { beeon(fd)。 beeDutyCycle(fd,)。 beeCycle(fd, )。 sleep(10)。 beeoff(fd)。 cflags[16] = cflags[16]%10000。 } hongwai1_iotcl(fd2,amp。j)。 43 if(((cflags[4]!=0)||(cflags[5]!=0))amp。amp。((k=3000)||(j==0))) { beeon(fd)。 if((j==0)amp。amp。(cflags[4]!=0)) { beeDutyCycle(fd,)。 beeCycle(fd, )。 } if((k=3000)amp。amp。(cflags[5]!=0)) { beeDutyCycle(fd,)。 beeCycle(fd, )。 } if((k=3000)amp。amp。(cflags[5]==2)amp。amp。((cflags[18]/10000)=3600 )) { cflags[18] = cflags[18]%10000。 pthread_mutex_lock(amp。gprs_rfid_mutex)。 SendMes(gas or firewarning,shoujihaoma)。 pthread_mutex_unlock(amp。gprs_rfid_mutex)。 } if((j==0)amp。amp。(cflags[4]==2)amp。amp。((cflags[18]%10000)=3600 )) { cflags[18] = cflags[18]/10000*10000。 pthread_mutex_lock(amp。gprs_rfid_mutex)。 SendMes(invade,shoujihaoma)。 pt