... | ... |
@@ -264,7 +264,7 @@ int do_accept(mcomm *c, fd_set *fds) |
264 | 264 |
c[i].fd[0] = accept(s, (struct sockaddr *)&ss, &sslen); |
265 | 265 |
switch(ss.ss_family){ |
266 | 266 |
case AF_UNIX: |
267 |
- lprintf(5, "%s: socket=%d\n", __func__, i); |
|
267 |
+ lprintf(5, "%s: socket=%d from %s\n", __func__, i, moption.uaddr.sun_path); |
|
268 | 268 |
break; |
269 | 269 |
case AF_INET: |
270 | 270 |
case AF_INET6: |
... | ... |
@@ -381,11 +381,9 @@ int mexec_send(mcomm *c, int n, int sync) |
381 | 381 |
argv[i] = c->parse[n][i]; |
382 | 382 |
} |
383 | 383 |
argv[i] = NULL; |
384 |
+ optind = 1; |
|
384 | 385 |
#ifdef HAVE_GETOPT_OPTRESET |
385 |
- optind = 1; |
|
386 | 386 |
optreset = 1; |
387 |
-#else |
|
388 |
- optind = 1; |
|
389 | 387 |
#endif |
390 | 388 |
while((i=getopt(c->argc[n], argv, "g:t:nr")) != -1){ |
391 | 389 |
switch(i){ |
... | ... |
@@ -565,11 +563,9 @@ int mexec_check(mcomm *c, int n) |
565 | 565 |
for(i=0;i<c->argc[n];i++) |
566 | 566 |
argv[i] = c->parse[n][i]; |
567 | 567 |
argv[i] = NULL; |
568 |
+ optind = 1; |
|
568 | 569 |
#ifdef HAVE_GETOPT_OPTRESET |
569 |
- optind = 1; |
|
570 | 570 |
optreset = 1; |
571 |
-#else |
|
572 |
- optind = 0; |
|
573 | 571 |
#endif |
574 | 572 |
while((i=getopt(c->argc[n], argv, "t:r")) != -1){ |
575 | 573 |
switch(i){ |
... | ... |
@@ -673,11 +669,9 @@ int mexec_dsync(mcomm *c, int n) |
673 | 673 |
for(i=0;i<c->argc[n];i++) |
674 | 674 |
argv[i] = c->parse[n][i]; |
675 | 675 |
argv[i] = NULL; |
676 |
+ optind = 1; |
|
676 | 677 |
#ifdef HAVE_GETOPT_OPTRESET |
677 |
- optind = 1; |
|
678 | 678 |
optreset = 1; |
679 |
-#else |
|
680 |
- optind = 0; |
|
681 | 679 |
#endif |
682 | 680 |
while((i=getopt(c->argc[n], argv, "t:nr")) != -1){ |
683 | 681 |
switch(i){ |
... | ... |
@@ -1225,11 +1225,20 @@ static void mrecv_req_del_open(mdata *data, struct sockaddr_in *addr) |
1225 | 1225 |
len -= sizeof(uint32_t); |
1226 | 1226 |
data_safeget(data, path, len); |
1227 | 1227 |
path[len] = 0; |
1228 |
+#ifdef MAKUO_DEBUG |
|
1229 |
+ lprintf(9, "%s: %s", __func__, path); |
|
1230 |
+#endif |
|
1228 | 1231 |
if(lstat(path, &(a->fs)) == -1 && errno == ENOENT){ |
1232 |
+#ifdef MAKUO_DEBUG |
|
1233 |
+ lprintf(9, " [DELETE]"); |
|
1234 |
+#endif |
|
1229 | 1235 |
data_safeset16(&(a->mdata), len + sizeof(uint32_t)); |
1230 | 1236 |
data_safeset32(&(a->mdata), 0); |
1231 | 1237 |
data_safeset(&(a->mdata), path, len); |
1232 | 1238 |
} |
1239 |
+#ifdef MAKUO_DEBUG |
|
1240 |
+ lprintf(9, "\n"); |
|
1241 |
+#endif |
|
1233 | 1242 |
} |
1234 | 1243 |
msend(a); |
1235 | 1244 |
} |
... | ... |
@@ -1,5 +1,5 @@ |
1 | 1 |
Name: makuosan |
2 |
-Version: 1.2.1 |
|
2 |
+Version: 1.2.2 |
|
3 | 3 |
Release: 1%{?dist} |
4 | 4 |
Summary: Multicasts All-Kinds of Updating Operation for Servers on Administered Network |
5 | 5 |
|
... | ... |
@@ -41,7 +41,6 @@ also alive. Therefore, it never stalls waiting for a dead server, or timeouts. |
41 | 41 |
%prep |
42 | 42 |
%setup -q |
43 | 43 |
|
44 |
- |
|
45 | 44 |
%build |
46 | 45 |
%configure --prefix=/usr |
47 | 46 |
|
... | ... |
@@ -51,11 +50,8 @@ make %{?_smp_mflags} |
51 | 51 |
rm -rf %{buildroot} |
52 | 52 |
make install DESTDIR=%{buildroot} |
53 | 53 |
|
54 |
-# remove memcached-debug |
|
55 |
-rm -f %{buildroot}/%{_bindir}/makuosan-debug |
|
56 |
- |
|
57 | 54 |
# Init script |
58 |
-install -Dp -m0755 makuosan.sysv %{buildroot}%{_initrddir}/makuosan |
|
55 |
+install -Dp -m0755 support/makuosan.sysv %{buildroot}%{_initrddir}/makuosan |
|
59 | 56 |
|
60 | 57 |
# Default configs |
61 | 58 |
mkdir -p %{buildroot}/%{_sysconfdir}/sysconfig |
... | ... |
@@ -83,10 +79,9 @@ rm -rf %{buildroot} |
83 | 83 |
|
84 | 84 |
|
85 | 85 |
%changelog |
86 |
+* Mon Jun 16 2009 Masanobu Yasui <yasui0906@gmail.com> - 1.2.2 |
|
86 | 87 |
* Mon Jun 16 2009 Masanobu Yasui <yasui0906@gmail.com> - 1.2.1 |
87 |
- |
|
88 | 88 |
* Mon May 25 2009 Masanobu Yasui <yasui0906@gmail.com> - 1.2.0 |
89 |
- |
|
90 | 89 |
* Thu Nov 6 2008 Naoya Nakazawa <naoya.n@gmail.com> - 1.0.0 |
91 | 90 |
- Initial version |
92 | 91 |
|