Changeset 6674 for trunk/Ohana/src/addstar
- Timestamp:
- Mar 24, 2006, 2:42:35 PM (21 years ago)
- Location:
- trunk/Ohana/src/addstar
- Files:
-
- 9 edited
-
Makefile (modified) (4 diffs)
-
include/addstar.h (modified) (2 diffs)
-
src/DatasetOps.c (modified) (5 diffs)
-
src/ListenClients_Thread.c (modified) (1 diff)
-
src/NewRefcat_Thread.c (modified) (1 diff)
-
src/NewReflist_Thread.c (modified) (1 diff)
-
src/addstart.c (modified) (3 diffs)
-
src/load_pt_catalog.c (modified) (1 diff)
-
src/match_refstars.c (modified) (1 diff)
Legend:
- Unmodified
- Added
- Removed
-
trunk/Ohana/src/addstar/Makefile
r5899 r6674 87 87 $(SRC)/match_refstars.$(ARCH).o \ 88 88 89 SERVER = \ 89 ADDSTARD = \ 90 $(SRC)/addstard.$(ARCH).o \ 90 91 $(SRC)/SocketOps.$(ARCH).o \ 91 92 $(SRC)/ConfigInit.$(ARCH).o \ … … 130 131 $(SRC)/NewRefcat.$(ARCH).o 131 132 132 CLIENT = \ 133 ADDSTART = \ 134 $(SRC)/addstart.$(ARCH).o \ 135 $(SRC)/DatasetOps.$(ARCH).o \ 136 $(SRC)/SocketOps.$(ARCH).o \ 137 $(SRC)/ConfigInit.$(ARCH).o \ 138 $(SRC)/args_server.$(ARCH).o \ 139 $(SRC)/CheckPassword.$(ARCH).o \ 140 $(SRC)/UpdateDatabase_Image.$(ARCH).o \ 141 $(SRC)/UpdateDatabase_Reflist.$(ARCH).o \ 142 $(SRC)/UpdateDatabase_Refcat.$(ARCH).o \ 143 $(SRC)/airmass.$(ARCH).o \ 144 $(SRC)/build_links.$(ARCH).o \ 145 $(SRC)/calibrate.$(ARCH).o \ 146 $(SRC)/find_matches.$(ARCH).o \ 147 $(SRC)/find_matches_closest.$(ARCH).o \ 148 $(SRC)/find_matches_refstars.$(ARCH).o \ 149 $(SRC)/find_subset.$(ARCH).o \ 150 $(SRC)/get2mass.$(ARCH).o \ 151 $(SRC)/get2mass_as.$(ARCH).o \ 152 $(SRC)/get2mass_dr2.$(ARCH).o \ 153 $(SRC)/getgsc.$(ARCH).o \ 154 $(SRC)/getusno.$(ARCH).o \ 155 $(SRC)/greference.$(ARCH).o \ 156 $(SRC)/gcatalog.$(ARCH).o \ 157 $(SRC)/gimages.$(ARCH).o \ 158 $(SRC)/image-db.$(ARCH).o \ 159 $(SRC)/in_image.$(ARCH).o \ 160 $(SRC)/load_pt_catalog.$(ARCH).o \ 161 $(SRC)/load_subpix.$(ARCH).o \ 162 $(SRC)/mkcatalog.$(ARCH).o \ 163 $(SRC)/replace_match.$(ARCH).o \ 164 $(SRC)/SetSignals.$(ARCH).o \ 165 $(SRC)/SkyRegionUtils.$(ARCH).o \ 166 $(SRC)/SkyListForStars.$(ARCH).o \ 167 $(SRC)/sort_lists.$(ARCH).o \ 168 $(SRC)/update_coords.$(ARCH).o \ 169 $(SRC)/wcatalog.$(ARCH).o \ 170 $(SRC)/Shutdown.$(ARCH).o \ 171 $(SRC)/edge_check.$(ARCH).o \ 172 $(SRC)/check_permissions.$(ARCH).o \ 173 $(SRC)/opening_angle.$(ARCH).o \ 174 $(SRC)/ListenClients_Thread.$(ARCH).o \ 175 $(SRC)/NewImage_Thread.$(ARCH).o \ 176 $(SRC)/NewReflist_Thread.$(ARCH).o \ 177 $(SRC)/NewRefcat_Thread.$(ARCH).o 178 179 ADDSTARC = \ 180 $(SRC)/addstarc.$(ARCH).o \ 133 181 $(SRC)/SocketOps.$(ARCH).o \ 134 182 $(SRC)/ConfigInit.$(ARCH).o \ … … 143 191 $(SRC)/args_client.$(ARCH).o 144 192 145 ADDSTARC = $(SRC)/addstarc.$(ARCH).o $(CLIENT)146 ADDSTARD = $(SRC)/addstard.$(ARCH).o $(SERVER)147 148 193 $(ADDSTARC) : $(INC)/addstar.h 149 194 $(ADDSTARD) : $(INC)/addstar.h 195 $(ADDSTART) : $(INC)/addstar.h 150 196 $(ADDSTAR) : $(INC)/addstar.h 151 197 … … 155 201 addstard : $(BIN)/addstard.$(ARCH) 156 202 $(BIN)/addstard.$(ARCH) : $(ADDSTARD) 203 204 addstart : $(BIN)/addstart.$(ARCH) 205 $(BIN)/addstart.$(ARCH) : $(ADDSTART) 206 @if [ ! -d $(BIN) ]; then mkdir -p $(BIN); fi 207 $(CC) $^ -o $@ $(LFLAGS) -lpthread 157 208 158 209 addstarc : $(BIN)/addstarc.$(ARCH) -
trunk/Ohana/src/addstar/include/addstar.h
r5945 r6674 20 20 fprintf (stderr, "ERROR: photcode %s not found in photcode table\n", NAME); \ 21 21 exit (0); } 22 23 typedef struct { 24 int Nstars; 25 Stars *stars; 26 Image *image; 27 Coords *mosaic; 28 SkyRegion *patch; 29 AddstarClientOptions *options; 30 char *refcat; 31 } DVO_DATA; 22 32 23 33 typedef struct sockaddr_in SockAddress; … … 204 214 int SkyListSetPath (SkyList *list, char *path); 205 215 SkyTable *SkyTableLoadOptimal (); 216 217 int InitDataset (); 218 int PushDataset (DVO_DATA *data); 219 DVO_DATA *PopDataset (void); 220 void *ListenClients_Thread (void *data); 221 int NewImage_Thread (int BindSocket); 222 int NewRefcat_Thread (int BindSocket); 223 int NewReflist_Thread (int BindSocket); -
trunk/Ohana/src/addstar/src/DatasetOps.c
r6498 r6674 1 1 # include "addstar.h" 2 # include <pthread.h> 2 3 3 4 /* the init function is an alternative */ … … 5 6 pthread_mutex_t fastmutex = PTHREAD_MUTEX_INITIALIZER; 6 7 7 static int lock = FALSE;8 8 static int Ndataset = 0; 9 9 static int NDATASET = 0; … … 29 29 int N; 30 30 31 pthread_mutex_lock(& mutex);31 pthread_mutex_lock(&fastmutex); 32 32 33 33 N = Ndataset; 34 34 Ndataset ++; 35 CHECK_REALLOCATE (dataset, DVO_DATA , NDATASET, Ndataset, 100);35 CHECK_REALLOCATE (dataset, DVO_DATA *, NDATASET, Ndataset, 100); 36 36 37 37 dataset[N] = data; 38 38 39 pthread_mutex_unlock(& mutex);39 pthread_mutex_unlock(&fastmutex); 40 40 return (TRUE); 41 41 } … … 44 44 DVO_DATA *PopDataset (void) { 45 45 46 int i; 46 47 DVO_DATA *data; 47 48 48 pthread_mutex_lock(& mutex);49 pthread_mutex_lock(&fastmutex); 49 50 50 51 if (Ndataset == 0) { 51 pthread_mutex_unlock(& mutex);52 pthread_mutex_unlock(&fastmutex); 52 53 return (NULL); 53 54 } … … 61 62 if ((Ndataset < NDATASET / 2) && (Ndataset > 50)) { 62 63 NDATASET = Ndataset / 2; 63 REALLOCATE (dataset, DVO_DATA , NDATASET);64 REALLOCATE (dataset, DVO_DATA *, NDATASET); 64 65 } 65 66 66 pthread_mutex_unlock(& mutex);67 pthread_mutex_unlock(&fastmutex); 67 68 return (data); 68 69 } -
trunk/Ohana/src/addstar/src/ListenClients_Thread.c
r6498 r6674 2 2 3 3 /* wait for incoming messages from clients */ 4 int ListenClients_Thread () {4 void *ListenClients_Thread (void *data) { 5 5 6 6 int status, InitSocket, BindSocket; 7 7 SockAddress Address; 8 8 IOBuffer message; 9 AddstarClientOptions options;10 9 11 10 /* if we have multiple threads, each one creates its own socket? */ -
trunk/Ohana/src/addstar/src/NewRefcat_Thread.c
r6498 r6674 7 7 IOBuffer message; 8 8 SkyRegion *patch; 9 DVO_DATA *dataset; 9 10 10 11 /* accept incoming data set */ -
trunk/Ohana/src/addstar/src/NewReflist_Thread.c
r6498 r6674 6 6 Stars *stars; 7 7 AddstarClientOptions *options; 8 DVO_DATA *dataset; 8 9 9 10 /* accept incoming data set */ -
trunk/Ohana/src/addstar/src/addstart.c
r6498 r6674 1 1 # include "addstar.h" 2 # include <pthread.h> 2 3 3 4 int main (int argc, char **argv) { 4 5 5 int status, InitSocket, BindSocket;6 SockAddress Address;7 IOBuffer message;8 6 AddstarClientOptions options; 7 pthread_t thread; 8 DVO_DATA *dataset; 9 // pthread_attr_t attr; 9 10 10 11 options = ConfigInit (&argc, argv); … … 13 14 /* store the sky table in a global for internal use */ 14 15 ServerSky = SkyTableLoadOptimal (CATDIR, SKY_TABLE, GSCFILE, SKY_DEPTH, VERBOSE); 15 SkyTableSetFilename (ServerSky, CATDIR, "cpt");16 SkyTableSetFilenames (ServerSky, CATDIR, "cpt"); 16 17 17 18 VERBOSE = TRUE; … … 24 25 25 26 /* decide if we need an argument to dbthread */ 26 pthread_create ( thread, attr,ListenClients_Thread, NULL);27 pthread_create (&thread, NULL, &ListenClients_Thread, NULL); 27 28 28 29 while (1) { -
trunk/Ohana/src/addstar/src/load_pt_catalog.c
r5945 r6674 3 3 int load_pt_catalog (Catalog *catalog, SkyRegion *region) { 4 4 5 check_permissions (catalog[0].filename); 5 if (!check_file_access (catalog[0].filename, TRUE, TRUE)) { 6 exit (1); 7 } 8 6 9 if (VERBOSE) fprintf (stderr, "adding to %s\n", catalog[0].filename); 7 10 -
trunk/Ohana/src/addstar/src/match_refstars.c
r3339 r6674 13 13 if (stars[i].found != -1) continue; 14 14 gregion_star (&stars[i], ®ion); 15 check_permissions (region.filename); 15 if (!check_file_access (region.filename, TRUE, TRUE)) { 16 exit (0); 17 } 16 18 make_backup (region.filename); 17 19
Note:
See TracChangeset
for help on using the changeset viewer.
