summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authormatz <matz@b2dd03c8-39d4-4d8f-98ff-823fe69b080e>2008-01-21 19:47:26 +0000
committermatz <matz@b2dd03c8-39d4-4d8f-98ff-823fe69b080e>2008-01-21 19:47:26 +0000
commit070760eda165135fa6d8f4a19890043a239a3199 (patch)
tree2ae0c620f08f299d6b7b0c775982e165e82b3f7f
parent306fbb6a0c2af726f7a30585c59f8b4c14878437 (diff)
* parse.y (rb_intern3): do not call rb_enc_mbclen() if *m is
ASCII. [ruby-talk:287225] * string.c (rb_str_each_line): use rb_enc_is_newline() to gain performance if the record separator ($/) is not modified. git-svn-id: http://svn.ruby-lang.org/repos/ruby/trunk@15163 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
-rw-r--r--ChangeLog8
-rw-r--r--include/ruby/encoding.h3
-rw-r--r--parse.y9
-rw-r--r--string.c20
4 files changed, 37 insertions, 3 deletions
diff --git a/ChangeLog b/ChangeLog
index 1a433fc76..85eaf1743 100644
--- a/ChangeLog
+++ b/ChangeLog
@@ -1,3 +1,11 @@
+Tue Jan 22 04:40:28 2008 Yukihiro Matsumoto <matz@ruby-lang.org>
+
+ * parse.y (rb_intern3): do not call rb_enc_mbclen() if *m is
+ ASCII. [ruby-talk:287225]
+
+ * string.c (rb_str_each_line): use rb_enc_is_newline() to gain
+ performance if the record separator ($/) is not modified.
+
Tue Jan 22 01:15:51 2008 Kazuhiro NISHIYAMA <zn@mbf.nifty.com>
* ChangeLog: format-time-string under C locale. [ruby-dev:33261]
diff --git a/include/ruby/encoding.h b/include/ruby/encoding.h
index b914913b4..fad89a6da 100644
--- a/include/ruby/encoding.h
+++ b/include/ruby/encoding.h
@@ -133,6 +133,9 @@ int rb_enc_codelen(int code, rb_encoding *enc);
#define rb_enc_left_char_head(s,p,enc) (char *)onigenc_get_left_adjust_char_head(enc,(UChar*)(s),(UChar*)(p))
#define rb_enc_right_char_head(s,p,enc) (char *)onigenc_get_right_adjust_char_head(enc,(UChar*)(s),(UChar*)(p))
+/* ptr, ptr, encoding -> newline_or_not */
+#define rb_enc_is_newline(p,end,enc) ONIGENC_IS_MBC_NEWLINE(enc,p,end)
+
#define rb_enc_isctype(c,t,enc) ONIGENC_IS_CODE_CTYPE(enc,c,t)
#define rb_enc_isascii(c,enc) ONIGENC_IS_CODE_ASCII(c)
#define rb_enc_isalpha(c,enc) ONIGENC_IS_CODE_ALPHA(enc,c)
diff --git a/parse.y b/parse.y
index 3f4b8c29c..8f7c90a3c 100644
--- a/parse.y
+++ b/parse.y
@@ -8966,8 +8966,13 @@ rb_intern3(const char *name, long len, rb_encoding *enc)
mb = 0;
if (!rb_enc_isdigit(*m, enc)) {
while (m <= name + last && is_identchar(m, e, enc)) {
- if (!ISASCII(*m)) mb = 1;
- m += rb_enc_mbclen(m, e, enc);
+ if (ISASCII(*m)) {
+ m++;
+ }
+ else {
+ mb = 1;
+ m += rb_enc_mbclen(m, e, enc);
+ }
}
}
if (m - name < len) id = ID_JUNK;
diff --git a/string.c b/string.c
index 4d3d83792..3865dbcd7 100644
--- a/string.c
+++ b/string.c
@@ -4468,6 +4468,7 @@ rb_str_each_line(int argc, VALUE *argv, VALUE str)
char *ptr = p;
long len = RSTRING_LEN(str), rslen;
VALUE line;
+ int n;
if (rb_scan_args(argc, argv, "01", &rs) == 0) {
rs = rb_rs;
@@ -4480,6 +4481,22 @@ rb_str_each_line(int argc, VALUE *argv, VALUE str)
}
StringValue(rs);
enc = rb_enc_check(str, rs);
+ if (rs == rb_default_rs) {
+ while (p < pend) {
+ n = rb_enc_mbclen(p, pend, enc);
+ if (rb_enc_is_newline(p, pend, enc)) {
+ line = rb_str_new5(str, s, p - s + n);
+ OBJ_INFECT(line, str);
+ rb_enc_copy(line, str);
+ rb_yield(line);
+ str_mod_check(str, ptr, len);
+ s = p + n;
+ }
+ p += n;
+ }
+ goto finish;
+ }
+
rslen = RSTRING_LEN(rs);
if (rslen == 0) {
newline = '\n';
@@ -4490,8 +4507,8 @@ rb_str_each_line(int argc, VALUE *argv, VALUE str)
while (p < pend) {
int c = rb_enc_codepoint(p, pend, enc);
- int n = rb_enc_codelen(c, enc);
+ n = rb_enc_codelen(c, enc);
if (rslen == 0 && c == newline) {
while (p < pend && rb_enc_codepoint(p, pend, enc) == newline) {
p += n;
@@ -4510,6 +4527,7 @@ rb_str_each_line(int argc, VALUE *argv, VALUE str)
p += n;
}
+ finish:
if (s != pend) {
if (p > pend) p = pend;
line = rb_str_new5(str, s, p - s);
quot; #include "glusterd-quotad-svc.h" #include "glusterd-nfs-svc.h" #include "glusterd-locks.h" static void glusterd_dump_peer (glusterd_peerinfo_t *peerinfo, char *input_key, int index, gf_boolean_t xpeers) { char subkey[50] = {0,}; char key[GF_DUMP_MAX_BUF_LEN] = {0,}; strncpy (key, input_key, (GF_DUMP_MAX_BUF_LEN - 1)); snprintf (subkey, sizeof (subkey), "%s%d", key, index); gf_proc_dump_build_key (key, subkey, "uuid"); gf_proc_dump_write (key, "%s", uuid_utoa (peerinfo->uuid)); gf_proc_dump_build_key (key, subkey, "hostname"); gf_proc_dump_write (key, "%s", peerinfo->hostname); gf_proc_dump_build_key (key, subkey, "port"); gf_proc_dump_write (key, "%d", peerinfo->port); gf_proc_dump_build_key (key, subkey, "state"); gf_proc_dump_write (key, "%d", peerinfo->state.state); gf_proc_dump_build_key (key, subkey, "quorum-action"); gf_proc_dump_write (key, "%d", peerinfo->quorum_action); gf_proc_dump_build_key (key, subkey, "quorum-contrib"); gf_proc_dump_write (key, "%d", peerinfo->quorum_contrib); gf_proc_dump_build_key (key, subkey, "detaching"); gf_proc_dump_write (key, "%d", peerinfo->detaching); gf_proc_dump_build_key (key, subkey, "locked"); gf_proc_dump_write (key, "%d", peerinfo->locked); } static void glusterd_dump_peer_rpcstat (glusterd_peerinfo_t *peerinfo, char *input_key, int index) { rpc_clnt_connection_t *conn = NULL; int ret = -1; rpc_clnt_t *rpc = NULL; char rpcsvc_peername[RPCSVC_PEER_STRLEN] = {0,}; char subkey[50] = {0,}; char key[GF_DUMP_MAX_BUF_LEN] = {0,}; strncpy (key, input_key, (GF_DUMP_MAX_BUF_LEN - 1)); /* Dump the rpc connection statistics */ rpc = peerinfo->rpc; if (rpc) { conn = &rpc->conn; snprintf (subkey, sizeof (subkey), "%s%d", key, index); ret = rpcsvc_transport_peername (conn->trans, (char *)&rpcsvc_peername, sizeof (rpcsvc_peername)); if (!ret) { gf_proc_dump_build_key (key, subkey, "rpc.peername"); gf_proc_dump_write (key, "%s", rpcsvc_peername); } gf_proc_dump_build_key (key, subkey, "rpc.connected"); gf_proc_dump_write (key, "%d", conn->connected); gf_proc_dump_build_key (key, subkey, "rpc.total-bytes-read"); gf_proc_dump_write (key, "%"PRIu64, conn->trans->total_bytes_read); gf_proc_dump_build_key (key, subkey, "rpc.total-bytes-written"); gf_proc_dump_write (key, "%"PRIu64, conn->trans->total_bytes_write); gf_proc_dump_build_key (key, subkey, "rpc.ping_msgs_sent"); gf_proc_dump_write (key, "%"PRIu64, conn->pingcnt); gf_proc_dump_build_key (key, subkey, "rpc.msgs_sent"); gf_proc_dump_write (key, "%"PRIu64, conn->msgcnt); } } static void glusterd_dump_client_details (glusterd_conf_t *conf) { rpc_transport_t *xprt = NULL; char key[GF_DUMP_MAX_BUF_LEN] = {0,}; char subkey[50] = {0,}; int index = 1; pthread_mutex_lock (&conf->xprt_lock); { list_for_each_entry (xprt, &conf->xprt_list, list) { snprintf (subkey, sizeof (subkey), "glusterd.client%d", index); gf_proc_dump_build_key (key, subkey, "identifier"); gf_proc_dump_write (key, "%s", xprt->peerinfo.identifier); gf_proc_dump_build_key (key, subkey, "volname"); gf_proc_dump_write (key, "%s", xprt->peerinfo.volname); gf_proc_dump_build_key (key, subkey, "max-op-version"); gf_proc_dump_write (key, "%u", xprt->peerinfo.max_op_version); gf_proc_dump_build_key (key, subkey, "min-op-version"); gf_proc_dump_write (key, "%u", xprt->peerinfo.min_op_version); index++; } } pthread_mutex_unlock (&conf->xprt_lock); } /* The following function is just for dumping mgmt_v3_lock dictionary, any other * dict passed to this API will not work */ static void glusterd_dict_mgmt_v3_lock_statedump (dict_t *dict) { int ret = 0; int dumplen = 0; data_pair_t *trav = NULL; char key[GF_DUMP_MAX_BUF_LEN] = {0,}; char dump[64*1024] = {0,}; if (!dict) { gf_log_callingfn ("glusterd", GF_LOG_WARNING, "dict NULL"); goto out; } for (trav = dict->members_list; trav; trav = trav->next) { if (strstr (trav->key, "debug.last-success-bt") != NULL) { ret = snprintf (&dump[dumplen], sizeof(dump) - dumplen, "\n\t%s:%s", trav->key, trav->value->data); } else { ret = snprintf (&dump[dumplen], sizeof(dump) - dumplen, "\n\t%s:%s", trav->key, uuid_utoa (((glusterd_mgmt_v3_lock_obj *) (trav->value->data))->lock_owner)); } if ((ret == -1) || !ret) return; dumplen += ret; } if (dumplen) { gf_proc_dump_build_key (key, "glusterd", "mgmt_v3_lock"); gf_proc_dump_write (key, "%s", dump); } out: return; } int glusterd_dump_priv (xlator_t *this) { int index = 1; glusterd_conf_t *priv = NULL; char key[GF_DUMP_MAX_BUF_LEN] = {0,}; char subkey[50] = {0,}; glusterd_peerinfo_t *peerinfo = NULL; glusterd_volinfo_t *volinfo = NULL; GF_VALIDATE_OR_GOTO ("glusterd", this, out); priv = this->private; if (!priv) return 0; gf_proc_dump_build_key (key, "xlator.glusterd", "priv"); gf_proc_dump_add_section (key); pthread_mutex_lock (&priv->mutex); { gf_proc_dump_build_key (key, "glusterd", "my-uuid"); gf_proc_dump_write (key, "%s", uuid_utoa (priv->uuid)); gf_proc_dump_build_key (key, "glusterd", "working-directory"); gf_proc_dump_write (key, "%s", priv->workdir); gf_proc_dump_build_key (key, "glusterd", "max-op-version"); gf_proc_dump_write (key, "%d", GD_OP_VERSION_MAX); gf_proc_dump_build_key (key, "glusterd", "min-op-version"); gf_proc_dump_write (key, "%d", GD_OP_VERSION_MIN); gf_proc_dump_build_key (key, "glusterd", "current-op-version"); gf_proc_dump_write (key, "%d", priv->op_version); gf_proc_dump_build_key (key, "glusterd", "ping-timeout"); gf_proc_dump_write (key, "%d", priv->ping_timeout); gf_proc_dump_build_key (key, "glusterd", "shd.online"); gf_proc_dump_write (key, "%d", priv->shd_svc.online); gf_proc_dump_build_key (key, "glusterd", "nfs.online"); gf_proc_dump_write (key, "%d", priv->nfs_svc.online); gf_proc_dump_build_key (key, "glusterd", "quotad.online"); gf_proc_dump_write (key, "%d", priv->quotad_svc.online); GLUSTERD_DUMP_PEERS (&priv->peers, uuid_list, _gf_false); glusterd_dump_client_details (priv); glusterd_dict_mgmt_v3_lock_statedump(priv->mgmt_v3_lock); dict_dump_to_statedump (priv->opts, "options", "glusterd"); } pthread_mutex_unlock (&priv->mutex); out: return 0; }